[jira] [Commented] (FLINK-1512) Add CsvReader for reading into POJOs.

2015-02-11 Thread Chiwan Park (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14317644#comment-14317644 ] Chiwan Park commented on FLINK-1512: I'm trying to implement this feature. I can't und

[jira] [Assigned] (FLINK-1512) Add CsvReader for reading into POJOs.

2015-02-11 Thread Chiwan Park (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chiwan Park reassigned FLINK-1512: -- Assignee: Chiwan Park > Add CsvReader for reading into POJOs. > ---

[jira] [Commented] (FLINK-1437) Bug in PojoSerializer's copy() method

2015-02-11 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14317313#comment-14317313 ] Timo Walther commented on FLINK-1437: - Is it too late to get this bugfix into 0.8.1?

[jira] [Resolved] (FLINK-1411) PlanVisualizer is not working

2015-02-11 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1411. - Resolution: Fixed Fix Version/s: 0.8 0.9 Assignee: Stephan Ewen

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

2015-02-11 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri updated FLINK-1515: - Assignee: Martin Kiefer > [Gelly] Enable access to aggregators and broadcast sets in vertex-centri

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

2015-02-11 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14316881#comment-14316881 ] Vasia Kalavri commented on FLINK-1515: -- Done! Thank you :) > [Gelly] Enable access t

[jira] [Commented] (FLINK-1529) Improve JobManager startup robustness

2015-02-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14316860#comment-14316860 ] ASF GitHub Bot commented on FLINK-1529: --- GitHub user StephanEwen opened a pull reque

[GitHub] flink pull request: [FLINK-1529] [jobmanager] Improve error handli...

2015-02-11 Thread StephanEwen
GitHub user StephanEwen opened a pull request: https://github.com/apache/flink/pull/385 [FLINK-1529] [jobmanager] Improve error handling on JobManager startup This patch improves JobManager startup error behavior, by pulling the heavy initialization of components (BlobServer, Librar

[jira] [Resolved] (FLINK-1530) Cache ExecutionConfig in AbstractInvokable

2015-02-11 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1530. - Resolution: Fixed Fixed via 69b794561c151261d48f7fa5463c3b24894a8efa > Cache ExecutionConfig in A

[jira] [Commented] (FLINK-1487) Failing SchedulerIsolatedTasksTest.testScheduleQueueing test case

2015-02-11 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14316832#comment-14316832 ] Robert Metzger commented on FLINK-1487: --- It happened again: {code} Failed tests:

[jira] [Updated] (FLINK-1487) Failing SchedulerIsolatedTasksTest.testScheduleQueueing test case

2015-02-11 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1487: -- Component/s: JobManager > Failing SchedulerIsolatedTasksTest.testScheduleQueueing test case > --

[jira] [Updated] (FLINK-1487) Failing SchedulerIsolatedTasksTest.testScheduleQueueing test case

2015-02-11 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1487: -- Affects Version/s: 0.9 > Failing SchedulerIsolatedTasksTest.testScheduleQueueing test case > ---

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

2015-02-11 Thread Martin Kiefer (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14316819#comment-14316819 ] Martin Kiefer commented on FLINK-1515: -- I will do it. You can assign me. > [Gelly] E

[GitHub] flink pull request: [FLINK-377] [FLINK-671] Generic Interface / PA...

2015-02-11 Thread zentol
Github user zentol commented on the pull request: https://github.com/apache/flink/pull/202#issuecomment-73945405 @mxm I've added another potential fix. --- 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

[jira] [Commented] (FLINK-377) Create a general purpose framework for language bindings

2015-02-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14316813#comment-14316813 ] ASF GitHub Bot commented on FLINK-377: -- Github user zentol commented on the pull reque

[jira] [Commented] (FLINK-377) Create a general purpose framework for language bindings

2015-02-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14316728#comment-14316728 ] ASF GitHub Bot commented on FLINK-377: -- Github user zentol commented on the pull reque

[GitHub] flink pull request: [FLINK-377] [FLINK-671] Generic Interface / PA...

2015-02-11 Thread zentol
Github user zentol commented on the pull request: https://github.com/apache/flink/pull/202#issuecomment-73936205 in my case, it returns this: ```python >>> import socket >>> socket.gethostname() 'Linux' >>> socket.getaddrinfo(socket.gethostname(), None, socket.AF_INE

[jira] [Commented] (FLINK-377) Create a general purpose framework for language bindings

2015-02-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14316662#comment-14316662 ] ASF GitHub Bot commented on FLINK-377: -- Github user mxm commented on the pull request:

[GitHub] flink pull request: [FLINK-377] [FLINK-671] Generic Interface / PA...

2015-02-11 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/202#issuecomment-73931484 Why should the resulting address be different from the one Java uses? What does import socket socket.getaddrinfo(socket.gethostname(), None, socket.AF_INET

[jira] [Closed] (FLINK-1491) Inconsistent logging between Akka and other components

2015-02-11 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-1491. Resolution: Fixed Fixed with 90834ca706d369b7c2bd739835766c490ee44042 > Inconsistent logging betwee

[GitHub] flink pull request: [FLINK-377] [FLINK-671] Generic Interface / PA...

2015-02-11 Thread zentol
Github user zentol commented on the pull request: https://github.com/apache/flink/pull/202#issuecomment-73928499 too bad, I'll revert the change. i assume that with your change to /etc/hosts it can now resolve your hostname to some address(this failed earlier with an exception

[jira] [Commented] (FLINK-377) Create a general purpose framework for language bindings

2015-02-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14316632#comment-14316632 ] ASF GitHub Bot commented on FLINK-377: -- Github user zentol commented on the pull reque

[jira] [Commented] (FLINK-377) Create a general purpose framework for language bindings

2015-02-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14316616#comment-14316616 ] ASF GitHub Bot commented on FLINK-377: -- Github user mxm commented on the pull request:

[GitHub] flink pull request: [FLINK-377] [FLINK-671] Generic Interface / PA...

2015-02-11 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/202#issuecomment-73926790 No, same result. I tried including my hostname in /etc/hosts which got me past the above exception. However, now I get 02/11/2015 18:41:00 Job execution s

[jira] [Commented] (FLINK-1504) Add support for accessing secured HDFS clusters in standalone mode

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

[jira] [Commented] (FLINK-785) Add Chained operators for AllReduce and AllGroupReduce

2015-02-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14316569#comment-14316569 ] ASF GitHub Bot commented on FLINK-785: -- Github user zentol commented on the pull reque

[jira] [Resolved] (FLINK-1504) Add support for accessing secured HDFS clusters in standalone mode

2015-02-11 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-1504. --- Resolution: Fixed Fix Version/s: 0.9 Assignee: Max Michels Resolved in http://

[GitHub] flink pull request: [FLINK-785] Chained AllReduce

2015-02-11 Thread zentol
Github user zentol commented on the pull request: https://github.com/apache/flink/pull/370#issuecomment-73923184 sorry for not making it clear that i forced pushed some changes, forgot making a separate branch. the changes you made to the driver are already in, sorry for wasti

[GitHub] flink pull request: [FLINK-1504] support for secure HDFS access us...

2015-02-11 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/383 --- 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

[jira] [Updated] (FLINK-1499) Make TaskManager to disconnect from JobManager in case of a restart

2015-02-11 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-1499: - Summary: Make TaskManager to disconnect from JobManager in case of a restart (was: Make TaskManag

[jira] [Created] (FLINK-1530) Cache ExecutionConfig in AbstractInvokable

2015-02-11 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-1530: --- Summary: Cache ExecutionConfig in AbstractInvokable Key: FLINK-1530 URL: https://issues.apache.org/jira/browse/FLINK-1530 Project: Flink Issue Type: Improvemen

[GitHub] flink pull request: [FLINK-1510] Make AvroInputFormat splittable

2015-02-11 Thread rmetzger
Github user rmetzger closed the pull request at: https://github.com/apache/flink/pull/382 --- 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 ena

[jira] [Commented] (FLINK-1510) Make AvroInputFormat splittable

2015-02-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14316519#comment-14316519 ] ASF GitHub Bot commented on FLINK-1510: --- Github user rmetzger closed the pull reques

[GitHub] flink pull request: [FLINK-1510] Make AvroInputFormat splittable

2015-02-11 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/382#issuecomment-73917179 I'm closing the PR until I've added tests. --- 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-1510) Make AvroInputFormat splittable

2015-02-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14316518#comment-14316518 ] ASF GitHub Bot commented on FLINK-1510: --- Github user rmetzger commented on the pull

[jira] [Commented] (FLINK-1504) Add support for accessing secured HDFS clusters in standalone mode

2015-02-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14316516#comment-14316516 ] ASF GitHub Bot commented on FLINK-1504: --- Github user rmetzger commented on the pull

[GitHub] flink pull request: [FLINK-1504] support for secure HDFS access us...

2015-02-11 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/383#issuecomment-73916367 Rebased to master: https://github.com/rmetzger/flink/tree/kerberos_hdfs --- If your project is set up for it, you can reply to this email and have your reply appear on Gi

[jira] [Created] (FLINK-1529) Improve JobManager startup robustness

2015-02-11 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-1529: --- Summary: Improve JobManager startup robustness Key: FLINK-1529 URL: https://issues.apache.org/jira/browse/FLINK-1529 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-1455) ExternalSortLargeRecordsITCase.testSortWithShortMediumAndLargeRecords: Potential Memory leak

2015-02-11 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14316504#comment-14316504 ] Stephan Ewen commented on FLINK-1455: - I improved the robustness for the tests by maki

[jira] [Resolved] (FLINK-1455) ExternalSortLargeRecordsITCase.testSortWithShortMediumAndLargeRecords: Potential Memory leak

2015-02-11 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1455. - Resolution: Fixed Fix Version/s: 0.9 Assignee: Stephan Ewen Fixed (again) in f577c

[jira] [Resolved] (FLINK-1489) Failing JobManager due to blocking calls in Execution.scheduleOrUpdateConsumers

2015-02-11 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-1489. --- Resolution: Fixed Fix Version/s: 0.9 Merged in http://git-wip-us.apache.org/repos/asf/f

[GitHub] flink pull request: [FLINK-785] Chained AllReduce

2015-02-11 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/370#issuecomment-73914381 Oh, just saw that you updated your PR. Won't open a PR. You can have a look at my branch here: https://github.com/fhueske/flink/tree/chained_all_reduce --- If your pr

[jira] [Commented] (FLINK-785) Add Chained operators for AllReduce and AllGroupReduce

2015-02-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14316496#comment-14316496 ] ASF GitHub Bot commented on FLINK-785: -- Github user fhueske commented on the pull requ

[jira] [Commented] (FLINK-785) Add Chained operators for AllReduce and AllGroupReduce

2015-02-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14316489#comment-14316489 ] ASF GitHub Bot commented on FLINK-785: -- Github user fhueske commented on the pull requ

[GitHub] flink pull request: [FLINK-785] Chained AllReduce

2015-02-11 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/370#issuecomment-73913500 Hi @zentol, I had a look at your PR and the failing test case. The test was in place to ensure that objects are reused. For that the functions were implemented in

[jira] [Commented] (FLINK-1489) Failing JobManager due to blocking calls in Execution.scheduleOrUpdateConsumers

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

[GitHub] flink pull request: [FLINK-1489] Fixes blocking scheduleOrUpdateCo...

2015-02-11 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/378 --- 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

[jira] [Commented] (FLINK-1504) Add support for accessing secured HDFS clusters in standalone mode

2015-02-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14316475#comment-14316475 ] ASF GitHub Bot commented on FLINK-1504: --- Github user rmetzger commented on the pull

[GitHub] flink pull request: [FLINK-1504] support for secure HDFS access us...

2015-02-11 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/383#issuecomment-73912267 Looks good to 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 does not have this fea

[GitHub] flink pull request: support for secure HDFS access using kerberos

2015-02-11 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/383#issuecomment-73910366 https://issues.apache.org/jira/browse/FLINK-1504 --- 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 p

[jira] [Commented] (FLINK-1489) Failing JobManager due to blocking calls in Execution.scheduleOrUpdateConsumers

2015-02-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14316466#comment-14316466 ] ASF GitHub Bot commented on FLINK-1489: --- Github user rmetzger commented on the pull

[jira] [Commented] (FLINK-1508) Remove AkkaUtils.ask to encourage explicit future handling

2015-02-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14316460#comment-14316460 ] ASF GitHub Bot commented on FLINK-1508: --- GitHub user tillrohrmann opened a pull requ

[GitHub] flink pull request: [FLINK-1489] Fixes blocking scheduleOrUpdateCo...

2015-02-11 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/378#issuecomment-73911265 The job that was previously failing is fixed with this change. We should merge this change ASAP, because its kinda impossible right now to seriously use flink 0.9

[GitHub] flink pull request: [FLINK-1508] Removes AkkaUtil.ask

2015-02-11 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/384 [FLINK-1508] Removes AkkaUtil.ask This PR removes the AkkaUtil.ask method and replaces all existing occurrences by explicit future handling. Furthemore, it removes the explicit actor address re

[jira] [Commented] (FLINK-1504) Add support for accessing secured HDFS clusters in standalone mode

2015-02-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14316453#comment-14316453 ] ASF GitHub Bot commented on FLINK-1504: --- Github user rmetzger commented on the pull

[jira] [Commented] (FLINK-1489) Failing JobManager due to blocking calls in Execution.scheduleOrUpdateConsumers

2015-02-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14316451#comment-14316451 ] ASF GitHub Bot commented on FLINK-1489: --- Github user rmetzger commented on the pull

[GitHub] flink pull request: [FLINK-1489] Fixes blocking scheduleOrUpdateCo...

2015-02-11 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/378#issuecomment-73910248 Cool. I'm testing this PR on a cluster now. --- 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 projec

[GitHub] flink pull request: support for secure HDFS access using kerberos

2015-02-11 Thread mxm
GitHub user mxm opened a pull request: https://github.com/apache/flink/pull/383 support for secure HDFS access using kerberos You can merge this pull request into a Git repository by running: $ git pull https://github.com/mxm/flink kerberos_hdfs Alternatively you can review a

[jira] [Commented] (FLINK-1489) Failing JobManager due to blocking calls in Execution.scheduleOrUpdateConsumers

2015-02-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14316438#comment-14316438 ] ASF GitHub Bot commented on FLINK-1489: --- Github user tillrohrmann commented on the p

[GitHub] flink pull request: [FLINK-1489] Fixes blocking scheduleOrUpdateCo...

2015-02-11 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/378#issuecomment-73908802 I added the UpdateTask message aggregation. I also had to rework the PartitionInfo creation to make it work with the concurrent task updates. This requires another re

[jira] [Assigned] (FLINK-1052) Access to stdout and log information of Taskmanagers from the web interface

2015-02-11 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-1052: - Assignee: Robert Metzger > Access to stdout and log information of Taskmanagers from the

[jira] [Commented] (FLINK-1052) Access to stdout and log information of Taskmanagers from the web interface

2015-02-11 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14316426#comment-14316426 ] Robert Metzger commented on FLINK-1052: --- I'm assigning the issue to myself, but I wo

[jira] [Updated] (FLINK-1052) Access to stdout and log information of Taskmanagers from the web interface

2015-02-11 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1052: -- Priority: Major (was: Minor) > Access to stdout and log information of Taskmanagers from the we

[jira] [Updated] (FLINK-1052) Access to stdout and log information of Taskmanagers from the web interface

2015-02-11 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1052: -- Component/s: JobManager > Access to stdout and log information of Taskmanagers from the web inte

[jira] [Updated] (FLINK-1052) Access to stdout and log information of Taskmanagers from the web interface

2015-02-11 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1052: -- Affects Version/s: 0.9 > Access to stdout and log information of Taskmanagers from the web inter

[jira] [Resolved] (FLINK-1524) Job Manager does not handle the RequestArchivedJobs message

2015-02-11 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi resolved FLINK-1524. Resolution: Fixed Fixed in bec9c4dae79928f55bcc3de3c6f5d5417f9b5608 > Job Manager does not handle t

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

2015-02-11 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri updated FLINK-1514: - Component/s: Gelly > [Gelly] Add a Gather-Sum-Apply iteration method > ---

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

2015-02-11 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri updated FLINK-1515: - Component/s: Gelly > [Gelly] Enable access to aggregators and broadcast sets in vertex-centric >

[jira] [Created] (FLINK-1528) Add local clustering coefficient library method and example

2015-02-11 Thread Vasia Kalavri (JIRA)
Vasia Kalavri created FLINK-1528: Summary: Add local clustering coefficient library method and example Key: FLINK-1528 URL: https://issues.apache.org/jira/browse/FLINK-1528 Project: Flink Is

[jira] [Assigned] (FLINK-785) Add Chained operators for AllReduce and AllGroupReduce

2015-02-11 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-785: -- Assignee: Chesnay Schepler > Add Chained operators for AllReduce and AllGroupReduce > --

[jira] [Updated] (FLINK-1526) Add Minimum Spanning Tree library method and example

2015-02-11 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri updated FLINK-1526: - Description: This issue proposes the addition of a library method and an example for distributed

[jira] [Created] (FLINK-1526) Add Minimum Spanning Tree library method and example

2015-02-11 Thread Vasia Kalavri (JIRA)
Vasia Kalavri created FLINK-1526: Summary: Add Minimum Spanning Tree library method and example Key: FLINK-1526 URL: https://issues.apache.org/jira/browse/FLINK-1526 Project: Flink Issue Type

[jira] [Created] (FLINK-1527) Incomplete Accumulator documentation (no mention of the shorthand methods)

2015-02-11 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-1527: - Summary: Incomplete Accumulator documentation (no mention of the shorthand methods) Key: FLINK-1527 URL: https://issues.apache.org/jira/browse/FLINK-1527 Project: F

[jira] [Commented] (FLINK-1524) Job Manager does not handle the RequestArchivedJobs message

2015-02-11 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1524?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14316300#comment-14316300 ] Chesnay Schepler commented on FLINK-1524: - this issue was discussed earlier today

[jira] [Updated] (FLINK-1524) Job Manager does not handle the RequestArchivedJobs message

2015-02-11 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-1524: Assignee: Till Rohrmann (was: Chesnay Schepler) > Job Manager does not handle the RequestAr

[jira] [Assigned] (FLINK-1524) Job Manager does not handle the RequestArchivedJobs message

2015-02-11 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-1524: --- Assignee: Chesnay Schepler > Job Manager does not handle the RequestArchivedJobs mes

[jira] [Created] (FLINK-1525) Provide utils to pass -D parameters to UDFs

2015-02-11 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-1525: - Summary: Provide utils to pass -D parameters to UDFs Key: FLINK-1525 URL: https://issues.apache.org/jira/browse/FLINK-1525 Project: Flink Issue Type: Impr

[jira] [Commented] (FLINK-377) Create a general purpose framework for language bindings

2015-02-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14316293#comment-14316293 ] ASF GitHub Bot commented on FLINK-377: -- Github user zentol commented on the pull reque

[GitHub] flink pull request: [FLINK-377] [FLINK-671] Generic Interface / PA...

2015-02-11 Thread zentol
Github user zentol commented on the pull request: https://github.com/apache/flink/pull/202#issuecomment-73893194 @mxm could you try it again with the latest commit? it may fix your issue. --- If your project is set up for it, you can reply to this email and have your reply appear on G

[jira] [Created] (FLINK-1524) Job Manager does not handle the RequestArchivedJobs message

2015-02-11 Thread Sergey Dudoladov (JIRA)
Sergey Dudoladov created FLINK-1524: --- Summary: Job Manager does not handle the RequestArchivedJobs message Key: FLINK-1524 URL: https://issues.apache.org/jira/browse/FLINK-1524 Project: Flink

[jira] [Created] (FLINK-1523) Vertex-centric iteration extensions

2015-02-11 Thread Vasia Kalavri (JIRA)
Vasia Kalavri created FLINK-1523: Summary: Vertex-centric iteration extensions Key: FLINK-1523 URL: https://issues.apache.org/jira/browse/FLINK-1523 Project: Flink Issue Type: Improvement

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

2015-02-11 Thread Vasia Kalavri (JIRA)
Vasia Kalavri created FLINK-1522: Summary: Add tests for the library methods and examples Key: FLINK-1522 URL: https://issues.apache.org/jira/browse/FLINK-1522 Project: Flink Issue Type: New

[jira] [Commented] (FLINK-1521) Some Chained Drivers do not respect object-reuse/non-reuse flag

2015-02-11 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14316240#comment-14316240 ] Ufuk Celebi commented on FLINK-1521: Is the discussion here related? http://apache-fl

[jira] [Commented] (FLINK-1455) ExternalSortLargeRecordsITCase.testSortWithShortMediumAndLargeRecords: Potential Memory leak

2015-02-11 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14316231#comment-14316231 ] Stephan Ewen commented on FLINK-1455: - Again, this is not a memory leak. See explanati

[jira] [Created] (FLINK-1521) Some Chained Drivers do not respect object-reuse/non-reuse flag

2015-02-11 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-1521: --- Summary: Some Chained Drivers do not respect object-reuse/non-reuse flag Key: FLINK-1521 URL: https://issues.apache.org/jira/browse/FLINK-1521 Project: Flink

[jira] [Created] (FLINK-1520) Read edges and vertices from CSV files

2015-02-11 Thread Vasia Kalavri (JIRA)
Vasia Kalavri created FLINK-1520: Summary: Read edges and vertices from CSV files Key: FLINK-1520 URL: https://issues.apache.org/jira/browse/FLINK-1520 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-1519) Web frontend task state mismatch when cancelling

2015-02-11 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-1519: -- Summary: Web frontend task state mismatch when cancelling Key: FLINK-1519 URL: https://issues.apache.org/jira/browse/FLINK-1519 Project: Flink Issue Type: Improv

[jira] [Created] (FLINK-1518) Laggy task cancelling on task managers

2015-02-11 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-1518: -- Summary: Laggy task cancelling on task managers Key: FLINK-1518 URL: https://issues.apache.org/jira/browse/FLINK-1518 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-1493) Support for streaming jobs preserving global ordering of records

2015-02-11 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14316204#comment-14316204 ] Gyula Fora commented on FLINK-1493: --- Hey, I implemented a simple indexed iterator from w

[jira] [Comment Edited] (FLINK-1455) ExternalSortLargeRecordsITCase.testSortWithShortMediumAndLargeRecords: Potential Memory leak

2015-02-11 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14316190#comment-14316190 ] Fabian Hueske edited comment on FLINK-1455 at 2/11/15 1:28 PM: -

[jira] [Commented] (FLINK-1517) Modify inputiterator for streaming so the channel index of the last record is accessible

2015-02-11 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1517?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14316192#comment-14316192 ] Gyula Fora commented on FLINK-1517: --- https://github.com/mbalassi/flink/commit/ee3590ec44

[jira] [Reopened] (FLINK-1455) ExternalSortLargeRecordsITCase.testSortWithShortMediumAndLargeRecords: Potential Memory leak

2015-02-11 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reopened FLINK-1455: -- One of my Travis build failed on the same test case with the following exception: {code} testSortW

[GitHub] flink pull request: [FLINK-1486] add print method for prefixing a ...

2015-02-11 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/372#issuecomment-73879164 +1 for conciseness. --- 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 fea

[jira] [Commented] (FLINK-1486) Add a string to the print method to identify output

2015-02-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14316181#comment-14316181 ] ASF GitHub Bot commented on FLINK-1486: --- Github user fhueske commented on the pull r

[jira] [Created] (FLINK-1517) Modify inputiterator for streaming so the channel index of the last record is accessible

2015-02-11 Thread Gyula Fora (JIRA)
Gyula Fora created FLINK-1517: - Summary: Modify inputiterator for streaming so the channel index of the last record is accessible Key: FLINK-1517 URL: https://issues.apache.org/jira/browse/FLINK-1517 Proj

[jira] [Created] (FLINK-1516) JobManagerFailsITCase: akka.actor.InvalidActorNameException: actor name [jobmanager] is not unique!

2015-02-11 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-1516: - Summary: JobManagerFailsITCase: akka.actor.InvalidActorNameException: actor name [jobmanager] is not unique! Key: FLINK-1516 URL: https://issues.apache.org/jira/browse/FLINK-151

[jira] [Updated] (FLINK-1516) JobManagerFailsITCase: akka.actor.InvalidActorNameException: actor name [jobmanager] is not unique!

2015-02-11 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1516: -- Affects Version/s: 0.9 > JobManagerFailsITCase: akka.actor.InvalidActorNameException: actor name

[jira] [Closed] (FLINK-603) Add Spargel GAS pattern

2015-02-11 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri closed FLINK-603. --- Resolution: Duplicate > Add Spargel GAS pattern > --- > > Key: FLIN

[jira] [Commented] (FLINK-603) Add Spargel GAS pattern

2015-02-11 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14316116#comment-14316116 ] Vasia Kalavri commented on FLINK-603: - Replaced by FLINK-1514. > Add Spargel GAS patte

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

2015-02-11 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14316113#comment-14316113 ] Vasia Kalavri commented on FLINK-1514: -- Thanks a lot [~fhueske]! Yes, it seems that

  1   2   >