{"action":"created","issue":{"url":"https://api.github.com/repos/nupic-community/flink-htm/issues/13","repository_url":"https://api.github.com/repos/nupic-community/flink-htm","labels_url":"https://api.github.com/repos/nupic-community/flink-htm/issues/13/labels{/name}","comments_url":"https://api.github.com/repos/nupic-community/flink-htm/issues/13/comments","events_url":"https://api.github.com/repos/nupic-community/flink-htm/issues/13/events","html_url":"https://github.com/nupic-community/flink-htm/issues/13","id":145431837,"number":13,"title":"Implement event-time ordering","user":{"login":"EronWright","id":1775518,"avatar_url":"https://avatars.githubusercontent.com/u/1775518?v=3","gravatar_id":"","url":"https://api.github.com/users/EronWright","html_url":"https://github.com/EronWright","followers_url":"https://api.github.com/users/EronWright/followers","following_url":"https://api.github.com/users/EronWright/following{/other_user}","gists_url":"https://api.github.com/users/EronWright/gists{/gist_id}","starred_url":"https://api.github.com/users/EronWright/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/EronWright/subscriptions","organizations_url":"https://api.github.com/users/EronWright/orgs","repos_url":"https://api.github.com/users/EronWright/repos","events_url":"https://api.github.com/users/EronWright/events{/privacy}","received_events_url":"https://api.github.com/users/EronWright/received_events","type":"User","site_admin":false},"labels":[{"url":"https://api.github.com/repos/nupic-community/flink-htm/labels/help%20wanted","name":"help wanted","color":"159818"},{"url":"https://api.github.com/repos/nupic-community/flink-htm/labels/operators","name":"operators","color":"c2e0c6"}],"state":"open","locked":false,"assignee":null,"milestone":null,"comments":2,"created_at":"2016-04-02T23:47:54Z","updated_at":"2016-04-03T19:16:06Z","closed_at":null,"body":"It is possible for events to arrive out-of-order into the HTM operator.   We should reorder the events using an internal queue, using the watermark to make progress.\r\n\r\nSee the flink-cep library for an example of this: [CEPPatternOperator](https://github.com/apache/flink/blob/e3759a5e65181040066dbb278266f2c1fa226347/flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/operator/CEPPatternOperator.java#L85)."},"comment":{"url":"https://api.github.com/repos/nupic-community/flink-htm/issues/comments/205037604","html_url":"https://github.com/nupic-community/flink-htm/issues/13#issuecomment-205037604","issue_url":"https://api.github.com/repos/nupic-community/flink-htm/issues/13","id":205037604,"user":{"login":"EronWright","id":1775518,"avatar_url":"https://avatars.githubusercontent.com/u/1775518?v=3","gravatar_id":"","url":"https://api.github.com/users/EronWright","html_url":"https://github.com/EronWright","followers_url":"https://api.github.com/users/EronWright/followers","following_url":"https://api.github.com/users/EronWright/following{/other_user}","gists_url":"https://api.github.com/users/EronWright/gists{/gist_id}","starred_url":"https://api.github.com/users/EronWright/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/EronWright/subscriptions","organizations_url":"https://api.github.com/users/EronWright/orgs","repos_url":"https://api.github.com/users/EronWright/repos","events_url":"https://api.github.com/users/EronWright/events{/privacy}","received_events_url":"https://api.github.com/users/EronWright/received_events","type":"User","site_admin":false},"created_at":"2016-04-03T19:16:06Z","updated_at":"2016-04-03T19:16:06Z","body":"@cogmission reordering must be done at the Flink layer, using the event time information and watermarks."}}