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 2e123bf [improve]change use-new-schema-change config deafult to true
(#318)
2e123bf is described below
commit 2e123bfa294b984f1009fd048c72e06b5894b536
Author: wudi <[email protected]>
AuthorDate: Fri Feb 23 11:04:24 2024 +0800
[improve]change use-new-schema-change config deafult to true (#318)
---
.../src/main/java/org/apache/doris/flink/sink/BackendUtil.java | 4 +++-
.../flink/sink/writer/serializer/JsonDebeziumSchemaSerializer.java | 2 +-
.../src/main/java/org/apache/doris/flink/tools/cdc/CdcTools.java | 2 --
.../src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSync.java | 2 +-
4 files changed, 5 insertions(+), 5 deletions(-)
diff --git
a/flink-doris-connector/src/main/java/org/apache/doris/flink/sink/BackendUtil.java
b/flink-doris-connector/src/main/java/org/apache/doris/flink/sink/BackendUtil.java
index 9a45ff0..cb5b6f2 100644
---
a/flink-doris-connector/src/main/java/org/apache/doris/flink/sink/BackendUtil.java
+++
b/flink-doris-connector/src/main/java/org/apache/doris/flink/sink/BackendUtil.java
@@ -89,7 +89,9 @@ public class BackendUtil {
public static boolean tryHttpConnection(String host) {
try {
- LOG.info("try to connect host {}", host);
+ if (LOG.isDebugEnabled()) {
+ LOG.debug("try to connect host {}", host);
+ }
host = "http://"; + host;
URL url = new URL(host);
HttpURLConnection co = (HttpURLConnection) url.openConnection();
diff --git
a/flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/JsonDebeziumSchemaSerializer.java
b/flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/JsonDebeziumSchemaSerializer.java
index d34c1a3..c633264 100644
---
a/flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/JsonDebeziumSchemaSerializer.java
+++
b/flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/JsonDebeziumSchemaSerializer.java
@@ -196,7 +196,7 @@ public class JsonDebeziumSchemaSerializer implements
DorisRecordSerializer<Strin
private DorisOptions dorisOptions;
private Pattern addDropDDLPattern;
private String sourceTableName;
- private boolean newSchemaChange;
+ private boolean newSchemaChange = true;
private DorisExecutionOptions executionOptions;
private Map<String, String> tableMapping;
private Map<String, String> tableProperties;
diff --git
a/flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/CdcTools.java
b/flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/CdcTools.java
index c76506a..e1a01ab 100644
---
a/flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/CdcTools.java
+++
b/flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/CdcTools.java
@@ -117,7 +117,6 @@ public class CdcTools {
String multiToOneTarget = params.get("multi-to-one-target");
boolean createTableOnly = params.has("create-table-only");
boolean ignoreDefaultValue = params.has("ignore-default-value");
- boolean useNewSchemaChange = params.has("use-new-schema-change");
boolean singleSink = params.has("single-sink");
Preconditions.checkArgument(params.has("sink-conf"));
@@ -140,7 +139,6 @@ public class CdcTools {
.setSinkConfig(sinkConfig)
.setTableConfig(tableMap)
.setCreateTableOnly(createTableOnly)
- .setNewSchemaChange(useNewSchemaChange)
.setSingleSink(singleSink)
.create();
databaseSync.build();
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 c211789..2aa09b6 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
@@ -73,7 +73,7 @@ public abstract class DatabaseSync {
public StreamExecutionEnvironment env;
private boolean createTableOnly = false;
- private boolean newSchemaChange;
+ private boolean newSchemaChange = true;
protected String includingTables;
protected String excludingTables;
protected String multiToOneOrigin;
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
