[flink] branch master updated: [FLINK-11180][tests] Use random port in ProcessFailureCancelingITCase

[chesnay]

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 b02121c  [FLINK-11180][tests] Use random port in 
ProcessFailureCancelingITCase
b02121c is described below

commit b02121c4673f80e606c7211d73de29c7295df7ae
Author: Hequn Cheng <heq...@163.com>
AuthorDate: Wed Dec 19 19:45:16 2018 +0800

    [FLINK-11180][tests] Use random port in ProcessFailureCancelingITCase
---
 .../org/apache/flink/test/recovery/ProcessFailureCancelingITCase.java   | 2 ++
 1 file changed, 2 insertions(+)

diff --git 
a/flink-tests/src/test/java/org/apache/flink/test/recovery/ProcessFailureCancelingITCase.java
 
b/flink-tests/src/test/java/org/apache/flink/test/recovery/ProcessFailureCancelingITCase.java
index ed987d6..96e289d 100644
--- 
a/flink-tests/src/test/java/org/apache/flink/test/recovery/ProcessFailureCancelingITCase.java
+++ 
b/flink-tests/src/test/java/org/apache/flink/test/recovery/ProcessFailureCancelingITCase.java
@@ -32,6 +32,7 @@ import org.apache.flink.configuration.AkkaOptions;
 import org.apache.flink.configuration.Configuration;
 import org.apache.flink.configuration.HighAvailabilityOptions;
 import org.apache.flink.configuration.JobManagerOptions;
+import org.apache.flink.configuration.RestOptions;
 import org.apache.flink.configuration.TaskManagerOptions;
 import org.apache.flink.runtime.client.JobStatusMessage;
 import org.apache.flink.runtime.clusterframework.ApplicationStatus;
@@ -116,6 +117,7 @@ public class ProcessFailureCancelingITCase extends 
TestLogger {
                config.setInteger(TaskManagerOptions.NUM_TASK_SLOTS, 2);
                config.setString(TaskManagerOptions.MANAGED_MEMORY_SIZE, "4m");
                config.setInteger(TaskManagerOptions.NETWORK_NUM_BUFFERS, 100);
+               config.setInteger(RestOptions.PORT, 0);
 
                final RpcService rpcService = 
AkkaRpcServiceUtils.createRpcService("localhost", 0, config);
                final int jobManagerPort = rpcService.getPort();