Fix NPE in IPFSCompat.

apache · Aug 20, 2020 · 76be216 · 76be216
1 parent 2d12c13
commit 76be216
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/contrib/storage-ipfs/src/main/java/org/apache/drill/exec/store/ipfs/IPFSCompat.java b/contrib/storage-ipfs/src/main/java/org/apache/drill/exec/store/ipfs/IPFSCompat.java
@@ -135,9 +135,9 @@ public class DHT {
      * @return List of Multiaddresses of the peer
      */
     public List<String> findpeerListTimeout(Multihash id, int timeout, ExecutorService executor) {
-      AtomicReference<List<String>> ret = new AtomicReference<>();
+      AtomicReference<List<String>> ret = new AtomicReference<>(new ArrayList<>());
       timeLimitedExec(
-          "name/resolve?arg=" + id,
+          "dht/findpeer?arg=" + id,
           timeout,
           res -> {
             Map peer = (Map) res;