clean code format

Author: xiaohongbo

paimon-core/src/main/java/org/apache/paimon/table/source/DataTableBatchScan.java

@@ -135,6 +135,7 @@ private Optional<StartingScanner.Result> applyPushDownLimit() {
             return Optional.of(result);
         }
 
+        long scannedRowCount = 0;
         SnapshotReader.Plan plan = ((ScannedResult) result).plan();
         List<Split> planSplits = plan.splits();
         if (planSplits.stream().anyMatch(s -> !(s instanceof DataSplit))) {
@@ -143,7 +144,6 @@ private Optional<StartingScanner.Result> applyPushDownLimit() {
         @SuppressWarnings("unchecked")
         List<DataSplit> splits = (List<DataSplit>) (List<?>) planSplits;
 
-        long scannedRowCount = 0;
         LOG.info("Applying limit pushdown. Original splits count: {}", splits.size());
         if (splits.isEmpty()) {
             return Optional.of(result);
@@ -200,7 +200,6 @@ private Optional<StartingScanner.Result> applyPushDownTopN() {
 
         SnapshotReader.Plan plan = ((ScannedResult) result).plan();
         List<Split> planSplits = plan.splits();
-        // TopN pushdown only supports DataSplit. Skip for IncrementalSplit.
         if (planSplits.stream().anyMatch(s -> !(s instanceof DataSplit))) {
             return Optional.of(result);
         }

paimon-spark/paimon-spark-ut/src/test/scala/org/apache/paimon/spark/sql/TableValuedFunctionsTest.scala

@@ -344,8 +344,7 @@ class TableValuedFunctionsTest extends PaimonHiveTestBase {
     }
   }
 
-  test(
-    "incremental query by tag with LIMIT - no ClassCastException (IncrementalSplit handled in applyPushDownLimit)") {
+  test("incremental query by tag with LIMIT") {
     sql("use paimon")
     withTable("t") {
       spark.sql("""