You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ga...@apache.org on 2019/12/17 10:47:46 UTC
[flink] 04/04: [hotfix][tests] Remove unnecessary override of
close() method
This is an automated email from the ASF dual-hosted git repository.
gary pushed a commit to branch release-1.10
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 1e942417fc65ac65cb79e894a64c30466cd24f54
Author: Gary Yao <ga...@apache.org>
AuthorDate: Wed Dec 11 11:31:03 2019 +0100
[hotfix][tests] Remove unnecessary override of close() method
---
.../checkpointing/ContinuousFileProcessingCheckpointITCase.java | 9 ---------
1 file changed, 9 deletions(-)
diff --git a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/ContinuousFileProcessingCheckpointITCase.java b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/ContinuousFileProcessingCheckpointITCase.java
index 2bcb09d..b79d322 100644
--- a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/ContinuousFileProcessingCheckpointITCase.java
+++ b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/ContinuousFileProcessingCheckpointITCase.java
@@ -229,15 +229,6 @@ public class ContinuousFileProcessingCheckpointITCase extends StreamFaultToleran
}
@Override
- public void close() {
- try {
- super.close();
- } catch (Exception e) {
- e.printStackTrace();
- }
- }
-
- @Override
public List<Tuple2<Long, Map<Integer, Set<String>>>> snapshotState(long checkpointId, long checkpointTimestamp) throws Exception {
Tuple2<Long, Map<Integer, Set<String>>> state = new Tuple2<>(elementCounter, actualContent);
return Collections.singletonList(state);