You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@seatunnel.apache.org by ga...@apache.org on 2022/09/24 02:56:01 UTC
[incubator-seatunnel] branch dev updated: [Bug][Connector-V2] Fix hive sink bug (#2870)
This is an automated email from the ASF dual-hosted git repository.
gaojun2048 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 d661fa011 [Bug][Connector-V2] Fix hive sink bug (#2870)
d661fa011 is described below
commit d661fa011e7a018e8fc843a09f824f2f83a65a3e
Author: TyrantLucifer <Ty...@gmail.com>
AuthorDate: Sat Sep 24 10:55:56 2022 +0800
[Bug][Connector-V2] Fix hive sink bug (#2870)
---
.../org/apache/seatunnel/connectors/seatunnel/hive/sink/HiveSink.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/sink/HiveSink.java b/seatunnel-connectors-v2/connector-hive/src/main/java/org/apache/seatunnel/connectors/seatunnel/hive/sink/HiveSink.java
index c56beedcb..0fe82358e 100644
--- a/seatunnel-connectors-v2/connector-hive/src/main/java/org/apache/seatunnel/connectors/seatunnel/hive/sink/HiveSink.java
+++ b/seatunnel-connectors-v2/connector-hive/src/main/java/org/apache/seatunnel/connectors/seatunnel/hive/sink/HiveSink.java
@@ -129,6 +129,6 @@ public class HiveSink extends BaseHdfsFileSink {
} catch (URISyntaxException e) {
throw new RuntimeException("Get hdfs cluster address failed, please check.", e);
}
- super.prepare(pluginConfig);
+ this.pluginConfig = pluginConfig;
}
}