{"action":"created","issue":{"url":"https://api.github.com/repos/apache/flink/issues/5405","repository_url":"https://api.github.com/repos/apache/flink","labels_url":"https://api.github.com/repos/apache/flink/issues/5405/labels{/name}","comments_url":"https://api.github.com/repos/apache/flink/issues/5405/comments","events_url":"https://api.github.com/repos/apache/flink/issues/5405/events","html_url":"https://github.com/apache/flink/pull/5405","id":294070115,"number":5405,"title":"[FLINK-8477][Window]Add api to support user to skip serval broken window","user":{"login":"Aitozi","id":9486140,"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":0,"created_at":"2018-02-03T01:24:09Z","updated_at":"2018-02-03T01:33:33Z","closed_at":null,"author_association":"NONE","pull_request":{"url":"https://api.github.com/repos/apache/flink/pulls/5405","html_url":"https://github.com/apache/flink/pull/5405","diff_url":"https://github.com/apache/flink/pull/5405.diff","patch_url":"https://github.com/apache/flink/pull/5405.patch"},"body":"In production, some application like monitor type , it need the accuarcy data,but in this scenario: if we start a job at 10:45:20s with a 1min window aggregate, we may produce a broken data of 10:45min ,so may lead to mistake. We can support a user api to choose to skip serveral windows to avoid the broken data by user self.\r\n\r\n## Brief change log\r\n\r\n  - add a streaming api \r\n\r\n\r\n"},"comment":{"url":"https://api.github.com/repos/apache/flink/issues/comments/362761431","html_url":"https://github.com/apache/flink/pull/5405#issuecomment-362761431","issue_url":"https://api.github.com/repos/apache/flink/issues/5405","id":362761431,"user":{"login":"Aitozi","id":9486140,"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-02-03T01:33:32Z","updated_at":"2018-02-03T01:33:32Z","author_association":"NONE","body":"cc @aljoscha please help review this patch.\r\n![image](https://user-images.githubusercontent.com/9486140/35761522-6e00f4b8-08c4-11e8-8063-7ec015802428.png)\r\nsee the picture above, when user choose to use without a checkpoint to avoid catch up data after a crash , and use kafka#setStartFromLatest to consume the latest data. if use without the skip api , we can see that it can  produce a broken data which may lead to the alert in monitor Scenario。if user want to skip the broken window, can hava a choice to skip serveral window after the first fire.\r\n"}}
{"actor":{"display_login":"Aitozi"}}