[jira] [Commented] (FLINK-2310) Add an Adamic-Adar Similarity example

[ https://issues.apache.org/jira/browse/FLINK-2310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14662844#comment-14662844 ] ASF GitHub Bot commented on FLINK-2310: --- Github user andralungu commented on the

[GitHub] flink pull request: [FLINK-2314]

Github user chenliang613 commented on the pull request: https://github.com/apache/flink/pull/997#issuecomment-128926651 Thanks for your contribution. Suggestions: Please give a valid PR name. It would be useful if you could give more description about the PR, it could help

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

[ https://issues.apache.org/jira/browse/FLINK-2314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14662858#comment-14662858 ] ASF GitHub Bot commented on FLINK-2314: --- Github user chenliang613 commented on the

[jira] [Created] (FLINK-2501) [py] Remove the need to specify types for transformations

Chesnay Schepler created FLINK-2501: --- Summary: [py] Remove the need to specify types for transformations Key: FLINK-2501 URL: https://issues.apache.org/jira/browse/FLINK-2501 Project: Flink

[jira] [Commented] (FLINK-2106) Add outer joins to API, Optimizer, and Runtime

[ https://issues.apache.org/jira/browse/FLINK-2106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14662873#comment-14662873 ] Ricky Pogalz commented on FLINK-2106: - Hello [~fhueske], [~StephanEwen] and Watchers,

[jira] [Commented] (FLINK-2500) Some reviews to improve code quality

[ https://issues.apache.org/jira/browse/FLINK-2500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14662898#comment-14662898 ] ASF GitHub Bot commented on FLINK-2500: --- Github user gyfora commented on the pull

[GitHub] flink pull request: [FLINK-2500][Streaming]remove a unwanted if ...

Github user gyfora commented on the pull request: https://github.com/apache/flink/pull/1001#issuecomment-128949528 These are just API calls so performance is not an issue here. We should focus more on the readability. Your change does not do any harm in that sense so I guess

[jira] [Commented] (FLINK-2450) IndexOutOfBoundsException in KryoSerializer

[ https://issues.apache.org/jira/browse/FLINK-2450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14663085#comment-14663085 ] Andra Lungu commented on FLINK-2450: Ignore this issue, I corrupted the data set when

[jira] [Resolved] (FLINK-2450) IndexOutOfBoundsException in KryoSerializer

[ https://issues.apache.org/jira/browse/FLINK-2450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andra Lungu resolved FLINK-2450. Resolution: Not A Problem IndexOutOfBoundsException in KryoSerializer

[jira] [Commented] (FLINK-2501) [py] Remove the need to specify types for transformations

[ https://issues.apache.org/jira/browse/FLINK-2501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14663105#comment-14663105 ] Aljoscha Krettek commented on FLINK-2501: - I think 2) is the way to go here. Java

[GitHub] flink pull request: [FLINK-2423] [streaming] ITCase for checkpoint...

Github user mbalassi commented on the pull request: https://github.com/apache/flink/pull/980#issuecomment-129042045 Simplified the testing topology and added a bit more comments. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as

[jira] [Assigned] (FLINK-2491) Operators are not participating in state checkpointing in some cases

[ https://issues.apache.org/jira/browse/FLINK-2491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi reassigned FLINK-2491: - Assignee: Márton Balassi Operators are not participating in state checkpointing in some

[jira] [Updated] (FLINK-2491) Operators are not participating in state checkpointing in some cases

[ https://issues.apache.org/jira/browse/FLINK-2491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi updated FLINK-2491: -- Fix Version/s: 0.10 Operators are not participating in state checkpointing in some cases

[jira] [Commented] (FLINK-2444) Add tests for HadoopInputFormats

[ https://issues.apache.org/jira/browse/FLINK-2444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14663178#comment-14663178 ] James Cao commented on FLINK-2444: -- Hi Fabian, Thanks for your explanation, if I

[jira] [Commented] (FLINK-2423) Properly test checkpoint notifications

[ https://issues.apache.org/jira/browse/FLINK-2423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14663270#comment-14663270 ] ASF GitHub Bot commented on FLINK-2423: --- Github user gyfora commented on a diff in