Skip to content

Commit 03939d5

Browse files
sfc-gh-rchengkhsoneji
authored andcommitted
Change pipe already registered log from error to warn level (snowflakedb#679)
1 parent c7889ea commit 03939d5

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/main/java/com/snowflake/kafka/connector/internal/SnowflakeSinkServiceV1.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -108,7 +108,7 @@ public void startTask(final String tableName, final TopicPartition topicPartitio
108108
String stageName = Utils.stageName(conn.getConnectorName(), tableName);
109109
String nameIndex = getNameIndex(topicPartition.topic(), topicPartition.partition());
110110
if (pipes.containsKey(nameIndex)) {
111-
LOGGER.error("task is already registered, name: {}", nameIndex);
111+
LOGGER.warn("task is already registered with {} partition", nameIndex);
112112
} else {
113113
String pipeName =
114114
Utils.pipeName(conn.getConnectorName(), tableName, topicPartition.partition());

0 commit comments

Comments
 (0)