[
https://issues.apache.org/jira/browse/FLINK-2261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14604075#comment-14604075
]
ASF GitHub Bot commented on FLINK-2261:
---
Github user gyfora commented on the pull
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/860#issuecomment-11616
+1
---
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
[
https://issues.apache.org/jira/browse/FLINK-2261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14604081#comment-14604081
]
ASF GitHub Bot commented on FLINK-2261:
---
Github user aljoscha commented on the pull
Github user gyfora commented on the pull request:
https://github.com/apache/flink/pull/860#issuecomment-115999618
I also added a GroupedDataStream to scala to make the two APIs more inline.
I think it is safe to merge now.
---
If your project is set up for it, you can reply to
[
https://issues.apache.org/jira/browse/FLINK-2261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14604088#comment-14604088
]
ASF GitHub Bot commented on FLINK-2261:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/860
---
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
[
https://issues.apache.org/jira/browse/FLINK-2275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14604183#comment-14604183
]
ASF GitHub Bot commented on FLINK-2275:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/866#issuecomment-116077164
@gyfora re-enabled a disabled Kafka test in this pull request:
https://github.com/apache/flink/pull/747/files
The test is known to be unstable, thats why I disabled
Github user mjsax commented on the pull request:
https://github.com/apache/flink/pull/866#issuecomment-116060075
Done. Failing tests revile a Kafka problem (in my Travis, too
https://travis-ci.org/mjsax/flink/builds/68598571). Is it known? Module
flink-tests passed in all runs.
[
https://issues.apache.org/jira/browse/FLINK-2275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14604162#comment-14604162
]
ASF GitHub Bot commented on FLINK-2275:
---
Github user mjsax commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-2275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14604263#comment-14604263
]
ASF GitHub Bot commented on FLINK-2275:
---
Github user gyfora commented on the pull
Github user gyfora commented on the pull request:
https://github.com/apache/flink/pull/866#issuecomment-116106232
Sorry about re-enabling the failing test, I completely missed it...
Matthias please @ignore it :P
Btw @rmetzger do we have a JIRA for this?
---
If your
[
https://issues.apache.org/jira/browse/FLINK-2279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora resolved FLINK-2279.
---
Resolution: Fixed
Allow treating iteration head as ConnectedDataStream
[
https://issues.apache.org/jira/browse/FLINK-2138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14604264#comment-14604264
]
ASF GitHub Bot commented on FLINK-2138:
---
Github user gyfora commented on the pull
Github user gyfora commented on the pull request:
https://github.com/apache/flink/pull/872#issuecomment-116106372
I think I could find several use cases if I wanted to :) For example I
would often like to broadcast some model information to many downstream
operators at once. (not
Gyula Fora created FLINK-2282:
-
Summary: Deprecate non-grouped stream reduce/fold/aggregations for
0.9.1
Key: FLINK-2282
URL: https://issues.apache.org/jira/browse/FLINK-2282
Project: Flink
Gyula Fora created FLINK-2283:
-
Summary: Make grouped reduce/fold/aggregations stateful using
Partitioned state
Key: FLINK-2283
URL: https://issues.apache.org/jira/browse/FLINK-2283
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-2122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reopened FLINK-2122:
-
Assignee: Aljoscha Krettek
This feature is not yet implemented.
Make all internal
Github user gaborhermann commented on the pull request:
https://github.com/apache/flink/pull/872#issuecomment-116103719
I guess it is easier for the users to understand and partitioning to
multiple channels at a time is rarely needed. Is there a use-case where it is
needed?
Github user mjsax commented on the pull request:
https://github.com/apache/flink/pull/866#issuecomment-116165324
Done. If Travis is green, please merge. :)
---
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
[
https://issues.apache.org/jira/browse/FLINK-2275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14604423#comment-14604423
]
ASF GitHub Bot commented on FLINK-2275:
---
Github user mjsax commented on the pull
21 matches
Mail list logo
