This is an automated email from the ASF dual-hosted git repository.
diwu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris-flink-connector.git
The following commit(s) were added to refs/heads/master by this push:
new 2b523f4 [fix]fix SchemaChangeManager cannot serializable (#239)
2b523f4 is described below
commit 2b523f43a7b4c6b90f3d6505e000572306a62a5f
Author: wudongliang <46414265+donglian...@users.noreply.github.com>
AuthorDate: Thu Nov 23 14:08:54 2023 +0800
[fix]fix SchemaChangeManager cannot serializable (#239)
---
.../java/org/apache/doris/flink/sink/schema/SchemaChangeManager.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git
a/flink-doris-connector/src/main/java/org/apache/doris/flink/sink/schema/SchemaChangeManager.java
b/flink-doris-connector/src/main/java/org/apache/doris/flink/sink/schema/SchemaChangeManager.java
index 26e43cf..aff30c9 100644
---
a/flink-doris-connector/src/main/java/org/apache/doris/flink/sink/schema/SchemaChangeManager.java
+++
b/flink-doris-connector/src/main/java/org/apache/doris/flink/sink/schema/SchemaChangeManager.java
@@ -40,11 +40,13 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.io.IOException;
+import java.io.Serializable;
import java.nio.charset.StandardCharsets;
import java.util.HashMap;
import java.util.Map;
-public class SchemaChangeManager {
+public class SchemaChangeManager implements Serializable {
+ private static final long serialVersionUID = 1L;
private static final Logger LOG =
LoggerFactory.getLogger(SchemaChangeManager.class);
private static final String CHECK_SCHEMA_CHANGE_API =
"http://%s/api/enable_light_schema_change/%s/%s";;
private static final String SCHEMA_CHANGE_API =
"http://%s/api/query/default_cluster/";;
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
