This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch pull/19923/head
in repository https://gitbox.apache.org/repos/asf/flink.git
commit dcdfa56beaf0abbeedfa0335769c5de63af7d7ef
Author: Chesnay Schepler <ches...@apache.org>
AuthorDate: Wed Sep 14 18:28:07 2022 +0200
Enable checkpointing
---
.../flink-sql-client-test/src/test/java/SqlClientITCase.java | 10 +++++++++-
1 file changed, 9 insertions(+), 1 deletion(-)
diff --git
a/flink-end-to-end-tests/flink-sql-client-test/src/test/java/SqlClientITCase.java
b/flink-end-to-end-tests/flink-sql-client-test/src/test/java/SqlClientITCase.java
index 125d395e4ec..f5381fe1fd2 100644
---
a/flink-end-to-end-tests/flink-sql-client-test/src/test/java/SqlClientITCase.java
+++
b/flink-end-to-end-tests/flink-sql-client-test/src/test/java/SqlClientITCase.java
@@ -20,6 +20,7 @@ import
org.apache.flink.connector.testframe.container.FlinkContainers;
import org.apache.flink.connector.testframe.container.FlinkContainersSettings;
import org.apache.flink.connector.testframe.container.TestcontainersSettings;
import org.apache.flink.connector.upserttest.sink.UpsertTestFileUtil;
+import
org.apache.flink.streaming.api.environment.ExecutionCheckpointingOptions;
import org.apache.flink.test.util.SQLJobSubmission;
import org.apache.flink.tests.util.TestUtils;
import org.apache.flink.tests.util.kafka.KafkaContainerClient;
@@ -43,6 +44,7 @@ import org.testcontainers.utility.DockerImageName;
import java.io.File;
import java.io.IOException;
import java.nio.file.Path;
+import java.time.Duration;
import java.util.Arrays;
import java.util.List;
@@ -76,7 +78,13 @@ public class SqlClientITCase {
public final FlinkContainers flink =
FlinkContainers.builder()
.withFlinkContainersSettings(
-
FlinkContainersSettings.builder().numTaskManagers(1).build())
+ FlinkContainersSettings.builder()
+ .numTaskManagers(1)
+ // enable checkpointing for the
UpsertTestSink to write anything
+ .setConfigOption(
+
ExecutionCheckpointingOptions.CHECKPOINTING_INTERVAL,
+ Duration.ofMillis(500))
+ .build())
.withTestcontainersSettings(
TestcontainersSettings.builder()
.network(NETWORK)
