Support for empty value of master option
This commit is contained in:
parent
bd8af33850
commit
9a6d44c5b4
|
@ -2,6 +2,7 @@ package eu.dnetlib.dhp.application
|
||||||
|
|
||||||
import eu.dnetlib.dhp.common.Constants
|
import eu.dnetlib.dhp.common.Constants
|
||||||
import eu.dnetlib.dhp.utils.DHPUtils.writeHdfsFile
|
import eu.dnetlib.dhp.utils.DHPUtils.writeHdfsFile
|
||||||
|
import org.apache.commons.lang3.StringUtils
|
||||||
|
|
||||||
import scala.io.Source
|
import scala.io.Source
|
||||||
|
|
||||||
|
@ -69,7 +70,7 @@ abstract class AbstractScalaApplication(
|
||||||
.builder()
|
.builder()
|
||||||
.config(conf)
|
.config(conf)
|
||||||
.appName(getClass.getSimpleName)
|
.appName(getClass.getSimpleName)
|
||||||
if (master != null)
|
if (StringUtils.isNotBlank(master))
|
||||||
b.master(master)
|
b.master(master)
|
||||||
b.getOrCreate()
|
b.getOrCreate()
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue