Update AbstractJdbcSourceChunkSplitter.java

empty commit
apache · Sep 20, 2024 · 73ac654 · 73ac654
1 parent 9a9b724
commit 73ac654
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...unnel/connectors/cdc/base/source/enumerator/splitter/AbstractJdbcSourceChunkSplitter.java b/...unnel/connectors/cdc/base/source/enumerator/splitter/AbstractJdbcSourceChunkSplitter.java
@@ -406,7 +406,7 @@ protected Column getSplitColumn(
                         uniqueKey.getColumnNames();
                 for (ConstraintKey.ConstraintKeyColumn uniqueKeyColumn : uniqueKeyColumns) {
                     Column column = table.columnWithName(uniqueKeyColumn.getColumnName());
-                    if (column!=null && isEvenlySplitColumn(column)) {
+                    if (column != null && isEvenlySplitColumn(column)) {
                         splitColumn = columnComparable(splitColumn, column);
                         if (sqlTypePriority(splitColumn) == 1) {
                             return splitColumn;