[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

[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

[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

[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

[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

[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

[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-tabpanelfocusedCommentId=14316516#comment-14316516 ] ASF GitHub Bot commented on FLINK-1504: --- Github user rmetzger commented on the pull

[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

[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-tabpanelfocusedCommentId=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-tabpanelfocusedCommentId=14316451#comment-14316451 ] ASF GitHub Bot commented on FLINK-1489: --- 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

[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-tabpanelfocusedCommentId=14316518#comment-14316518 ] ASF GitHub Bot commented on FLINK-1510: --- Github user rmetzger commented on the pull

[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

[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

[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:

[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] [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-tabpanelfocusedCommentId=14316240#comment-14316240 ] Ufuk Celebi commented on FLINK-1521: Is the discussion here related?

[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-tabpanelfocusedCommentId=14316300#comment-14316300 ] Chesnay Schepler commented on FLINK-1524: - this issue was discussed earlier today

[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

[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

[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-tabpanelfocusedCommentId=14316496#comment-14316496 ] ASF GitHub Bot commented on FLINK-785: -- Github user fhueske commented on the pull

[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

[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

[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

[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-tabpanelfocusedCommentId=14316426#comment-14316426 ] Robert Metzger commented on FLINK-1052: --- I'm assigning the issue to myself, but I

[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-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-tabpanelfocusedCommentId=14316438#comment-14316438 ] ASF GitHub Bot commented on FLINK-1489: --- Github user tillrohrmann commented on the

[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-tabpanelfocusedCommentId=14316466#comment-14316466 ] ASF GitHub Bot commented on FLINK-1489: --- Github user rmetzger commented on the pull

[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

[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-tabpanelfocusedCommentId=14316504#comment-14316504 ] Stephan Ewen commented on FLINK-1455: - I improved the robustness for the tests by

[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

[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-tabpanelfocusedCommentId=14316475#comment-14316475 ] ASF GitHub Bot commented on FLINK-1504: --- Github user rmetzger commented on the pull

[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-tabpanelfocusedCommentId=14316489#comment-14316489 ] ASF GitHub Bot commented on FLINK-785: -- Github user fhueske commented on the pull

[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

[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-tabpanelfocusedCommentId=14316567#comment-14316567 ] ASF GitHub Bot commented on FLINK-1504: --- Github user asfgit closed the pull request

[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

[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-tabpanelfocusedCommentId=14316484#comment-14316484 ] ASF GitHub Bot commented on FLINK-1489: --- Github user asfgit closed the pull request

[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

[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] [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:

[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,

[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-tabpanelfocusedCommentId=14316632#comment-14316632 ] ASF GitHub Bot commented on FLINK-377: -- Github user zentol commented on the pull

[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

[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-tabpanelfocusedCommentId=14316819#comment-14316819 ] Martin Kiefer commented on FLINK-1515: -- I will do it. You can assign me. [Gelly]

[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

[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

[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

[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-tabpanelfocusedCommentId=14316662#comment-14316662 ] ASF GitHub Bot commented on FLINK-377: -- Github user mxm commented on the pull request:

[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

[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_INET,

[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-tabpanelfocusedCommentId=14316728#comment-14316728 ] ASF GitHub Bot commented on FLINK-377: -- Github user zentol commented on the pull

[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] [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] [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:

[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

[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] [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] [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

[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-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-tabpanelfocusedCommentId=14316231#comment-14316231 ] Stephan Ewen commented on FLINK-1455: - Again, this is not a memory leak. See

[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:

[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-tabpanelfocusedCommentId=14316860#comment-14316860 ] ASF GitHub Bot commented on FLINK-1529: --- GitHub user StephanEwen opened a pull

[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-tabpanelfocusedCommentId=14316881#comment-14316881 ] Vasia Kalavri commented on FLINK-1515: -- Done! Thank you :) [Gelly] Enable access to

[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-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-tabpanelfocusedCommentId=14317644#comment-14317644 ] Chiwan Park commented on FLINK-1512: I'm trying to implement this feature. I can't

[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-tabpanelfocusedCommentId=14315889#comment-14315889 ] ASF GitHub Bot commented on FLINK-1510: --- GitHub user rmetzger opened a pull request:

[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-tabpanelfocusedCommentId=14315897#comment-14315897 ] ASF GitHub Bot commented on FLINK-1510: --- Github user StephanEwen commented on the

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

2015-02-11 Thread uce
Github user uce commented on the pull request: https://github.com/apache/flink/pull/378#issuecomment-73854842 There is a problem: https://travis-ci.org/apache/flink/jobs/50215407 ``` java.lang.IllegalStateException: Consumer state is FINISHED but was expected to be RUNNING.

[jira] [Created] (FLINK-1513) Remove GlobalConfiguration Singleton

2015-02-11 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-1513: --- Summary: Remove GlobalConfiguration Singleton Key: FLINK-1513 URL: https://issues.apache.org/jira/browse/FLINK-1513 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-1511) Scala classes not identified as Pojos

2015-02-11 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14315935#comment-14315935 ] Aljoscha Krettek commented on FLINK-1511: - From the flink documentation:

[jira] [Assigned] (FLINK-1511) Scala classes not identified as Pojos

2015-02-11 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-1511: --- Assignee: Aljoscha Krettek Scala classes not identified as Pojos

[jira] [Resolved] (FLINK-1496) Events at unitialized input channels are lost

2015-02-11 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi resolved FLINK-1496. Resolution: Fixed Fixed in 0a4c7694cb4189129ae7686120921818343123ed Events at unitialized input

[jira] [Closed] (FLINK-1511) Scala classes not identified as Pojos

2015-02-11 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-1511. Resolution: Not a Problem Scala classes not identified as Pojos

[GitHub] flink pull request: [FLINK-1492] Fix exceptions on blob store shut...

2015-02-11 Thread uce
Github user uce commented on the pull request: https://github.com/apache/flink/pull/376#issuecomment-73859776 The problem is totally deterministic when shutting down the job/task managers. I've fixed it here:

[jira] [Commented] (FLINK-1492) Exceptions on shutdown concerning BLOB store cleanup

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

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

2015-02-11 Thread fhueske
GitHub user fhueske opened a pull request: https://github.com/apache/flink/pull/381 [FLINK-1461][api-extending] Add SortPartition operator to Java and Scala APIs. Adds the sortPartition operator to locally sort partitions of a DataSet. You can merge this pull request into a Git

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

2015-02-11 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-1510: - Summary: Make AvroInputFormat splittable Key: FLINK-1510 URL: https://issues.apache.org/jira/browse/FLINK-1510 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-1343) Branching Join Program Deadlocks

2015-02-11 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14315815#comment-14315815 ] Ufuk Celebi commented on FLINK-1343: I've just checked this with

[jira] [Commented] (FLINK-1496) Events at unitialized input channels are lost

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

[GitHub] flink pull request: [FLINK-1496] [distributed runtime] Fix loss of...

2015-02-11 Thread uce
Github user uce commented on the pull request: https://github.com/apache/flink/pull/380#issuecomment-73850043 I will merge this. From the linked discussion it seems to solve the issue for now. --- If your project is set up for it, you can reply to this email and have your reply

[jira] [Created] (FLINK-1511) Scala classes not identified as Pojos

2015-02-11 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-1511: Summary: Scala classes not identified as Pojos Key: FLINK-1511 URL: https://issues.apache.org/jira/browse/FLINK-1511 Project: Flink Issue Type: Bug

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

2015-02-11 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-1512: - Summary: Add CsvReader for reading into POJOs. Key: FLINK-1512 URL: https://issues.apache.org/jira/browse/FLINK-1512 Project: Flink Issue Type: New

[jira] [Commented] (FLINK-1343) Branching Join Program Deadlocks

2015-02-11 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14315873#comment-14315873 ] Ufuk Celebi commented on FLINK-1343: No, I don't think so. The task, where the flow

[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-tabpanelfocusedCommentId=14315843#comment-14315843 ] ASF GitHub Bot commented on FLINK-1489: --- Github user tillrohrmann commented on the

[jira] [Commented] (FLINK-1496) Events at unitialized input channels are lost

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

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

2015-02-11 Thread rmetzger
GitHub user rmetzger opened a pull request: https://github.com/apache/flink/pull/382 [FLINK-1510] Make AvroInputFormat splittable I'm currently working on testing the format on a cluster. You can merge this pull request into a Git repository by running: $ git pull

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

2015-02-11 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/382#issuecomment-73854731 Is it possible to add a local test? Something small, like a file with 30 lines, slit into 4 splits? --- If your project is set up for it, you can reply to this email

[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-tabpanelfocusedCommentId=14315899#comment-14315899 ] ASF GitHub Bot commented on FLINK-1489: --- Github user uce commented on the pull

[jira] [Commented] (FLINK-1492) Exceptions on shutdown concerning BLOB store cleanup

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

[GitHub] flink pull request: [FLINK-1492] Fix exceptions on blob store shut...

2015-02-11 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/376#issuecomment-73855452 I still get 05:26:08,841 ERROR org.apache.flink.runtime.blob.BlobServer - Error during shutdown of blob service via JVM shutdown hook: Shutdown in progress

[jira] [Commented] (FLINK-1492) Exceptions on shutdown concerning BLOB store cleanup

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

[GitHub] flink pull request: [FLINK-1492] Fix exceptions on blob store shut...

2015-02-11 Thread uce
Github user uce commented on the pull request: https://github.com/apache/flink/pull/376#issuecomment-73856074 OK, thanks for reporting this. @StephanEwen has some pending changes to the blob manager and he will look into it as well. It is not allowed to remove the shutdown

[jira] [Commented] (FLINK-1511) Scala classes not identified as Pojos

2015-02-11 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14315952#comment-14315952 ] Robert Metzger commented on FLINK-1511: --- By the way, at least for the Java API, the

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

2015-02-11 Thread uce
Github user uce commented on the pull request: https://github.com/apache/flink/pull/372#issuecomment-73853743 I think this is very valuable. I've tried it out and it looks good to me. Personally, I would prefer the shorter versions proposed by Fabian. If we don't

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

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

[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-73851481 You're right. At the moment there is no aggregation of messages. I'll add it. --- If your project is set up for it, you can reply to this email and have your reply

[jira] [Commented] (FLINK-1343) Branching Join Program Deadlocks

2015-02-11 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14315846#comment-14315846 ] Fabian Hueske commented on FLINK-1343: -- Very nice! Does that mean we can get rid of

[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-tabpanelfocusedCommentId=14315882#comment-14315882 ] ASF GitHub Bot commented on FLINK-1486: --- Github user uce commented on the pull

[GitHub] flink pull request: [FLINK-1496] [distributed runtime] Fix loss of...

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

  1   2   >