Bugfix - fixed NumberFormatException when optional min/max WriteTimeStampFilter values are not provided

Author: pravinbhat

pom.xml

@@ -3,7 +3,7 @@
 
   <groupId>com.datastax.spark.example</groupId>
   <artifactId>migrate</artifactId>
-  <version>0.14</version>
+  <version>0.15</version>
   <packaging>jar</packaging>
 
   <properties>

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

@@ -94,10 +94,16 @@ protected AbstractJobSession(CqlSession sourceSession, CqlSession astraSession,
             }
         }
 
-        minWriteTimeStampFilter = new Long(
-                sparkConf.get("spark.migrate.source.minWriteTimeStampFilter", "0"));
-        maxWriteTimeStampFilter = new Long(
-                sparkConf.get("spark.migrate.source.maxWriteTimeStampFilter", "" + Long.MAX_VALUE));
+        String minWriteTimeStampFilterStr =
+                sparkConf.get("spark.migrate.source.minWriteTimeStampFilter", "0");
+        if (null != minWriteTimeStampFilterStr && minWriteTimeStampFilterStr.trim().length() > 1) {
+            minWriteTimeStampFilter = Long.parseLong(minWriteTimeStampFilterStr);
+        }
+        String maxWriteTimeStampFilterStr =
+                sparkConf.get("spark.migrate.source.maxWriteTimeStampFilter", "0");
+        if (null != maxWriteTimeStampFilterStr && maxWriteTimeStampFilterStr.trim().length() > 1) {
+            maxWriteTimeStampFilter = Long.parseLong(maxWriteTimeStampFilterStr);
+        }
 
         logger.info(" DEFAULT -- Write Batch Size: " + batchSize);
         logger.info(" DEFAULT -- Source Keyspace Table: " + sourceKeyspaceTable);