Skip to content

Commit d9519d6

Browse files
authored
[improve][connector] The Factory#factoryIdentifier must be consistent with PluginIdentifierInterface#getPluginName (#3328)
1 parent 9659430 commit d9519d6

File tree

7 files changed

+7
-7
lines changed

7 files changed

+7
-7
lines changed

seatunnel-connectors-v2/connector-assert/src/main/java/org/apache/seatunnel/connectors/seatunnel/assertion/sink/AssertSinkFactory.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,7 @@ public class AssertSinkFactory implements TableSinkFactory {
3030

3131
@Override
3232
public String factoryIdentifier() {
33-
return "AssertSink";
33+
return "Assert";
3434
}
3535

3636
@Override

seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/client/ClickhouseSinkFactory.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -38,7 +38,7 @@
3838
public class ClickhouseSinkFactory implements TableSinkFactory {
3939
@Override
4040
public String factoryIdentifier() {
41-
return "ClickhouseSink";
41+
return "Clickhouse";
4242
}
4343

4444
@Override

seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/file/ClickhouseFileSinkFactory.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -38,7 +38,7 @@
3838
public class ClickhouseFileSinkFactory implements TableSinkFactory {
3939
@Override
4040
public String factoryIdentifier() {
41-
return "ClickhouseFileSink";
41+
return "ClickhouseFile";
4242
}
4343

4444
@Override

seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/source/ClickhouseSourceFactory.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -33,7 +33,7 @@
3333
public class ClickhouseSourceFactory implements TableSourceFactory {
3434
@Override
3535
public String factoryIdentifier() {
36-
return "ClickhouseSource";
36+
return "Clickhouse";
3737
}
3838

3939
@Override

seatunnel-connectors-v2/connector-console/src/main/java/org/apache/seatunnel/connectors/seatunnel/console/sink/ConsoleSinkFactory.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,7 @@
2727
public class ConsoleSinkFactory implements TableSinkFactory {
2828
@Override
2929
public String factoryIdentifier() {
30-
return "ConsoleSink";
30+
return "Console";
3131
}
3232

3333
@Override

seatunnel-connectors-v2/connector-datahub/src/main/java/org/apache/seatunnel/connectors/seatunnel/sink/DataHubSinkFactory.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -35,7 +35,7 @@
3535
public class DataHubSinkFactory implements TableSinkFactory {
3636
@Override
3737
public String factoryIdentifier() {
38-
return "DataHubSink";
38+
return "DataHub";
3939
}
4040

4141
@Override

seatunnel-connectors-v2/connector-dingtalk/src/main/java/org/apache/seatunnel/connectors/seatunnel/sink/DingTalkSinkFactory.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,7 @@
3030
public class DingTalkSinkFactory implements TableSinkFactory {
3131
@Override
3232
public String factoryIdentifier() {
33-
return "DingTalkSink";
33+
return "DingTalk";
3434
}
3535

3636
@Override

0 commit comments

Comments
 (0)