[jira] [Commented] (FLINK-1501) Integrate metrics library and report basic metrics to JobManager web interface

2015-02-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14328795#comment-14328795 ] ASF GitHub Bot commented on FLINK-1501: --- Github user vasia commented on the pull

[jira] [Commented] (FLINK-1587) coGroup throws NoSuchElementException on iterator.next()

2015-02-20 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14328808#comment-14328808 ] Vasia Kalavri commented on FLINK-1587: -- Hi, you can easily reproduce if you have an

[GitHub] flink pull request: [FLINK-1515]Splitted runVertexCentricIteration...

2015-02-20 Thread vasia
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:

[jira] [Commented] (FLINK-1515) [Gelly] Enable access to aggregators and broadcast sets in vertex-centric iteration

2015-02-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14328814#comment-14328814 ] ASF GitHub Bot commented on FLINK-1515: --- Github user vasia commented on the pull

[jira] [Created] (FLINK-1588) Load flink configuration also from classloader

2015-02-20 Thread Robert Metzger (JIRA)
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:

[jira] [Created] (FLINK-1589) Add option to pass Configuration to LocalExecutor

2015-02-20 Thread Robert Metzger (JIRA)
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

[jira] [Assigned] (FLINK-1589) Add option to pass Configuration to LocalExecutor

2015-02-20 Thread Robert Metzger (JIRA)
[ 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

[GitHub] flink pull request: [FLINK-1589] Add option to pass configuration ...

2015-02-20 Thread rmetzger
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

[jira] [Updated] (FLINK-1586) Add support for iteration visualization for Streaming programs

2015-02-20 Thread Gyula Fora (JIRA)
[ 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

[jira] [Commented] (FLINK-1589) Add option to pass Configuration to LocalExecutor

2015-02-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14328841#comment-14328841 ] ASF GitHub Bot commented on FLINK-1589: --- GitHub user rmetzger opened a pull request:

[jira] [Resolved] (FLINK-1584) Spurious failure of TaskManagerFailsITCase

2015-02-20 Thread Stephan Ewen (JIRA)
[ 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

[GitHub] flink pull request: [FLINK-1501] Add metrics library for monitorin...

2015-02-20 Thread tillrohrmann
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

[jira] [Commented] (FLINK-1501) Integrate metrics library and report basic metrics to JobManager web interface

2015-02-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14328723#comment-14328723 ] ASF GitHub Bot commented on FLINK-1501: --- Github user tillrohrmann commented on the

[jira] [Resolved] (FLINK-1556) JobClient does not wait until a job failed completely if submission exception

2015-02-20 Thread Stephan Ewen (JIRA)
[ 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

[jira] [Resolved] (FLINK-1451) Enable parallel execution of streaming file sources

2015-02-20 Thread Gyula Fora (JIRA)
[ 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)

[jira] [Commented] (FLINK-1421) Implement a SAMOA Adapter for Flink Streaming

2015-02-20 Thread Paris Carbone (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14328882#comment-14328882 ] Paris Carbone commented on FLINK-1421: -- Thanks for all the great feedback everyone! I

[jira] [Assigned] (FLINK-1555) Add utility to log the serializers of composite types

2015-02-20 Thread Robert Metzger (JIRA)
[ 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

[jira] [Commented] (FLINK-1589) Add option to pass Configuration to LocalExecutor

2015-02-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14328963#comment-14328963 ] ASF GitHub Bot commented on FLINK-1589: --- Github user rmetzger commented on the pull

[GitHub] flink pull request: [FLINK-1589] Add option to pass configuration ...

2015-02-20 Thread rmetzger
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

[jira] [Created] (FLINK-1590) Log environment information also in YARN mode

2015-02-20 Thread Robert Metzger (JIRA)
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:

[jira] [Created] (FLINK-1591) Remove window merge before flatten as an optimization

2015-02-20 Thread Gyula Fora (JIRA)
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:

[jira] [Commented] (FLINK-1514) [Gelly] Add a Gather-Sum-Apply iteration method

2015-02-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14328998#comment-14328998 ] ASF GitHub Bot commented on FLINK-1514: --- Github user vasia commented on the pull

[jira] [Created] (FLINK-1592) Refactor StreamGraph to store vertex IDs as Integers instead of Strings

2015-02-20 Thread Gyula Fora (JIRA)
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

[GitHub] flink pull request: [FLINK-1444][api-extending] Add support for sp...

2015-02-20 Thread asfgit
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

[jira] [Updated] (FLINK-1592) Refactor StreamGraph to store vertex IDs as Integers instead of Strings

2015-02-20 Thread Gyula Fora (JIRA)
[ 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

[jira] [Commented] (FLINK-1501) Integrate metrics library and report basic metrics to JobManager web interface

2015-02-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14329502#comment-14329502 ] ASF GitHub Bot commented on FLINK-1501: --- Github user fhueske commented on the pull

[GitHub] flink pull request: [FLINK-1505] Separate reader API from result c...

2015-02-20 Thread gyfora
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

[GitHub] flink pull request: [FLINK-1582][streaming]Allow SocketStream to r...

2015-02-20 Thread mbalassi
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

[GitHub] flink pull request: [FLINK-1501] Add metrics library for monitorin...

2015-02-20 Thread fhueske
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

[jira] [Commented] (FLINK-1505) Separate buffer reader and channel consumption logic

2015-02-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14329591#comment-14329591 ] ASF GitHub Bot commented on FLINK-1505: --- Github user gyfora commented on the pull

[jira] [Commented] (FLINK-1582) SocketStream gets stuck when socket closes

2015-02-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14329670#comment-14329670 ] ASF GitHub Bot commented on FLINK-1582: --- Github user mbalassi commented on the pull

[GitHub] flink pull request: [FLINK-1461][api-extending] Add SortPartition ...

2015-02-20 Thread asfgit
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

[jira] [Commented] (FLINK-1484) JobManager restart does not notify the TaskManager

2015-02-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14329046#comment-14329046 ] ASF GitHub Bot commented on FLINK-1484: --- Github user uce commented on the pull

[jira] [Commented] (FLINK-1505) Separate buffer reader and channel consumption logic

2015-02-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14329028#comment-14329028 ] ASF GitHub Bot commented on FLINK-1505: --- GitHub user uce opened a pull request:

[GitHub] flink pull request: [FLINK-1505] Separate reader API from result c...

2015-02-20 Thread gyfora
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

[GitHub] flink pull request: [FLINK-1589] Add option to pass configuration ...

2015-02-20 Thread tillrohrmann
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

[jira] [Commented] (FLINK-1461) Add sortPartition operator

2015-02-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14329033#comment-14329033 ] ASF GitHub Bot commented on FLINK-1461: --- Github user asfgit closed the pull request

[jira] [Commented] (FLINK-1505) Separate buffer reader and channel consumption logic

2015-02-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14329061#comment-14329061 ] ASF GitHub Bot commented on FLINK-1505: --- Github user gyfora commented on the pull

[jira] [Resolved] (FLINK-1466) Add InputFormat to read HCatalog tables

2015-02-20 Thread Fabian Hueske (JIRA)
[ 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

[GitHub] flink pull request: [FLINK-1505] Separate reader API from result c...

2015-02-20 Thread uce
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

[jira] [Commented] (FLINK-1466) Add InputFormat to read HCatalog tables

2015-02-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14329032#comment-14329032 ] ASF GitHub Bot commented on FLINK-1466: --- Github user asfgit closed the pull request

[jira] [Commented] (FLINK-1444) Add data properties for data sources

2015-02-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14329031#comment-14329031 ] ASF GitHub Bot commented on FLINK-1444: --- Github user asfgit closed the pull request

[jira] [Created] (FLINK-1594) DataStreams don't support self-join

2015-02-20 Thread Daniel Bali (JIRA)
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

[jira] [Commented] (FLINK-1589) Add option to pass Configuration to LocalExecutor

2015-02-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14329117#comment-14329117 ] ASF GitHub Bot commented on FLINK-1589: --- Github user tillrohrmann commented on a

[jira] [Commented] (FLINK-1484) JobManager restart does not notify the TaskManager

2015-02-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14329056#comment-14329056 ] ASF GitHub Bot commented on FLINK-1484: --- Github user tillrohrmann closed the pull

[GitHub] flink pull request: [FLINK-1484] Adds explicit disconnect message ...

2015-02-20 Thread tillrohrmann
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

[jira] [Commented] (FLINK-1484) JobManager restart does not notify the TaskManager

2015-02-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14329055#comment-14329055 ] ASF GitHub Bot commented on FLINK-1484: --- Github user tillrohrmann commented on the

[GitHub] flink pull request: [FLINK-1484] Adds explicit disconnect message ...

2015-02-20 Thread tillrohrmann
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

[jira] [Updated] (FLINK-1594) DataStreams don't support self-join

2015-02-20 Thread Daniel Bali (JIRA)
[ 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

[jira] [Resolved] (FLINK-1444) Add data properties for data sources

2015-02-20 Thread Fabian Hueske (JIRA)
[ 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

[GitHub] flink pull request: [FLINK-1484] Adds explicit disconnect message ...

2015-02-20 Thread uce
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. :-)

[GitHub] flink pull request: [FLINK-1567] Add switch to use the AvroSeriali...

2015-02-20 Thread tillrohrmann
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() {

[jira] [Commented] (FLINK-1587) coGroup throws NoSuchElementException on iterator.next()

2015-02-20 Thread Andra Lungu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14329218#comment-14329218 ] Andra Lungu commented on FLINK-1587: If there are no time constraints, I will take it

[jira] [Commented] (FLINK-1515) [Gelly] Enable access to aggregators and broadcast sets in vertex-centric iteration

2015-02-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14329204#comment-14329204 ] ASF GitHub Bot commented on FLINK-1515: --- Github user tillrohrmann commented on the

[jira] [Commented] (FLINK-1567) Add option to switch between Avro and Kryo serialization for GenericTypes

2015-02-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14329215#comment-14329215 ] ASF GitHub Bot commented on FLINK-1567: --- Github user tillrohrmann commented on a

[GitHub] flink pull request: [FLINK-1589] Add option to pass configuration ...

2015-02-20 Thread tillrohrmann
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

[GitHub] flink pull request: [FLINK-1555] Add serializer hierarchy debug ut...

2015-02-20 Thread tillrohrmann
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(ClassT

[jira] [Assigned] (FLINK-1587) coGroup throws NoSuchElementException on iterator.next()

2015-02-20 Thread Andra Lungu (JIRA)
[ 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] flink pull request: [FLINK-1515]Splitted runVertexCentricIteration...

2015-02-20 Thread tillrohrmann
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 notificati...@github.com

[jira] [Commented] (FLINK-1567) Add option to switch between Avro and Kryo serialization for GenericTypes

2015-02-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14329219#comment-14329219 ] ASF GitHub Bot commented on FLINK-1567: --- Github user tillrohrmann commented on a

[GitHub] flink pull request: [FLINK-1567] Add switch to use the AvroSeriali...

2015-02-20 Thread tillrohrmann
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

[jira] [Commented] (FLINK-1567) Add option to switch between Avro and Kryo serialization for GenericTypes

2015-02-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14329227#comment-14329227 ] ASF GitHub Bot commented on FLINK-1567: --- Github user tillrohrmann commented on the

[jira] [Created] (FLINK-1595) Add a complex integration test for Streaming API

2015-02-20 Thread Gyula Fora (JIRA)
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

[jira] [Updated] (FLINK-1595) Add a complex integration test for Streaming API

2015-02-20 Thread Gyula Fora (JIRA)
[ 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

[jira] [Updated] (FLINK-1594) DataStreams don't support self-join

2015-02-20 Thread Gyula Fora (JIRA)
[ 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

[jira] [Commented] (FLINK-1594) DataStreams don't support self-join

2015-02-20 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14329268#comment-14329268 ] Gyula Fora commented on FLINK-1594: --- We will have to take a look at how self joins are

[GitHub] flink pull request: [FLINK-1522][gelly] Added test for SSSP Exampl...

2015-02-20 Thread andralungu
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

[jira] [Commented] (FLINK-1522) Add tests for the library methods and examples

2015-02-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14329381#comment-14329381 ] ASF GitHub Bot commented on FLINK-1522: --- GitHub user andralungu opened a pull

[jira] [Commented] (FLINK-1522) Add tests for the library methods and examples

2015-02-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14329379#comment-14329379 ] ASF GitHub Bot commented on FLINK-1522: --- Github user andralungu closed the pull

[GitHub] flink pull request: [FLINK-1522][gelly] Added test for SSSP Exampl...

2015-02-20 Thread fhueske
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)

[jira] [Commented] (FLINK-1522) Add tests for the library methods and examples

2015-02-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14329479#comment-14329479 ] ASF GitHub Bot commented on FLINK-1522: --- Github user fhueske commented on the pull

[GitHub] flink pull request: [FLINK-1522][gelly] Added test for SSSP Exampl...

2015-02-20 Thread andralungu
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

[jira] [Commented] (FLINK-1522) Add tests for the library methods and examples

2015-02-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14329497#comment-14329497 ] ASF GitHub Bot commented on FLINK-1522: --- Github user andralungu commented on the