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 9045295d8b4c03c3b2b52ee13f6d97874f4e6339 Author: Sergey Nuyanzin <[email protected]> AuthorDate: Sat Mar 8 14:54:18 2025 +0100 [hotfix] Make it compilable with Flink 2.0-preview --- flink-connector-hive-e2e-tests/pom.xml | 4 ++-- .../table/catalog/hive/factories/TestLockTableSinkFactory.java | 6 ++---- flink-sql-connector-hive-3.1.3/pom.xml | 2 +- pom.xml | 2 +- 4 files changed, 6 insertions(+), 8 deletions(-) diff --git a/flink-connector-hive-e2e-tests/pom.xml b/flink-connector-hive-e2e-tests/pom.xml index 400ad586..053a7658 100644 --- a/flink-connector-hive-e2e-tests/pom.xml +++ b/flink-connector-hive-e2e-tests/pom.xml @@ -85,7 +85,7 @@ under the License. <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-sql-connector-hive-${hive.version}</artifactId> - <version>${flink.version}</version> + <version>${project.version}</version> </dependency> <!-- hadoop dependencies for end-to-end test --> @@ -183,7 +183,7 @@ under the License. <artifactId> flink-sql-connector-hive-${hive.version} </artifactId> - <version>${flink.version}</version> + <version>${project.version}</version> <destFileName> sql-hive-${hive.version}_${scala.binary.version}.jar </destFileName> diff --git a/flink-connector-hive/src/test/java/org/apache/flink/table/catalog/hive/factories/TestLockTableSinkFactory.java b/flink-connector-hive/src/test/java/org/apache/flink/table/catalog/hive/factories/TestLockTableSinkFactory.java index 056727af..7ec3f777 100644 --- a/flink-connector-hive/src/test/java/org/apache/flink/table/catalog/hive/factories/TestLockTableSinkFactory.java +++ b/flink-connector-hive/src/test/java/org/apache/flink/table/catalog/hive/factories/TestLockTableSinkFactory.java @@ -18,10 +18,8 @@ package org.apache.flink.table.catalog.hive.factories; +import org.apache.flink.api.common.functions.OpenContext; import org.apache.flink.configuration.ConfigOption; -import org.apache.flink.configuration.Configuration; -import org.apache.flink.streaming.api.functions.sink.RichSinkFunction; -import org.apache.flink.streaming.api.functions.sink.SinkFunction; import org.apache.flink.streaming.api.functions.sink.legacy.RichSinkFunction; import org.apache.flink.streaming.api.functions.sink.legacy.SinkFunction; import org.apache.flink.table.catalog.CatalogLock; @@ -129,7 +127,7 @@ public class TestLockTableSinkFactory implements DynamicTableSinkFactory { } @Override - public void open(Configuration configuration) throws Exception { + public void open(OpenContext openContext) throws Exception { this.lock = lockFactory.create(); } diff --git a/flink-sql-connector-hive-3.1.3/pom.xml b/flink-sql-connector-hive-3.1.3/pom.xml index 43f3b240..13329c56 100644 --- a/flink-sql-connector-hive-3.1.3/pom.xml +++ b/flink-sql-connector-hive-3.1.3/pom.xml @@ -90,7 +90,7 @@ under the License. <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-connector-hive</artifactId> - <version>${flink.version}</version> + <version>${project.version}</version> </dependency> <dependency> diff --git a/pom.xml b/pom.xml index bdec5e3b..4b50e118 100644 --- a/pom.xml +++ b/pom.xml @@ -44,7 +44,7 @@ under the License. </modules> <properties> - <flink.version>1.20.0</flink.version> + <flink.version>2.0-preview1</flink.version> <assertj.version>3.27.0</assertj.version> <!--
