Skip to content

Commit 8171926

Browse files
committed
[fix-34344][kafka] use apache common split
1 parent 4e48f31 commit 8171926

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

kafka-base/kafka-base-sink/src/main/java/com/dtstack/flink/sql/sink/kafka/AbstractKafkaSink.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -116,7 +116,7 @@ protected TableSchema buildTableSchema(String[] fieldNames, TypeInformation<?>[]
116116
protected String[] getPartitionKeys(KafkaSinkTableInfo kafkaSinkTableInfo) {
117117
String keysStr = kafkaSinkTableInfo.getPartitionKeys();
118118
if (StringUtils.isNotBlank(keysStr)) {
119-
String[] keys = keysStr.split(",");
119+
String[] keys = StringUtils.split(keysStr, ",");
120120
String[] cleanedKeys = Arrays.stream(keys)
121121
.map(x -> x.trim())
122122
.toArray(String[]::new);

0 commit comments

Comments
 (0)