From df0cd6208016894a94638856a54d92d9bf4325d5 Mon Sep 17 00:00:00 2001 From: Liang Zhang Date: Tue, 27 Aug 2024 01:35:00 +0800 Subject: [PATCH] Refactor PipelineDataSourceSink (#32694) --- .../core/importer/sink/type/PipelineDataSourceSink.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/importer/sink/type/PipelineDataSourceSink.java b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/importer/sink/type/PipelineDataSourceSink.java index 8fdf6cfb94d93..d6e180dfb0626 100644 --- a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/importer/sink/type/PipelineDataSourceSink.java +++ b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/importer/sink/type/PipelineDataSourceSink.java @@ -206,7 +206,7 @@ private void executeUpdate(final Connection connection, final DataRecord dataRec // TODO if table without unique key the conditionColumns before values is null, so update will fail at PostgreSQL int updateCount = preparedStatement.executeUpdate(); if (1 != updateCount) { - log.warn("execute update failed, update count: {}, sql: {}, set columns: {}, sharding columns: {}, condition columns: {}", + log.warn("Update failed, update count: {}, sql: {}, set columns: {}, sharding columns: {}, condition columns: {}", updateCount, sql, setColumns, JsonUtils.toJsonString(shardingColumns), JsonUtils.toJsonString(conditionColumns)); } } catch (final SQLException ex) {