Merge 9691db7 into 33444b6

apache · Dec 9, 2019 · 5dbdb5a · 5dbdb5a
2 parents 33444b6 + 9691db7
commit 5dbdb5a
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...che/shardingsphere/shardingscaling/core/execute/executor/channel/RealtimeSyncChannel.java b/...che/shardingsphere/shardingscaling/core/execute/executor/channel/RealtimeSyncChannel.java
@@ -90,7 +90,7 @@ public final synchronized void pushRecord(final Record record) throws Interrupte
             }
             // hash by table name
             DataRecord dataRecord = (DataRecord) record;
-            String index = Integer.toString(dataRecord.getTableName().hashCode() % channelNumber);
+            String index = Integer.toString(Math.abs(dataRecord.getTableName().hashCode()) % channelNumber);
             channels.get(index).pushRecord(dataRecord);
         } else if (PlaceholderRecord.class.equals(record.getClass())) {
             if (0 < ackCallbacks.size()) {