[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=14943704#comment-14943704 ] ASF GitHub Bot commented on FLINK-2810: --- Github user greghogan commented on a diff in the pull

[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

[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

[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=14943780#comment-14943780 ] ASF GitHub Bot commented on FLINK-2811: --- Github user sachingoel0101 commented on the pull request:

[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=14943852#comment-14943852 ] Chengxuan Wang commented on FLINK-2066: --- Hi, Maximilian, Do I need to make change based on 0.10? I

[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=14943860#comment-14943860 ] ASF GitHub Bot commented on FLINK-2797: --- Github user sachingoel0101 commented on the pull request:

[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=14943701#comment-14943701 ] ASF GitHub Bot commented on FLINK-2767: --- Github user chiwanpark commented on the pull request:

[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=14943816#comment-14943816 ] ASF GitHub Bot commented on FLINK-2741: --- Github user rerngvit commented on the pull request:

[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

[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=14943848#comment-14943848 ] ASF GitHub Bot commented on FLINK-2811: --- Github user sachingoel0101 commented on the pull request:

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

[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

[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

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

[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

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

[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

[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

[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=14944491#comment-14944491 ] ASF GitHub Bot commented on FLINK-2815: --- Github user hsaputra commented on the pull request:

[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

[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=14944495#comment-14944495 ] ASF GitHub Bot commented on FLINK-2066: --- Github user WangCHX commented on the pull request:

[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=14944008#comment-14944008 ] ASF GitHub Bot commented on FLINK-2283: --- Github user mbalassi commented on the pull request:

[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

[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

[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

[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] [Created] (FLINK-2819) Add Windowed Join/CoGroup Operator Based on Tagged Union

2015-10-05 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-2819: --- Summary: Add Windowed Join/CoGroup Operator Based on Tagged Union Key: FLINK-2819 URL: https://issues.apache.org/jira/browse/FLINK-2819 Project: Flink

[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=14942997#comment-14942997 ] ASF GitHub Bot commented on FLINK-2354: --- Github user uce commented on a diff in the pull request:

[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_r41115679 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/ZooKeeperCheckpointIDCounter.java --- @@ -0,0 +1,130 @@ +/* + * Licensed to

[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_r41115736 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/SuccessfulCheckpoint.java --- @@ -19,29 +19,28 @@ package

[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=14942998#comment-14942998 ] ASF GitHub Bot commented on FLINK-2354: --- Github user uce commented on a diff in the pull request:

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

2015-10-05 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/1221#discussion_r41115826 --- Diff: flink-core/src/test/java/org/apache/flink/util/TestLogger.java --- @@ -37,23 +37,26 @@ @Override public void

[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=14942999#comment-14942999 ] ASF GitHub Bot commented on FLINK-2741: --- Github user uce commented on a diff in the pull request:

[GitHub] flink pull request: Flink 1745

2015-10-05 Thread uce
Github user uce commented on the pull request: https://github.com/apache/flink/pull/1220#issuecomment-145449146 Thanks for this impressive PR. A minor comment: could you edit the title of the PR to include more details than the issue ID (we can't do it because the ASF is managing the

[jira] [Commented] (FLINK-1745) Add exact k-nearest-neighbours algorithm to machine learning library

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

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

2015-10-05 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/1213#issuecomment-145450115 I think TMs are only kept alive if their containers have been properly started. If the AM happens to die while the TM container are started up, I think they will

[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=14943008#comment-14943008 ] ASF GitHub Bot commented on FLINK-2790: --- Github user tillrohrmann commented on the pull request:

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

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

2015-10-05 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/1213#issuecomment-145456411 I was just curious whether he killed them gracefully with a `PoisonPill` or via killing the JVM process. --- If your project is set up for it, you can reply to

[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=14943029#comment-14943029 ] ASF GitHub Bot commented on FLINK-2790: --- Github user tillrohrmann commented on the pull request:

[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-145458067 On the user end, a url '/config' makes more sense IMO. On the server end, `config` is already mapped to something else, so I chose a `/jmconfig` there. If you

[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=14943030#comment-14943030 ] ASF GitHub Bot commented on FLINK-2811: --- Github user sachingoel0101 commented on the pull request:

[GitHub] flink pull request: [FLINK-2806] [scala-api] Add a TypeInformation...

2015-10-05 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/1212#issuecomment-145462515 Looks good to me. @tillrohrmann can you have a quick look? You recently did some work on the TypeInformation and TypeSerializers. --- If your project is set up for

[GitHub] flink pull request: [FLINK-2642] [table] Scala Table API crashes w...

2015-10-05 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/1209#issuecomment-145462685 @twalthr Please go ahead and merge it. :smile: Then we can close the issue. --- If your project is set up for it, you can reply to this email and have your reply

[jira] [Commented] (FLINK-2730) Add CPU/Network utilization graphs to new web dashboard

2015-10-05 Thread Sachin Goel (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14943067#comment-14943067 ] Sachin Goel commented on FLINK-2730: Of course the charts are updated in real time. Here's an example:

[jira] [Updated] (FLINK-2550) Rework DataStream API

2015-10-05 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-2550: Issue Type: Sub-task (was: Improvement) Parent: FLINK-2674 > Rework DataStream API

[jira] [Commented] (FLINK-2642) Scala Table API crashes when executing word count example

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

[jira] [Commented] (FLINK-2806) No TypeInfo for Scala's Nothing type

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

[GitHub] flink pull request: Stream API Refactoring

2015-10-05 Thread ktzoumas
Github user ktzoumas commented on a diff in the pull request: https://github.com/apache/flink/pull/1215#discussion_r41125302 --- Diff: flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/IterativeDataStream.java --- @@ -81,56

[GitHub] flink pull request: [FLINK-2806] [scala-api] Add a TypeInformation...

2015-10-05 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1212#discussion_r41125339 --- Diff: flink-scala/src/main/scala/org/apache/flink/api/scala/typeutils/ScalaNothingTypeInfo.scala --- @@ -0,0 +1,47 @@ +/* + * Licensed to

[GitHub] flink pull request: [FLINK-2806] [scala-api] Add a TypeInformation...

2015-10-05 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/1212#issuecomment-145476115 LGTM. Only one minor comment. --- 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] [Commented] (FLINK-2806) No TypeInfo for Scala's Nothing type

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

[GitHub] flink pull request: Stream API Refactoring

2015-10-05 Thread ktzoumas
Github user ktzoumas commented on a diff in the pull request: https://github.com/apache/flink/pull/1215#discussion_r41125467 --- Diff: flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/KeyedStream.java --- @@ -87,7 +207,7

[GitHub] flink pull request: Stream API Refactoring

2015-10-05 Thread ktzoumas
Github user ktzoumas commented on a diff in the pull request: https://github.com/apache/flink/pull/1215#discussion_r41125422 --- Diff: flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/KeyedStream.java --- @@ -24,49 +24,169

[jira] [Commented] (FLINK-2806) No TypeInfo for Scala's Nothing type

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

[GitHub] flink pull request: Stream API Refactoring

2015-10-05 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/1215#discussion_r41125469 --- Diff: flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/IterativeDataStream.java --- @@ -81,56

[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=14943132#comment-14943132 ] ASF GitHub Bot commented on FLINK-2354: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request: Stream API Refactoring

2015-10-05 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1215#issuecomment-145482078 Impressive work, looks good! Merging this means that we need to commit to reworking the `join()` implementation very soon. If that is the case, +1

[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_r41126140 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java --- @@ -871,7 +898,13 @@ public Object call() throws

[GitHub] flink pull request: Stream API Refactoring

2015-10-05 Thread ktzoumas
Github user ktzoumas commented on the pull request: https://github.com/apache/flink/pull/1215#issuecomment-145482079 +1 to merge. This will make the testing of the new API much easier --- If your project is set up for it, you can reply to this email and have your reply appear on

[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_r41126346 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/StandaloneSubmittedJobGraphs.java --- @@ -0,0 +1,65 @@ +/* + *

[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=14943135#comment-14943135 ] ASF GitHub Bot commented on FLINK-2354: --- Github user tillrohrmann commented on a diff in the pull

[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=14943137#comment-14943137 ] ASF GitHub Bot commented on FLINK-2354: --- Github user tillrohrmann commented on a diff in the pull

[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_r41126510 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/ZooKeeperSubmittedJobGraphs.java --- @@ -0,0 +1,356 @@ +/* + *

[GitHub] flink pull request: [FLINK-2809] [scala-api] Added UnitTypeInfo an...

2015-10-05 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/1217#discussion_r41126581 --- Diff: flink-scala/src/main/scala/org/apache/flink/api/scala/typeutils/UnitSerializer.scala --- @@ -0,0 +1,60 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-2809) DataSet[Unit] doesn't work

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

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

2015-10-05 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/1214#issuecomment-145483163 Fair enough, we can do this but the error reporting must be pretty good. Otherwise it might confuse users because not everyone gets that eager execution spawns multiple

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

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

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

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

[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

[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=14943876#comment-14943876 ] ASF GitHub Bot commented on FLINK-2786: --- GitHub user vasia opened a pull request:

[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

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

[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

[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=14944455#comment-14944455 ] ASF GitHub Bot commented on FLINK-2066: --- Github user WangCHX commented on the pull request:

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

2015-10-05 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-2066: -- Affects Version/s: 0.10 > Make delay between execution retries configurable >

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

2015-10-05 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-2066: -- Fix Version/s: 0.10 > Make delay between execution retries configurable >

[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_r41127946 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/util/ZooKeeperUtils.java --- @@ -47,8 +55,10 @@ public static CuratorFramework

[jira] [Resolved] (FLINK-2802) Watermark triggered operators cannot progress with cyclic flows

2015-10-05 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-2802. --- Resolution: Fixed Fix Version/s: 0.10 As far as I understand this has been

[jira] [Updated] (FLINK-2504) ExternalSortLargeRecordsITCase.testSortWithLongAndShortRecordsMixed failed spuriously

2015-10-05 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-2504: -- Affects Version/s: 0.10 >

[jira] [Updated] (FLINK-2670) Unstable CombineTaskTest

2015-10-05 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-2670: -- Fix Version/s: 0.10 > Unstable CombineTaskTest > > >

[jira] [Updated] (FLINK-2504) ExternalSortLargeRecordsITCase.testSortWithLongAndShortRecordsMixed failed spuriously

2015-10-05 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-2504: -- Fix Version/s: 0.10 >

[jira] [Updated] (FLINK-2670) Unstable CombineTaskTest

2015-10-05 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-2670: -- Affects Version/s: 0.10 > Unstable CombineTaskTest > > >

[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_r41129860 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/zookeeper/ZooKeeperStateHandleStore.java --- @@ -0,0 +1,422 @@ +/* + * Licensed

[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_r41129869 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/zookeeper/ZooKeeperStateHandleStore.java --- @@ -0,0 +1,422 @@ +/* + * Licensed

[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_r41129801 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/zookeeper/ZooKeeperStateHandleStore.java --- @@ -0,0 +1,422 @@ +/* + * Licensed

[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=14943207#comment-14943207 ] ASF GitHub Bot commented on FLINK-2354: --- Github user tillrohrmann commented on a diff in the pull

[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=14943209#comment-14943209 ] ASF GitHub Bot commented on FLINK-2354: --- Github user tillrohrmann commented on a diff in the pull

[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_r41129709 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/zookeeper/ZooKeeperStateHandleStore.java --- @@ -0,0 +1,422 @@ +/* + * Licensed

[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=14943205#comment-14943205 ] ASF GitHub Bot commented on FLINK-2354: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Resolved] (FLINK-2367) “flink-xx-jobmanager-linux-3lsu.log" file can't auto be recovered/detected after mistaking delete

2015-10-05 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-2367. --- Resolution: Auto Closed Until further clarification I'm closing this issue. Feel free

[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=14943208#comment-14943208 ] ASF GitHub Bot commented on FLINK-2354: --- Github user tillrohrmann commented on a diff in the pull

[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=14943218#comment-14943218 ] ASF GitHub Bot commented on FLINK-2354: --- Github user uce commented on a diff in the pull request:

[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_r41130914 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/zookeeper/ZooKeeperStateHandleStore.java --- @@ -0,0 +1,422 @@ +/* + * Licensed to the

[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=14943297#comment-14943297 ] ASF GitHub Bot commented on FLINK-2767: --- Github user nikste commented on the pull request:

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

2015-10-05 Thread nikste
Github user nikste commented on the pull request: https://github.com/apache/flink/pull/1197#issuecomment-145510215 For me it says: ~~~bash Failed to created JLineReader: java.lang.NoClassDefFoundError: jline/console/completer/Completer Falling back to SimpleReader. ~~~

[jira] [Commented] (FLINK-1675) Rework Accumulators

2015-10-05 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14943301#comment-14943301 ] Ufuk Celebi commented on FLINK-1675: Max, there was this PR which addressed (5):

  1   2   3   4   >