Skip to content

Commit 6de84fb

Browse files
committed
Accept it as a token
1 parent cf24f9c commit 6de84fb

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

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

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2,9 +2,11 @@
22

33
import com.datastax.oss.driver.api.core.CqlSession;
44
import com.datastax.oss.driver.api.core.cql.*;
5+
import com.datastax.oss.driver.internal.core.metadata.token.Murmur3Token;
56
import org.apache.log4j.Logger;
67
import org.apache.spark.SparkConf;
78

9+
import java.math.BigInteger;
810
import java.util.ArrayList;
911
import java.util.Collection;
1012
import java.util.List;
@@ -79,7 +81,7 @@ public void getDataAndInsert(Long min, Long max) {
7981

8082
try {
8183

82-
ResultSet resultSet = sourceSession.execute(sourceSelectStatement.bind().set(0,min,Long.class).set(1,max,Long.class));
84+
ResultSet resultSet = sourceSession.execute(sourceSelectStatement.bind(new Murmur3Token(min), new Murmur3Token(max)));
8385
Collection<CompletionStage<AsyncResultSet>> writeResults = new ArrayList<CompletionStage<AsyncResultSet>>();
8486

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

0 commit comments

Comments
 (0)