Skip to content

Commit 28cec61

Browse files
pravinbhatpravinbhat
committed
Fix typo (Tread to Thread)
1 parent 79a459d commit 28cec61

File tree

5 files changed

+16
-16
lines changed

5 files changed

+16
-16
lines changed

‎src/main/java/datastax/astra/migrate/CopyJobSession.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -36,7 +36,7 @@ public static CopyJobSession getInstance(CqlSession sourceSession, CqlSession as
3636
}
3737

3838
public void getDataAndInsert(BigInteger min, BigInteger max) {
39-
logger.info("TreadID: " + Thread.currentThread().getId() + " Processing min: " + min + " max:" + max);
39+
logger.info("ThreadID: " + Thread.currentThread().getId() + " Processing min: " + min + " max:" + max);
4040
int maxAttempts = maxRetries;
4141
for (int retryCount = 1; retryCount <= maxAttempts; retryCount++) {
4242

@@ -118,13 +118,13 @@ public void getDataAndInsert(BigInteger min, BigInteger max) {
118118
retryCount = maxAttempts;
119119
} catch (Exception e) {
120120
logger.error("Error occurred retry#: " + retryCount, e);
121-
logger.error("Error with PartitionRange -- TreadID: " + Thread.currentThread().getId() + " Processing min: " + min + " max:" + max + " -- Retry# " + retryCount);
121+
logger.error("Error with PartitionRange -- ThreadID: " + Thread.currentThread().getId() + " Processing min: " + min + " max:" + max + " -- Retry# " + retryCount);
122122
}
123123
}
124124
}
125125

126126
public synchronized void printCounts(boolean isFinal) {
127-
String msg = "TreadID: " + Thread.currentThread().getId();
127+
String msg = "ThreadID: " + Thread.currentThread().getId();
128128
if (isFinal) {
129129
msg += " Final";
130130
logger.info("################################################################################################");

‎src/main/java/datastax/astra/migrate/CopyPKJobSession.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -70,9 +70,9 @@ public void printCounts(boolean isFinal) {
7070
if (isFinal) {
7171
logger.info("################################################################################################");
7272
}
73-
logger.info("TreadID: " + Thread.currentThread().getId() + " Read Record Count: " + readCounter.get());
74-
logger.info("TreadID: " + Thread.currentThread().getId() + " Read Missing Count: " + missingCounter.get());
75-
logger.info("TreadID: " + Thread.currentThread().getId() + " Inserted Record Count: " + writeCounter.get());
73+
logger.info("ThreadID: " + Thread.currentThread().getId() + " Read Record Count: " + readCounter.get());
74+
logger.info("ThreadID: " + Thread.currentThread().getId() + " Read Missing Count: " + missingCounter.get());
75+
logger.info("ThreadID: " + Thread.currentThread().getId() + " Inserted Record Count: " + writeCounter.get());
7676
if (isFinal) {
7777
logger.info("################################################################################################");
7878
}

‎src/main/java/datastax/astra/migrate/DiffJobSession.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -55,7 +55,7 @@ public static DiffJobSession getInstance(CqlSession sourceSession, CqlSession as
5555
}
5656

5757
public void getDataAndDiff(BigInteger min, BigInteger max) {
58-
logger.info("TreadID: " + Thread.currentThread().getId() + " Processing min: " + min + " max:" + max);
58+
logger.info("ThreadID: " + Thread.currentThread().getId() + " Processing min: " + min + " max:" + max);
5959
int maxAttempts = maxRetries;
6060
for (int retryCount = 1; retryCount <= maxAttempts; retryCount++) {
6161

@@ -89,7 +89,7 @@ public void getDataAndDiff(BigInteger min, BigInteger max) {
8989
retryCount = maxAttempts;
9090
} catch (Exception e) {
9191
logger.error("Error occurred retry#: " + retryCount, e);
92-
logger.error("Error with PartitionRange -- TreadID: " + Thread.currentThread().getId()
92+
logger.error("Error with PartitionRange -- ThreadID: " + Thread.currentThread().getId()
9393
+ " Processing min: " + min + " max:" + max + " -- Retry# " + retryCount);
9494
}
9595
}
@@ -109,7 +109,7 @@ private void diffAndClear(Map<Row, CompletionStage<AsyncResultSet>> srcToTargetR
109109
}
110110

111111
public synchronized void printCounts(boolean isFinal) {
112-
String msg = "TreadID: " + Thread.currentThread().getId();
112+
String msg = "ThreadID: " + Thread.currentThread().getId();
113113
if (isFinal) {
114114
msg += " Final";
115115
logger.info("################################################################################################");

‎src/main/java/datastax/astra/migrate/OriginCountJobSession.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -79,7 +79,7 @@ public static OriginCountJobSession getInstance(CqlSession sourceSession, SparkC
7979
}
8080

8181
public void getData(BigInteger min, BigInteger max) {
82-
logger.info("TreadID: " + Thread.currentThread().getId() + " Processing min: " + min + " max:" + max);
82+
logger.info("ThreadID: " + Thread.currentThread().getId() + " Processing min: " + min + " max:" + max);
8383
int maxAttempts = maxRetries;
8484
for (int retryCount = 1; retryCount <= maxAttempts; retryCount++) {
8585

@@ -132,18 +132,18 @@ public void getData(BigInteger min, BigInteger max) {
132132
}
133133

134134
if (readCounter.incrementAndGet() % 1000 == 0) {
135-
logger.info("TreadID: " + Thread.currentThread().getId() + " Read Record Count: " + readCounter.get());
135+
logger.info("ThreadID: " + Thread.currentThread().getId() + " Read Record Count: " + readCounter.get());
136136
}
137137

138138
}
139139
}
140140

141141

142-
logger.info("TreadID: " + Thread.currentThread().getId() + " Final Read Record Count: " + readCounter.get());
142+
logger.info("ThreadID: " + Thread.currentThread().getId() + " Final Read Record Count: " + readCounter.get());
143143
retryCount = maxAttempts;
144144
} catch (Exception e) {
145145
logger.error("Error occurred retry#: " + retryCount, e);
146-
logger.error("Error with PartitionRange -- TreadID: " + Thread.currentThread().getId() + " Processing min: " + min + " max:" + max + " -- Retry# " + retryCount);
146+
logger.error("Error with PartitionRange -- ThreadID: " + Thread.currentThread().getId() + " Processing min: " + min + " max:" + max + " -- Retry# " + retryCount);
147147
}
148148
}
149149

‎src/main/java/datastax/astra/migrate/SplitPartitions.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,7 @@ public static void main(String[] args) throws IOException {
3131
}
3232

3333
public static Collection<Partition> getRandomSubPartitions(int splitSize, BigInteger min, BigInteger max, int coveragePercent) {
34-
logger.info("TreadID: " + Thread.currentThread().getId() + " Splitting min: " + min + " max:" + max);
34+
logger.info("ThreadID: " + Thread.currentThread().getId() + " Splitting min: " + min + " max:" + max);
3535
List<Partition> partitions = getSubPartitions(splitSize, min, max, coveragePercent);
3636
Collections.shuffle(partitions);
3737
Collections.shuffle(partitions);
@@ -41,7 +41,7 @@ public static Collection<Partition> getRandomSubPartitions(int splitSize, BigInt
4141
}
4242

4343
public static List<Partition> getSubPartitionsFromFile(int splitSize) throws IOException {
44-
logger.info("TreadID: " + Thread.currentThread().getId() +
44+
logger.info("ThreadID: " + Thread.currentThread().getId() +
4545
" Splitting partitions in file: ./partitions.csv using a split-size of " + splitSize);
4646
List<Partition> partitions = new ArrayList<Partition>();
4747
BufferedReader reader = Util.getfileReader("./partitions.csv");
@@ -62,7 +62,7 @@ public static List<Partition> getSubPartitionsFromFile(int splitSize) throws IOE
6262
}
6363

6464
public static List<PKRows> getRowPartsFromFile(int splitSize) throws IOException {
65-
logger.info("TreadID: " + Thread.currentThread().getId() +
65+
logger.info("ThreadID: " + Thread.currentThread().getId() +
6666
" Splitting rows in file: ./primary_key_rows.csv using a split-size of " + splitSize);
6767
List<String> pkRows = new ArrayList<String>();
6868
BufferedReader reader = Util.getfileReader("./primary_key_rows.csv");

0 commit comments

Comments
 (0)