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 2019/08/15 06:12:31 UTC
[flink] branch release-1.9 updated: [FLINK-13530][qs][tests]
Increase port range size
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch release-1.9
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.9 by this push:
new 2a22967 [FLINK-13530][qs][tests] Increase port range size
2a22967 is described below
commit 2a2296717e292fcdca775039fe8b8fb9d1fc75b0
Author: Chesnay Schepler <ch...@apache.org>
AuthorDate: Thu Aug 1 12:07:49 2019 +0200
[FLINK-13530][qs][tests] Increase port range size
---
.../flink/queryablestate/network/AbstractServerTest.java | 13 +++++++------
1 file changed, 7 insertions(+), 6 deletions(-)
diff --git a/flink-queryable-state/flink-queryable-state-runtime/src/test/java/org/apache/flink/queryablestate/network/AbstractServerTest.java b/flink-queryable-state/flink-queryable-state-runtime/src/test/java/org/apache/flink/queryablestate/network/AbstractServerTest.java
index 4ef6bf7..9e5720d 100644
--- a/flink-queryable-state/flink-queryable-state-runtime/src/test/java/org/apache/flink/queryablestate/network/AbstractServerTest.java
+++ b/flink-queryable-state/flink-queryable-state-runtime/src/test/java/org/apache/flink/queryablestate/network/AbstractServerTest.java
@@ -44,6 +44,8 @@ import java.util.Collections;
import java.util.Iterator;
import java.util.List;
import java.util.concurrent.CompletableFuture;
+import java.util.stream.Collectors;
+import java.util.stream.IntStream;
/**
* Tests general behavior of the {@link AbstractServerBase}.
@@ -88,10 +90,9 @@ public class AbstractServerTest extends TestLogger {
AtomicKvStateRequestStats serverStats = new AtomicKvStateRequestStats();
AtomicKvStateRequestStats clientStats = new AtomicKvStateRequestStats();
- List<Integer> portList = new ArrayList<>();
- portList.add(7777);
- portList.add(7778);
- portList.add(7779);
+ final int portRangeStart = 7777;
+ final int portRangeEnd = 7900;
+ List<Integer> portList = IntStream.range(portRangeStart, portRangeEnd + 1).boxed().collect(Collectors.toList());
try (
TestServer server1 = new TestServer("Test Server 1", serverStats, portList.iterator());
@@ -104,10 +105,10 @@ public class AbstractServerTest extends TestLogger {
)
) {
server1.start();
- Assert.assertTrue(server1.getServerAddress().getPort() >= 7777 && server1.getServerAddress().getPort() <= 7779);
+ Assert.assertTrue(server1.getServerAddress().getPort() >= portRangeStart && server1.getServerAddress().getPort() <= portRangeEnd);
server2.start();
- Assert.assertTrue(server2.getServerAddress().getPort() >= 7777 && server2.getServerAddress().getPort() <= 7779);
+ Assert.assertTrue(server2.getServerAddress().getPort() >= portRangeStart && server2.getServerAddress().getPort() <= portRangeEnd);
TestMessage response1 = client.sendRequest(server1.getServerAddress(), new TestMessage("ping")).join();
Assert.assertEquals(server1.getServerName() + "-ping", response1.getMessage());