This is an automated email from the ASF dual-hosted git repository. gaoyunhaii pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit 64367a2f134ba9f174986845479d3fc0560f756f Author: Gen Luo <[email protected]> AuthorDate: Tue Mar 1 17:32:33 2022 +0800 Revert "[FLINK-26314][connectors/filesystem] Disable unaligned checkpoints for StreamingExecutionFileSinkITCase." This reverts commit 69276df0 --- .../connector/file/sink/StreamingCompactingFileSinkITCase.java | 8 -------- .../connector/file/sink/StreamingExecutionFileSinkITCase.java | 3 --- 2 files changed, 11 deletions(-) diff --git a/flink-connectors/flink-connector-files/src/test/java/org/apache/flink/connector/file/sink/StreamingCompactingFileSinkITCase.java b/flink-connectors/flink-connector-files/src/test/java/org/apache/flink/connector/file/sink/StreamingCompactingFileSinkITCase.java index de701d1..227d49a 100644 --- a/flink-connectors/flink-connector-files/src/test/java/org/apache/flink/connector/file/sink/StreamingCompactingFileSinkITCase.java +++ b/flink-connectors/flink-connector-files/src/test/java/org/apache/flink/connector/file/sink/StreamingCompactingFileSinkITCase.java @@ -27,7 +27,6 @@ import org.apache.flink.connector.file.sink.utils.IntegerFileSinkTestDataUtils.I import org.apache.flink.core.fs.Path; import org.apache.flink.runtime.minicluster.RpcServiceSharing; import org.apache.flink.runtime.testutils.MiniClusterResourceConfiguration; -import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment; import org.apache.flink.test.util.MiniClusterWithClientResource; import org.junit.Rule; @@ -60,13 +59,6 @@ public class StreamingCompactingFileSinkITCase extends StreamingExecutionFileSin .build(); } - @Override - protected void configureEnvironment(StreamExecutionEnvironment env) { - super.configureEnvironment(env); - // Disable unaligned checkpoints explicitly to avoid being randomly enabled - env.getCheckpointConfig().enableUnalignedCheckpoints(false); - } - private static FileCompactor createFileCompactor() { return new RecordWiseFileCompactor<>(new DecoderBasedReader.Factory<>(IntDecoder::new)); } diff --git a/flink-connectors/flink-connector-files/src/test/java/org/apache/flink/connector/file/sink/StreamingExecutionFileSinkITCase.java b/flink-connectors/flink-connector-files/src/test/java/org/apache/flink/connector/file/sink/StreamingExecutionFileSinkITCase.java index 6209a46..c9d8f9f 100644 --- a/flink-connectors/flink-connector-files/src/test/java/org/apache/flink/connector/file/sink/StreamingExecutionFileSinkITCase.java +++ b/flink-connectors/flink-connector-files/src/test/java/org/apache/flink/connector/file/sink/StreamingExecutionFileSinkITCase.java @@ -82,7 +82,6 @@ public class StreamingExecutionFileSinkITCase extends FileSinkITBase { env.configure(config, getClass().getClassLoader()); env.enableCheckpointing(10, CheckpointingMode.EXACTLY_ONCE); - configureEnvironment(env); if (triggerFailover) { env.setRestartStrategy(RestartStrategies.fixedDelayRestart(1, Time.milliseconds(100))); @@ -99,8 +98,6 @@ public class StreamingExecutionFileSinkITCase extends FileSinkITBase { return streamGraph.getJobGraph(); } - protected void configureEnvironment(StreamExecutionEnvironment env) {} - // ------------------------ Streaming mode user functions ---------------------------------- private static class StreamingExecutionTestSource extends RichParallelSourceFunction<Integer>
