{"action":"created","issue":{"url":"https://api.github.com/repos/apache/flink/issues/6205","repository_url":"https://api.github.com/repos/apache/flink","labels_url":"https://api.github.com/repos/apache/flink/issues/6205/labels{/name}","comments_url":"https://api.github.com/repos/apache/flink/issues/6205/comments","events_url":"https://api.github.com/repos/apache/flink/issues/6205/events","html_url":"https://github.com/apache/flink/pull/6205","id":335099566,"node_id":"MDExOlB1bGxSZXF1ZXN0MTk2OTAxMzg0","number":6205,"title":"[FLINK-9642]Reduce the count to deal with state during a CEP process","user":{"login":"Aitozi","id":9486140,"node_id":"MDQ6VXNlcjk0ODYxNDA=","avatar_url":"https://avatars1.githubusercontent.com/u/9486140?v=4","gravatar_id":"","url":"https://api.github.com/users/Aitozi","html_url":"https://github.com/Aitozi","followers_url":"https://api.github.com/users/Aitozi/followers","following_url":"https://api.github.com/users/Aitozi/following{/other_user}","gists_url":"https://api.github.com/users/Aitozi/gists{/gist_id}","starred_url":"https://api.github.com/users/Aitozi/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/Aitozi/subscriptions","organizations_url":"https://api.github.com/users/Aitozi/orgs","repos_url":"https://api.github.com/users/Aitozi/repos","events_url":"https://api.github.com/users/Aitozi/events{/privacy}","received_events_url":"https://api.github.com/users/Aitozi/received_events","type":"User","site_admin":false},"labels":[],"state":"open","locked":false,"assignee":null,"assignees":[],"milestone":null,"comments":16,"created_at":"2018-06-23T13:09:52Z","updated_at":"2018-08-16T15:02:32Z","closed_at":null,"author_association":"CONTRIBUTOR","pull_request":{"url":"https://api.github.com/repos/apache/flink/pulls/6205","html_url":"https://github.com/apache/flink/pull/6205","diff_url":"https://github.com/apache/flink/pull/6205.diff","patch_url":"https://github.com/apache/flink/pull/6205.patch"},"body":"## What is the purpose of the change\r\n\r\nWith the rework of sharedBuffer Flink-9418, the lock & release operation is deal with state backend which is different from the previous version which will read the state of sharedBuffer all to memory, i think we can add a cache or variable in sharedbuffer to cache the LockAble Object to mark the ref change in once process in NFA, this will reduce the count when the events point to the same Node. And flush the result to MapState at the end of process. \r\n\r\n\r\n## Brief change log\r\n\r\n- add the eventsBufferCache and entryCache\r\n- flush the cache after one turn process "},"comment":{"url":"https://api.github.com/repos/apache/flink/issues/comments/413577032","html_url":"https://github.com/apache/flink/pull/6205#issuecomment-413577032","issue_url":"https://api.github.com/repos/apache/flink/issues/6205","id":413577032,"node_id":"MDEyOklzc3VlQ29tbWVudDQxMzU3NzAzMg==","user":{"login":"Aitozi","id":9486140,"node_id":"MDQ6VXNlcjk0ODYxNDA=","avatar_url":"https://avatars1.githubusercontent.com/u/9486140?v=4","gravatar_id":"","url":"https://api.github.com/users/Aitozi","html_url":"https://github.com/Aitozi","followers_url":"https://api.github.com/users/Aitozi/followers","following_url":"https://api.github.com/users/Aitozi/following{/other_user}","gists_url":"https://api.github.com/users/Aitozi/gists{/gist_id}","starred_url":"https://api.github.com/users/Aitozi/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/Aitozi/subscriptions","organizations_url":"https://api.github.com/users/Aitozi/orgs","repos_url":"https://api.github.com/users/Aitozi/repos","events_url":"https://api.github.com/users/Aitozi/events{/privacy}","received_events_url":"https://api.github.com/users/Aitozi/received_events","type":"User","site_admin":false},"created_at":"2018-08-16T15:02:32Z","updated_at":"2018-08-16T15:02:32Z","author_association":"CONTRIBUTOR","body":"Hi, @dawidwys  can you help review again, 3Q ?"}}
{"actor":{"display_login":"Aitozi"}}