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 <[email protected]>
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;
}
}