This is an automated email from the ASF dual-hosted git repository.
lzljs3620320 pushed a commit to branch release-0.3
in repository https://gitbox.apache.org/repos/asf/incubator-paimon.git
The following commit(s) were added to refs/heads/release-0.3 by this push:
new b785d9f9 [hotfix] Introduce SerializableFunction in table store to
support flink 1.14.2
b785d9f9 is described below
commit b785d9f9bc572f77b9aa3eff5572b508596255fb
Author: JingsongLi <[email protected]>
AuthorDate: Fri Mar 17 17:15:01 2023 +0800
[hotfix] Introduce SerializableFunction in table store to support flink
1.14.2
---
.../store/connector/SerializableFunction.java | 26 ++++++++++++++++++++++
.../store/connector/sink/CommitterOperator.java | 2 +-
.../table/store/connector/sink/CompactorSink.java | 2 +-
.../table/store/connector/sink/FileStoreSink.java | 2 +-
.../table/store/connector/sink/FlinkSink.java | 2 +-
5 files changed, 30 insertions(+), 4 deletions(-)
diff --git
a/flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/SerializableFunction.java
b/flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/SerializableFunction.java
new file mode 100644
index 00000000..17429e1e
--- /dev/null
+++
b/flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/SerializableFunction.java
@@ -0,0 +1,26 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.flink.table.store.connector;
+
+import java.io.Serializable;
+import java.util.function.Function;
+
+/** A {@link Function} that is also {@link Serializable}. */
+@FunctionalInterface
+public interface SerializableFunction<T, R> extends Function<T, R>,
Serializable {}
diff --git
a/flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/sink/CommitterOperator.java
b/flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/sink/CommitterOperator.java
index 509adac5..c467747e 100644
---
a/flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/sink/CommitterOperator.java
+++
b/flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/sink/CommitterOperator.java
@@ -24,8 +24,8 @@ import
org.apache.flink.streaming.api.operators.BoundedOneInput;
import org.apache.flink.streaming.api.operators.ChainingStrategy;
import org.apache.flink.streaming.api.operators.OneInputStreamOperator;
import org.apache.flink.streaming.runtime.streamrecord.StreamRecord;
+import org.apache.flink.table.store.connector.SerializableFunction;
import org.apache.flink.table.store.file.manifest.ManifestCommittable;
-import org.apache.flink.util.function.SerializableFunction;
import java.util.ArrayDeque;
import java.util.ArrayList;
diff --git
a/flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/sink/CompactorSink.java
b/flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/sink/CompactorSink.java
index c234858f..e516b18e 100644
---
a/flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/sink/CompactorSink.java
+++
b/flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/sink/CompactorSink.java
@@ -20,9 +20,9 @@ package org.apache.flink.table.store.connector.sink;
import org.apache.flink.streaming.api.operators.OneInputStreamOperator;
import org.apache.flink.table.data.RowData;
+import org.apache.flink.table.store.connector.SerializableFunction;
import org.apache.flink.table.store.file.operation.Lock;
import org.apache.flink.table.store.table.FileStoreTable;
-import org.apache.flink.util.function.SerializableFunction;
/** {@link FlinkSink} for dedicated compact jobs. */
public class CompactorSink extends FlinkSink {
diff --git
a/flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/sink/FileStoreSink.java
b/flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/sink/FileStoreSink.java
index 0151f18d..8ae9e676 100644
---
a/flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/sink/FileStoreSink.java
+++
b/flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/sink/FileStoreSink.java
@@ -20,11 +20,11 @@ package org.apache.flink.table.store.connector.sink;
import org.apache.flink.streaming.api.operators.OneInputStreamOperator;
import org.apache.flink.table.data.RowData;
+import org.apache.flink.table.store.connector.SerializableFunction;
import
org.apache.flink.table.store.file.manifest.ManifestCommittableSerializer;
import org.apache.flink.table.store.file.operation.Lock;
import org.apache.flink.table.store.table.FileStoreTable;
import org.apache.flink.table.store.table.sink.LogSinkFunction;
-import org.apache.flink.util.function.SerializableFunction;
import javax.annotation.Nullable;
diff --git
a/flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/sink/FlinkSink.java
b/flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/sink/FlinkSink.java
index a3a33d90..90103a4b 100644
---
a/flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/sink/FlinkSink.java
+++
b/flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/sink/FlinkSink.java
@@ -32,10 +32,10 @@ import
org.apache.flink.streaming.api.functions.sink.DiscardingSink;
import org.apache.flink.streaming.api.operators.OneInputStreamOperator;
import org.apache.flink.table.data.RowData;
import org.apache.flink.table.store.CoreOptions;
+import org.apache.flink.table.store.connector.SerializableFunction;
import
org.apache.flink.table.store.connector.utils.StreamExecutionEnvironmentUtils;
import org.apache.flink.table.store.table.FileStoreTable;
import org.apache.flink.util.Preconditions;
-import org.apache.flink.util.function.SerializableFunction;
import java.io.Serializable;
import java.util.UUID;
