[jira] [Commented] (FLINK-2066) Make delay between execution retries configurable

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

[GitHub] flink pull request: [FLINK-2066][core] Add delay between execution...

2015-10-05 Thread WangCHX
Github user WangCHX commented on the pull request: https://github.com/apache/flink/pull/1223#issuecomment-145740461 Thank you very much. --- 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 f

[jira] [Commented] (FLINK-2815) [REFACTOR] Remove Pact from class and file names since it is no longer valid reference

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

[GitHub] flink pull request: [FLINK-2815] [REFACTOR] Remove Pact from class...

2015-10-05 Thread hsaputra
Github user hsaputra commented on the pull request: https://github.com/apache/flink/pull/1218#issuecomment-145740343 Updated based on review. --- 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 t

[jira] [Commented] (FLINK-2552) Sporadic failure of PartialConsumePipelinedResultTest

2015-10-05 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14944467#comment-14944467 ] Robert Metzger commented on FLINK-2552: --- Ran into the problem again as well: https:

[jira] [Commented] (FLINK-2066) Make delay between execution retries configurable

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

[GitHub] flink pull request: [FLINK-2066][core] Add delay between execution...

2015-10-05 Thread WangCHX
Github user WangCHX commented on the pull request: https://github.com/apache/flink/pull/1223#issuecomment-145733727 Thank you. Sure. I will do 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 h

[jira] [Commented] (FLINK-2798) Prepare new web dashboard for executing in on YARN

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

[GitHub] flink pull request: [FLINK-2798] Serve static files for the new we...

2015-10-05 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/1222#issuecomment-145733149 Thank you for the review. I'm trying to update the PR within the next 24 hours Sorry for not explaining why I changed all the request URLs to relative paths: When a

[GitHub] flink pull request: [FLINK-2767] [scala shell] Add Scala 2.11 supp...

2015-10-05 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/1197#issuecomment-145708723 Thank you for the review @nikste! --- 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 n

[jira] [Commented] (FLINK-2767) Add support Scala 2.11 to Scala shell

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

[jira] [Commented] (FLINK-2066) Make delay between execution retries configurable

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

[GitHub] flink pull request: [FLINK-2066][core] Add delay between execution...

2015-10-05 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/1223#issuecomment-145708133 Thanks a lot for your contribution to Flink! Sorry for not giving you feedback earlier. Many committers are currently busy preparing the next Flink release.

[jira] [Created] (FLINK-2821) Change Akka configuration to allow accessing actors from different URLs

2015-10-05 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-2821: - Summary: Change Akka configuration to allow accessing actors from different URLs Key: FLINK-2821 URL: https://issues.apache.org/jira/browse/FLINK-2821 Project: Flin

[jira] [Commented] (FLINK-2283) Make grouped reduce/fold/aggregations stateful using Partitioned state

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

[GitHub] flink pull request: [FLINK-2283] [streaming] Make grouped reduce/f...

2015-10-05 Thread mbalassi
Github user mbalassi commented on the pull request: https://github.com/apache/flink/pull/1155#issuecomment-145665200 @StephanEwen : Thanks for the heads-up. Now I have addressed the comments and would like to merge this tomorrow if there are no objections. --- If your projec

[jira] [Created] (FLINK-2820) Configuration not passed to JobGraphGenerator

2015-10-05 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-2820: - Summary: Configuration not passed to JobGraphGenerator Key: FLINK-2820 URL: https://issues.apache.org/jira/browse/FLINK-2820 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-2786) Remove Spargel from source code and update documentation in favor of Gelly

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

[GitHub] flink pull request: [FLINK-2786] Remove Spargel from source code a...

2015-10-05 Thread vasia
GitHub user vasia opened a pull request: https://github.com/apache/flink/pull/1229 [FLINK-2786] Remove Spargel from source code and update docs. I also ported 2 Spargel tests that we hadn't copied over to Gelly. You can merge this pull request into a Git repository by running:

[jira] [Assigned] (FLINK-2737) KeyedDataStream should not be a subclass of DataStream

2015-10-05 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-2737: --- Assignee: Aljoscha Krettek > KeyedDataStream should not be a subclass of DataStream >

[jira] [Commented] (FLINK-2797) CLI: Missing option to submit jobs in detached mode

2015-10-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14943860#comment-14943860 ] ASF GitHub Bot commented on FLINK-2797: --- Github user sachingoel0101 commented on the

[GitHub] flink pull request: [FLINK-2797][cli] Add support for running jobs...

2015-10-05 Thread sachingoel0101
Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/1214#issuecomment-145635600 @uce , I have pushed a commit with my fix for disabling eager execution in detached mode. Please have a look. If it's okay, I can go ahead with adding docs for it

[jira] [Commented] (FLINK-2066) Make delay between execution retries configurable

2015-10-05 Thread Chengxuan Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14943852#comment-14943852 ] Chengxuan Wang commented on FLINK-2066: --- Hi, Maximilian, Do I need to make change ba

[GitHub] flink pull request: [FLINK-2811][web-dashboard]Add page with Confi...

2015-10-05 Thread sachingoel0101
Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/1219#issuecomment-145633502 Yes. You're right. I'd misunderstood Stephan's comment. The goal is to group similar keys together, and sorting alphabetically will definitely take care of that.

[jira] [Commented] (FLINK-2811) Add page with configuration overview

2015-10-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14943848#comment-14943848 ] ASF GitHub Bot commented on FLINK-2811: --- Github user sachingoel0101 commented on the

[jira] [Commented] (FLINK-2811) Add page with configuration overview

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

[GitHub] flink pull request: [FLINK-2811][web-dashboard]Add page with Confi...

2015-10-05 Thread uce
Github user uce commented on the pull request: https://github.com/apache/flink/pull/1219#issuecomment-145630566 I see. But pixel length or number of characters does not make it easier to navigate when you want to look up a specific key, e.g. `jobmanager.X.Y`. --- If your project is s

[GitHub] flink pull request: [FLINK-2741] - Use single log statement in Tes...

2015-10-05 Thread rerngvit
Github user rerngvit commented on the pull request: https://github.com/apache/flink/pull/1221#issuecomment-145629889 Thanks all for suggestions. --- 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 hav

[jira] [Commented] (FLINK-2741) Use single log statement in TestLogger

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

[GitHub] flink pull request: [FLINK-2811][web-dashboard]Add page with Confi...

2015-10-05 Thread sachingoel0101
Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/1219#issuecomment-145620411 I was thinking more about the actual pixel length but achieving that is proving to be kind of hard. Alphabetically should be okay I think. --- If your projec

[jira] [Commented] (FLINK-2811) Add page with configuration overview

2015-10-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14943780#comment-14943780 ] ASF GitHub Bot commented on FLINK-2811: --- Github user sachingoel0101 commented on the

[jira] [Commented] (FLINK-2811) Add page with configuration overview

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

[GitHub] flink pull request: [FLINK-2811][web-dashboard]Add page with Confi...

2015-10-05 Thread uce
Github user uce commented on the pull request: https://github.com/apache/flink/pull/1219#issuecomment-145617179 I think alphabetically is better. --- 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 ha

[jira] [Commented] (FLINK-2810) Warn user if bc not installed

2015-10-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14943704#comment-14943704 ] ASF GitHub Bot commented on FLINK-2810: --- Github user greghogan commented on a diff i

[GitHub] flink pull request: [FLINK-2810] Warn user if bc not installed

2015-10-05 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/1228#discussion_r41172866 --- Diff: flink-dist/src/main/flink-bin/bin/taskmanager.sh --- @@ -73,6 +73,13 @@ if [[ $STARTSTOP == "start" ]]; then TM_OFFHEAP_SIZE=$

[jira] [Commented] (FLINK-2767) Add support Scala 2.11 to Scala shell

2015-10-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14943701#comment-14943701 ] ASF GitHub Bot commented on FLINK-2767: --- Github user chiwanpark commented on the pul

[GitHub] flink pull request: [FLINK-2767] [scala shell] Add Scala 2.11 supp...

2015-10-05 Thread chiwanpark
Github user chiwanpark commented on the pull request: https://github.com/apache/flink/pull/1197#issuecomment-145606437 It occured by jline library version mismatching between Scala 2.10 and 2.11. Since Scala 2.11.5, we don't need jline dependency. Scala REPL uses its own jline library

[GitHub] flink pull request: [FLINK-2811][web-dashboard]Add page with Confi...

2015-10-05 Thread sachingoel0101
Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/1219#issuecomment-145604812 @uce , Great. I think someone else was working on providing job manager log and out access. If not, I'll give it a shot in a few days. @StephanEwen, is sorting

[jira] [Commented] (FLINK-2811) Add page with configuration overview

2015-10-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14943695#comment-14943695 ] ASF GitHub Bot commented on FLINK-2811: --- Github user sachingoel0101 commented on the

[GitHub] flink pull request: [FLINK-2810] Warn user if bc not installed

2015-10-05 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/1228#discussion_r41170708 --- Diff: flink-dist/src/main/flink-bin/bin/taskmanager.sh --- @@ -73,6 +73,13 @@ if [[ $STARTSTOP == "start" ]]; then TM_OFFHEAP_SIZE=${FLINK

[jira] [Commented] (FLINK-2810) Warn user if bc not installed

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

[jira] [Commented] (FLINK-2793) Redirect to leading JobManager web fronted in non-standalone mode

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

[GitHub] flink pull request: [FLINK-2793] [dashboard] Redirect to leader in...

2015-10-05 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/1202#discussion_r41169783 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/JobManagerArchiveRetriever.java --- @@ -70,28 +104,68 @@ public ActorGateway getArc

[GitHub] flink pull request: [FLINK-2793] [dashboard] Redirect to leader in...

2015-10-05 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/1202#discussion_r41169911 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala --- @@ -1773,8 +1812,7 @@ object JobManager { .asSubclas

[jira] [Commented] (FLINK-2793) Redirect to leading JobManager web fronted in non-standalone mode

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

[jira] [Commented] (FLINK-2810) Warn user if bc not installed

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

[GitHub] flink pull request: [FLINK-2810] Warn user if bc not installed

2015-10-05 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/1228#discussion_r41169165 --- Diff: flink-dist/src/main/flink-bin/bin/taskmanager.sh --- @@ -73,6 +73,13 @@ if [[ $STARTSTOP == "start" ]]; then TM_OFFHEAP_SIZE=${FLINK

[jira] [Commented] (FLINK-2793) Redirect to leading JobManager web fronted in non-standalone mode

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

[GitHub] flink pull request: [FLINK-2793] [dashboard] Redirect to leader in...

2015-10-05 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/1202#issuecomment-145598003 The PR looks good. I think we cannot do much about it being a temporary workaround for the limitation that our `ExecutionGraph` is not serializable. Once we have th

[jira] [Commented] (FLINK-2793) Redirect to leading JobManager web fronted in non-standalone mode

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

[jira] [Commented] (FLINK-2810) Warn user if bc not installed

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

[GitHub] flink pull request: [FLINK-2810] Warn user if bc not installed

2015-10-05 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/1228#issuecomment-145596622 Thanks for the pull request. Looks good. Will merge your changes. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as w

[GitHub] flink pull request: [FLINK-2793] [dashboard] Redirect to leader in...

2015-10-05 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1202#discussion_r41167164 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/JobManagerArchiveRetriever.java --- @@ -70,28 +104,68 @@ public ActorGatew

[jira] [Commented] (FLINK-2793) Redirect to leading JobManager web fronted in non-standalone mode

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

[GitHub] flink pull request: [FLINK-2793] [dashboard] Redirect to leader in...

2015-10-05 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1202#discussion_r41167117 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/JobManagerArchiveRetriever.java --- @@ -70,28 +104,68 @@ public ActorGatew

[jira] [Commented] (FLINK-2810) Warn user if bc not installed

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

[GitHub] flink pull request: [FLINK-2810] Warn user if bc not installed

2015-10-05 Thread greghogan
GitHub user greghogan opened a pull request: https://github.com/apache/flink/pull/1228 [FLINK-2810] Warn user if bc not installed You can merge this pull request into a Git repository by running: $ git pull https://github.com/greghogan/flink 2810_warn_user_if_bc_not_installed

[jira] [Assigned] (FLINK-2786) Remove Spargel from source code and update documentation in favor of Gelly

2015-10-05 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri reassigned FLINK-2786: Assignee: Vasia Kalavri > Remove Spargel from source code and update documentation in favor

[GitHub] flink pull request: [FLINK-2813] document parameter for off-heap m...

2015-10-05 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1226#issuecomment-145592253 Super! +1 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

[jira] [Commented] (FLINK-2813) Document off-heap configuration

2015-10-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14943616#comment-14943616 ] ASF GitHub Bot commented on FLINK-2813: --- Github user StephanEwen commented on the pu

[jira] [Commented] (FLINK-2793) Redirect to leading JobManager web fronted in non-standalone mode

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

[GitHub] flink pull request: [FLINK-2793] [dashboard] Redirect to leader in...

2015-10-05 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1202#discussion_r41164549 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala --- @@ -1761,11 +1803,8 @@ object JobManager { * @pa

[GitHub] flink pull request: [FLINK-2793] [dashboard] Redirect to leader in...

2015-10-05 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1202#discussion_r41164567 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala --- @@ -1773,8 +1812,7 @@ object JobManager { .

[jira] [Commented] (FLINK-2793) Redirect to leading JobManager web fronted in non-standalone mode

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

[GitHub] flink pull request: [FLINK-2813] document parameter for off-heap m...

2015-10-05 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/1226#issuecomment-145588890 I've added a managed memory section with a little bit more explanation. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHu

[jira] [Commented] (FLINK-2793) Redirect to leading JobManager web fronted in non-standalone mode

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

[jira] [Commented] (FLINK-2793) Redirect to leading JobManager web fronted in non-standalone mode

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

[GitHub] flink pull request: [FLINK-2793] [dashboard] Redirect to leader in...

2015-10-05 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1202#discussion_r41164028 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala --- @@ -129,6 +129,13 @@ class JobManager( var leader

[GitHub] flink pull request: [FLINK-2793] [dashboard] Redirect to leader in...

2015-10-05 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1202#discussion_r41163935 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala --- @@ -129,6 +129,13 @@ class JobManager( var leader

[jira] [Commented] (FLINK-2813) Document off-heap configuration

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

[jira] [Commented] (FLINK-2790) Add high availability support for Yarn

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

[GitHub] flink pull request: [FLINK-2790] [yarn] [ha] Adds high availabilit...

2015-10-05 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/1213#issuecomment-145577205 I killed the AM using "kill" from the command line, and all the Taskmanagers were shutting down --- If your project is set up for it, you can reply to this email and

[jira] [Commented] (FLINK-2703) Remove log4j classes from fat jar / document how to use Flink with logback

2015-10-05 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14943554#comment-14943554 ] Robert Metzger commented on FLINK-2703: --- Sorry. I forgot to close it. > Remove log4

[jira] [Resolved] (FLINK-2703) Remove log4j classes from fat jar / document how to use Flink with logback

2015-10-05 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-2703. --- Resolution: Fixed Fix Version/s: 0.10 The issue has been resolved in http://git-wip-us

[jira] [Commented] (FLINK-2741) Use single log statement in TestLogger

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

[jira] [Commented] (FLINK-2703) Remove log4j classes from fat jar / document how to use Flink with logback

2015-10-05 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14943551#comment-14943551 ] Fabian Hueske commented on FLINK-2703: -- [~rmetzger] Was this issue completely resolve

[GitHub] flink pull request: [FLINK-2741] - Use single log statement in Tes...

2015-10-05 Thread uce
Github user uce commented on the pull request: https://github.com/apache/flink/pull/1221#issuecomment-145575983 Thanks :). I'm going to merge this (I will insert the missing line breaks). --- If your project is set up for it, you can reply to this email and have your reply appear on G

[GitHub] flink pull request: [FLINK-2811][web-dashboard]Add page with Confi...

2015-10-05 Thread uce
Github user uce commented on the pull request: https://github.com/apache/flink/pull/1219#issuecomment-145575599 Regarding 1) Great idea Sachin. I never liked it in Travis, but I see how it can be useful for the JM logs. What about addressing Stephans comments for now and then adding t

[jira] [Commented] (FLINK-2811) Add page with configuration overview

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

[jira] [Closed] (FLINK-2333) Stream Data Sink that periodically rolls files

2015-10-05 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-2333. Resolution: Duplicate Duplicate of FLINK-2583 > Stream Data Sink that periodically rolls files > -

[GitHub] flink pull request: [FLINK-2805] [blobmanager] Write JARs to file ...

2015-10-05 Thread uce
GitHub user uce opened a pull request: https://github.com/apache/flink/pull/1227 [FLINK-2805] [blobmanager] Write JARs to file state backend for recovery This is a follow up to #1153. I've taken two changes from #1153 for convenience. Other than that, this is independent. W

[GitHub] flink pull request: [FLINK-2813] document parameter for off-heap m...

2015-10-05 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1226#issuecomment-145571671 I think it would be great to add a little more on this, in a dedicated section, like for some other parameters. Would help people understand what kind of data is sto

[GitHub] flink pull request: [FLINK-2354] Add job graph and checkpoint reco...

2015-10-05 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1153#discussion_r41158214 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/ZooKeeperCheckpointIDCounter.java --- @@ -0,0 +1,130 @@ +/* + * Licens

[jira] [Commented] (FLINK-2805) Make user jars available for all job managers to recover

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

[jira] [Commented] (FLINK-2354) Recover running jobs on JobManager failure

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

[jira] [Commented] (FLINK-2813) Document off-heap configuration

2015-10-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14943529#comment-14943529 ] ASF GitHub Bot commented on FLINK-2813: --- Github user StephanEwen commented on the pu

[jira] [Closed] (FLINK-2489) Improve the streaming window join

2015-10-05 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-2489. Resolution: Duplicate Duplicate of FLINK-2819 > Improve the streaming window join > ---

[jira] [Commented] (FLINK-2813) Document off-heap configuration

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

[GitHub] flink pull request: [FLINK-2813] document parameter for off-heap m...

2015-10-05 Thread mxm
GitHub user mxm opened a pull request: https://github.com/apache/flink/pull/1226 [FLINK-2813] document parameter for off-heap memory You can merge this pull request into a Git repository by running: $ git pull https://github.com/mxm/flink FLINK-2813 Alternatively you can revi

[jira] [Commented] (FLINK-2749) CliFrontendAddressConfigurationTest fails on GCE

2015-10-05 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14943499#comment-14943499 ] Fabian Hueske commented on FLINK-2749: -- How critical is this? Does it needs to be fi

[jira] [Commented] (FLINK-2354) Recover running jobs on JobManager failure

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

[jira] [Commented] (FLINK-2354) Recover running jobs on JobManager failure

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

[jira] [Commented] (FLINK-2354) Recover running jobs on JobManager failure

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

[GitHub] flink pull request: [FLINK-2354] Add job graph and checkpoint reco...

2015-10-05 Thread uce
Github user uce commented on the pull request: https://github.com/apache/flink/pull/1153#issuecomment-145557954 Thanks for taking the time to review. Thanks for the great renaming suggestions and all the other more subtle remarks. I agree with virtually all comments. The only

[GitHub] flink pull request: [FLINK-2354] Add job graph and checkpoint reco...

2015-10-05 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1153#discussion_r41152047 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/zookeeper/ZooKeeperStateHandleStore.java --- @@ -0,0 +1,422 @@ +/* + * Licensed t

[jira] [Commented] (FLINK-2354) Recover running jobs on JobManager failure

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

[GitHub] flink pull request: [FLINK-2354] Add job graph and checkpoint reco...

2015-10-05 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/1153#discussion_r41152813 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/zookeeper/ZooKeeperStateHandleStore.java --- @@ -0,0 +1,422 @@ +/* + * Licensed to the Apa

[jira] [Commented] (FLINK-2354) Recover running jobs on JobManager failure

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

[GitHub] flink pull request: [FLINK-2354] Add job graph and checkpoint reco...

2015-10-05 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/1153#discussion_r41152515 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/SuccessfulCheckpoint.java --- @@ -19,29 +19,28 @@ package org.apache.flink.runtime

[jira] [Commented] (FLINK-2354) Recover running jobs on JobManager failure

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

  1   2   3   4   >