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 0fa19486 [fix]Fix NPE that occurs when schemaChangeMode is not
specified (#444)
0fa19486 is described below
commit 0fa19486bdef44c302de3a4fcaa7ed9e3224c433
Author: wudongliang <[email protected]>
AuthorDate: Thu Jul 25 16:43:06 2024 +0800
[fix]Fix NPE that occurs when schemaChangeMode is not specified (#444)
---
.../src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSync.java | 5 +++++
1 file changed, 5 insertions(+)
diff --git
a/flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSync.java
b/flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSync.java
index 4abe8c61..1e66dd4c 100644
---
a/flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSync.java
+++
b/flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSync.java
@@ -37,6 +37,7 @@ import org.apache.doris.flink.cfg.DorisOptions;
import org.apache.doris.flink.cfg.DorisReadOptions;
import org.apache.doris.flink.exception.DorisSystemException;
import org.apache.doris.flink.sink.DorisSink;
+import org.apache.doris.flink.sink.schema.SchemaChangeMode;
import org.apache.doris.flink.sink.writer.WriteMode;
import org.apache.doris.flink.sink.writer.serializer.DorisRecordSerializer;
import
org.apache.doris.flink.sink.writer.serializer.JsonDebeziumSchemaSerializer;
@@ -550,6 +551,10 @@ public abstract class DatabaseSync {
}
public DatabaseSync setSchemaChangeMode(String schemaChangeMode) {
+ if (org.apache.commons.lang3.StringUtils.isEmpty(schemaChangeMode)) {
+ this.schemaChangeMode =
SchemaChangeMode.DEBEZIUM_STRUCTURE.getName();
+ return this;
+ }
this.schemaChangeMode = schemaChangeMode.trim();
return this;
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
