Limit PortFinder to 0xFFFF

2016-02-25 08:09:08 -08:00 · 2016-02-25 08:09:08 -08:00 · 3fa7a7ebfe
parent 917e7e58f5
commit 3fa7a7ebfe
1 changed files with 2 additions and 1 deletions
--- a/indexing-service/src/main/java/io/druid/indexing/overlord/PortFinder.java
+++ b/indexing-service/src/main/java/io/druid/indexing/overlord/PortFinder.java
@ -95,7 +95,8 @@ public class PortFinder

  private int chooseNext(int start)
  {
-    for (int i = start; i < Integer.MAX_VALUE; i++) {
+    // up to unsigned short max (65535)
+    for (int i = start; i <= 0xFFFF; i++) {
      if (!usedPorts.contains(i)) {
        return i;
      }