This is an automated email from the ASF dual-hosted git repository. martijnvisser pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/flink-connector-kudu.git
commit 6da6ad7ad427b23392d3bcbbd43391c05846ad5e Author: Darcy <331046...@qq.com> AuthorDate: Mon Jan 20 04:22:46 2020 +0800 Fix NotSerializableException in Kudu connector (#74) --- .../org/apache/flink/connectors/kudu/connector/KuduFilterInfo.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/KuduFilterInfo.java b/flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/KuduFilterInfo.java index c37bc9a..c7ae4a4 100644 --- a/flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/KuduFilterInfo.java +++ b/flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/KuduFilterInfo.java @@ -21,10 +21,11 @@ import org.apache.kudu.ColumnSchema; import org.apache.kudu.Schema; import org.apache.kudu.client.KuduPredicate; +import java.io.Serializable; import java.util.List; @PublicEvolving -public class KuduFilterInfo { +public class KuduFilterInfo implements Serializable { private String column; private FilterType type;