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/04/16 09:43:38 UTC
[flink] 04/04: [hotfix][tests] Fix typo in exception message
This is an automated email from the ASF dual-hosted git repository.
gary pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 3e5a240a35936f4b953bbd3226dfa81d9ed3ab43
Author: Gary Yao <ga...@apache.org>
AuthorDate: Tue Apr 16 11:29:37 2019 +0200
[hotfix][tests] Fix typo in exception message
---
.../apache/flink/streaming/tests/DataStreamAllroundTestJobFactory.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/flink-end-to-end-tests/flink-datastream-allround-test/src/main/java/org/apache/flink/streaming/tests/DataStreamAllroundTestJobFactory.java b/flink-end-to-end-tests/flink-datastream-allround-test/src/main/java/org/apache/flink/streaming/tests/DataStreamAllroundTestJobFactory.java
index a897bf2..913d030 100644
--- a/flink-end-to-end-tests/flink-datastream-allround-test/src/main/java/org/apache/flink/streaming/tests/DataStreamAllroundTestJobFactory.java
+++ b/flink-end-to-end-tests/flink-datastream-allround-test/src/main/java/org/apache/flink/streaming/tests/DataStreamAllroundTestJobFactory.java
@@ -303,7 +303,7 @@ public class DataStreamAllroundTestJobFactory {
restartStrategy = RestartStrategies.noRestart();
break;
default:
- throw new IllegalArgumentException("Unkown restart strategy: " + restartStrategyConfig);
+ throw new IllegalArgumentException("Unknown restart strategy: " + restartStrategyConfig);
}
env.setRestartStrategy(restartStrategy);
}