Skip to content

Commit d7ee62c

Browse files
committed
Fix IPFSGroupScan.
1 parent 1d7b9e4 commit d7ee62c

1 file changed

Lines changed: 8 additions & 4 deletions

File tree

contrib/storage-ipfs/src/main/java/org/apache/drill/exec/store/ipfs/IPFSGroupScan.java

Lines changed: 8 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -75,6 +75,10 @@ public class IPFSGroupScan extends AbstractGroupScan {
7575
private List<SchemaPath> columns;
7676

7777
private static final long DEFAULT_NODE_SIZE = 1000L;
78+
private static final int DEFAULT_USER_PORT = 31010;
79+
private static final int DEFAULT_CONTROL_PORT = 31011;
80+
private static final int DEFAULT_DATA_PORT = 31012;
81+
private static final int DEFAULT_HTTP_PORT = 8047;
7882

7983
private ListMultimap<Integer, IPFSWork> assignments;
8084
private List<IPFSWork> ipfsWorkList = Lists.newArrayList();
@@ -130,10 +134,10 @@ private void init() {
130134
//DRILL-7754: read ports & version info from IPFS instead of hard-coded
131135
ep = DrillbitEndpoint.newBuilder()
132136
.setAddress(peerHostname)
133-
.setUserPort(31010)
134-
.setControlPort(31011)
135-
.setDataPort(31012)
136-
.setHttpPort(8047)
137+
.setUserPort(DEFAULT_USER_PORT)
138+
.setControlPort(DEFAULT_CONTROL_PORT)
139+
.setDataPort(DEFAULT_DATA_PORT)
140+
.setHttpPort(DEFAULT_HTTP_PORT)
137141
.setVersion(DrillVersionInfo.getVersion())
138142
.setState(DrillbitEndpoint.State.ONLINE)
139143
.build();

0 commit comments

Comments
 (0)