File tree Expand file tree Collapse file tree 1 file changed +3
-1
lines changed
src/main/scala/com/datastax/cdm/job Expand file tree Collapse file tree 1 file changed +3
-1
lines changed Original file line number Diff line number Diff line change @@ -69,7 +69,9 @@ abstract class BaseJob[T: ClassTag] extends App {
69
69
maxPartition = getMaxPartition(propertyHelper.getString(KnownProperties .PARTITION_MAX ), hasRandomPartitioner)
70
70
coveragePercent = propertyHelper.getInteger(KnownProperties .TOKEN_COVERAGE_PERCENT )
71
71
numSplits = propertyHelper.getInteger(KnownProperties .PERF_NUM_PARTS )
72
- this .fileName = propertyHelper.getString(KnownProperties .PARTITIONS_TOKEN_RANGE_FILE )
72
+ if (" " .equals(this .fileName)) {
73
+ this .fileName = propertyHelper.getString(KnownProperties .PARTITIONS_TOKEN_RANGE_FILE )
74
+ }
73
75
abstractLogger.info(" PARAM -- Min Partition: " + minPartition)
74
76
abstractLogger.info(" PARAM -- Max Partition: " + maxPartition)
75
77
abstractLogger.info(" PARAM -- Number of Splits : " + numSplits)
You can’t perform that action at this time.
0 commit comments