Implement PR comments

Author: faizalrub-datastax

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

@@ -5,6 +5,7 @@
 import com.datastax.oss.driver.api.core.cql.PreparedStatement;
 import com.datastax.oss.driver.api.core.cql.Row;
 import com.datastax.oss.driver.shaded.guava.common.util.concurrent.RateLimiter;
+import org.apache.commons.lang.StringUtils;
 import org.apache.spark.SparkConf;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -72,7 +73,7 @@ protected AbstractJobSession(CqlSession sourceSession, CqlSession astraSession,
 
         String customWriteTimeStr =
                 sparkConf.get("spark.destination.custom.writeTime", "0");
-        if (null != customWriteTimeStr && customWriteTimeStr.trim().length() > 1) {
+        if (null != customWriteTimeStr && customWriteTimeStr.trim().length() > 1 && StringUtils.isNumeric(customWriteTimeStr.trim())) {
             customWritetime = Long.parseLong(customWriteTimeStr);
         }
 

src/resources/sparkConf.properties

@@ -13,6 +13,7 @@ spark.destination.read.consistency.level                LOCAL_QUORUM
 spark.destination.keyspaceTable                         test.a2
 spark.destination.autocorrect.missing                   false
 spark.destination.autocorrect.mismatch                  false
+spark.destination.custom.writeTime 			            0
 
 spark.maxRetries                                        10
 spark.readRateLimit                                     20000
@@ -40,8 +41,6 @@ spark.source.writeTimeStampFilter                       false
 spark.source.minWriteTimeStampFilter                    0
 spark.source.maxWriteTimeStampFilter                    9223372036854775807
 
-spark.destination.custom.writeTime 			            1664980600000000
-
 ########################## ONLY USE if SSL clientAuth is enabled on source Cassandra/DSE ###############################
 #spark.source.trustStore.path
 #spark.source.trustStore.password