[rocketmq-streams] branch async-ck updated: add 'synchronized', fix joinwindow firewindow issue

[xi...@apache.org]

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

xiaodong pushed a commit to branch async-ck
in repository https://gitbox.apache.org/repos/asf/rocketmq-streams.git


The following commit(s) were added to refs/heads/async-ck by this push:
     new f629927  add 'synchronized', fix joinwindow firewindow issue
     new c621e7d  Merge pull request #83 from xstorm1/async-ck
f629927 is described below

commit f629927b14d49befa9544195a547ba511b16defb
Author: xstorm1 <xs...@live.cn>
AuthorDate: Thu Oct 14 17:16:31 2021 +0800

    add 'synchronized', fix joinwindow firewindow issue
---
 .../org/apache/rocketmq/streams/window/operator/join/JoinWindow.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/operator/join/JoinWindow.java b/rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/operator/join/JoinWindow.java
index 920d525..f377370 100644
--- a/rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/operator/join/JoinWindow.java
+++ b/rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/operator/join/JoinWindow.java
@@ -461,7 +461,7 @@ public class JoinWindow extends AbstractShuffleWindow {
      * @param windowInstance
      */
     @Override
-    public void clearFireWindowInstance(WindowInstance windowInstance) {
+    public synchronized void clearFireWindowInstance(WindowInstance windowInstance) {
 //        String partitionNum=(getOrderBypPrefix()+ windowInstance.getSplitId());
 
         List<WindowInstance> removeInstances = new ArrayList<>();