Skip to content

Commit 76be216

Browse files
committed
Fix NPE in IPFSCompat.
1 parent 2d12c13 commit 76be216

File tree

1 file changed

+2
-2
lines changed
  • contrib/storage-ipfs/src/main/java/org/apache/drill/exec/store/ipfs

1 file changed

+2
-2
lines changed

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -135,9 +135,9 @@ public class DHT {
135135
* @return List of Multiaddresses of the peer
136136
*/
137137
public List<String> findpeerListTimeout(Multihash id, int timeout, ExecutorService executor) {
138-
AtomicReference<List<String>> ret = new AtomicReference<>();
138+
AtomicReference<List<String>> ret = new AtomicReference<>(new ArrayList<>());
139139
timeLimitedExec(
140-
"name/resolve?arg=" + id,
140+
"dht/findpeer?arg=" + id,
141141
timeout,
142142
res -> {
143143
Map peer = (Map) res;

0 commit comments

Comments
 (0)