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:20 UTC

[07/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/8eb4604c
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/8eb4604c
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/8eb4604c

Branch: refs/heads/master
Commit: 8eb4604cd82a89258a6581ca8be4f419784e5096
Parents: 4f0fa0b
Author: zentol <ch...@apache.org>
Authored: Thu Apr 5 11:00:23 2018 +0200
Committer: zentol <ch...@apache.org>
Committed: Mon Apr 16 21:17:53 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/8eb4604c/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,