[flink] fix & doc

apache · Nov 27, 2024 · 95df419 · 95df419
1 parent 8e8bde0
commit 95df419
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...-spark-ut/src/test/scala/org/apache/paimon/spark/procedure/CompactProcedureTestBase.scala b/...-spark-ut/src/test/scala/org/apache/paimon/spark/procedure/CompactProcedureTestBase.scala
@@ -85,7 +85,7 @@ abstract class CompactProcedureTestBase extends PaimonSparkTestBase with StreamT
             split => {
               Assertions
                 .assertThat(split.dataFiles.size)
-                .isEqualTo(if (split.partition().getInt(1) == 16) 2 else 1)
+                .isEqualTo(if (split.partition().getInt(0) == 16) 2 else 1)
             })
         }
       })