diff --git a/flink-doris-connector/src/test/java/org/apache/doris/flink/catalog/DorisCatalogFactoryTest.java b/flink-doris-connector/src/test/java/org/apache/doris/flink/catalog/DorisCatalogFactoryTest.java index 2fa74fd4e..b7a9e411d 100644 --- a/flink-doris-connector/src/test/java/org/apache/doris/flink/catalog/DorisCatalogFactoryTest.java +++ b/flink-doris-connector/src/test/java/org/apache/doris/flink/catalog/DorisCatalogFactoryTest.java @@ -20,6 +20,7 @@ import org.apache.flink.table.catalog.Catalog; import org.apache.flink.table.factories.FactoryUtil; +import org.apache.doris.flink.table.DorisConfigOptions; import org.junit.Test; import java.util.HashMap; @@ -33,7 +34,7 @@ public class DorisCatalogFactoryTest { @Test public void testCreateCatalog() { final Map options = new HashMap<>(); - options.put("type", "doris"); + options.put("type", DorisConfigOptions.IDENTIFIER); options.put("jdbc-url", "jdbc:mysql://127.0.0.1:9030"); options.put("fenodes", "127.0.0.1:8030"); options.put("default-database", "doris_db"); diff --git a/flink-doris-connector/src/test/java/org/apache/doris/flink/catalog/DorisCatalogITCase.java b/flink-doris-connector/src/test/java/org/apache/doris/flink/catalog/DorisCatalogITCase.java index 099f6ebd6..fe6f72d17 100644 --- a/flink-doris-connector/src/test/java/org/apache/doris/flink/catalog/DorisCatalogITCase.java +++ b/flink-doris-connector/src/test/java/org/apache/doris/flink/catalog/DorisCatalogITCase.java @@ -42,6 +42,7 @@ import com.google.common.collect.Lists; import org.apache.doris.flink.cfg.DorisConnectionOptions; import org.apache.doris.flink.container.AbstractITCaseService; +import org.apache.doris.flink.table.DorisConfigOptions; import org.junit.Assert; import org.junit.Before; import org.junit.Ignore; @@ -402,7 +403,7 @@ private static CatalogTable createTable() { TABLE_SCHEMA, new HashMap() { { - put("connector", "doris"); + put("connector", DorisConfigOptions.IDENTIFIER); put("table.properties.replication_num", "1"); } }, diff --git a/flink-doris-connector/src/test/java/org/apache/doris/flink/container/e2e/Doris2DorisE2ECase.java b/flink-doris-connector/src/test/java/org/apache/doris/flink/container/e2e/Doris2DorisE2ECase.java index f7b3bee7a..ce25c677e 100644 --- a/flink-doris-connector/src/test/java/org/apache/doris/flink/container/e2e/Doris2DorisE2ECase.java +++ b/flink-doris-connector/src/test/java/org/apache/doris/flink/container/e2e/Doris2DorisE2ECase.java @@ -26,6 +26,7 @@ import org.apache.doris.flink.container.AbstractContainerTestBase; import org.apache.doris.flink.container.ContainerUtils; +import org.apache.doris.flink.table.DorisConfigOptions; import org.junit.Assert; import org.junit.Test; import org.slf4j.Logger; @@ -72,7 +73,9 @@ public void testDoris2Doris() throws Exception { + "c16 ROW, \n" + "c17 STRING \n" + ") WITH (" - + " 'connector' = 'doris'," + + " 'connector' = '" + + DorisConfigOptions.IDENTIFIER + + "'," + " 'fenodes' = '%s'," + " 'table.identifier' = '%s'," + " 'sink.label-prefix' = '" @@ -109,7 +112,9 @@ public void testDoris2Doris() throws Exception { + "c16 ROW, \n" + "c17 STRING \n" + ") WITH (" - + " 'connector' = 'doris'," + + " 'connector' = '" + + DorisConfigOptions.IDENTIFIER + + "'," + " 'fenodes' = '%s'," + " 'sink.label-prefix' = '" + UUID.randomUUID() diff --git a/flink-doris-connector/src/test/java/org/apache/doris/flink/container/e2e/Mysql2DorisE2ECase.java b/flink-doris-connector/src/test/java/org/apache/doris/flink/container/e2e/Mysql2DorisE2ECase.java index 68b5d43b6..938aa2184 100644 --- a/flink-doris-connector/src/test/java/org/apache/doris/flink/container/e2e/Mysql2DorisE2ECase.java +++ b/flink-doris-connector/src/test/java/org/apache/doris/flink/container/e2e/Mysql2DorisE2ECase.java @@ -54,6 +54,8 @@ private List setMysql2DorisDefaultConfig(List argList) { argList.add(PASSWORD + "=" + getMySQLPassword()); argList.add(MYSQL_CONF); argList.add(DATABASE_NAME + "=" + DATABASE); + // argList.add(MYSQL_CONF); + // argList.add("server-time-zone=UTC"); // set doris database argList.add(DORIS_DATABASE); diff --git a/flink-doris-connector/src/test/java/org/apache/doris/flink/CDCSchemaChangeExample.java b/flink-doris-connector/src/test/java/org/apache/doris/flink/example/CDCSchemaChangeExample.java similarity index 99% rename from flink-doris-connector/src/test/java/org/apache/doris/flink/CDCSchemaChangeExample.java rename to flink-doris-connector/src/test/java/org/apache/doris/flink/example/CDCSchemaChangeExample.java index 01c33833f..8fe017e1c 100644 --- a/flink-doris-connector/src/test/java/org/apache/doris/flink/CDCSchemaChangeExample.java +++ b/flink-doris-connector/src/test/java/org/apache/doris/flink/example/CDCSchemaChangeExample.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package org.apache.doris.flink; +package org.apache.doris.flink.example; import org.apache.flink.api.common.eventtime.WatermarkStrategy; import org.apache.flink.cdc.connectors.mysql.source.MySqlSource; diff --git a/flink-doris-connector/src/test/java/org/apache/doris/flink/catalog/CatalogExample.java b/flink-doris-connector/src/test/java/org/apache/doris/flink/example/CatalogExample.java similarity index 98% rename from flink-doris-connector/src/test/java/org/apache/doris/flink/catalog/CatalogExample.java rename to flink-doris-connector/src/test/java/org/apache/doris/flink/example/CatalogExample.java index 1d7cf1df2..3cdf30ec9 100644 --- a/flink-doris-connector/src/test/java/org/apache/doris/flink/catalog/CatalogExample.java +++ b/flink-doris-connector/src/test/java/org/apache/doris/flink/example/CatalogExample.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package org.apache.doris.flink.catalog; +package org.apache.doris.flink.example; import org.apache.flink.api.common.RuntimeExecutionMode; import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment; diff --git a/flink-doris-connector/src/test/java/org/apache/doris/flink/DorisDateAndTimestampSqlTest.java b/flink-doris-connector/src/test/java/org/apache/doris/flink/example/DorisDateAndTimestampSqlTest.java similarity index 98% rename from flink-doris-connector/src/test/java/org/apache/doris/flink/DorisDateAndTimestampSqlTest.java rename to flink-doris-connector/src/test/java/org/apache/doris/flink/example/DorisDateAndTimestampSqlTest.java index 883e96b44..f904ef44e 100644 --- a/flink-doris-connector/src/test/java/org/apache/doris/flink/DorisDateAndTimestampSqlTest.java +++ b/flink-doris-connector/src/test/java/org/apache/doris/flink/example/DorisDateAndTimestampSqlTest.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package org.apache.doris.flink; +package org.apache.doris.flink.example; import org.apache.flink.table.api.EnvironmentSettings; import org.apache.flink.table.api.TableEnvironment; diff --git a/flink-doris-connector/src/test/java/org/apache/doris/flink/DorisIntranetAccessSinkExample.java b/flink-doris-connector/src/test/java/org/apache/doris/flink/example/DorisIntranetAccessSinkExample.java similarity index 99% rename from flink-doris-connector/src/test/java/org/apache/doris/flink/DorisIntranetAccessSinkExample.java rename to flink-doris-connector/src/test/java/org/apache/doris/flink/example/DorisIntranetAccessSinkExample.java index cda0ae46f..debc81406 100644 --- a/flink-doris-connector/src/test/java/org/apache/doris/flink/DorisIntranetAccessSinkExample.java +++ b/flink-doris-connector/src/test/java/org/apache/doris/flink/example/DorisIntranetAccessSinkExample.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package org.apache.doris.flink; +package org.apache.doris.flink.example; import org.apache.flink.api.common.RuntimeExecutionMode; import org.apache.flink.api.common.functions.MapFunction; diff --git a/flink-doris-connector/src/test/java/org/apache/doris/flink/DorisSinkArraySQLExample.java b/flink-doris-connector/src/test/java/org/apache/doris/flink/example/DorisSinkArraySQLExample.java similarity index 99% rename from flink-doris-connector/src/test/java/org/apache/doris/flink/DorisSinkArraySQLExample.java rename to flink-doris-connector/src/test/java/org/apache/doris/flink/example/DorisSinkArraySQLExample.java index 307a08e71..99514d328 100644 --- a/flink-doris-connector/src/test/java/org/apache/doris/flink/DorisSinkArraySQLExample.java +++ b/flink-doris-connector/src/test/java/org/apache/doris/flink/example/DorisSinkArraySQLExample.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package org.apache.doris.flink; +package org.apache.doris.flink.example; import org.apache.flink.api.common.RuntimeExecutionMode; import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment; diff --git a/flink-doris-connector/src/test/java/org/apache/doris/flink/DorisSinkBatchExample.java b/flink-doris-connector/src/test/java/org/apache/doris/flink/example/DorisSinkBatchExample.java similarity index 99% rename from flink-doris-connector/src/test/java/org/apache/doris/flink/DorisSinkBatchExample.java rename to flink-doris-connector/src/test/java/org/apache/doris/flink/example/DorisSinkBatchExample.java index 47add1211..7a111b258 100644 --- a/flink-doris-connector/src/test/java/org/apache/doris/flink/DorisSinkBatchExample.java +++ b/flink-doris-connector/src/test/java/org/apache/doris/flink/example/DorisSinkBatchExample.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package org.apache.doris.flink; +package org.apache.doris.flink.example; import org.apache.flink.streaming.api.datastream.DataStreamSource; import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment; diff --git a/flink-doris-connector/src/test/java/org/apache/doris/flink/DorisSinkExample.java b/flink-doris-connector/src/test/java/org/apache/doris/flink/example/DorisSinkExample.java similarity index 99% rename from flink-doris-connector/src/test/java/org/apache/doris/flink/DorisSinkExample.java rename to flink-doris-connector/src/test/java/org/apache/doris/flink/example/DorisSinkExample.java index 3e908f7d6..35ef73fd0 100644 --- a/flink-doris-connector/src/test/java/org/apache/doris/flink/DorisSinkExample.java +++ b/flink-doris-connector/src/test/java/org/apache/doris/flink/example/DorisSinkExample.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package org.apache.doris.flink; +package org.apache.doris.flink.example; import org.apache.flink.api.common.RuntimeExecutionMode; import org.apache.flink.api.common.functions.MapFunction; diff --git a/flink-doris-connector/src/test/java/org/apache/doris/flink/DorisSinkExampleRowData.java b/flink-doris-connector/src/test/java/org/apache/doris/flink/example/DorisSinkExampleRowData.java similarity index 99% rename from flink-doris-connector/src/test/java/org/apache/doris/flink/DorisSinkExampleRowData.java rename to flink-doris-connector/src/test/java/org/apache/doris/flink/example/DorisSinkExampleRowData.java index e19148016..8037e2eaa 100644 --- a/flink-doris-connector/src/test/java/org/apache/doris/flink/DorisSinkExampleRowData.java +++ b/flink-doris-connector/src/test/java/org/apache/doris/flink/example/DorisSinkExampleRowData.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package org.apache.doris.flink; +package org.apache.doris.flink.example; import org.apache.flink.api.common.RuntimeExecutionMode; import org.apache.flink.api.common.functions.FlatMapFunction; diff --git a/flink-doris-connector/src/test/java/org/apache/doris/flink/DorisSinkMultiTableExample.java b/flink-doris-connector/src/test/java/org/apache/doris/flink/example/DorisSinkMultiTableExample.java similarity index 99% rename from flink-doris-connector/src/test/java/org/apache/doris/flink/DorisSinkMultiTableExample.java rename to flink-doris-connector/src/test/java/org/apache/doris/flink/example/DorisSinkMultiTableExample.java index f78390ef8..feff8b326 100644 --- a/flink-doris-connector/src/test/java/org/apache/doris/flink/DorisSinkMultiTableExample.java +++ b/flink-doris-connector/src/test/java/org/apache/doris/flink/example/DorisSinkMultiTableExample.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package org.apache.doris.flink; +package org.apache.doris.flink.example; import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment; import org.apache.flink.streaming.api.functions.source.SourceFunction; diff --git a/flink-doris-connector/src/test/java/org/apache/doris/flink/DorisSinkSQLExample.java b/flink-doris-connector/src/test/java/org/apache/doris/flink/example/DorisSinkSQLExample.java similarity index 98% rename from flink-doris-connector/src/test/java/org/apache/doris/flink/DorisSinkSQLExample.java rename to flink-doris-connector/src/test/java/org/apache/doris/flink/example/DorisSinkSQLExample.java index 6cf819c9c..a31ab8a55 100644 --- a/flink-doris-connector/src/test/java/org/apache/doris/flink/DorisSinkSQLExample.java +++ b/flink-doris-connector/src/test/java/org/apache/doris/flink/example/DorisSinkSQLExample.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package org.apache.doris.flink; +package org.apache.doris.flink.example; import org.apache.flink.api.common.RuntimeExecutionMode; import org.apache.flink.api.java.tuple.Tuple2; diff --git a/flink-doris-connector/src/test/java/org/apache/doris/flink/DorisSinkStreamMultiTableExample.java b/flink-doris-connector/src/test/java/org/apache/doris/flink/example/DorisSinkStreamMultiTableExample.java similarity index 99% rename from flink-doris-connector/src/test/java/org/apache/doris/flink/DorisSinkStreamMultiTableExample.java rename to flink-doris-connector/src/test/java/org/apache/doris/flink/example/DorisSinkStreamMultiTableExample.java index 8f69a1a6c..e2b8dae9f 100644 --- a/flink-doris-connector/src/test/java/org/apache/doris/flink/DorisSinkStreamMultiTableExample.java +++ b/flink-doris-connector/src/test/java/org/apache/doris/flink/example/DorisSinkStreamMultiTableExample.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package org.apache.doris.flink; +package org.apache.doris.flink.example; import org.apache.flink.api.common.restartstrategy.RestartStrategies; import org.apache.flink.api.common.time.Time; diff --git a/flink-doris-connector/src/test/java/org/apache/doris/flink/DorisSourceDataStream.java b/flink-doris-connector/src/test/java/org/apache/doris/flink/example/DorisSourceDataStream.java similarity index 97% rename from flink-doris-connector/src/test/java/org/apache/doris/flink/DorisSourceDataStream.java rename to flink-doris-connector/src/test/java/org/apache/doris/flink/example/DorisSourceDataStream.java index 507947b0a..ee3fa1357 100644 --- a/flink-doris-connector/src/test/java/org/apache/doris/flink/DorisSourceDataStream.java +++ b/flink-doris-connector/src/test/java/org/apache/doris/flink/example/DorisSourceDataStream.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package org.apache.doris.flink; +package org.apache.doris.flink.example; import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment; diff --git a/flink-doris-connector/src/test/java/org/apache/doris/flink/DorisSourceExample.java b/flink-doris-connector/src/test/java/org/apache/doris/flink/example/DorisSourceExample.java similarity index 98% rename from flink-doris-connector/src/test/java/org/apache/doris/flink/DorisSourceExample.java rename to flink-doris-connector/src/test/java/org/apache/doris/flink/example/DorisSourceExample.java index 503163a5b..90e461cfc 100644 --- a/flink-doris-connector/src/test/java/org/apache/doris/flink/DorisSourceExample.java +++ b/flink-doris-connector/src/test/java/org/apache/doris/flink/example/DorisSourceExample.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package org.apache.doris.flink; +package org.apache.doris.flink.example; import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment; import org.apache.flink.table.api.Table; diff --git a/flink-doris-connector/src/test/java/org/apache/doris/flink/DorisSourceSinkExample.java b/flink-doris-connector/src/test/java/org/apache/doris/flink/example/DorisSourceSinkExample.java similarity index 99% rename from flink-doris-connector/src/test/java/org/apache/doris/flink/DorisSourceSinkExample.java rename to flink-doris-connector/src/test/java/org/apache/doris/flink/example/DorisSourceSinkExample.java index ddd310b7f..d64a39673 100644 --- a/flink-doris-connector/src/test/java/org/apache/doris/flink/DorisSourceSinkExample.java +++ b/flink-doris-connector/src/test/java/org/apache/doris/flink/example/DorisSourceSinkExample.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package org.apache.doris.flink; +package org.apache.doris.flink.example; import org.apache.flink.api.common.RuntimeExecutionMode; import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment; diff --git a/flink-doris-connector/src/test/java/org/apache/doris/flink/lookup/LookupJoinCdcExample.java b/flink-doris-connector/src/test/java/org/apache/doris/flink/example/LookupJoinCdcExample.java similarity index 98% rename from flink-doris-connector/src/test/java/org/apache/doris/flink/lookup/LookupJoinCdcExample.java rename to flink-doris-connector/src/test/java/org/apache/doris/flink/example/LookupJoinCdcExample.java index b67d2fe17..f972d6e27 100644 --- a/flink-doris-connector/src/test/java/org/apache/doris/flink/lookup/LookupJoinCdcExample.java +++ b/flink-doris-connector/src/test/java/org/apache/doris/flink/example/LookupJoinCdcExample.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package org.apache.doris.flink.lookup; +package org.apache.doris.flink.example; import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment; import org.apache.flink.table.api.Table; diff --git a/flink-doris-connector/src/test/java/org/apache/doris/flink/lookup/LookupJoinExample.java b/flink-doris-connector/src/test/java/org/apache/doris/flink/example/LookupJoinExample.java similarity index 99% rename from flink-doris-connector/src/test/java/org/apache/doris/flink/lookup/LookupJoinExample.java rename to flink-doris-connector/src/test/java/org/apache/doris/flink/example/LookupJoinExample.java index 053ebbd42..9e82c6d41 100644 --- a/flink-doris-connector/src/test/java/org/apache/doris/flink/lookup/LookupJoinExample.java +++ b/flink-doris-connector/src/test/java/org/apache/doris/flink/example/LookupJoinExample.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package org.apache.doris.flink.lookup; +package org.apache.doris.flink.example; import org.apache.flink.api.java.tuple.Tuple2; import org.apache.flink.streaming.api.datastream.DataStreamSource; diff --git a/flink-doris-connector/src/test/java/org/apache/doris/flink/sink/DorisSinkITCase.java b/flink-doris-connector/src/test/java/org/apache/doris/flink/sink/DorisSinkITCase.java index 96562fa40..877074edf 100644 --- a/flink-doris-connector/src/test/java/org/apache/doris/flink/sink/DorisSinkITCase.java +++ b/flink-doris-connector/src/test/java/org/apache/doris/flink/sink/DorisSinkITCase.java @@ -37,6 +37,7 @@ import org.apache.doris.flink.sink.DorisSink.Builder; import org.apache.doris.flink.sink.batch.DorisBatchSink; import org.apache.doris.flink.sink.writer.serializer.SimpleStringSerializer; +import org.apache.doris.flink.table.DorisConfigOptions; import org.apache.doris.flink.utils.MockSource; import org.junit.Rule; import org.junit.Test; @@ -172,7 +173,9 @@ public void testTableSinkJsonFormat() throws Exception { + " name STRING," + " age INT" + ") WITH (" - + " 'connector' = 'doris'," + + " 'connector' = '" + + DorisConfigOptions.IDENTIFIER + + "'," + " 'fenodes' = '%s'," + " 'benodes' = '%s'," + " 'auto-redirect' = 'false'," @@ -221,7 +224,9 @@ public void testTableBatch() throws Exception { + " name STRING," + " age INT" + ") WITH (" - + " 'connector' = 'doris'," + + " 'connector' = '" + + DorisConfigOptions.IDENTIFIER + + "'," + " 'fenodes' = '%s'," + " 'table.identifier' = '%s'," + " 'username' = '%s'," @@ -309,7 +314,9 @@ public void testTableGroupCommit() throws Exception { + " name STRING," + " age INT" + ") WITH (" - + " 'connector' = 'doris'," + + " 'connector' = '" + + DorisConfigOptions.IDENTIFIER + + "'," + " 'fenodes' = '%s'," + " 'table.identifier' = '%s'," + " 'username' = '%s'," @@ -358,7 +365,9 @@ public void testTableGzFormat() throws Exception { + " name STRING," + " age INT" + ") WITH (" - + " 'connector' = 'doris'," + + " 'connector' = '" + + DorisConfigOptions.IDENTIFIER + + "'," + " 'fenodes' = '%s'," + " 'table.identifier' = '%s'," + " 'username' = '%s'," diff --git a/flink-doris-connector/src/test/java/org/apache/doris/flink/source/DorisSourceITCase.java b/flink-doris-connector/src/test/java/org/apache/doris/flink/source/DorisSourceITCase.java index 96a08d1cd..4fb6fba8f 100644 --- a/flink-doris-connector/src/test/java/org/apache/doris/flink/source/DorisSourceITCase.java +++ b/flink-doris-connector/src/test/java/org/apache/doris/flink/source/DorisSourceITCase.java @@ -36,6 +36,7 @@ import org.apache.doris.flink.container.ContainerUtils; import org.apache.doris.flink.datastream.DorisSourceFunction; import org.apache.doris.flink.deserialization.SimpleListDeserializationSchema; +import org.apache.doris.flink.table.DorisConfigOptions; import org.junit.Assert; import org.junit.Rule; import org.junit.Test; @@ -143,7 +144,9 @@ public void testTableSource() throws Exception { + " name STRING," + " age INT" + ") WITH (" - + " 'connector' = 'doris'," + + " 'connector' = '" + + DorisConfigOptions.IDENTIFIER + + "'," + " 'fenodes' = '%s'," + " 'table.identifier' = '%s'," + " 'username' = '%s'," @@ -191,7 +194,9 @@ public void testTableSourceOldApi() throws Exception { + " name STRING," + " age INT" + ") WITH (" - + " 'connector' = 'doris'," + + " 'connector' = '" + + DorisConfigOptions.IDENTIFIER + + "'," + " 'fenodes' = '%s'," + " 'table.identifier' = '%s'," + " 'source.use-old-api' = 'true'," @@ -228,7 +233,9 @@ public void testTableSourceAllOptions() throws Exception { + " name STRING," + " age INT" + ") WITH (" - + " 'connector' = 'doris'," + + " 'connector' = '" + + DorisConfigOptions.IDENTIFIER + + "'," + " 'fenodes' = '%s'," + " 'table.identifier' = '%s'," + " 'source.use-old-api' = 'true'," @@ -274,7 +281,9 @@ public void testTableSourceFilterAndProjectionPushDown() throws Exception { + " name STRING," + " age INT" + ") WITH (" - + " 'connector' = 'doris'," + + " 'connector' = '" + + DorisConfigOptions.IDENTIFIER + + "'," + " 'fenodes' = '%s'," + " 'table.identifier' = '%s'," + " 'username' = '%s'," @@ -314,7 +323,9 @@ public void testTableSourceFilterWithUnionAll() throws Exception { + " name STRING," + " age INT" + ") WITH (" - + " 'connector' = 'doris'," + + " 'connector' = '" + + DorisConfigOptions.IDENTIFIER + + "'," + " 'fenodes' = '%s'," + " 'table.identifier' = '%s'," + " 'username' = '%s'," @@ -357,7 +368,9 @@ public void testJobManagerFailoverSource() throws Exception { + " name STRING," + " age INT" + ") WITH (" - + " 'connector' = 'doris'," + + " 'connector' = '" + + DorisConfigOptions.IDENTIFIER + + "'," + " 'fenodes' = '%s'," + " 'table.identifier' = '%s'," + " 'username' = '%s'," @@ -436,7 +449,9 @@ public void testTaskManagerFailoverSource() throws Exception { + " name STRING," + " age INT" + ") WITH (" - + " 'connector' = 'doris'," + + " 'connector' = '" + + DorisConfigOptions.IDENTIFIER + + "'," + " 'fenodes' = '%s'," + " 'table.identifier' = '%s'," + " 'username' = '%s'," diff --git a/flink-doris-connector/src/test/java/org/apache/doris/flink/table/DorisDynamicTableFactoryTest.java b/flink-doris-connector/src/test/java/org/apache/doris/flink/table/DorisDynamicTableFactoryTest.java index 6b7ef1f7b..2baf6f56f 100644 --- a/flink-doris-connector/src/test/java/org/apache/doris/flink/table/DorisDynamicTableFactoryTest.java +++ b/flink-doris-connector/src/test/java/org/apache/doris/flink/table/DorisDynamicTableFactoryTest.java @@ -239,7 +239,7 @@ public void testDorisSinkProperties() { private Map getAllOptions() { Map options = new HashMap<>(); - options.put("connector", "doris"); + options.put("connector", DorisConfigOptions.IDENTIFIER); options.put("fenodes", "127.0.0.1:8030"); options.put("benodes", "127.0.0.1:8040"); options.put("jdbc-url", "jdbc:mysql://127.0.0.1:9030");