[jira] [Commented] (FLINK-2178) groupReduceOnNeighbors throws NoSuchElementException

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

[GitHub] flink pull request: [FLINK-2178][gelly] Fixed groupReduceOnNeighbo...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/799 --- 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 project does not have this feature enabled and wishes so, or if the feature is

[jira] [Resolved] (FLINK-2178) groupReduceOnNeighbors throws NoSuchElementException

[ https://issues.apache.org/jira/browse/FLINK-2178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andra Lungu resolved FLINK-2178. Resolution: Fixed Fix Version/s: 0.10 groupReduceOnNeighbors throws NoSuchElementException

[GitHub] flink pull request: New operator state interfaces

Github user gyfora commented on the pull request: https://github.com/apache/flink/pull/747#issuecomment-113890106 Thanks for the nice feedback Stephan it makes a lot of sense what you have written :+1: Let me quickly react to these points separately: ### Current

[jira] [Commented] (FLINK-2221) Checkpoints to file:// are not cleaned up

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

[GitHub] flink pull request: [streaming] Fast calculation of medians of win...

Github user ggevay commented on the pull request: https://github.com/apache/flink/pull/684#issuecomment-113907348 I merged Marton's changes (moving to contrib) to this PR. I also added a paragraph to the streaming programming guide. I couldn't think of any better name for

[jira] [Resolved] (FLINK-2140) Access the number of vertices from within the GSA functions

[ https://issues.apache.org/jira/browse/FLINK-2140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andra Lungu resolved FLINK-2140. Resolution: Fixed Fix Version/s: 0.10 Access the number of vertices from within the GSA

[jira] [Created] (FLINK-2255) In the TopSpeedWindowing examples, every window contains only 1 element, because event time is in millisec, but eviction is in sec

Gabor Gevay created FLINK-2255: -- Summary: In the TopSpeedWindowing examples, every window contains only 1 element, because event time is in millisec, but eviction is in sec Key: FLINK-2255 URL:

[GitHub] flink pull request: [FLINK-2140][gelly] Allowed access to the numb...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/779 --- 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 project does not have this feature enabled and wishes so, or if the feature is

[jira] [Commented] (FLINK-2140) Access the number of vertices from within the GSA functions

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

[GitHub] flink pull request: New operator state interfaces

Github user hsaputra commented on a diff in the pull request: https://github.com/apache/flink/pull/747#discussion_r32903547 --- Diff: flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/state/PartitionedStreamOperatorState.java --- @@

[GitHub] flink pull request: New operator state interfaces

Github user hsaputra commented on a diff in the pull request: https://github.com/apache/flink/pull/747#discussion_r32903537 --- Diff: flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/state/PartitionedStreamOperatorState.java --- @@

[jira] [Commented] (FLINK-2125) String delimiter for SocketTextStream

[ https://issues.apache.org/jira/browse/FLINK-2125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14595213#comment-14595213 ] Hubert Czerpak commented on FLINK-2125: --- Me and [~nmarquesantos] are on this one :)

[GitHub] flink pull request: New operator state interfaces

Github user gyfora commented on the pull request: https://github.com/apache/flink/pull/747#issuecomment-113958824 @rmetzger : I think I found the cause of the random kafka issues, it was swallowed nul-lpointer exceptions which somehow led to this error, good to know

[jira] [Assigned] (FLINK-2200) Flink API with Scala 2.11 - Maven Repository

[ https://issues.apache.org/jira/browse/FLINK-2200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chiwan Park reassigned FLINK-2200: -- Assignee: Chiwan Park Flink API with Scala 2.11 - Maven Repository

[jira] [Created] (FLINK-2254) Add Bipartite Graph Support for Gelly

Andra Lungu created FLINK-2254: -- Summary: Add Bipartite Graph Support for Gelly Key: FLINK-2254 URL: https://issues.apache.org/jira/browse/FLINK-2254 Project: Flink Issue Type: New Feature

[GitHub] flink pull request: New operator state interfaces

Github user gyfora commented on the pull request: https://github.com/apache/flink/pull/747#issuecomment-113879705 Its always the same error in the KafkaITcase: org.apache.flink.streaming.connectors.kafka.KafkaITCase