You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ji...@apache.org on 2019/01/03 05:12:01 UTC
[flink] branch master updated: [FLINK-11181][tests] Fix
SimpleRecoveryFailureRateStrategyITBase test error
This is an automated email from the ASF dual-hosted git repository.
jincheng pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new f6995f0 [FLINK-11181][tests] Fix SimpleRecoveryFailureRateStrategyITBase test error
f6995f0 is described below
commit f6995f01ef748e4992a37defd60197d1ab4bd00e
Author: hequn8128 <ch...@gmail.com>
AuthorDate: Thu Jan 3 10:10:20 2019 +0800
[FLINK-11181][tests] Fix SimpleRecoveryFailureRateStrategyITBase test error
This colses #7316
---
.../test/recovery/SimpleRecoveryFailureRateStrategyITBase.java | 1 +
.../org/apache/flink/test/recovery/SimpleRecoveryITCaseBase.java | 6 ++++++
2 files changed, 7 insertions(+)
diff --git a/flink-tests/src/test/java/org/apache/flink/test/recovery/SimpleRecoveryFailureRateStrategyITBase.java b/flink-tests/src/test/java/org/apache/flink/test/recovery/SimpleRecoveryFailureRateStrategyITBase.java
index 6783df0..1a5b2a3 100644
--- a/flink-tests/src/test/java/org/apache/flink/test/recovery/SimpleRecoveryFailureRateStrategyITBase.java
+++ b/flink-tests/src/test/java/org/apache/flink/test/recovery/SimpleRecoveryFailureRateStrategyITBase.java
@@ -33,6 +33,7 @@ public class SimpleRecoveryFailureRateStrategyITBase extends SimpleRecoveryITCas
@ClassRule
public static final MiniClusterWithClientResource MINI_CLUSTER_RESOURCE = new MiniClusterWithClientResource(
new MiniClusterResourceConfiguration.Builder()
+ .setConfiguration(getConfiguration())
.setNumberTaskManagers(2)
.setNumberSlotsPerTaskManager(2)
.build());
diff --git a/flink-tests/src/test/java/org/apache/flink/test/recovery/SimpleRecoveryITCaseBase.java b/flink-tests/src/test/java/org/apache/flink/test/recovery/SimpleRecoveryITCaseBase.java
index d81274d..43de1f4 100644
--- a/flink-tests/src/test/java/org/apache/flink/test/recovery/SimpleRecoveryITCaseBase.java
+++ b/flink-tests/src/test/java/org/apache/flink/test/recovery/SimpleRecoveryITCaseBase.java
@@ -110,6 +110,8 @@ public abstract class SimpleRecoveryITCaseBase {
catch (Exception e) {
e.printStackTrace();
fail(e.getMessage());
+ } finally {
+ FailingMapper1.failuresBeforeSuccess = 1;
}
}
@@ -158,6 +160,8 @@ public abstract class SimpleRecoveryITCaseBase {
catch (Exception e) {
e.printStackTrace();
fail(e.getMessage());
+ } finally {
+ FailingMapper2.failuresBeforeSuccess = 1;
}
}
@@ -194,6 +198,8 @@ public abstract class SimpleRecoveryITCaseBase {
catch (Exception e) {
e.printStackTrace();
fail(e.getMessage());
+ } finally {
+ FailingMapper3.failuresBeforeSuccess = 3;
}
}