update DorisMetadataApplier

qg-lin · qg-lin · commit cbfcbec22332 · 2025-01-15T12:44:56.000+08:00
diff --git a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-doris/src/main/java/org/apache/flink/cdc/connectors/doris/sink/DorisMetadataApplier.java b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-doris/src/main/java/org/apache/flink/cdc/connectors/doris/sink/DorisMetadataApplier.java
@@ -78,7 +78,7 @@ public class DorisMetadataApplier implements MetadataApplier {
     public DorisMetadataApplier(DorisOptions dorisOptions, Configuration config) {
         this.dorisOptions = dorisOptions;
         this.schemaChangeManager =
-                new SchemaChangeManager(dorisOptions, config.get(CHARSET_ENCODING));
+                new DorisSchemaChangeManager(dorisOptions, config.get(CHARSET_ENCODING));
         this.config = config;
         this.enabledSchemaEvolutionTypes = getSupportedSchemaEvolutionTypes();
     }
diff --git a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-doris/src/main/java/org/apache/flink/cdc/connectors/doris/sink/DorisSchemaChangeManager.java b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-doris/src/main/java/org/apache/flink/cdc/connectors/doris/sink/DorisSchemaChangeManager.java
@@ -27,8 +27,8 @@
 
 /** An enriched version of Doris' {@link SchemaChangeManager}. */
 public class DorisSchemaChangeManager extends SchemaChangeManager {
-    public DorisSchemaChangeManager(DorisOptions dorisOptions) {
-        super(dorisOptions);
+    public DorisSchemaChangeManager(DorisOptions dorisOptions, String charsetEncoding) {
+        super(dorisOptions, charsetEncoding);
     }
 
     public boolean truncateTable(String databaseName, String tableName)

Original file line number	Diff line number	Diff line change
`@@ -78,7 +78,7 @@ public class DorisMetadataApplier implements MetadataApplier {`
`78`	`78`	`public DorisMetadataApplier(DorisOptions dorisOptions, Configuration config) {`
`79`	`79`	`this.dorisOptions = dorisOptions;`
`80`	`80`	`this.schemaChangeManager =`
`81`		`- new SchemaChangeManager(dorisOptions, config.get(CHARSET_ENCODING));`
	`81`	`+ new DorisSchemaChangeManager(dorisOptions, config.get(CHARSET_ENCODING));`
`82`	`82`	`this.config = config;`
`83`	`83`	`this.enabledSchemaEvolutionTypes = getSupportedSchemaEvolutionTypes();`
`84`	`84`	`}`
Original file line number	Diff line number	Diff line change
`@@ -27,8 +27,8 @@`
`27`	`27`
`28`	`28`	`/** An enriched version of Doris' {@link SchemaChangeManager}. */`
`29`	`29`	`public class DorisSchemaChangeManager extends SchemaChangeManager {`
`30`		`- public DorisSchemaChangeManager(DorisOptions dorisOptions) {`
`31`		`- super(dorisOptions);`
	`30`	`+ public DorisSchemaChangeManager(DorisOptions dorisOptions, String charsetEncoding) {`
	`31`	`+ super(dorisOptions, charsetEncoding);`
`32`	`32`	`}`
`33`	`33`
`34`	`34`	`public boolean truncateTable(String databaseName, String tableName)`