Github user kiszk commented on a diff in the pull request:

    https://github.com/apache/spark/pull/22399#discussion_r218635691
  
    --- Diff: 
common/network-common/src/test/java/org/apache/spark/network/ChunkFetchIntegrationSuite.java
 ---
    @@ -143,37 +143,38 @@ public void releaseBuffers() {
       }
     
       private FetchResult fetchChunks(List<Integer> chunkIndices) throws 
Exception {
    -    TransportClient client = 
clientFactory.createClient(TestUtils.getLocalHost(), server.getPort());
    -    final Semaphore sem = new Semaphore(0);
    -
         final FetchResult res = new FetchResult();
    --- End diff --
    
    I see, thanks.


---

---------------------------------------------------------------------
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail: reviews-h...@spark.apache.org

Reply via email to