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 62360c74 [Improve] improve case and extraction identifier config (#488)
62360c74 is described below
commit 62360c74697f742c7cb7320d5788c77f8b25963b
Author: wudi <[email protected]>
AuthorDate: Fri Sep 13 10:05:55 2024 +0800
[Improve] improve case and extraction identifier config (#488)
---
.../flink/catalog/DorisCatalogFactoryTest.java | 3 ++-
.../doris/flink/catalog/DorisCatalogITCase.java | 3 ++-
.../flink/container/e2e/Doris2DorisE2ECase.java | 9 +++++--
.../flink/container/e2e/Mysql2DorisE2ECase.java | 2 ++
.../{ => example}/CDCSchemaChangeExample.java | 2 +-
.../flink/{catalog => example}/CatalogExample.java | 2 +-
.../DorisDateAndTimestampSqlTest.java | 2 +-
.../DorisIntranetAccessSinkExample.java | 2 +-
.../{ => example}/DorisSinkArraySQLExample.java | 2 +-
.../flink/{ => example}/DorisSinkBatchExample.java | 2 +-
.../flink/{ => example}/DorisSinkExample.java | 2 +-
.../{ => example}/DorisSinkExampleRowData.java | 2 +-
.../{ => example}/DorisSinkMultiTableExample.java | 2 +-
.../flink/{ => example}/DorisSinkSQLExample.java | 2 +-
.../DorisSinkStreamMultiTableExample.java | 2 +-
.../flink/{ => example}/DorisSourceDataStream.java | 2 +-
.../flink/{ => example}/DorisSourceExample.java | 2 +-
.../{ => example}/DorisSourceSinkExample.java | 2 +-
.../{lookup => example}/LookupJoinCdcExample.java | 2 +-
.../{lookup => example}/LookupJoinExample.java | 2 +-
.../apache/doris/flink/sink/DorisSinkITCase.java | 17 ++++++++++---
.../doris/flink/source/DorisSourceITCase.java | 29 ++++++++++++++++------
.../flink/table/DorisDynamicTableFactoryTest.java | 2 +-
23 files changed, 65 insertions(+), 32 deletions(-)
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 2fa74fd4..b7a9e411 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 @@ package org.apache.doris.flink.catalog;
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<String, String> 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 099f6ebd..fe6f72d1 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 org.apache.flink.util.CollectionUtil;
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 @@ public class DorisCatalogITCase extends
AbstractITCaseService {
TABLE_SCHEMA,
new HashMap<String, String>() {
{
- 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 f7b3bee7..ce25c677 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.flink.util.CloseableIterator;
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 class Doris2DorisE2ECase extends
AbstractContainerTestBase {
+ "c16 ROW<name String, age int>, \n"
+ "c17 STRING \n"
+ ") WITH ("
- + " 'connector' = 'doris',"
+ + " 'connector' = '"
+ + DorisConfigOptions.IDENTIFIER
+ + "',"
+ " 'fenodes' = '%s',"
+ " 'table.identifier' = '%s',"
+ " 'sink.label-prefix' = '"
@@ -109,7 +112,9 @@ public class Doris2DorisE2ECase extends
AbstractContainerTestBase {
+ "c16 ROW<name String, age int>, \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 68b5d43b..938aa218 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 @@ public class Mysql2DorisE2ECase extends AbstractE2EService {
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 01c33833..8fe017e1 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 1d7cf1df..3cdf30ec 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 883e96b4..f904ef44 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 cda0ae46..debc8140 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 307a08e7..99514d32 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 47add121..7a111b25 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 3e908f7d..35ef73fd 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 e1914801..8037e2ea 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 f78390ef..feff8b32 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 6cf819c9..a31ab8a5 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 8f69a1a6..e2b8dae9 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 507947b0..ee3fa135 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 503163a5..90e461cf 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 ddd310b7..d64a3967 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 b67d2fe1..f972d6e2 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 053ebbd4..9e82c6d4 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 96562fa4..877074ed 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.container.ContainerUtils;
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 class DorisSinkITCase extends AbstractITCaseService {
+ " name STRING,"
+ " age INT"
+ ") WITH ("
- + " 'connector' = 'doris',"
+ + " 'connector' = '"
+ + DorisConfigOptions.IDENTIFIER
+ + "',"
+ " 'fenodes' = '%s',"
+ " 'benodes' = '%s',"
+ " 'auto-redirect' = 'false',"
@@ -221,7 +224,9 @@ public class DorisSinkITCase extends AbstractITCaseService {
+ " name STRING,"
+ " age INT"
+ ") WITH ("
- + " 'connector' = 'doris',"
+ + " 'connector' = '"
+ + DorisConfigOptions.IDENTIFIER
+ + "',"
+ " 'fenodes' = '%s',"
+ " 'table.identifier' = '%s',"
+ " 'username' = '%s',"
@@ -309,7 +314,9 @@ public class DorisSinkITCase extends AbstractITCaseService {
+ " name STRING,"
+ " age INT"
+ ") WITH ("
- + " 'connector' = 'doris',"
+ + " 'connector' = '"
+ + DorisConfigOptions.IDENTIFIER
+ + "',"
+ " 'fenodes' = '%s',"
+ " 'table.identifier' = '%s',"
+ " 'username' = '%s',"
@@ -358,7 +365,9 @@ public class DorisSinkITCase extends AbstractITCaseService {
+ " 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 96a08d1c..4fb6fba8 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.AbstractITCaseService;
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 class DorisSourceITCase extends
AbstractITCaseService {
+ " name STRING,"
+ " age INT"
+ ") WITH ("
- + " 'connector' = 'doris',"
+ + " 'connector' = '"
+ + DorisConfigOptions.IDENTIFIER
+ + "',"
+ " 'fenodes' = '%s',"
+ " 'table.identifier' = '%s',"
+ " 'username' = '%s',"
@@ -191,7 +194,9 @@ public class DorisSourceITCase extends
AbstractITCaseService {
+ " 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 class DorisSourceITCase extends
AbstractITCaseService {
+ " 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 class DorisSourceITCase extends
AbstractITCaseService {
+ " name STRING,"
+ " age INT"
+ ") WITH ("
- + " 'connector' = 'doris',"
+ + " 'connector' = '"
+ + DorisConfigOptions.IDENTIFIER
+ + "',"
+ " 'fenodes' = '%s',"
+ " 'table.identifier' = '%s',"
+ " 'username' = '%s',"
@@ -314,7 +323,9 @@ public class DorisSourceITCase extends
AbstractITCaseService {
+ " name STRING,"
+ " age INT"
+ ") WITH ("
- + " 'connector' = 'doris',"
+ + " 'connector' = '"
+ + DorisConfigOptions.IDENTIFIER
+ + "',"
+ " 'fenodes' = '%s',"
+ " 'table.identifier' = '%s',"
+ " 'username' = '%s',"
@@ -357,7 +368,9 @@ public class DorisSourceITCase extends
AbstractITCaseService {
+ " name STRING,"
+ " age INT"
+ ") WITH ("
- + " 'connector' = 'doris',"
+ + " 'connector' = '"
+ + DorisConfigOptions.IDENTIFIER
+ + "',"
+ " 'fenodes' = '%s',"
+ " 'table.identifier' = '%s',"
+ " 'username' = '%s',"
@@ -436,7 +449,9 @@ public class DorisSourceITCase extends
AbstractITCaseService {
+ " 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 6b7ef1f7..2baf6f56 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 class DorisDynamicTableFactoryTest {
private Map<String, String> getAllOptions() {
Map<String, String> 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");
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
