File tree Expand file tree Collapse file tree 1 file changed +1
-10
lines changed
src/main/scala/datastax/astra/migrate Expand file tree Collapse file tree 1 file changed +1
-10
lines changed Original file line number Diff line number Diff line change @@ -48,16 +48,7 @@ class BaseJob extends App {
48
48
val maxPartition = new BigInteger (Util .getSparkPropOr(sc, " spark.origin.maxPartition" , " 9223372036854775807" ))
49
49
val coveragePercent = Util .getSparkPropOr(sc, " spark.coveragePercent" , " 100" )
50
50
val splitSize = Integer .parseInt(Util .getSparkPropOr(sc, " spark.splitSize" , " 10000" ))
51
-
52
- val checkTableforColSize = Util .getSparkPropOr(sc, " spark.origin.checkTableforColSize" , " false" )
53
- val checkTableforselectCols = Util .getSparkPropOrEmpty(sc, " spark.origin.checkTableforColSize.cols" )
54
- // val checkTableforColSizeTypes = getTypes(Util.getSparkPropOr(sc, "spark.origin.checkTableforColSize.cols.types"))
55
- val filterColName = Util .getSparkPropOrEmpty(sc, " spark.origin.FilterColumn" )
56
- val filterColType = Util .getSparkPropOrEmpty(sc, " spark.origin.FilterColumnType" )
57
- val filterColIndex = Util .getSparkPropOr(sc, " spark.origin.FilterColumnIndex" , " 0" )
58
- val fieldGuardraillimitMB = Util .getSparkPropOr(sc, " spark.fieldGuardraillimitMB" , " 0" )
59
-
60
-
51
+
61
52
protected def exitSpark () = {
62
53
spark.stop()
63
54
abstractLogger.info(" ################################################################################################" )
You can’t perform that action at this time.
0 commit comments