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 2020/08/04 14:12:13 UTC
[flink] branch master updated: [FLINK-18658][tests] Forward
RpcServiceSharing setting
This is an automated email from the ASF dual-hosted git repository.
chesnay 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 86594ba [FLINK-18658][tests] Forward RpcServiceSharing setting
86594ba is described below
commit 86594ba8e14c70c435fb26c916e86cdddad85cfa
Author: Chesnay Schepler <ch...@apache.org>
AuthorDate: Tue Jul 21 10:57:21 2020 +0200
[FLINK-18658][tests] Forward RpcServiceSharing setting
---
.../java/org/apache/flink/runtime/testutils/MiniClusterResource.java | 1 +
1 file changed, 1 insertion(+)
diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/testutils/MiniClusterResource.java b/flink-runtime/src/test/java/org/apache/flink/runtime/testutils/MiniClusterResource.java
index 60a89a2..aaa7f54 100644
--- a/flink-runtime/src/test/java/org/apache/flink/runtime/testutils/MiniClusterResource.java
+++ b/flink-runtime/src/test/java/org/apache/flink/runtime/testutils/MiniClusterResource.java
@@ -172,6 +172,7 @@ public class MiniClusterResource extends ExternalResource {
.setConfiguration(configuration)
.setNumTaskManagers(miniClusterResourceConfiguration.getNumberTaskManagers())
.setNumSlotsPerTaskManager(miniClusterResourceConfiguration.getNumberSlotsPerTaskManager())
+ .setRpcServiceSharing(miniClusterResourceConfiguration.getRpcServiceSharing())
.build();
miniCluster = new MiniCluster(miniClusterConfiguration);