[jira] [Commented] (FLINK-2044) Implementation of Gelly HITS Algorithm

[ https://issues.apache.org/jira/browse/FLINK-2044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15295405#comment-15295405 ] ASF GitHub Bot commented on FLINK-2044: --- Github user gallenvara commented on a diff

[GitHub] flink pull request: [FLINK-2044] [gelly] Implementation of Gelly H...

Github user gallenvara commented on a diff in the pull request: https://github.com/apache/flink/pull/1956#discussion_r64144375 --- Diff: flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/HITSAlgorithm.java --- @@ -273,4 +289,23 @@ public void sendMessages(Ve

[jira] [Commented] (FLINK-3923) Unify configuration conventions of the Kinesis producer to the same as the consumer

[ https://issues.apache.org/jira/browse/FLINK-3923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15295060#comment-15295060 ] ASF GitHub Bot commented on FLINK-3923: --- Github user rmetzger commented on the pull

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

Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/2016#issuecomment-220782124 Thanks a lot for your contribution. I quickly scrolled over the changes and I like them at first sight. I assigned the JIRA issue to you. I hope I can review th

[jira] [Updated] (FLINK-3923) Unify configuration conventions of the Kinesis producer to the same as the consumer

[ https://issues.apache.org/jira/browse/FLINK-3923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-3923: -- Assignee: Abdullah Ozturk > Unify configuration conventions of the Kinesis producer to the same

[jira] [Commented] (FLINK-3923) Unify configuration conventions of the Kinesis producer to the same as the consumer

[ https://issues.apache.org/jira/browse/FLINK-3923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15295051#comment-15295051 ] ASF GitHub Bot commented on FLINK-3923: --- GitHub user aozturk opened a pull request:

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

GitHub user aozturk opened a pull request: https://github.com/apache/flink/pull/2016 [FLINK-3923] [connector-kinesis] Unify configuration conventions of t… This pull request includes the changes as clearly described in the issue. [FLINK-3923] Unify configuration convention

[jira] [Updated] (FLINK-3702) DataStream API PojoFieldAccessor doesn't support nested POJOs

[ https://issues.apache.org/jira/browse/FLINK-3702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-3702: -- Issue Type: Improvement (was: Bug) > DataStream API PojoFieldAccessor doesn't support nested PO

[jira] [Commented] (FLINK-3632) Clean up Table API exceptions

[ https://issues.apache.org/jira/browse/FLINK-3632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15294838#comment-15294838 ] ASF GitHub Bot commented on FLINK-3632: --- GitHub user yjshen opened a pull request:

[GitHub] flink pull request: [FLINK-3632][TableAPI]Clean up Table API excep...

GitHub user yjshen opened a pull request: https://github.com/apache/flink/pull/2015 [FLINK-3632][TableAPI]Clean up Table API exceptions As suggested by @fhueske in https://github.com/apache/flink/pull/1958#discussion_r62680699, we should use `TableException` in the following cases:

[jira] [Commented] (FLINK-3947) Provide low level access to RocksDB state backend

[ https://issues.apache.org/jira/browse/FLINK-3947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15294810#comment-15294810 ] Aljoscha Krettek commented on FLINK-3947: - There is already this: FLINK-3582 which

[jira] [Comment Edited] (FLINK-3582) Add Iterator over State for All Keys in Partitioned State

[ https://issues.apache.org/jira/browse/FLINK-3582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15294806#comment-15294806 ] Aljoscha Krettek edited comment on FLINK-3582 at 5/21/16 7:03 AM: --

[jira] [Commented] (FLINK-3582) Add Iterator over State for All Keys in Partitioned State

[ https://issues.apache.org/jira/browse/FLINK-3582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15294806#comment-15294806 ] Aljoscha Krettek commented on FLINK-3582: - This is addressed in this PR: https://g