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
---
@@ -0
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
---
@@ -0
[
https://issues.apache.org/jira/browse/FLINK-2125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14595213#comment-14595213
]
Hubert Czerpak commented on FLINK-2125:
---
Me and [~nmarquesantos] are on this one :)
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
@StephanE
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 WindowedD
[
https://issues.apache.org/jira/browse/FLINK-2221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14595044#comment-14595044
]
ASF GitHub Bot commented on FLINK-2221:
---
Github user mbalassi commented on the pull
Github user mbalassi commented on the pull request:
https://github.com/apache/flink/pull/747#issuecomment-113898364
Thanks for the design outline guys, it looks great. Two minor comments in
terms of implementation:
* Let us make some more emphasis on the architecture of disc
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 Stat
[
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
[
https://issues.apache.org/jira/browse/FLINK-2178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14595019#comment-14595019
]
ASF GitHub Bot commented on FLINK-2178:
---
Github user asfgit closed the pull request
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 enabl
Github user ggevay commented on a diff in the pull request:
https://github.com/apache/flink/pull/684#discussion_r32892426
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/util/FieldAccessorTest.java
---
@@ -0,0 +1,75 @@
+/*
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: https://issues.apache.
[
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 fun
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 enabl
[
https://issues.apache.org/jira/browse/FLINK-2140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14595012#comment-14595012
]
ASF GitHub Bot commented on FLINK-2140:
---
Github user asfgit closed the pull request
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/747#issuecomment-113881056
I like this very much, Kudos Gyula and Paris, this is good work. This text
should definitely go into the Wiki, for reference.
I have a few thoughts and ideas
[
https://issues.apache.org/jira/browse/FLINK-2178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14595004#comment-14595004
]
ASF GitHub Bot commented on FLINK-2178:
---
Github user andralungu commented on the pul
Github user andralungu commented on the pull request:
https://github.com/apache/flink/pull/799#issuecomment-113880523
Merging...
---
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
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
testPersistentSourceWithOffsetUpdates(org.apache.flink.st
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
[
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
>
22 matches
Mail list logo
