[jira] [Issue Comment Deleted] (FLINK-1476) Flink VS Spark on loop test

2015-02-06 Thread xuhong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuhong updated FLINK-1476: -- Comment: was deleted (was: Hi Fabian, I am very grateful for you advise. By your advise, is that mean i shoul

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

2015-02-06 Thread xuhong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14310584#comment-14310584 ] xuhong commented on FLINK-1476: --- Hi Fabian, I am very grateful for you advise. By your ad

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

2015-02-06 Thread xuhong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14310583#comment-14310583 ] xuhong commented on FLINK-1476: --- Hi Fabian, I am very grateful for you advise. By your ad

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

2015-02-06 Thread xuhong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14310579#comment-14310579 ] xuhong commented on FLINK-1476: --- thanks very much, i will get try by your advises and keep g

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

2015-02-06 Thread hsaputra
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 pul

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

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

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

2015-02-06 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-456: - Component/s: TaskManager JobManager > Optional runtime statistics collection > ---

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

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

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

2015-02-06 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-456: Assignee: Robert Metzger > Optional runtime statistics / metrics collection > --

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

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

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

2015-02-06 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/372#issuecomment-73270614 Looks good. --- 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 ena

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

2015-02-06 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14309410#comment-14309410 ] Robert Metzger commented on FLINK-1166: --- The first part of this issue has been resol

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

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

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

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

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

2015-02-06 Thread JIRA
Márton Balassi created FLINK-1493: - Summary: Support for streaming jobs preserving global ordering of records Key: FLINK-1493 URL: https://issues.apache.org/jira/browse/FLINK-1493 Project: Flink

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

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

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

2015-02-06 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/371 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabl

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

2015-02-06 Thread hsaputra
Github user hsaputra commented on the pull request: https://github.com/apache/flink/pull/368#issuecomment-73263118 +1 LGTM --- 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 featur

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

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

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

2015-02-06 Thread Max Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14309355#comment-14309355 ] Max Michels commented on FLINK-1486: Thanks for the code hint [~vkalavri]. I've integr

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

2015-02-06 Thread mxm
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 pull

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

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

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

2015-02-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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

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

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

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

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

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

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

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

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

2015-02-06 Thread jkirsch
Github user jkirsch commented on the pull request: https://github.com/apache/flink/pull/369#issuecomment-73251735 No problem .. small but equally important :smiley: --- 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] [Resolved] (FLINK-1485) Typo in Documentation - Join with Join-Function

2015-02-06 Thread Fabian Hueske (JIRA)
[ 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 76dd725d7ce1757c778db58448fbac5036e626ef.

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

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

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

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

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

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

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

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

[jira] [Resolved] (FLINK-1490) Incorrect local output sort for tuple position keys with nested tuples

2015-02-06 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske resolved FLINK-1490. -- Resolution: Fixed Assignee: Fabian Hueske Fixed in 6187292bca47e7a42fe73a3f8fead50d522be06

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

2015-02-06 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1470?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14309232#comment-14309232 ] Till Rohrmann commented on FLINK-1470: -- Yes it is. > JobManagerITCase fails on Travi

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

2015-02-06 Thread Till Rohrmann (JIRA)
[ 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 T

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

2015-02-06 Thread aalexandrov
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 r

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

2015-02-06 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14309212#comment-14309212 ] Stephan Ewen commented on FLINK-1492: - The current solution is a bit hacky. Right now,

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

2015-02-06 Thread Stephan Ewen (JIRA)
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] [Created] (FLINK-1491) Inconsistent logging between Akka and other components

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

[jira] [Created] (FLINK-1490) Incorrect local output sort for tuple position keys with nested tuples

2015-02-06 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-1490: Summary: Incorrect local output sort for tuple position keys with nested tuples Key: FLINK-1490 URL: https://issues.apache.org/jira/browse/FLINK-1490 Project: Flink

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

2015-02-06 Thread Till Rohrmann (JIRA)
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 Project

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

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

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

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

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

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

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

2015-02-06 Thread zentol
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 continu

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

2015-02-06 Thread Max Michels (JIRA)
[ 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] [Created] (FLINK-1487) Failing SchedulerIsolatedTasksTest.testScheduleQueueing test case

2015-02-06 Thread Till Rohrmann (JIRA)
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] [Commented] (FLINK-1418) Make 'print()' output on the client command line, rather than on the task manager sysout

2015-02-06 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14309100#comment-14309100 ] Stephan Ewen commented on FLINK-1418: - That would work, yes. Interesting idea. For ot

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

2015-02-06 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14309101#comment-14309101 ] Stephan Ewen commented on FLINK-1418: - If we ever break it, we should do it now. > Ma

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

2015-02-06 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14309085#comment-14309085 ] Chesnay Schepler commented on FLINK-1418: - is this not doable without breaking pro

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

2015-02-06 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1470?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14309073#comment-14309073 ] Chesnay Schepler commented on FLINK-1470: - is this issue related to FLINK-1481? >

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

2015-02-06 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14309070#comment-14309070 ] Chesnay Schepler commented on FLINK-1486: - +1, can see this being useful, and shou

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

2015-02-06 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14309043#comment-14309043 ] Vasia Kalavri commented on FLINK-1486: -- +1, I've needed this feature many times! We

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

2015-02-06 Thread Max Michels (JIRA)
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: Imp

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

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

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

2015-02-06 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/368#discussion_r24236048 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/messages/TaskManagerMessages.scala --- @@ -129,6 +129,13 @@ object TaskManagerMessages {

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

2015-02-06 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/368#discussion_r24232671 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/messages/TaskManagerMessages.scala --- @@ -129,6 +129,13 @@ object TaskManagerMessages { *

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

2015-02-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14308938#comment-14308938 ] ASF GitHub Bot commented on FLINK-1484: --- Github user mxm commented on a diff in the

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

2015-02-06 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14308934#comment-14308934 ] Fabian Hueske commented on FLINK-1388: -- Hi, the PojoTypeInfo contains all informatio

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

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

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

2015-02-06 Thread Fabian Hueske (JIRA)
[ 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] [Commented] (FLINK-1484) JobManager restart does not notify the TaskManager

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

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

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