Github user mbalassi commented on the pull request:
https://github.com/apache/flink/pull/424#issuecomment-75330500
I was thinking as high as a minute to have as a limit. But after
reconsidering it I am for your argument, trying to establish the connection
every couple of seconds shoul
[
https://issues.apache.org/jira/browse/FLINK-1582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14329670#comment-14329670
]
ASF GitHub Bot commented on FLINK-1582:
---
Github user mbalassi commented on the pull
Gyula Fora created FLINK-1595:
-
Summary: Add a complex integration test for Streaming API
Key: FLINK-1595
URL: https://issues.apache.org/jira/browse/FLINK-1595
Project: Flink
Issue Type: Task
[
https://issues.apache.org/jira/browse/FLINK-1595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-1595:
--
Labels: Starter (was: )
> Add a complex integration test for Streaming API
> --
[
https://issues.apache.org/jira/browse/FLINK-1592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-1592:
--
Labels: starter (was: )
> Refactor StreamGraph to store vertex IDs as Integers instead of Strings
> ---
[
https://issues.apache.org/jira/browse/FLINK-1505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14329591#comment-14329591
]
ASF GitHub Bot commented on FLINK-1505:
---
Github user gyfora commented on the pull re
Github user gyfora commented on the pull request:
https://github.com/apache/flink/pull/428#issuecomment-75322938
We have rebased and tried, it works fine for us, thank you. I will add
several minor changes afterwards but thats just for our convenience.
So from my side
+1
[
https://issues.apache.org/jira/browse/FLINK-1501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14329502#comment-14329502
]
ASF GitHub Bot commented on FLINK-1501:
---
Github user fhueske commented on the pull r
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/421#issuecomment-75313413
This is much needed monitoring and really great!
What are the current options for showing the detailed metrics? I see a
"show 3 TMs" and "show all TMs" button in the sc
[
https://issues.apache.org/jira/browse/FLINK-1522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14329497#comment-14329497
]
ASF GitHub Bot commented on FLINK-1522:
---
Github user andralungu commented on the pul
Github user andralungu commented on the pull request:
https://github.com/apache/flink/pull/429#issuecomment-75312569
Thank you for the tip! I am still learning the dirty insights of Git :)
Next time I will just update the PR.
---
If your project is set up for it, you can reply to th
[
https://issues.apache.org/jira/browse/FLINK-1522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14329479#comment-14329479
]
ASF GitHub Bot commented on FLINK-1522:
---
Github user fhueske commented on the pull r
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/429#issuecomment-75310637
Btw, you can update a PR by pushing into your remote branch and don't need
to close and open a new PR. If you want to change previous commits (including
commit message) or
[
https://issues.apache.org/jira/browse/FLINK-1522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14329379#comment-14329379
]
ASF GitHub Bot commented on FLINK-1522:
---
Github user andralungu closed the pull requ
[
https://issues.apache.org/jira/browse/FLINK-1522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14329381#comment-14329381
]
ASF GitHub Bot commented on FLINK-1522:
---
GitHub user andralungu opened a pull reques
Github user andralungu closed the pull request at:
https://github.com/apache/flink/pull/414
---
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 e
GitHub user andralungu opened a pull request:
https://github.com/apache/flink/pull/429
[FLINK-1522][gelly] Added test for SSSP Example
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/andralungu/flink tidySSSP
Alternatively you c
[
https://issues.apache.org/jira/browse/FLINK-1594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-1594:
--
Description:
Trying to window-join a DataStream with itself will result in exceptions. I get
the follow
[
https://issues.apache.org/jira/browse/FLINK-1594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14329268#comment-14329268
]
Gyula Fora commented on FLINK-1594:
---
We will have to take a look at how self joins are h
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/413#issuecomment-75283551
LGTM besides of my small comments.
---
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 doe
[
https://issues.apache.org/jira/browse/FLINK-1567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14329227#comment-14329227
]
ASF GitHub Bot commented on FLINK-1567:
---
Github user tillrohrmann commented on the p
[
https://issues.apache.org/jira/browse/FLINK-1567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14329226#comment-14329226
]
ASF GitHub Bot commented on FLINK-1567:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/413#discussion_r25086595
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/typeutils/runtime/AvroSerializer.java
---
@@ -154,6 +176,7 @@ private void checkAvroInitiali
[
https://issues.apache.org/jira/browse/FLINK-1567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14329219#comment-14329219
]
ASF GitHub Bot commented on FLINK-1567:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-1587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14329218#comment-14329218
]
Andra Lungu commented on FLINK-1587:
If there are no time constraints, I will take it
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/413#discussion_r25086445
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/typeutils/runtime/AvroSerializer.java
---
@@ -91,7 +98,22 @@ public T createInstance() {
[
https://issues.apache.org/jira/browse/FLINK-1567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14329215#comment-14329215
]
ASF GitHub Bot commented on FLINK-1567:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-1587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andra Lungu reassigned FLINK-1587:
--
Assignee: Andra Lungu
> coGroup throws NoSuchElementException on iterator.next()
>
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/413#discussion_r25086186
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/typeutils/GenericTypeInfo.java
---
@@ -66,6 +71,9 @@ public boolean isKeyType() {
[
https://issues.apache.org/jira/browse/FLINK-1515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14329204#comment-14329204
]
ASF GitHub Bot commented on FLINK-1515:
---
Github user tillrohrmann commented on the p
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/402#issuecomment-75279454
I'm currently working on fixing this problem. You can ignore it for the
moment.
On Fri, Feb 20, 2015 at 11:58 AM, Vasia Kalavri
wrote:
> Hi,
[
https://issues.apache.org/jira/browse/FLINK-1555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14329188#comment-14329188
]
ASF GitHub Bot commented on FLINK-1555:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/415#discussion_r25085047
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/typeutils/CompositeType.java
---
@@ -132,7 +133,31 @@ public CompositeType(Class typeClass
[
https://issues.apache.org/jira/browse/FLINK-1589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14329156#comment-14329156
]
ASF GitHub Bot commented on FLINK-1589:
---
Github user tillrohrmann commented on the p
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/427#issuecomment-75271706
I think we should rework the test case to check that the configuration is
properly passed to the system. Right now the exception is thrown in
```ds.writeAsText(null)`
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/427#discussion_r25080967
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/ExecutionEnvironmentITCase.java
---
@@ -0,0 +1,71 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-1589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14329117#comment-14329117
]
ASF GitHub Bot commented on FLINK-1589:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-1594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Bali updated FLINK-1594:
---
Description:
Trying to join a DataSet with itself will result in exceptions. I get the
following stac
Daniel Bali created FLINK-1594:
--
Summary: DataStreams don't support self-join
Key: FLINK-1594
URL: https://issues.apache.org/jira/browse/FLINK-1594
Project: Flink
Issue Type: Bug
Compo
Github user gyfora commented on the pull request:
https://github.com/apache/flink/pull/428#issuecomment-75257236
Thank you!
I will try it over the weekend and give you feedback.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub
[
https://issues.apache.org/jira/browse/FLINK-1505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14329061#comment-14329061
]
ASF GitHub Bot commented on FLINK-1505:
---
Github user gyfora commented on the pull re
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/368#issuecomment-75256160
This PR has been merged as part of PR #423
---
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 pr
[
https://issues.apache.org/jira/browse/FLINK-1484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14329055#comment-14329055
]
ASF GitHub Bot commented on FLINK-1484:
---
Github user tillrohrmann commented on the p
[
https://issues.apache.org/jira/browse/FLINK-1484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14329056#comment-14329056
]
ASF GitHub Bot commented on FLINK-1484:
---
Github user tillrohrmann closed the pull re
Github user tillrohrmann closed the pull request at:
https://github.com/apache/flink/pull/368
---
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
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/368#issuecomment-75254417
@tillrohrmann and @StephanEwen worked on some other reliablity issues. Will
the changes in this PR be subsumed by the upcoming changes? If not, we should
merge this. :-)
---
[
https://issues.apache.org/jira/browse/FLINK-1444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske resolved FLINK-1444.
--
Resolution: Implemented
Implemented with f0a28bf5345084a0a43df16021e60078e322e087
> Add data pr
[
https://issues.apache.org/jira/browse/FLINK-1484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14329046#comment-14329046
]
ASF GitHub Bot commented on FLINK-1484:
---
Github user uce commented on the pull reque
[
https://issues.apache.org/jira/browse/FLINK-1444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14329031#comment-14329031
]
ASF GitHub Bot commented on FLINK-1444:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-1505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14329028#comment-14329028
]
ASF GitHub Bot commented on FLINK-1505:
---
GitHub user uce opened a pull request:
GitHub user uce opened a pull request:
https://github.com/apache/flink/pull/428
[FLINK-1505] Separate reader API from result consumption
@gyfora, can you please rebase on this branch and verify that everything is
still working as expected for you?
This PR separates the read
[
https://issues.apache.org/jira/browse/FLINK-1466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14329032#comment-14329032
]
ASF GitHub Bot commented on FLINK-1466:
---
Github user asfgit closed the pull request
Gyula Fora created FLINK-1593:
-
Summary: Improve exception handling int Streaming runtime
Key: FLINK-1593
URL: https://issues.apache.org/jira/browse/FLINK-1593
Project: Flink
Issue Type: Improvem
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/381
---
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-1466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske resolved FLINK-1466.
--
Resolution: Implemented
Implemented with bed3da4a61a8637c0faa9632b8a05ccef8c5a6dc
> Add InputFo
[
https://issues.apache.org/jira/browse/FLINK-1461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske resolved FLINK-1461.
--
Resolution: Implemented
Implemented with 3d84970364ced41d1497269dc3c9d0b5835f9e1e
> Add sortPar
[
https://issues.apache.org/jira/browse/FLINK-1461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14329033#comment-14329033
]
ASF GitHub Bot commented on FLINK-1461:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/411
---
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 asfgit closed the pull request at:
https://github.com/apache/flink/pull/379
---
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
Gyula Fora created FLINK-1592:
-
Summary: Refactor StreamGraph to store vertex IDs as Integers
instead of Strings
Key: FLINK-1592
URL: https://issues.apache.org/jira/browse/FLINK-1592
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-1514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14328998#comment-14328998
]
ASF GitHub Bot commented on FLINK-1514:
---
Github user vasia commented on the pull req
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/408#issuecomment-75249793
Hi @balidani! Thanks a lot for this PR! Gather-Sum-Apply will be an awesome
addition to Gelly ^^
Here come my comments:
- There's no need for Gather, Sum and App
Gyula Fora created FLINK-1591:
-
Summary: Remove window merge before flatten as an optimization
Key: FLINK-1591
URL: https://issues.apache.org/jira/browse/FLINK-1591
Project: Flink
Issue Type: Imp
Robert Metzger created FLINK-1590:
-
Summary: Log environment information also in YARN mode
Key: FLINK-1590
URL: https://issues.apache.org/jira/browse/FLINK-1590
Project: Flink
Issue Type: Imp
[
https://issues.apache.org/jira/browse/FLINK-1555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger reassigned FLINK-1555:
-
Assignee: Robert Metzger
> Add utility to log the serializers of composite types
> --
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/427#issuecomment-75244751
I've added documentation and tests to the change.
Lets see if travis gives us a green light.
---
If your project is set up for it, you can reply to this email and hav
[
https://issues.apache.org/jira/browse/FLINK-1589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14328963#comment-14328963
]
ASF GitHub Bot commented on FLINK-1589:
---
Github user rmetzger commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora resolved FLINK-1451.
---
Resolution: Fixed
Assignee: Gyula Fora (was: Márton Balassi)
https://github.com/apache/flink/co
[
https://issues.apache.org/jira/browse/FLINK-1421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14328882#comment-14328882
]
Paris Carbone commented on FLINK-1421:
--
Thanks for all the great feedback everyone! I
[
https://issues.apache.org/jira/browse/FLINK-1421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Paris Carbone updated FLINK-1421:
-
Description:
Yahoo's Samoa is an experimental incremental machine learning library that
builds on
[
https://issues.apache.org/jira/browse/FLINK-1589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14328841#comment-14328841
]
ASF GitHub Bot commented on FLINK-1589:
---
GitHub user rmetzger opened a pull request:
GitHub user rmetzger opened a pull request:
https://github.com/apache/flink/pull/427
[FLINK-1589] Add option to pass configuration to LocalExecutor
Please review the changes.
I'll add a testcase and update the documentation later today.
You can merge this pull request into
[
https://issues.apache.org/jira/browse/FLINK-1589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger reassigned FLINK-1589:
-
Assignee: Robert Metzger
> Add option to pass Configuration to LocalExecutor
> --
Robert Metzger created FLINK-1589:
-
Summary: Add option to pass Configuration to LocalExecutor
Key: FLINK-1589
URL: https://issues.apache.org/jira/browse/FLINK-1589
Project: Flink
Issue Type:
Robert Metzger created FLINK-1588:
-
Summary: Load flink configuration also from classloader
Key: FLINK-1588
URL: https://issues.apache.org/jira/browse/FLINK-1588
Project: Flink
Issue Type: Ne
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/402#issuecomment-75220973
Hi,
if no more comments, I'd like to merge this.
There is a failing check in Travis (not related to this PR):
```
Tests in error:
JobManagerFailsITCas
[
https://issues.apache.org/jira/browse/FLINK-1515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14328814#comment-14328814
]
ASF GitHub Bot commented on FLINK-1515:
---
Github user vasia commented on the pull req
[
https://issues.apache.org/jira/browse/FLINK-1587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14328808#comment-14328808
]
Vasia Kalavri commented on FLINK-1587:
--
Hi,
you can easily reproduce if you have an
[
https://issues.apache.org/jira/browse/FLINK-1501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14328795#comment-14328795
]
ASF GitHub Bot commented on FLINK-1501:
---
Github user vasia commented on the pull req
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/421#issuecomment-75218017
This looks great! ^^
---
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 featu
[
https://issues.apache.org/jira/browse/FLINK-1586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-1586:
--
Component/s: Streaming
> Add support for iteration visualization for Streaming programs
> --
[
https://issues.apache.org/jira/browse/FLINK-1584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-1584.
-
Resolution: Fixed
Fix Version/s: 0.9
Assignee: Till Rohrmann
Fixed via 52b40debad6
[
https://issues.apache.org/jira/browse/FLINK-1556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-1556.
-
Resolution: Fixed
Fix Version/s: 0.9
Re-fixed in 4ff91cd7cd3e05637d70a56cfc6f5a4ba2f2501a
[
https://issues.apache.org/jira/browse/FLINK-1484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-1484.
-
Resolution: Fixed
Fix Version/s: 0.9
Assignee: Till Rohrmann
Fixed via 5ac1911a831
[
https://issues.apache.org/jira/browse/FLINK-1499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-1499.
-
Resolution: Fixed
Fix Version/s: 0.9
Assignee: Till Rohrmann
Fixed via 665e60128e0
[
https://issues.apache.org/jira/browse/FLINK-1585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-1585.
-
Resolution: Fixed
Fixed via a1104491b88ff3293142992900e69253206736ac
> Fix computation of TaskMan
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/421#issuecomment-75209814
Indeed :-)
What does the OS load mean? It would be really awesome to show the CPU
load, too. I think this is a helpful indicator.
---
If your project is se
[
https://issues.apache.org/jira/browse/FLINK-1501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14328723#comment-14328723
]
ASF GitHub Bot commented on FLINK-1501:
---
Github user tillrohrmann commented on the p
88 matches
Mail list logo
