You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2018/04/16 19:18:45 UTC

[04/11] flink git commit: [hotfix][tests] Add MCR constructor accepting configuration and type

[hotfix][tests] Add MCR constructor accepting configuration and type


Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a0a24b27
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a0a24b27
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/a0a24b27

Branch: refs/heads/release-1.5
Commit: a0a24b277882382d3c0712ec8fea7c5166a86f9a
Parents: 47909f4
Author: zentol <ch...@apache.org>
Authored: Thu Apr 5 11:00:23 2018 +0200
Committer: zentol <ch...@apache.org>
Committed: Mon Apr 16 21:18:32 2018 +0200

----------------------------------------------------------------------
 .../java/org/apache/flink/test/util/MiniClusterResource.java   | 6 ++++++
 1 file changed, 6 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/a0a24b27/flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/MiniClusterResource.java
----------------------------------------------------------------------
diff --git a/flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/MiniClusterResource.java b/flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/MiniClusterResource.java
index 9b0ac77..8a05750 100644
--- a/flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/MiniClusterResource.java
+++ b/flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/MiniClusterResource.java
@@ -77,6 +77,12 @@ public class MiniClusterResource extends ExternalResource {
 
 	public MiniClusterResource(
 			final MiniClusterResourceConfiguration miniClusterResourceConfiguration,
+			final MiniClusterType miniClusterType) {
+		this(miniClusterResourceConfiguration, miniClusterType, false);
+	}
+
+	public MiniClusterResource(
+			final MiniClusterResourceConfiguration miniClusterResourceConfiguration,
 			final boolean enableClusterClient) {
 		this(
 			miniClusterResourceConfiguration,