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 ed05a8a322ded0620bd1cfa95c4a6c1eff84e563 Author: Kunni <[email protected]> AuthorDate: Mon Sep 30 15:57:27 2024 +0800 [FLINK-36245] Relocate deprecated SourceFunction / SinkFunction and remove deprecated Sink V1 in 2.0 (#25331) --- .../src/main/java/org/apache/flink/connectors/hive/HiveTableSink.java | 4 ++-- .../org/apache/flink/table/catalog/hive/HiveCatalogUdfITCase.java | 2 +- .../flink/table/catalog/hive/factories/TestLockTableSinkFactory.java | 4 +++- 3 files changed, 6 insertions(+), 4 deletions(-) diff --git a/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTableSink.java b/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTableSink.java index d7e9a058..2350f675 100644 --- a/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTableSink.java +++ b/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTableSink.java @@ -52,8 +52,8 @@ import org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator; import org.apache.flink.streaming.api.functions.sink.filesystem.HadoopPathBasedBulkFormatBuilder; import org.apache.flink.streaming.api.functions.sink.filesystem.OutputFileConfig; import org.apache.flink.streaming.api.functions.sink.filesystem.PartFileInfo; -import org.apache.flink.streaming.api.functions.sink.filesystem.StreamingFileSink; -import org.apache.flink.streaming.api.functions.sink.filesystem.StreamingFileSink.BucketsBuilder; +import org.apache.flink.streaming.api.functions.sink.filesystem.legacy.StreamingFileSink; +import org.apache.flink.streaming.api.functions.sink.filesystem.legacy.StreamingFileSink.BucketsBuilder; import org.apache.flink.streaming.api.functions.sink.filesystem.rollingpolicies.CheckpointRollingPolicy; import org.apache.flink.table.api.ValidationException; import org.apache.flink.table.catalog.CatalogPropertiesUtil; diff --git a/flink-connector-hive/src/test/java/org/apache/flink/table/catalog/hive/HiveCatalogUdfITCase.java b/flink-connector-hive/src/test/java/org/apache/flink/table/catalog/hive/HiveCatalogUdfITCase.java index 429b19e9..47e94f8a 100644 --- a/flink-connector-hive/src/test/java/org/apache/flink/table/catalog/hive/HiveCatalogUdfITCase.java +++ b/flink-connector-hive/src/test/java/org/apache/flink/table/catalog/hive/HiveCatalogUdfITCase.java @@ -21,7 +21,7 @@ package org.apache.flink.table.catalog.hive; import org.apache.flink.api.common.functions.MapFunction; import org.apache.flink.api.java.tuple.Tuple2; import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment; -import org.apache.flink.streaming.api.functions.sink.SinkFunction; +import org.apache.flink.streaming.api.functions.sink.legacy.SinkFunction; import org.apache.flink.table.api.DataTypes; import org.apache.flink.table.api.EnvironmentSettings; import org.apache.flink.table.api.Schema; 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 d7dbe46a..056727af 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 @@ -22,13 +22,15 @@ 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; import org.apache.flink.table.catalog.ObjectIdentifier; import org.apache.flink.table.catalog.hive.HiveCatalogLock; import org.apache.flink.table.connector.ChangelogMode; import org.apache.flink.table.connector.RequireCatalogLock; import org.apache.flink.table.connector.sink.DynamicTableSink; -import org.apache.flink.table.connector.sink.SinkFunctionProvider; +import org.apache.flink.table.connector.sink.legacy.SinkFunctionProvider; import org.apache.flink.table.data.RowData; import org.apache.flink.table.factories.DynamicTableSinkFactory;
