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 05d8cdc0aeb83e8464825b746137060b25c9f1bf Author: JunRuiLee <[email protected]> AuthorDate: Mon Aug 26 14:27:05 2024 +0800 [FLINK-36249][streaming-java] Remove RestartStrategy-related configuration getters/setters that return/set complex Java objects. This closes #25256. --- .../java/org/apache/flink/connectors/hive/HiveTableSinkITCase.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveTableSinkITCase.java b/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveTableSinkITCase.java index f84b1554..160ccedb 100644 --- a/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveTableSinkITCase.java +++ b/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveTableSinkITCase.java @@ -20,7 +20,6 @@ package org.apache.flink.connectors.hive; import org.apache.flink.FlinkVersion; import org.apache.flink.api.common.eventtime.WatermarkStrategy; -import org.apache.flink.api.common.restartstrategy.RestartStrategies; import org.apache.flink.api.common.typeinfo.Types; import org.apache.flink.api.java.typeutils.RowTypeInfo; import org.apache.flink.connector.datagen.source.TestDataGenerators; @@ -28,6 +27,7 @@ import org.apache.flink.connector.file.table.FileSystemConnectorOptions; import org.apache.flink.core.fs.Path; import org.apache.flink.streaming.api.datastream.DataStream; import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment; +import org.apache.flink.streaming.util.RestartStrategyUtils; import org.apache.flink.table.api.DataTypes; import org.apache.flink.table.api.ExplainDetail; import org.apache.flink.table.api.Expressions; @@ -787,7 +787,7 @@ class HiveTableSinkITCase { env.setParallelism(1); env.enableCheckpointing(100); // avoid the job to restart infinitely - env.setRestartStrategy(RestartStrategies.fixedDelayRestart(3, 1_000)); + RestartStrategyUtils.configureFixedDelayRestartStrategy(env, 3, 1000L); StreamTableEnvironment tEnv = HiveTestUtils.createTableEnvInStreamingMode(env); tEnv.registerCatalog(hiveCatalog.getName(), hiveCatalog);
