diff --git a/src/main/java/com/yuandian/dataflow/master/Header.java b/src/main/java/com/yuandian/dataflow/master/Header.java
index 2f2b9f6..a1cdb8c 100644
--- a/src/main/java/com/yuandian/dataflow/master/Header.java
+++ b/src/main/java/com/yuandian/dataflow/master/Header.java
@@ -47,5 +47,18 @@ public class Header {
         log.error("{}", pheader);
         log.error("{}",PacketBase.createPacketBase(pheader));
 
+
+        //60010流需要解压
+        byte[] unzipbodydata = null;
+        if (pheader.getTableID() == 20) {
+    
+            pheader.parseNextHeader_60010(in);
+
+            byte[] zipbodydata = new byte[packetHeader.getMsg_len()];
+            readTillLength(zipbodydata, packetHeader.getMsg_len());
+            unzipbodydata = ZlibUtil.Inflate(zipbodydata);
+
+        }
+
     }
 }
diff --git a/src/main/java/com/yuandian/dataflow/proto/decode/BacktrackingFlow.java b/src/main/java/com/yuandian/dataflow/proto/decode/BacktrackingFlow.java
index 83aa13d..6cf81ba 100644
--- a/src/main/java/com/yuandian/dataflow/proto/decode/BacktrackingFlow.java
+++ b/src/main/java/com/yuandian/dataflow/proto/decode/BacktrackingFlow.java
@@ -29,9 +29,6 @@ public class BacktrackingFlow extends PacketBase{
 	private long appGroupId;//	4	app组ID
 	private long mplsLabel;//	4	
 
-
-	
-	
 	
 	@Override
 	public PacketBase  Parse(PacketHeader header,ByteBuffer data) throws Exception {