[GitHub] flink pull request: [FLINK-3923] [connector-kinesis] Unify configu...

2016-05-27 Thread aozturk
Github user aozturk commented on the pull request: https://github.com/apache/flink/pull/2016#issuecomment-222111542 Pushed updates according to your comments. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your

[jira] [Commented] (FLINK-2314) Make Streaming File Sources Persistent

2016-05-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15303855#comment-15303855 ] ASF GitHub Bot commented on FLINK-2314: --- Github user StephanEwen commented on a diff in the pull

[GitHub] flink pull request: [FLINK-2314] Make Streaming File Sources Persi...

2016-05-27 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2020#discussion_r64883424 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/io/DelimitedInputFormat.java --- @@ -135,16 +135,22 @@ protected static void

[jira] [Assigned] (FLINK-3317) Add timeout handler to CEP operator

2016-05-27 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-3317: Assignee: Till Rohrmann > Add timeout handler to CEP operator >

[GitHub] flink pull request:

2016-05-27 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/commit/bf256c7fbe05accdadc8470013879f567341d1aa#commitcomment-17643841 In flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/types/ResourceID.java: In

[GitHub] flink pull request:

2016-05-27 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/commit/bf256c7fbe05accdadc8470013879f567341d1aa#commitcomment-17643812 In flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/types/ResourceID.java: In

[GitHub] flink pull request:

2016-05-27 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/commit/5a7f4e3395bfb06da496584be88501c328f6ac1d#commitcomment-17643795 @StephanEwen I think this has been left there on purpose because the ExecutionConfig is declared Public and this would break the

<    1   2