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

[ https://issues.apache.org/jira/browse/FLINK-1484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14308834#comment-14308834 ] ASF GitHub Bot commented on FLINK-1484: --- Github user tillrohrmann commented on a

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

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/368#discussion_r24227786 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala --- @@ -125,6 +126,10 @@ Actor with ActorLogMessages with

[jira] [Commented] (FLINK-1476) Flink VS Spark on loop test

[ https://issues.apache.org/jira/browse/FLINK-1476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14310584#comment-14310584 ] xuhong commented on FLINK-1476: --- Hi Fabian, I am very grateful for you advise. By your

[jira] [Commented] (FLINK-1476) Flink VS Spark on loop test

[ https://issues.apache.org/jira/browse/FLINK-1476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14310579#comment-14310579 ] xuhong commented on FLINK-1476: --- thanks very much, i will get try by your advises and keep

[jira] [Resolved] (FLINK-1445) Add support to enforce local input split assignment

[ https://issues.apache.org/jira/browse/FLINK-1445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske resolved FLINK-1445. -- Resolution: Duplicate Duplicate of FLINK-1478 Add support to enforce local input split

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

[ https://issues.apache.org/jira/browse/FLINK-1484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14309033#comment-14309033 ] ASF GitHub Bot commented on FLINK-1484: --- Github user tillrohrmann commented on a

[jira] [Commented] (FLINK-1388) POJO support for writeAsCsv

[ https://issues.apache.org/jira/browse/FLINK-1388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14308934#comment-14308934 ] Fabian Hueske commented on FLINK-1388: -- Hi, the PojoTypeInfo contains all

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

Till Rohrmann created FLINK-1489: Summary: Failing JobManager due to blocking calls in Execution.scheduleOrUpdateConsumers Key: FLINK-1489 URL: https://issues.apache.org/jira/browse/FLINK-1489

[jira] [Closed] (FLINK-1470) JobManagerITCase fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-1470?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-1470. Resolution: Fixed Fixed with 0ccd1fd5b90dbdacb579e329016a0819cd301d43 JobManagerITCase fails on

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

Stephan Ewen created FLINK-1492: --- Summary: Exceptions on shutdown concerning BLOB store cleanup Key: FLINK-1492 URL: https://issues.apache.org/jira/browse/FLINK-1492 Project: Flink Issue Type:

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

[ https://issues.apache.org/jira/browse/FLINK-1492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14309212#comment-14309212 ] Stephan Ewen commented on FLINK-1492: - The current solution is a bit hacky. Right now,

[GitHub] flink pull request: Remove 'incubator-' prefix from README.md.

GitHub user aalexandrov opened a pull request: https://github.com/apache/flink/pull/371 Remove 'incubator-' prefix from README.md. You can merge this pull request into a Git repository by running: $ git pull https://github.com/aalexandrov/flink patch-1 Alternatively you can

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

Stephan Ewen created FLINK-1491: --- Summary: Inconsistent logging between Akka and other components Key: FLINK-1491 URL: https://issues.apache.org/jira/browse/FLINK-1491 Project: Flink Issue

[jira] [Assigned] (FLINK-1478) Add strictly local input split assignment

[ https://issues.apache.org/jira/browse/FLINK-1478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-1478: Assignee: Fabian Hueske Add strictly local input split assignment

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

Max Michels created FLINK-1486: -- Summary: Add a string to the print method to identify output Key: FLINK-1486 URL: https://issues.apache.org/jira/browse/FLINK-1486 Project: Flink Issue Type:

[jira] [Commented] (FLINK-1418) Make 'print()' output on the client command line, rather than on the task manager sysout

[ https://issues.apache.org/jira/browse/FLINK-1418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14309101#comment-14309101 ] Stephan Ewen commented on FLINK-1418: - If we ever break it, we should do it now.

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

GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/370 [FLINK-785] Chained AllReduce This a a preliminary PR to see whether I'm on the right track. I'm wondering whether this would be everything needed to add a Chained AllReduce, before i

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

[ https://issues.apache.org/jira/browse/FLINK-785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14309122#comment-14309122 ] ASF GitHub Bot commented on FLINK-785: -- GitHub user zentol opened a pull request:

[jira] [Created] (FLINK-1488) JobManager web interface logfile access broken

Robert Metzger created FLINK-1488: - Summary: JobManager web interface logfile access broken Key: FLINK-1488 URL: https://issues.apache.org/jira/browse/FLINK-1488 Project: Flink Issue Type:

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

[ https://issues.apache.org/jira/browse/FLINK-1486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14309355#comment-14309355 ] Max Michels commented on FLINK-1486: Thanks for the code hint [~vkalavri]. I've

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

GitHub user mxm opened a pull request: https://github.com/apache/flink/pull/372 [FLINK-1486] add print method for prefixing a user defined string - extend API to include a `print(String message)` method - change `PrintingOutputformat` to include a message You can merge this

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

[ https://issues.apache.org/jira/browse/FLINK-1486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14309354#comment-14309354 ] ASF GitHub Bot commented on FLINK-1486: --- GitHub user mxm opened a pull request:

[jira] [Commented] (FLINK-1418) Make 'print()' output on the client command line, rather than on the task manager sysout

[ https://issues.apache.org/jira/browse/FLINK-1418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14309085#comment-14309085 ] Chesnay Schepler commented on FLINK-1418: - is this not doable without breaking

[jira] [Resolved] (FLINK-1488) JobManager web interface logfile access broken

[ https://issues.apache.org/jira/browse/FLINK-1488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-1488. --- Resolution: Fixed Resolved in https://issues.apache.org/jira/browse/FLINK-1488 JobManager

[GitHub] flink pull request: [FLINK-1485] Typo in Documentation - Join with...

Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/369#issuecomment-73251849 Definitely! --- 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

[jira] [Commented] (FLINK-1485) Typo in Documentation - Join with Join-Function

[ https://issues.apache.org/jira/browse/FLINK-1485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14309286#comment-14309286 ] ASF GitHub Bot commented on FLINK-1485: --- Github user jkirsch commented on the pull

[jira] [Commented] (FLINK-1166) Add a QA bot to Flink that is testing pull requests

[ https://issues.apache.org/jira/browse/FLINK-1166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14309327#comment-14309327 ] ASF GitHub Bot commented on FLINK-1166: --- Github user rmetzger commented on the pull

[GitHub] flink pull request: [FLINK-1166] Add qa-check.sh tool

Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/366#issuecomment-73254306 I found out why the qa-check has more compile errors compared to the master: I've instructed the compiler to report them all ;) I've addressed all comments in

[jira] [Updated] (FLINK-456) Optional runtime statistics / metrics collection

[ https://issues.apache.org/jira/browse/FLINK-456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-456: - Summary: Optional runtime statistics / metrics collection (was: Optional runtime statistics

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

[ https://issues.apache.org/jira/browse/FLINK-1486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14309070#comment-14309070 ] Chesnay Schepler commented on FLINK-1486: - +1, can see this being useful, and

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

[ https://issues.apache.org/jira/browse/FLINK-1486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14309043#comment-14309043 ] Vasia Kalavri commented on FLINK-1486: -- +1, I've needed this feature many times! We

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

Till Rohrmann created FLINK-1487: Summary: Failing SchedulerIsolatedTasksTest.testScheduleQueueing test case Key: FLINK-1487 URL: https://issues.apache.org/jira/browse/FLINK-1487 Project: Flink

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

[ https://issues.apache.org/jira/browse/FLINK-1486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Max Michels reassigned FLINK-1486: -- Assignee: Max Michels Add a string to the print method to identify output

[jira] [Commented] (FLINK-1485) Typo in Documentation - Join with Join-Function

[ https://issues.apache.org/jira/browse/FLINK-1485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14309284#comment-14309284 ] ASF GitHub Bot commented on FLINK-1485: --- Github user asfgit closed the pull request

[GitHub] flink pull request: [FLINK-1485] Typo in Documentation - Join with...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/369 --- 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-1485) Typo in Documentation - Join with Join-Function

[ https://issues.apache.org/jira/browse/FLINK-1485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14309283#comment-14309283 ] ASF GitHub Bot commented on FLINK-1485: --- Github user fhueske commented on the pull

[jira] [Resolved] (FLINK-1485) Typo in Documentation - Join with Join-Function

[ https://issues.apache.org/jira/browse/FLINK-1485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske resolved FLINK-1485. -- Resolution: Fixed Fix Version/s: 0.9 Fixed with

[jira] [Commented] (FLINK-1485) Typo in Documentation - Join with Join-Function

[ https://issues.apache.org/jira/browse/FLINK-1485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14309288#comment-14309288 ] ASF GitHub Bot commented on FLINK-1485: --- Github user fhueske commented on the pull

[GitHub] flink pull request: [FLINK-1485] Typo in Documentation - Join with...

Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/369#issuecomment-73251309 Thanks for the 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 not have this

[GitHub] flink pull request: Remove 'incubator-' prefix from README.md.

Github user mbalassi commented on the pull request: https://github.com/apache/flink/pull/371#issuecomment-73255136 Good catch, pushing it. --- 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

[jira] [Resolved] (FLINK-1438) ClassCastException for Custom InputSplit in local mode and invalid type code in distributed mode

[ https://issues.apache.org/jira/browse/FLINK-1438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1438. - Resolution: Fixed Fix Version/s: 0.9 Assignee: Stephan Ewen Fixed via

[GitHub] flink pull request: Remove unused enum values from Aggregations en...

GitHub user hsaputra opened a pull request: https://github.com/apache/flink/pull/373 Remove unused enum values from Aggregations enum. SImple cleanup to remove unused enum values from Aggregations enum. You can merge this pull request into a Git repository by running: $ git

[GitHub] flink pull request: [FLINK-1166] Add qa-check.sh tool

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/366 --- 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-1166) Add a QA bot to Flink that is testing pull requests

[ https://issues.apache.org/jira/browse/FLINK-1166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14309409#comment-14309409 ] ASF GitHub Bot commented on FLINK-1166: --- Github user asfgit closed the pull request

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

[ https://issues.apache.org/jira/browse/FLINK-1486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14309431#comment-14309431 ] ASF GitHub Bot commented on FLINK-1486: --- Github user rmetzger commented on the pull