commit 390427027352d9d20035053fdbdac97baaae138c
author 维章 <unclerangoo@gmail.com> Tue Jun 21 11:50:23 2022 +0800
committer 维章 <unclerangoo@gmail.com> Tue Jun 21 11:50:23 2022 +0800
tree 43b7bbabaad31942ec8d773ad28d06df8386bacc
parent 1cd2dd0291dbcab033e6773021ddca13ce819f82

remove line

rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/model/WindowCache.java

diff --git a/rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/model/WindowCache.java b/rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/model/WindowCache.java
index c53a50f..28ed5da 100644
--- a/rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/model/WindowCache.java
+++ b/rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/model/WindowCache.java
@@ -105,7 +105,6 @@
             JSONObject jsonObject=shuffleChannel.createMsg(allMsgs,split);
 //            JSONObject zipJsonObject = new JSONObject();
 //            zipJsonObject.put(COMPRESSION_MSG_DATA, CompressUtil.gZip(jsonObject.toJSONString()));
-//            zipJsonObject.put(IS_COMPRESSION_MSG, true);
             shuffleChannel.getProducer().batchAdd(new Message(jsonObject), split);
             shuffleChannel.getProducer().flush(split.getQueueId());
             long cost=System.currentTimeMillis()-start;