[flink]some fix

Alibaba-HZY · Alibaba-HZY · commit 8781007006c9 · 2025-05-22T13:43:40.000+08:00
diff --git a/fluss-flink/fluss-flink-common/src/test/java/com/alibaba/fluss/flink/source/FlinkTableSourceITCase.java b/fluss-flink/fluss-flink-common/src/test/java/com/alibaba/fluss/flink/source/FlinkTableSourceITCase.java
@@ -994,8 +994,8 @@ void testStreamingReadMultiPartitionPushDown() throws Exception {
         assertResultsIgnoreOrder(rowIter, expectedRowValues, true);
     }
 
-    private List<String> writeRowsToTwoPartition(
-            TablePath tablePath, Collection<String> partitions) throws Exception {
+    private List<String> writeRowsToTwoPartition(TablePath tablePath, Collection<String> partitions)
+            throws Exception {
         List<InternalRow> rows = new ArrayList<>();
         List<String> expectedRowValues = new ArrayList<>();
 

Original file line number	Diff line number	Diff line change
`@@ -994,8 +994,8 @@ void testStreamingReadMultiPartitionPushDown() throws Exception {`
`994`	`994`	`assertResultsIgnoreOrder(rowIter, expectedRowValues, true);`
`995`	`995`	`}`
`996`	`996`
`997`		`- private List<String> writeRowsToTwoPartition(`
`998`		`- TablePath tablePath, Collection<String> partitions) throws Exception {`
	`997`	`+ private List<String> writeRowsToTwoPartition(TablePath tablePath, Collection<String> partitions)`
	`998`	`+ throws Exception {`
`999`	`999`	`List<InternalRow> rows = new ArrayList<>();`
`1000`	`1000`	`List<String> expectedRowValues = new ArrayList<>();`
`1001`	`1001`