Refactor PipelineDataSourceSink (#32694)

apache · Aug 26, 2024 · df0cd62 · df0cd62
1 parent 9eba36e
commit df0cd62
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...g/apache/shardingsphere/data/pipeline/core/importer/sink/type/PipelineDataSourceSink.java b/...g/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) {