[GitHub] flink pull request: [FLINK-1521] Chained operators respect reuse

2015-02-14 Thread gyfora
Github user gyfora commented on the pull request: https://github.com/apache/flink/pull/392#issuecomment-74367347 The problem here I think that an error caused by the reusing mapper could be very hard to detect. So some users might have it but they don't realise. For streaming

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

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

[jira] [Created] (FLINK-1545) Spurious failure of AsynchronousFileIOChannelsTest.testExceptionForwardsToClose

2015-02-14 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-1545: Summary: Spurious failure of AsynchronousFileIOChannelsTest.testExceptionForwardsToClose Key: FLINK-1545 URL: https://issues.apache.org/jira/browse/FLINK-1545

[jira] [Commented] (FLINK-1531) Custom Kryo Serializer fails in itertation scenario

2015-02-14 Thread Johannes (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14321520#comment-14321520 ] Johannes commented on FLINK-1531: - Thanks for the info [~StephanEwen] Makes sense to me

[jira] [Created] (FLINK-1546) Failed job causes JobManager to shutdown due to uncatched WebFrontend exception

2015-02-14 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-1546: - Summary: Failed job causes JobManager to shutdown due to uncatched WebFrontend exception Key: FLINK-1546 URL: https://issues.apache.org/jira/browse/FLINK-1546

[jira] [Commented] (FLINK-1547) Disable automated ApplicationMaster restart

2015-02-14 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14321551#comment-14321551 ] Stephan Ewen commented on FLINK-1547: - I agree, we should also deactivate the restart

[jira] [Created] (FLINK-1548) [DISCUSS] Make Scala implicit parameters explicit in the runtime

2015-02-14 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-1548: --- Summary: [DISCUSS] Make Scala implicit parameters explicit in the runtime Key: FLINK-1548 URL: https://issues.apache.org/jira/browse/FLINK-1548 Project: Flink

[jira] [Created] (FLINK-1547) Disable automated ApplicationMaster restart

2015-02-14 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-1547: - Summary: Disable automated ApplicationMaster restart Key: FLINK-1547 URL: https://issues.apache.org/jira/browse/FLINK-1547 Project: Flink Issue Type: Bug

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

2015-02-14 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/384 --- 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-1388) POJO support for writeAsCsv

2015-02-14 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14321635#comment-14321635 ] Robert Metzger commented on FLINK-1388: --- Yes, for private fields you need to make

[jira] [Commented] (FLINK-1546) Failed job causes JobManager to shutdown due to uncatched WebFrontend exception

2015-02-14 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14321649#comment-14321649 ] Till Rohrmann commented on FLINK-1546: -- The problem with the uncaught exception in

[jira] [Updated] (FLINK-1539) Runtime context not initialized when running streaming PojoExample

2015-02-14 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1539: -- Affects Version/s: 0.9 Runtime context not initialized when running streaming PojoExample

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

2015-02-14 Thread Adnan Khan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14321633#comment-14321633 ] Adnan Khan commented on FLINK-1388: --- Hey Timo, So the rules for defining a POJO

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

2015-02-14 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14321645#comment-14321645 ] Robert Metzger commented on FLINK-1388: --- How about

[jira] [Commented] (FLINK-1543) Proper exception handling in actors

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

[GitHub] flink pull request: [FLINK-1543] Adds better exception handling in...

2015-02-14 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/394#discussion_r24716021 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/taskmanager/TaskManagerTest.java --- @@ -486,7 +489,8 @@ protected void run() {

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

2015-02-14 Thread Adnan Khan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14321642#comment-14321642 ] Adnan Khan commented on FLINK-1388: --- Okay thanks, that sounds good. Also - Where should

[jira] [Commented] (FLINK-1547) Disable automated ApplicationMaster restart

2015-02-14 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14321654#comment-14321654 ] Till Rohrmann commented on FLINK-1547: -- This is not so surprising. I just looked into

[GitHub] flink pull request: [FLINK-1543] Adds better exception handling in...

2015-02-14 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/394 --- 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-1508) Remove AkkaUtils.ask to encourage explicit future handling

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

[jira] [Closed] (FLINK-1543) Proper exception handling in actors

2015-02-14 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-1543. Resolution: Fixed Fixed in 589b539c5acdd25f53ef6c9a453198a960ba93d5 Proper exception handling in

[jira] [Commented] (FLINK-1543) Proper exception handling in actors

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

[jira] [Commented] (FLINK-1543) Proper exception handling in actors

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

[jira] [Commented] (FLINK-1547) Disable automated ApplicationMaster restart

2015-02-14 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14321631#comment-14321631 ] Robert Metzger commented on FLINK-1547: --- The AM stopped due to:

[GitHub] flink pull request: [FLINK-1543] Adds better exception handling in...

2015-02-14 Thread hsaputra
Github user hsaputra commented on the pull request: https://github.com/apache/flink/pull/394#issuecomment-74388302 No worries, thanks for replying to my concern =) --- 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-1543) Proper exception handling in actors

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

[GitHub] flink pull request: [FLINK-1179] Add button to JobManager web inte...

2015-02-14 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/374 --- 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-1179) Add button to JobManager web interface to request stack trace of a TaskManager

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

[jira] [Resolved] (FLINK-1179) Add button to JobManager web interface to request stack trace of a TaskManager

2015-02-14 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-1179. --- Resolution: Fixed Fix Version/s: 0.9 Thank you Chiwan for implementing this! The

[jira] [Commented] (FLINK-1546) Failed job causes JobManager to shutdown due to uncatched WebFrontend exception

2015-02-14 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14321661#comment-14321661 ] Robert Metzger commented on FLINK-1546: --- Indeed. The uncaught exception doesn't

[GitHub] flink pull request: StreamWindow abstraction + modular window comp...

2015-02-14 Thread senorcarbone
Github user senorcarbone commented on the pull request: https://github.com/apache/flink/pull/395#issuecomment-74393323 +1 for merging asap. It's an improvement on both semantics and performance prospects for windowing. --- If your project is set up for it, you can reply to this

[jira] [Commented] (FLINK-1546) Failed job causes JobManager to shutdown due to uncatched WebFrontend exception

2015-02-14 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14321725#comment-14321725 ] Till Rohrmann commented on FLINK-1546: -- Apparently, the specified file is wrong and

[GitHub] flink pull request: [FLINK-1549] Adds proper exception handling to...

2015-02-14 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/397 [FLINK-1549] Adds proper exception handling to YarnJobManager Adds proper exception handling to ```YarnJobManager``` by catching the thrown exceptions and sending a

[jira] [Commented] (FLINK-1549) Add proper exception handling for YarnJobManager

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