[GitHub] flink pull request #6205: [FLINK-9642]Reduce the count to deal with state du...

Github user Aitozi commented on a diff in the pull request: https://github.com/apache/flink/pull/6205#discussion_r198151182 --- Diff: flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/SharedBuffer.java --- @@ -346,16 +351,87 @@ private void

[GitHub] flink pull request #6205: [FLINK-9642]Reduce the count to deal with state du...

Github user sihuazhou commented on a diff in the pull request: https://github.com/apache/flink/pull/6205#discussion_r198146934 --- Diff: flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/SharedBuffer.java --- @@ -346,16 +351,87 @@ private void

[GitHub] flink pull request #6205: [FLINK-9642]Reduce the count to deal with state du...

Github user sihuazhou commented on a diff in the pull request: https://github.com/apache/flink/pull/6205#discussion_r198146056 --- Diff: flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/SharedBuffer.java --- @@ -346,16 +351,87 @@ private void

[GitHub] flink pull request #6205: [FLINK-9642]Reduce the count to deal with state du...

Github user Aitozi commented on a diff in the pull request: https://github.com/apache/flink/pull/6205#discussion_r198143091 --- Diff: flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/SharedBuffer.java --- @@ -346,16 +351,87 @@ private void

[GitHub] flink pull request #6205: [FLINK-9642]Reduce the count to deal with state du...

Github user Aitozi commented on a diff in the pull request: https://github.com/apache/flink/pull/6205#discussion_r198142501 --- Diff: flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/SharedBuffer.java --- @@ -346,16 +351,87 @@ private void

[GitHub] flink pull request #6205: [FLINK-9642]Reduce the count to deal with state du...

Github user sihuazhou commented on a diff in the pull request: https://github.com/apache/flink/pull/6205#discussion_r198135717 --- Diff: flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/SharedBuffer.java --- @@ -346,16 +351,87 @@ private void

[GitHub] flink pull request #6205: [FLINK-9642]Reduce the count to deal with state du...

Github user sihuazhou commented on a diff in the pull request: https://github.com/apache/flink/pull/6205#discussion_r198136425 --- Diff: flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/SharedBuffer.java --- @@ -346,16 +351,87 @@ private void

[GitHub] flink pull request #6205: [FLINK-9642]Reduce the count to deal with state du...

Github user sihuazhou commented on a diff in the pull request: https://github.com/apache/flink/pull/6205#discussion_r198135796 --- Diff: flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/SharedBuffer.java --- @@ -346,16 +351,87 @@ private void

[GitHub] flink pull request #6205: [FLINK-9642]Reduce the count to deal with state du...

Github user sihuazhou commented on a diff in the pull request: https://github.com/apache/flink/pull/6205#discussion_r198136431 --- Diff: flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/SharedBuffer.java --- @@ -346,16 +351,87 @@ private void

[GitHub] flink pull request #6205: [FLINK-9642]Reduce the count to deal with state du...

Github user Aitozi commented on a diff in the pull request: https://github.com/apache/flink/pull/6205#discussion_r197629310 --- Diff: flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/SharedBuffer.java --- @@ -346,16 +351,87 @@ private void

[GitHub] flink pull request #6205: [FLINK-9642]Reduce the count to deal with state du...

Github user zhangminglei commented on a diff in the pull request: https://github.com/apache/flink/pull/6205#discussion_r197629304 --- Diff: flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/SharedBuffer.java --- @@ -346,16 +351,87 @@ private void

[GitHub] flink pull request #6205: [FLINK-9642]Reduce the count to deal with state du...

Github user Aitozi commented on a diff in the pull request: https://github.com/apache/flink/pull/6205#discussion_r197629218 --- Diff: flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/SharedBuffer.java --- @@ -75,6 +76,9 @@ private MapState

[GitHub] flink pull request #6205: [FLINK-9642]Reduce the count to deal with state du...

Github user Aitozi commented on a diff in the pull request: https://github.com/apache/flink/pull/6205#discussion_r197629205 --- Diff: flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/SharedBuffer.java --- @@ -346,16 +351,87 @@ private void

[GitHub] flink pull request #6205: [FLINK-9642]Reduce the count to deal with state du...

Github user zhangminglei commented on a diff in the pull request: https://github.com/apache/flink/pull/6205#discussion_r197627410 --- Diff: flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/SharedBuffer.java --- @@ -346,16 +351,87 @@ private void

[GitHub] flink pull request #6205: [FLINK-9642]Reduce the count to deal with state du...

Github user zhangminglei commented on a diff in the pull request: https://github.com/apache/flink/pull/6205#discussion_r197627451 --- Diff: flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/SharedBuffer.java --- @@ -75,6 +76,9 @@ private

[GitHub] flink pull request #6205: [FLINK-9642]Reduce the count to deal with state du...

Github user zhangminglei commented on a diff in the pull request: https://github.com/apache/flink/pull/6205#discussion_r197627422 --- Diff: flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/SharedBuffer.java --- @@ -346,16 +351,87 @@ private void

[GitHub] flink pull request #6205: [FLINK-9642]Reduce the count to deal with state du...

GitHub user Aitozi opened a pull request: https://github.com/apache/flink/pull/6205 [FLINK-9642]Reduce the count to deal with state during a CEP process ## What is the purpose of the change With the rework of sharedBuffer Flink-9418, the lock & release operation is deal