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 563637ebd [Bug][Connector-V2] Fix hive source text table name (#2797)
563637ebd is described below

commit 563637ebd1e597c3dbed3a62ca29cf716df3721e
Author: TyrantLucifer <[email protected]>
AuthorDate: Tue Sep 20 10:23:05 2022 +0800

    [Bug][Connector-V2] Fix hive source text table name (#2797)
---
 .../apache/seatunnel/connectors/seatunnel/hive/config/HiveConfig.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/seatunnel-connectors-v2/connector-hive/src/main/java/org/apache/seatunnel/connectors/seatunnel/hive/config/HiveConfig.java
 
b/seatunnel-connectors-v2/connector-hive/src/main/java/org/apache/seatunnel/connectors/seatunnel/hive/config/HiveConfig.java
index 16ab34b5e..b28d56b2a 100644
--- 
a/seatunnel-connectors-v2/connector-hive/src/main/java/org/apache/seatunnel/connectors/seatunnel/hive/config/HiveConfig.java
+++ 
b/seatunnel-connectors-v2/connector-hive/src/main/java/org/apache/seatunnel/connectors/seatunnel/hive/config/HiveConfig.java
@@ -27,7 +27,7 @@ import org.apache.hadoop.hive.metastore.api.Table;
 public class HiveConfig {
     public static final String TABLE_NAME = "table_name";
     public static final String METASTORE_URI = "metastore_uri";
-    public static final String TEXT_INPUT_FORMAT_CLASSNAME = 
"org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextInputFormat";
+    public static final String TEXT_INPUT_FORMAT_CLASSNAME = 
"org.apache.hadoop.mapred.TextInputFormat";
     public static final String TEXT_OUTPUT_FORMAT_CLASSNAME = 
"org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat";
     public static final String PARQUET_INPUT_FORMAT_CLASSNAME = 
"org.apache.hadoop.hive.ql.io.parquet.MapredParquetInputFormat";
     public static final String PARQUET_OUTPUT_FORMAT_CLASSNAME = 
"org.apache.hadoop.hive.ql.io.parquet.MapredParquetOutputFormat";

Reply via email to