Merge pull request #151 from data-integrations/fix/CDAP-17583-uuid-to-connector

CDAP-17583 Assign unique id to the sql server connector so that in case of multiple executors each connector can fetch data in parallel.

Author: sagarkapare

mysql-delta-plugins/src/main/java/io/cdap/delta/mysql/MySqlEventReader.java

@@ -49,6 +49,7 @@
 import java.time.temporal.Temporal;
 import java.util.Map;
 import java.util.Set;
+import java.util.UUID;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
 import java.util.concurrent.TimeUnit;
@@ -110,7 +111,7 @@ public void start(Offset offset) {
       .with("event", state.getOrDefault(MySqlConstantOffsetBackingStore.EVENT, ""))
       .with("gtids", state.getOrDefault(MySqlConstantOffsetBackingStore.GTID_SET, ""))
       /* begin connector properties */
-      .with("name", "delta")
+      .with("name", "delta" + UUID.randomUUID().toString().replace("-", ""))
       .with("database.hostname", config.getHost())
       .with("database.port", config.getPort())
       .with("database.user", config.getUser())

sqlserver-delta-plugins/src/main/java/io/cdap/delta/sqlserver/SqlServerEventReader.java

@@ -43,6 +43,7 @@
 import java.util.HashSet;
 import java.util.Map;
 import java.util.Set;
+import java.util.UUID;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
 import java.util.concurrent.TimeUnit;
@@ -116,7 +117,7 @@ public void start(Offset offset) {
       .with("snapshot", state.getOrDefault(SourceInfo.SNAPSHOT_KEY, ""))
       .with("snapshot_completed", isSnapshotCompleted)
       /* begin connector properties */
-      .with("name", "delta")
+      .with("name", "delta" + UUID.randomUUID().toString().replace("-", ""))
       .with("database.hostname", config.getHost())
       .with("database.port", config.getPort())
       .with("database.user", config.getUser())