From 5f7b16ec8d6017bc54877b220b573f8c57e91eb8 Mon Sep 17 00:00:00 2001 From: hequn8128 Date: Thu, 3 Jan 2019 10:10:20 +0800 Subject: [PATCH] [FLINK-11181][tests] Fix SimpleRecoveryFailureRateStrategyITBase test error --- .../recovery/SimpleRecoveryFailureRateStrategyITBase.java | 1 + .../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 6783df0a85b0a..1a5b2a32f9b75 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 d81274d497341..43de1f4645b30 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 Long reduce(Long value1, Long value2) { catch (Exception e) { e.printStackTrace(); fail(e.getMessage()); + } finally { + FailingMapper1.failuresBeforeSuccess = 1; } } @@ -158,6 +160,8 @@ public Long reduce(Long value1, Long value2) { catch (Exception e) { e.printStackTrace(); fail(e.getMessage()); + } finally { + FailingMapper2.failuresBeforeSuccess = 1; } } @@ -194,6 +198,8 @@ public Long reduce(Long value1, Long value2) { catch (Exception e) { e.printStackTrace(); fail(e.getMessage()); + } finally { + FailingMapper3.failuresBeforeSuccess = 3; } }