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);