Cassandra pr bug fixes (#64)

ollionorg · Jan 23, 2025 · 75da86c · 75da86c
1 parent d1526f5
commit 75da86c
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/...cedb/src/main/java/com/google/cloud/teleport/v2/templates/transforms/AssignShardIdFn.java b/...cedb/src/main/java/com/google/cloud/teleport/v2/templates/transforms/AssignShardIdFn.java
@@ -231,7 +231,9 @@ public void processElement(ProcessContext c) throws Exception {
 
       record.setShard(qualifiedShard);
       String finalKeyString = tableName + "_" + keysJsonStr + "_" + qualifiedShard;
-      Long finalKey = finalKeyString.hashCode() % maxConnectionsAcrossAllShards;
+      Long finalKey =
+          finalKeyString.hashCode() % maxConnectionsAcrossAllShards; // The total parallelism is
+      // maxConnectionsAcrossAllShards
       c.output(KV.of(finalKey, record));
 
     } catch (Exception e) {