[rocketmq-streams] branch snapshot-1.0.3 updated: remove line

[karp]

This is an automated email from the ASF dual-hosted git repository.

karp pushed a commit to branch snapshot-1.0.3
in repository https://gitbox.apache.org/repos/asf/rocketmq-streams.git


The following commit(s) were added to refs/heads/snapshot-1.0.3 by this push:
     new 3904270  remove line
3904270 is described below

commit 390427027352d9d20035053fdbdac97baaae138c
Author: 维章 <uncleran...@gmail.com>
AuthorDate: Tue Jun 21 11:50:23 2022 +0800

    remove line
---
 .../main/java/org/apache/rocketmq/streams/window/model/WindowCache.java  | 1 -
 1 file changed, 1 deletion(-)

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 @@ public abstract class WindowCache extends
             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;