From 82f2f4c6681193e43636f8c671cad437c27475b5 Mon Sep 17 00:00:00 2001 From: Zakelly Date: Wed, 13 Mar 2024 18:24:13 +0800 Subject: [PATCH] [FLINK-34516] Use new CheckpointingMode in flink-core in doc --- docs/content.zh/docs/dev/table/data_stream_api.md | 8 ++++---- docs/content/docs/dev/table/data_stream_api.md | 8 ++++---- 2 files changed, 8 insertions(+), 8 deletions(-) diff --git a/docs/content.zh/docs/dev/table/data_stream_api.md b/docs/content.zh/docs/dev/table/data_stream_api.md index 968066c13a7e38..8ee97c73954194 100644 --- a/docs/content.zh/docs/dev/table/data_stream_api.md +++ b/docs/content.zh/docs/dev/table/data_stream_api.md @@ -523,7 +523,7 @@ We recommend setting all configuration options in DataStream API early before sw {{< tab "Java" >}} ```java import java.time.ZoneId; -import org.apache.flink.streaming.api.CheckpointingMode; +import org.apache.flink.core.execution.CheckpointingMode.CheckpointingMode; import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment; import org.apache.flink.table.api.bridge.java.StreamTableEnvironment; @@ -537,7 +537,7 @@ env.setMaxParallelism(256); env.getConfig().addDefaultKryoSerializer(MyCustomType.class, CustomKryoSerializer.class); -env.getCheckpointConfig().setCheckpointingMode(CheckpointingMode.EXACTLY_ONCE); +env.getCheckpointConfig().setConsistencyMode(CheckpointingMode.EXACTLY_ONCE); // then switch to Java Table API @@ -553,9 +553,9 @@ tableEnv.getConfig().setLocalTimeZone(ZoneId.of("Europe/Berlin")); {{< tab "Scala" >}} ```scala import java.time.ZoneId +import org.apache.flink.core.execution.CheckpointingMode import org.apache.flink.api.scala._ import org.apache.flink.streaming.api.scala.StreamExecutionEnvironment -import org.apache.flink.streaming.api.CheckpointingMode import org.apache.flink.table.api.bridge.scala._ // create Scala DataStream API @@ -568,7 +568,7 @@ env.setMaxParallelism(256) env.getConfig.addDefaultKryoSerializer(classOf[MyCustomType], classOf[CustomKryoSerializer]) -env.getCheckpointConfig.setCheckpointingMode(CheckpointingMode.EXACTLY_ONCE) +env.getCheckpointConfig.setConsistencyMode(CheckpointingMode.EXACTLY_ONCE) // then switch to Scala Table API diff --git a/docs/content/docs/dev/table/data_stream_api.md b/docs/content/docs/dev/table/data_stream_api.md index cb67469f376e79..a14ff3e0b75374 100644 --- a/docs/content/docs/dev/table/data_stream_api.md +++ b/docs/content/docs/dev/table/data_stream_api.md @@ -521,7 +521,7 @@ We recommend setting all configuration options in DataStream API early before sw {{< tab "Java" >}} ```java import java.time.ZoneId; -import org.apache.flink.streaming.api.CheckpointingMode; +import org.apache.flink.core.execution.CheckpointingMode; import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment; import org.apache.flink.table.api.bridge.java.StreamTableEnvironment; @@ -535,7 +535,7 @@ env.setMaxParallelism(256); env.getConfig().addDefaultKryoSerializer(MyCustomType.class, CustomKryoSerializer.class); -env.getCheckpointConfig().setCheckpointingMode(CheckpointingMode.EXACTLY_ONCE); +env.getCheckpointConfig().setConsistencyMode(CheckpointingMode.EXACTLY_ONCE); // then switch to Java Table API @@ -551,9 +551,9 @@ tableEnv.getConfig().setLocalTimeZone(ZoneId.of("Europe/Berlin")); {{< tab "Scala" >}} ```scala import java.time.ZoneId +import org.apache.flink.core.execution.CheckpointingMode import org.apache.flink.api.scala._ import org.apache.flink.streaming.api.scala.StreamExecutionEnvironment -import org.apache.flink.streaming.api.CheckpointingMode import org.apache.flink.table.api.bridge.scala._ // create Scala DataStream API @@ -566,7 +566,7 @@ env.setMaxParallelism(256) env.getConfig.addDefaultKryoSerializer(classOf[MyCustomType], classOf[CustomKryoSerializer]) -env.getCheckpointConfig.setCheckpointingMode(CheckpointingMode.EXACTLY_ONCE) +env.getCheckpointConfig.setConsistencyMode(CheckpointingMode.EXACTLY_ONCE) // then switch to Scala Table API