This is an automated email from the ASF dual-hosted git repository.
gaojun2048 pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git
The following commit(s) were added to refs/heads/dev by this push:
new d9519d696 [improve][connector] The Factory#factoryIdentifier must be
consistent with PluginIdentifierInterface#getPluginName (#3328)
d9519d696 is described below
commit d9519d696abf2513875ac65bd8feb527264dd19d
Author: Zongwen Li <[email protected]>
AuthorDate: Tue Nov 8 18:45:26 2022 +0800
[improve][connector] The Factory#factoryIdentifier must be consistent with
PluginIdentifierInterface#getPluginName (#3328)
---
.../connectors/seatunnel/assertion/sink/AssertSinkFactory.java | 2 +-
.../seatunnel/clickhouse/sink/client/ClickhouseSinkFactory.java | 2 +-
.../seatunnel/clickhouse/sink/file/ClickhouseFileSinkFactory.java | 2 +-
.../connectors/seatunnel/clickhouse/source/ClickhouseSourceFactory.java | 2 +-
.../seatunnel/connectors/seatunnel/console/sink/ConsoleSinkFactory.java | 2 +-
.../apache/seatunnel/connectors/seatunnel/sink/DataHubSinkFactory.java | 2 +-
.../apache/seatunnel/connectors/seatunnel/sink/DingTalkSinkFactory.java | 2 +-
7 files changed, 7 insertions(+), 7 deletions(-)
diff --git
a/seatunnel-connectors-v2/connector-assert/src/main/java/org/apache/seatunnel/connectors/seatunnel/assertion/sink/AssertSinkFactory.java
b/seatunnel-connectors-v2/connector-assert/src/main/java/org/apache/seatunnel/connectors/seatunnel/assertion/sink/AssertSinkFactory.java
index c3c6ad553..95e7b4577 100644
---
a/seatunnel-connectors-v2/connector-assert/src/main/java/org/apache/seatunnel/connectors/seatunnel/assertion/sink/AssertSinkFactory.java
+++
b/seatunnel-connectors-v2/connector-assert/src/main/java/org/apache/seatunnel/connectors/seatunnel/assertion/sink/AssertSinkFactory.java
@@ -30,7 +30,7 @@ public class AssertSinkFactory implements TableSinkFactory {
@Override
public String factoryIdentifier() {
- return "AssertSink";
+ return "Assert";
}
@Override
diff --git
a/seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/client/ClickhouseSinkFactory.java
b/seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/client/ClickhouseSinkFactory.java
index a804400f9..01fc05ece 100644
---
a/seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/client/ClickhouseSinkFactory.java
+++
b/seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/client/ClickhouseSinkFactory.java
@@ -38,7 +38,7 @@ import com.google.auto.service.AutoService;
public class ClickhouseSinkFactory implements TableSinkFactory {
@Override
public String factoryIdentifier() {
- return "ClickhouseSink";
+ return "Clickhouse";
}
@Override
diff --git
a/seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/file/ClickhouseFileSinkFactory.java
b/seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/file/ClickhouseFileSinkFactory.java
index c08f39484..2d9ccf220 100644
---
a/seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/file/ClickhouseFileSinkFactory.java
+++
b/seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/file/ClickhouseFileSinkFactory.java
@@ -38,7 +38,7 @@ import com.google.auto.service.AutoService;
public class ClickhouseFileSinkFactory implements TableSinkFactory {
@Override
public String factoryIdentifier() {
- return "ClickhouseFileSink";
+ return "ClickhouseFile";
}
@Override
diff --git
a/seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/source/ClickhouseSourceFactory.java
b/seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/source/ClickhouseSourceFactory.java
index 0f1c8e285..d57e5a62d 100644
---
a/seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/source/ClickhouseSourceFactory.java
+++
b/seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/source/ClickhouseSourceFactory.java
@@ -33,7 +33,7 @@ import com.google.auto.service.AutoService;
public class ClickhouseSourceFactory implements TableSourceFactory {
@Override
public String factoryIdentifier() {
- return "ClickhouseSource";
+ return "Clickhouse";
}
@Override
diff --git
a/seatunnel-connectors-v2/connector-console/src/main/java/org/apache/seatunnel/connectors/seatunnel/console/sink/ConsoleSinkFactory.java
b/seatunnel-connectors-v2/connector-console/src/main/java/org/apache/seatunnel/connectors/seatunnel/console/sink/ConsoleSinkFactory.java
index 6da69baf7..5363f2395 100644
---
a/seatunnel-connectors-v2/connector-console/src/main/java/org/apache/seatunnel/connectors/seatunnel/console/sink/ConsoleSinkFactory.java
+++
b/seatunnel-connectors-v2/connector-console/src/main/java/org/apache/seatunnel/connectors/seatunnel/console/sink/ConsoleSinkFactory.java
@@ -27,7 +27,7 @@ import com.google.auto.service.AutoService;
public class ConsoleSinkFactory implements TableSinkFactory {
@Override
public String factoryIdentifier() {
- return "ConsoleSink";
+ return "Console";
}
@Override
diff --git
a/seatunnel-connectors-v2/connector-datahub/src/main/java/org/apache/seatunnel/connectors/seatunnel/sink/DataHubSinkFactory.java
b/seatunnel-connectors-v2/connector-datahub/src/main/java/org/apache/seatunnel/connectors/seatunnel/sink/DataHubSinkFactory.java
index ac3d5b018..41277620c 100644
---
a/seatunnel-connectors-v2/connector-datahub/src/main/java/org/apache/seatunnel/connectors/seatunnel/sink/DataHubSinkFactory.java
+++
b/seatunnel-connectors-v2/connector-datahub/src/main/java/org/apache/seatunnel/connectors/seatunnel/sink/DataHubSinkFactory.java
@@ -35,7 +35,7 @@ import com.google.auto.service.AutoService;
public class DataHubSinkFactory implements TableSinkFactory {
@Override
public String factoryIdentifier() {
- return "DataHubSink";
+ return "DataHub";
}
@Override
diff --git
a/seatunnel-connectors-v2/connector-dingtalk/src/main/java/org/apache/seatunnel/connectors/seatunnel/sink/DingTalkSinkFactory.java
b/seatunnel-connectors-v2/connector-dingtalk/src/main/java/org/apache/seatunnel/connectors/seatunnel/sink/DingTalkSinkFactory.java
index e72cac30e..ca8aa2873 100644
---
a/seatunnel-connectors-v2/connector-dingtalk/src/main/java/org/apache/seatunnel/connectors/seatunnel/sink/DingTalkSinkFactory.java
+++
b/seatunnel-connectors-v2/connector-dingtalk/src/main/java/org/apache/seatunnel/connectors/seatunnel/sink/DingTalkSinkFactory.java
@@ -30,7 +30,7 @@ import com.google.auto.service.AutoService;
public class DingTalkSinkFactory implements TableSinkFactory {
@Override
public String factoryIdentifier() {
- return "DingTalkSink";
+ return "DingTalk";
}
@Override
