[flink]some fix

Alibaba-HZY · Alibaba-HZY · commit 7f193d10074f · 2025-06-25T17:11:48.000+08:00
diff --git a/fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/source/FlinkTableSource.java b/fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/source/FlinkTableSource.java
@@ -466,7 +466,7 @@ && hasPrimaryKey()
             return Result.of(acceptedFilters, remainingFilters);
         }
 
-        return Result.of(acceptedFilters, remainingFilters);
+        return Result.of(Collections.emptyList(), filters);
     }
 
     @Override

Original file line number	Diff line number	Diff line change
`@@ -466,7 +466,7 @@ && hasPrimaryKey()`
`466`	`466`	`return Result.of(acceptedFilters, remainingFilters);`
`467`	`467`	`}`
`468`	`468`
`469`		`- return Result.of(acceptedFilters, remainingFilters);`
	`469`	`+ return Result.of(Collections.emptyList(), filters);`
`470`	`470`	`}`
`471`	`471`
`472`	`472`	`@Override`