File tree Expand file tree Collapse file tree
contrib/storage-ipfs/src/main/java/org/apache/drill/exec/store/ipfs Expand file tree Collapse file tree Original file line number Diff line number Diff 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 ();
You can’t perform that action at this time.
0 commit comments