Update SparkRuntimeEnvironment.java (#10549)
Add spark support for hive
(cherry picked from commit 08e2c245a8)
This commit is contained in:
parent
a05d7cc8f4
commit
64b72a2968
|
|
@ -47,7 +47,7 @@ public class SparkRuntimeEnvironment {
|
||||||
}
|
}
|
||||||
|
|
||||||
public void prepare() {
|
public void prepare() {
|
||||||
sparkSession = SparkSession.builder().config(createSparkConf()).getOrCreate();
|
sparkSession = SparkSession.builder().config(createSparkConf()).enableHiveSupport().getOrCreate();
|
||||||
}
|
}
|
||||||
|
|
||||||
private SparkConf createSparkConf() {
|
private SparkConf createSparkConf() {
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue