diff --git a/skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/handler/CollectionServerDataHandler.java b/skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/handler/CollectionServerDataHandler.java
index 524a873c4..5dd262472 100644
--- a/skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/handler/CollectionServerDataHandler.java
+++ b/skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/handler/CollectionServerDataHandler.java
@@ -1,12 +1,13 @@
 package com.ai.cloud.skywalking.reciever.handler;
 
 import com.ai.cloud.skywalking.reciever.buffer.DataBufferThreadContainer;
+import com.ai.cloud.skywalking.reciever.util.ByteArrayUtil;
 import io.netty.channel.ChannelHandlerContext;
 import io.netty.channel.SimpleChannelInboundHandler;
 
-public class CollectionServerDataHandler extends SimpleChannelInboundHandler {
+public class CollectionServerDataHandler extends SimpleChannelInboundHandler<byte[]> {
     @Override
-    protected void channelRead0(ChannelHandlerContext ctx, Object msg) throws Exception {
-        DataBufferThreadContainer.getDataBufferThread().doCarry(msg.toString().getBytes());
+    protected void channelRead0(ChannelHandlerContext ctx, byte[] msg) throws Exception {
+        DataBufferThreadContainer.getDataBufferThread().doCarry(msg);
     }
 }