Upgraded pom & formatting changes

Author: pravinbhat

pom.xml

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

src/main/scala/datastax/astra/migrate/AbstractJob.scala

@@ -1,11 +1,6 @@
 package datastax.astra.migrate
 
 import com.datastax.spark.connector.cql.CassandraConnector
-import org.apache.spark.sql.SparkSession
-import org.slf4j.LoggerFactory
-
-import java.math.BigInteger
-import java.lang.Long
 
 class AbstractJob extends BaseJob {
 

src/main/scala/datastax/astra/migrate/BaseJob.scala

@@ -41,11 +41,11 @@ class BaseJob extends App {
   val destinationKeyStorePassword = sc.getConf.get("spark.destination.keyStore.password", "")
   val destinationEnabledAlgorithms = sc.getConf.get("spark.destination.enabledAlgorithms", "")
 
-  val minPartition = new BigInteger(sc.getConf.get("spark.source.minPartition","-9223372036854775808"))
-  val maxPartition = new BigInteger(sc.getConf.get("spark.source.maxPartition","9223372036854775807"))
+  val minPartition = new BigInteger(sc.getConf.get("spark.source.minPartition", "-9223372036854775808"))
+  val maxPartition = new BigInteger(sc.getConf.get("spark.source.maxPartition", "9223372036854775807"))
   val coveragePercent = sc.getConf.get("spark.coveragePercent", "100")
   val splitSize = sc.getConf.get("spark.splitSize", "10000")
-  val partitions = SplitPartitions.getRandomSubPartitions(BigInteger.valueOf(Long.parseLong(splitSize)), minPartition, maxPartition,Integer.parseInt(coveragePercent))
+  val partitions = SplitPartitions.getRandomSubPartitions(BigInteger.valueOf(Long.parseLong(splitSize)), minPartition, maxPartition, Integer.parseInt(coveragePercent))
 
   protected def exitSpark() = {
     spark.stop()