Skip to content

Commit cf24f9c

Browse files
committed
Add functionality for auto-correct when Diff finds missing Data in destination
1 parent 9b815a4 commit cf24f9c

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

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

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -78,7 +78,8 @@ public void getDataAndInsert(Long min, Long max) {
7878
for (int retryCount = 1; retryCount <= maxAttempts; retryCount++) {
7979

8080
try {
81-
ResultSet resultSet = sourceSession.execute(sourceSelectStatement.bind(min, max));
81+
82+
ResultSet resultSet = sourceSession.execute(sourceSelectStatement.bind().set(0,min,Long.class).set(1,max,Long.class));
8283
Collection<CompletionStage<AsyncResultSet>> writeResults = new ArrayList<CompletionStage<AsyncResultSet>>();
8384

8485
// cannot do batching if the writeFilter is greater than 0 or

0 commit comments

Comments
 (0)