StyleFix

Alluxio · Dec 22, 2016 · 6ab58a5 · 6ab58a5
1 parent 61d7b1d
commit 6ab58a5
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 3 deletions.
diff --git a/core/client/src/main/java/alluxio/client/block/stream/PacketInStream.java b/core/client/src/main/java/alluxio/client/block/stream/PacketInStream.java
@@ -22,7 +22,6 @@
 
 import com.google.common.base.Preconditions;
 import io.netty.buffer.ByteBuf;
-import io.netty.util.ReferenceCountUtil;
 
 import java.io.IOException;
 import java.io.InputStream;
@@ -266,7 +265,7 @@ private void closePacketReader() {
    * @param packet the packet
    */
   private void destroyPacket(ByteBuf packet) {
-    ReferenceCountUtil.release(packet);
+    packet.release();
   }
 
   /**

diff --git a/core/client/src/main/java/alluxio/client/block/stream/PacketOutStream.java b/core/client/src/main/java/alluxio/client/block/stream/PacketOutStream.java
@@ -27,7 +27,6 @@
 import java.io.OutputStream;
 import java.net.InetSocketAddress;
 import java.util.ArrayList;
-import java.util.Iterator;
 import java.util.List;
 
 import javax.annotation.concurrent.NotThreadSafe;