Merge pull request #54 from abinaya21/fix-npe-diff-job

[ISSUE-53] Fix NPE in DiffData job on printing final counts

Author: pravinbhat

pom.xml

@@ -3,7 +3,7 @@
 
   <groupId>datastax.astra.migrate</groupId>
   <artifactId>cassandra-data-migrator</artifactId>
-  <version>3.0.0</version>
+  <version>3.0.1</version>
   <packaging>jar</packaging>
 
   <properties>

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

@@ -25,6 +25,11 @@ protected AbstractJobSession(CqlSession sourceSession, CqlSession astraSession,
 
     protected AbstractJobSession(CqlSession sourceSession, CqlSession astraSession, SparkConf sc, boolean isJobMigrateRowsFromFile) {
         super(sc);
+        
+        if (sourceSession == null) {
+            return;
+        }
+        
         this.sourceSession = sourceSession;
         this.astraSession = astraSession;