|
@@ -27,7 +27,7 @@ object TestSparkSql {
|
|
|
throw new RuntimeException("warehouse dir not exists")
|
|
|
}
|
|
|
def main(args: Array[String]): Unit = {
|
|
|
- val spark: SparkSession = SparkUtils.InitEnv
|
|
|
+ val spark: SparkSession = SparkUtils.InitEnv("spark.conf")
|
|
|
|
|
|
import spark._
|
|
|
val tableName = "ods_company_all"
|