diff options
Diffstat (limited to 'exec/java-exec/src')
| -rw-r--r-- | exec/java-exec/src/main/java/org/apache/drill/exec/client/DrillClient.java | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/client/DrillClient.java b/exec/java-exec/src/main/java/org/apache/drill/exec/client/DrillClient.java index ae0f58070..4576eb4be 100644 --- a/exec/java-exec/src/main/java/org/apache/drill/exec/client/DrillClient.java +++ b/exec/java-exec/src/main/java/org/apache/drill/exec/client/DrillClient.java @@ -174,9 +174,10 @@ public class DrillClient implements Closeable, ConnectionThrottle { final DrillbitEndpoint endpoint; if (isDirectConnection) { String[] connectInfo = props.getProperty("drillbit").split(":"); + String port = connectInfo.length==2?connectInfo[1]:config.getString(ExecConstants.INITIAL_USER_PORT); endpoint = DrillbitEndpoint.newBuilder() .setAddress(connectInfo[0]) - .setUserPort(Integer.parseInt(connectInfo[1])) + .setUserPort(Integer.parseInt(port)) .build(); } else { if (ownsZkConnection) { |