This is an automated email from the ASF dual-hosted git repository. snuyanzin pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/flink-connector-hive.git
commit 3e28102949e2fed395d595b5ecf3368599cc7825 Author: Weijie Guo <[email protected]> AuthorDate: Mon Sep 23 17:15:48 2024 +0800 [FLINK-36366][core] Remove deprecate API in flink-core exclude connector and state part --- .../org/apache/flink/connectors/hive/write/HiveOutputFormatFactory.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/write/HiveOutputFormatFactory.java b/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/write/HiveOutputFormatFactory.java index a9f929ed..893b0771 100644 --- a/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/write/HiveOutputFormatFactory.java +++ b/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/write/HiveOutputFormatFactory.java @@ -62,7 +62,7 @@ public class HiveOutputFormatFactory implements OutputFormatFactory<Row> { public void configure(Configuration parameters) {} @Override - public void open(int taskNumber, int numTasks) {} + public void open(InitializationContext context) {} @Override public void writeRecord(Row record) throws IOException {
