This is an automated email from the ASF dual-hosted git repository.

zihaoxiang pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git


The following commit(s) were added to refs/heads/dev by this push:
     new 08e2c245a8 Update SparkRuntimeEnvironment.java (#10549)
08e2c245a8 is described below

commit 08e2c245a86e93abd1fcd401ac08a92ba861d523
Author: 飞侠美如画 <[email protected]>
AuthorDate: Thu Jun 23 14:17:45 2022 +0800

    Update SparkRuntimeEnvironment.java (#10549)
    
    Add spark support for hive
---
 .../data/quality/execution/SparkRuntimeEnvironment.java                 | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/dolphinscheduler-data-quality/src/main/java/org/apache/dolphinscheduler/data/quality/execution/SparkRuntimeEnvironment.java
 
b/dolphinscheduler-data-quality/src/main/java/org/apache/dolphinscheduler/data/quality/execution/SparkRuntimeEnvironment.java
index 82cf941aed..b746392bda 100644
--- 
a/dolphinscheduler-data-quality/src/main/java/org/apache/dolphinscheduler/data/quality/execution/SparkRuntimeEnvironment.java
+++ 
b/dolphinscheduler-data-quality/src/main/java/org/apache/dolphinscheduler/data/quality/execution/SparkRuntimeEnvironment.java
@@ -47,7 +47,7 @@ public class SparkRuntimeEnvironment {
     }
 
     public void prepare() {
-        sparkSession = 
SparkSession.builder().config(createSparkConf()).getOrCreate();
+        sparkSession = 
SparkSession.builder().config(createSparkConf()).enableHiveSupport().getOrCreate();
     }
 
     private SparkConf createSparkConf() {

Reply via email to