This is an automated email from the ASF dual-hosted git repository. lzljs3620320 pushed a commit to branch release-1.1 in repository https://gitbox.apache.org/repos/asf/paimon.git
commit 03c4985e4a0902bece993a14a89ad5770ceeabe7 Author: yuzelin <[email protected]> AuthorDate: Wed May 7 11:46:34 2025 +0800 [flink] Fix that NewLookupFunction is not serializable because of RefreshBlacklist (#5569) --- .../main/java/org/apache/paimon/flink/lookup/RefreshBlacklist.java | 5 ++++- .../src/test/java/org/apache/paimon/flink/LookupJoinITCase.java | 4 +++- 2 files changed, 7 insertions(+), 2 deletions(-) diff --git a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RefreshBlacklist.java b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RefreshBlacklist.java index e20294fe06..88d7d48a65 100644 --- a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RefreshBlacklist.java +++ b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RefreshBlacklist.java @@ -27,6 +27,7 @@ import org.slf4j.LoggerFactory; import javax.annotation.Nullable; +import java.io.Serializable; import java.time.format.DateTimeParseException; import java.util.ArrayList; import java.util.Collections; @@ -34,7 +35,9 @@ import java.util.List; import java.util.TimeZone; /** Refresh black list for {@link FileStoreLookupFunction}. */ -public class RefreshBlacklist { +public class RefreshBlacklist implements Serializable { + + private static final long serialVersionUID = 1L; private static final Logger LOG = LoggerFactory.getLogger(RefreshBlacklist.class); diff --git a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/LookupJoinITCase.java b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/LookupJoinITCase.java index 36844d4c52..dea30d4d13 100644 --- a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/LookupJoinITCase.java +++ b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/LookupJoinITCase.java @@ -159,7 +159,9 @@ public class LookupJoinITCase extends CatalogITCaseBase { BlockingIterator<Row, Row> streamIter = streamSqlBlockIter( "SELECT T.pt, T.id, T.data, D.pt, D.id, D.data " - + "FROM t1 AS T LEFT JOIN d /*+ OPTIONS('lookup.dynamic-partition'='max_pt()', 'scan.snapshot-id'='2') */ " + + "FROM t1 AS T LEFT JOIN d /*+ OPTIONS('lookup.dynamic-partition'='max_pt()', 'scan.snapshot-id'='2', " + // just test that black list won't cause exception + + " 'lookup.refresh.time-periods-blacklist'='2000-01-01 00:00->2000-01-01 01:00') */ " + "FOR SYSTEM_TIME AS OF T.proctime AS D ON T.id = D.id"); assertThat(streamIter.collect(3))
