[incubator-seatunnel] branch dev updated: [Feature]Use hive-sink to save table as ORCFileFormat (#1929) (#1956)

[kirs]

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

kirs pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git


The following commit(s) were added to refs/heads/dev by this push:
     new 97cc0d88 [Feature]Use hive-sink to save table as ORCFileFormat (#1929) 
(#1956)
97cc0d88 is described below

commit 97cc0d888ac3f6574e8543e9500576d812742af9
Author: yuwei zhan <34541162+dik...@users.noreply.github.com>
AuthorDate: Thu May 26 19:25:25 2022 +0800

    [Feature]Use hive-sink to save table as ORCFileFormat (#1929) (#1956)
    
    Co-authored-by: yuweizhan <yuwei.z...@sfygroup.com>
---
 .../src/main/scala/org/apache/seatunnel/spark/hive/sink/Hive.scala    | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hive/src/main/scala/org/apache/seatunnel/spark/hive/sink/Hive.scala
 
b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hive/src/main/scala/org/apache/seatunnel/spark/hive/sink/Hive.scala
index d685bfd3..85d429c7 100644
--- 
a/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hive/src/main/scala/org/apache/seatunnel/spark/hive/sink/Hive.scala
+++ 
b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hive/src/main/scala/org/apache/seatunnel/spark/hive/sink/Hive.scala
@@ -49,9 +49,9 @@ class Hive extends SparkBatchSink with Logging {
         df
       }
       val frameWriter: DataFrameWriter[Row] = if (config.hasPath("save_mode")) 
{
-        sinkFrame.write.mode(config.getString("save_mode"))
+        sinkFrame.write.format("Hive").mode(config.getString("save_mode"))
       } else {
-        sinkFrame.write
+        sinkFrame.write.format("Hive")
       }
       if (config.hasPath("partition_by")) {
         val partitionList: util.List[String] = 
config.getStringList("partition_by")