You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by pn...@apache.org on 2019/10/22 14:11:31 UTC
[flink] 01/04: [hotfix][kafka,
test] Drop unused field in FailingIdentityMapper
This is an automated email from the ASF dual-hosted git repository.
pnowojski pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit ee433955575abed85a043e3b5a837028ed88ccd4
Author: Piotr Nowojski <pi...@gmail.com>
AuthorDate: Fri Oct 18 16:27:32 2019 +0200
[hotfix][kafka,test] Drop unused field in FailingIdentityMapper
---
.../streaming/connectors/kafka/testutils/FailingIdentityMapper.java | 2 --
1 file changed, 2 deletions(-)
diff --git a/flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/testutils/FailingIdentityMapper.java b/flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/testutils/FailingIdentityMapper.java
index c25eefb..bd412c9 100644
--- a/flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/testutils/FailingIdentityMapper.java
+++ b/flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/testutils/FailingIdentityMapper.java
@@ -42,7 +42,6 @@ public class FailingIdentityMapper<T> extends RichMapFunction<T, T> implements
private static final long serialVersionUID = 6334389850158707313L;
public static volatile boolean failedBefore;
- public static volatile boolean hasBeenCheckpointedBeforeFailure;
private final int failCount;
private int numElementsTotal;
@@ -74,7 +73,6 @@ public class FailingIdentityMapper<T> extends RichMapFunction<T, T> implements
Thread.sleep(10);
if (failer && numElementsTotal >= failCount) {
- hasBeenCheckpointedBeforeFailure = hasBeenCheckpointed;
failedBefore = true;
throw new Exception("Artificial Test Failure");
}