[jira] [Created] (FLINK-2848) Refactor Flink benchmarks with JMH and move to flink-benchmark module

2015-10-09 Thread Chengxiang Li (JIRA)
Chengxiang Li created FLINK-2848: Summary: Refactor Flink benchmarks with JMH and move to flink-benchmark module Key: FLINK-2848 URL: https://issues.apache.org/jira/browse/FLINK-2848 Project: Flink

[jira] [Commented] (FLINK-2847) Fix flaky test in StormTestBase.testJob

2015-10-09 Thread Henry Saputra (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2847?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14951400#comment-14951400 ] Henry Saputra commented on FLINK-2847: -- The PR that trigger the test fail just updati

[jira] [Created] (FLINK-2847) Fix flaky test in StormTestBase.testJob

2015-10-09 Thread Henry Saputra (JIRA)
Henry Saputra created FLINK-2847: Summary: Fix flaky test in StormTestBase.testJob Key: FLINK-2847 URL: https://issues.apache.org/jira/browse/FLINK-2847 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-2842) S3FileSystem is broken

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

[GitHub] flink pull request: [FLINK-2842] [documentation] Remove Flink S3Fi...

2015-10-09 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/1245#issuecomment-147009826 Great that we finally get rid of this AWS dependency. It seems that the dependency actually influenced somehow other dependencies from Hadoop. I have a test

[jira] [Commented] (FLINK-2591) Add configuration parameter for default number of yarn containers

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

[GitHub] flink pull request: [FLINK-2591] Add configuration parameter for d...

2015-10-09 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/1121#issuecomment-147009266 That's indeed a good question. I don't have much time currently, but I'm trying to answer you within the next few days. --- If your project is set up for it, you can r

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

2015-10-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14951247#comment-14951247 ] 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-09 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/1202#issuecomment-146991947 Oh I forgot. I still want to test it on Yarn. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If you

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

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

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

2015-10-09 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/1202#issuecomment-146991673 Great ;) --- 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-2793] [dashboard] Redirect to leader in...

2015-10-09 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/1202#issuecomment-146991497 Have fixed a possible race condition in `JobManagerRetriever` and rebased on the latest master. If Travis gives green light, I'll merge it. --- If your project is

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

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

[jira] [Commented] (FLINK-2844) Remove old web interface and default to the new one

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

[GitHub] flink pull request: [FLINK-2844][jobmanager] remove old web interf...

2015-10-09 Thread sachingoel0101
Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/1246#issuecomment-146988445 `YarnSessionFIFOITCase` checks the old job manager web interface. We should change that too. --- If your project is set up for it, you can reply to this email an

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

2015-10-09 Thread sachingoel0101
Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/1214#issuecomment-146980054 @mxm @StephanEwen I have an implementation ready. I have also added unit tests to verify the behavior. Let me know if this is an acceptable way. All the relevant

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

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

[jira] [Commented] (FLINK-2804) Support blocking job submission with Job Manager recovery

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

[GitHub] flink pull request: [FLINK-2804] [runtime] Add blocking job submis...

2015-10-09 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/1249 [FLINK-2804] [runtime] Add blocking job submission support for HA The JobClientActor is now repsonsible for receiving the JobStatus updates from a newly elected leader. It uses the LeaderRe

[jira] [Created] (FLINK-2846) Emit checkpoint barriers earlier, before drawing the state snapshot

2015-10-09 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-2846: --- Summary: Emit checkpoint barriers earlier, before drawing the state snapshot Key: FLINK-2846 URL: https://issues.apache.org/jira/browse/FLINK-2846 Project: Flink

[jira] [Commented] (FLINK-2843) Add documentation for DataSet outer joins

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

[GitHub] flink pull request: [FLINK-2843] Add documentation for outer joins...

2015-10-09 Thread fhueske
GitHub user fhueske opened a pull request: https://github.com/apache/flink/pull/1248 [FLINK-2843] Add documentation for outer joins. You can merge this pull request into a Git repository by running: $ git pull https://github.com/fhueske/flink outerJoinDocs Alternatively you c

[jira] [Assigned] (FLINK-2845) TimestampITCase.testWatermarkPropagation

2015-10-09 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-2845: --- Assignee: Aljoscha Krettek > TimestampITCase.testWatermarkPropagation > -

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

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

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

2015-10-09 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/1227#issuecomment-146954580 Looks good. I will rebase it on the latest state recovery branch and if travis gives green light, then I'll merge it. --- If your project is set up for it, you can

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

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

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

2015-10-09 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/1153#issuecomment-146948889 I made some more fixes for the shading of the curator dependency. Once Travis gives green light, I'll merge it. --- If your project is set up for it, you can reply

[jira] [Commented] (FLINK-2844) Remove old web interface and default to the new one

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

[GitHub] flink pull request: [FLINK-2844][jobmanager] remove old web interf...

2015-10-09 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1246#issuecomment-146941673 This should also remove all Jetty dependencies (runtime pom and root pom) --- If your project is set up for it, you can reply to this email and have your reply appea

[jira] [Commented] (FLINK-2844) Remove old web interface and default to the new one

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

[GitHub] flink pull request: [FLINK-2844][jobmanager] remove old web interf...

2015-10-09 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/1246#issuecomment-146940476 The WebFrontendITCase still needs to be adapted. --- 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 proj

[jira] [Commented] (FLINK-2842) S3FileSystem is broken

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

[GitHub] flink pull request: [FLINK-2842] [documentation] Remove Flink S3Fi...

2015-10-09 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1245#issuecomment-146934980 Thanks for the pointer. I removed the AWS dependency. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If

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

2015-10-09 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-2730. - Resolution: Fixed > Add CPU/Network utilization graphs to new web dashboard >

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

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

[GitHub] flink pull request: [FLINK-2730][web-dashboard] Adds cpu and memor...

2015-10-09 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1236 --- 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 enab

[GitHub] flink pull request: [FLINK-2774] [scala shell] Import some Java an...

2015-10-09 Thread chiwanpark
GitHub user chiwanpark opened a pull request: https://github.com/apache/flink/pull/1247 [FLINK-2774] [scala shell] Import some Java and Core API classes automatically This PR adds some packages and classes into scala shell import list for improving user experience. Please check the

[jira] [Closed] (FLINK-687) Add support for outer-joins

2015-10-09 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-687. --- Resolution: Implemented Assignee: Ricky Pogalz (was: Chiwan Park) Fix Version/s: (w

[jira] [Updated] (FLINK-2107) Implement Hash Outer Join algorithm

2015-10-09 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-2107: - Issue Type: New Feature (was: Sub-task) Parent: (was: FLINK-687) > Implement Hash Out

[jira] [Updated] (FLINK-2576) Add outer joins to API and Optimizer

2015-10-09 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-2576: - Fix Version/s: (was: pre-apache) 0.10 > Add outer joins to API and Optimize

[jira] [Reopened] (FLINK-2576) Add outer joins to API and Optimizer

2015-10-09 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reopened FLINK-2576: -- > Add outer joins to API and Optimizer > > > Ke

[jira] [Closed] (FLINK-2576) Add outer joins to API and Optimizer

2015-10-09 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-2576. Resolution: Fixed > Add outer joins to API and Optimizer > > >

[jira] [Closed] (FLINK-2576) Add outer joins to API and Optimizer

2015-10-09 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-2576. > Add outer joins to API and Optimizer > > > Key: F

[jira] [Commented] (FLINK-2576) Add outer joins to API and Optimizer

2015-10-09 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14950685#comment-14950685 ] Fabian Hueske commented on FLINK-2576: -- Implemented via b00c1d7e7b83a3f2e42223fe97dd3

[jira] [Resolved] (FLINK-2576) Add outer joins to API and Optimizer

2015-10-09 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske resolved FLINK-2576. -- Resolution: Fixed > Add outer joins to API and Optimizer >

[jira] [Assigned] (FLINK-2774) Import Java API classes automatically in Flink's Scala shell

2015-10-09 Thread Chiwan Park (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chiwan Park reassigned FLINK-2774: -- Assignee: Chiwan Park > Import Java API classes automatically in Flink's Scala shell >

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

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

[GitHub] flink pull request: [FLINK-2730][web-dashboard] Adds cpu and memor...

2015-10-09 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/1236#issuecomment-146922016 Merging this after a final test... --- 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

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

2015-10-09 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/1214#issuecomment-146918295 Good points. I think that should do it, Sachin. Curious, how you'll implement it :) Don't we run into the problem that we never know if another execution followed

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

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

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

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

[GitHub] flink pull request: [FLINK-2730][web-dashboard] Adds cpu and memor...

2015-10-09 Thread sachingoel0101
Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/1236#issuecomment-146915677 Build passes successfully. Looking forward to seeing this merged. :) --- If your project is set up for it, you can reply to this email and have your reply appear

[GitHub] flink pull request: [FLINK-2842] [documentation] Remove Flink S3Fi...

2015-10-09 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1245#issuecomment-146914047 sure, will do --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature

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

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

[jira] [Commented] (FLINK-2842) S3FileSystem is broken

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

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

2015-10-09 Thread sachingoel0101
Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/1214#issuecomment-146914064 There are three root causes(please add if I've missed any.) 1. Call to execute twice 2. Access job execution results. 3. Executing one of the eager exec

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

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

[jira] [Resolved] (FLINK-2782) Remove deprecated features for 0.10

2015-10-09 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2782?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri resolved FLINK-2782. -- Resolution: Done > Remove deprecated features for 0.10 > --- > >

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

2015-10-09 Thread sachingoel0101
Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/1214#issuecomment-146913514 IMO even removing the detached mode might be better than restricting to `Program` interface. Instead of failing late in the execution, or with a non-informative w

[jira] [Resolved] (FLINK-2784) Remove deprecated config keys

2015-10-09 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2784?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri resolved FLINK-2784. -- Resolution: Done > Remove deprecated config keys > - > >

[jira] [Commented] (FLINK-2842) S3FileSystem is broken

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

[jira] [Resolved] (FLINK-2833) Unstage Gelly and Module refactoring

2015-10-09 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri resolved FLINK-2833. -- Resolution: Done > Unstage Gelly and Module refactoring > >

[GitHub] flink pull request: [FLINK-2842] [documentation] Remove Flink S3Fi...

2015-10-09 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1245#issuecomment-146912958 Looks good. Can you also remove the AWS tools dependency in the flink-runtime POM? --- If your project is set up for it, you can reply to this email and hav

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

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

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

2015-10-09 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1214#issuecomment-146912518 We can go with the `Program` interface ,but I think that is such a heavy restriction that this effectively renders the feature useless... --- If your project is set

[jira] [Commented] (FLINK-2833) Unstage Gelly and Module refactoring

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

[jira] [Commented] (FLINK-2784) Remove deprecated config keys

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

[GitHub] flink pull request: [FLINK-2784] Remove deprecated configuration k...

2015-10-09 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1244 --- 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 enab

[GitHub] flink pull request: [FLINK-2833] [gelly] unstage Gelly and move to...

2015-10-09 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1241 --- 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 enab

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

2015-10-09 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/1214#issuecomment-146911998 With proper documentation, failing on the second execute could be an acceptable workaround but it's bound to cause trouble. In addition we might want to warn users on the co

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

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

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

2015-10-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14950605#comment-14950605 ] 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-09 Thread sachingoel0101
Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/1214#issuecomment-146911063 I think we need to ensure that interactive programs which can execute successfully should still be allowed. What I proposed should work. I can push a commit an

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

2015-10-09 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-2798: -- Summary: Prepare new web dashboard for executing it on YARN (was: Prepare new web dashb

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

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

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

2015-10-09 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/1214#issuecomment-146909986 I would solve it pragmatically and simply make the Program interface a requirement for detached programs. Otherwise, fail with an explanation. --- If your project is set up

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

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

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

2015-10-09 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/1214#issuecomment-146909628 This will fail hard when users rely on the result of the first job. So imagine your program always worked. You submit it detached and then it fails after 12 hours when the f

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

2015-10-09 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1214#issuecomment-146908658 The way we do this with the Optimizer plan is a bit pragmatic. We wick the first runnable part and use that. We could do the same here. Detached mode would submit th

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

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

[jira] [Commented] (FLINK-2844) Remove old web interface and default to the new one

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

[GitHub] flink pull request: [FLINK-2844][jobmanager] remove old web interf...

2015-10-09 Thread mxm
GitHub user mxm opened a pull request: https://github.com/apache/flink/pull/1246 [FLINK-2844][jobmanager] remove old web interface The new web interface supports all features of the old web interface once #1164 and #1233 have been merged. It's time to remove the old one. You can me

[jira] [Updated] (FLINK-2845) TimestampITCase.testWatermarkPropagation

2015-10-09 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated FLINK-2845: --- Description: https://travis-ci.org/apache/flink/jobs/84479912 {noformat} Tests run: 8, Failure

[jira] [Created] (FLINK-2845) TimestampITCase.testWatermarkPropagation

2015-10-09 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created FLINK-2845: -- Summary: TimestampITCase.testWatermarkPropagation Key: FLINK-2845 URL: https://issues.apache.org/jira/browse/FLINK-2845 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-2842) S3FileSystem is broken

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

[GitHub] flink pull request: [FLINK-2842] [documentation] Remove Flink S3Fi...

2015-10-09 Thread fhueske
GitHub user fhueske opened a pull request: https://github.com/apache/flink/pull/1245 [FLINK-2842] [documentation] Remove Flink S3FileSystem Extend documentation to use Hadoop S3FileSystem. You can merge this pull request into a Git repository by running: $ git pull https://gith

[jira] [Created] (FLINK-2844) Remove old web interface and default to the new one

2015-10-09 Thread Maximilian Michels (JIRA)
Maximilian Michels created FLINK-2844: - Summary: Remove old web interface and default to the new one Key: FLINK-2844 URL: https://issues.apache.org/jira/browse/FLINK-2844 Project: Flink I

[jira] [Commented] (FLINK-2784) Remove deprecated config keys

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

[GitHub] flink pull request: [FLINK-2784] Remove deprecated configuration k...

2015-10-09 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/1244#issuecomment-146903415 I'll merge this one too. --- 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-2833) Unstage Gelly and Module refactoring

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

[GitHub] flink pull request: [FLINK-2833] [gelly] unstage Gelly and move to...

2015-10-09 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/1241#issuecomment-146902805 :dancers: :tada: :fireworks: merging ^^ --- 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 doe

[GitHub] flink pull request: [FLINK-2725] Max/Min/Sum Aggregation of mutabl...

2015-10-09 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/1191#discussion_r41641649 --- Diff: flink-java/src/main/java/org/apache/flink/api/java/aggregation/SumAggregationFunction.java --- @@ -113,11 +182,32 @@ public Long getAggregate() {

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

2015-10-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14950553#comment-14950553 ] 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-09 Thread sachingoel0101
Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/1214#issuecomment-146901927 That won't suffice. Even if we allow one execute call, we cannot be sure that user won't try to access the `JobExecutionResult`. That also is an issue. Disallo

[jira] [Commented] (FLINK-2725) Max/Min/Sum Aggregation of mutable types

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

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

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

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

2015-10-09 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/1214#issuecomment-146899718 OKnow I'm confused. This PR was all about disallowing "multiple round trips" and that's what Sachin tried to solve. Failing all interactive programs detached is a quick

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

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

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

2015-10-09 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1214#issuecomment-146898360 When we grab the Optimizer Plan from interactive programs, we also have a similar problem - we would in theory need to execute the whole program. What we do instead

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

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

  1   2   3   >