[jira] [Created] (FLINK-2838) Inconsistent use of URL and Path classes for resources

2015-10-09 Thread Maximilian Michels (JIRA)
Maximilian Michels created FLINK-2838: - Summary: Inconsistent use of URL and Path classes for resources Key: FLINK-2838 URL: https://issues.apache.org/jira/browse/FLINK-2838 Project: Flink

[jira] [Commented] (FLINK-2834) Global round-robin for temporary directories

2015-10-09 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14950096#comment-14950096 ] Maximilian Michels commented on FLINK-2834: --- +1 > Global round-robin for temporary directories

[GitHub] flink pull request: [FLINK-2780] Remove Old Windowing Logic and AP...

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

[jira] [Commented] (FLINK-2780) Remove Old Windowing Logic and API

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

[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-146802623 The screenshots look great. I'll check out your work now :) --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well.

[jira] [Comment Edited] (FLINK-2831) Failing Test: WrapperSetupHelperTest

2015-10-09 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14950060#comment-14950060 ] Matthias J. Sax edited comment on FLINK-2831 at 10/9/15 9:14 AM: - The last

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

2015-10-09 Thread sachingoel0101
Github user sachingoel0101 commented on a diff in the pull request: https://github.com/apache/flink/pull/1236#discussion_r41615077 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/TaskManagersHandler.java --- @@ -39,6 +42,7 @@

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

[GitHub] flink pull request: [FLINK-2779][FLINK-2794][streaming][docs] New ...

2015-10-09 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/1208#issuecomment-146826450 I will merge this now since the code is also changed. We can iterate on this if need be. --- If your project is set up for it, you can reply to this email and have

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

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

2015-10-09 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/1236#discussion_r41612793 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/TaskManagersHandler.java --- @@ -39,6 +42,7 @@ private

[jira] [Closed] (FLINK-2780) Remove Old Windowing Logic and API

2015-10-09 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-2780. --- Resolution: Fixed Removed in

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

2015-10-09 Thread uce
Github user uce commented on the pull request: https://github.com/apache/flink/pull/1153#issuecomment-146810519 Rebased on the current master and incorporated the job manager state modification fix. Thanks for that! Can we merge this after Travis gives the green light? ---

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

[jira] [Commented] (FLINK-2779) Update documentation to reflect new Stream/Window API

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

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

[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

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

[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=14951400#comment-14951400 ] Henry Saputra commented on FLINK-2847: -- The PR that trigger the test fail just updating the Javadoc.

[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

[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

[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

[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

[GitHub] flink pull request: [FLINK-2576] Add Outer Join operator to Optimi...

2015-10-09 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1138#issuecomment-146790205 Thanks for the update @jkovacs and @r-pogalz. Very good work! I will go ahead, try this PR, and merge it :-) --- If your project is set up for it, you can reply to

[jira] [Commented] (FLINK-2831) Failing Test: WrapperSetupHelperTest

2015-10-09 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14950060#comment-14950060 ] Matthias J. Sax commented on FLINK-2831: It's a stupid test and it does have an issue... I will

[jira] [Commented] (FLINK-2611) YARN reports failed final state for successful jobs

2015-10-09 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14950043#comment-14950043 ] Maximilian Michels commented on FLINK-2611: --- The user ran {{flink run -m yarn-cluster run ...}}.

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

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

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

[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

[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

[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

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

[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

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

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

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

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

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

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

[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

[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

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

[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

[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

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

[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=14950613#comment-14950613 ] ASF GitHub Bot commented on FLINK-2833: --- Github user asfgit closed the pull request at:

[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=14950614#comment-14950614 ] ASF GitHub Bot commented on FLINK-2784: --- Github user asfgit closed the pull request at:

[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

[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

[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

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

[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

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

[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

[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

[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

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

[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

[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

[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

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

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

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

[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

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

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

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

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

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

[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

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

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

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

[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

[GitHub] flink pull request: [FLINK-2808] Rework state abstraction and clea...

2015-10-09 Thread mbalassi
Github user mbalassi commented on the pull request: https://github.com/apache/flink/pull/1239#issuecomment-146830200 I think when drawing the snapshot with `Checkpointed` you are already inside a streaming `Function` or internal operator where one can easily access that information

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

2015-10-09 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/1236#discussion_r41617830 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala --- @@ -536,6 +536,11 @@ class JobManager( )

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

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

[GitHub] flink pull request: [FLINK-2576] Add Outer Join operator to Optimi...

2015-10-09 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1138#issuecomment-146835992 Looks good. I added one commit to restore binary compatibility. The code is not super nice, but it allows to runt programs which have been previously compiled without

[jira] [Created] (FLINK-2839) Failing test: OperatorStatsAccumulatorTest.testAccumulatorAllStatistics

2015-10-09 Thread Gabor Gevay (JIRA)
Gabor Gevay created FLINK-2839: -- Summary: Failing test: OperatorStatsAccumulatorTest.testAccumulatorAllStatistics Key: FLINK-2839 URL: https://issues.apache.org/jira/browse/FLINK-2839 Project: Flink

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

[jira] [Commented] (FLINK-2831) Failing Test: WrapperSetupHelperTest

2015-10-09 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14950200#comment-14950200 ] Matthias J. Sax commented on FLINK-2831: Fixed via 998be1bbbc823e1299dcb6bfe56774ec2f7286ab >

[jira] [Resolved] (FLINK-2831) Failing Test: WrapperSetupHelperTest

2015-10-09 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved FLINK-2831. Resolution: Fixed > Failing Test: WrapperSetupHelperTest >

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

[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-146841207 @mxm I modified the code to remove null values. It should be mergeable now. --- If your project is set up for it, you can reply to this email and have your reply

[jira] [Created] (FLINK-2840) KMeans library for Flink ML

2015-10-09 Thread Devang Bacharwar (JIRA)
Devang Bacharwar created FLINK-2840: --- Summary: KMeans library for Flink ML Key: FLINK-2840 URL: https://issues.apache.org/jira/browse/FLINK-2840 Project: Flink Issue Type: Task

[GitHub] flink pull request: [FLINK-2624]: RabbitMQSource now extends Messa...

2015-10-09 Thread HilmiYildirim
GitHub user HilmiYildirim opened a pull request: https://github.com/apache/flink/pull/1243 [FLINK-2624]: RabbitMQSource now extends MessageAcknowledgingSourceBase. It now participates in checkpointing. You can merge this pull request into a Git repository by running: $ git

[jira] [Closed] (FLINK-2840) KMeans library for Flink ML

2015-10-09 Thread Chiwan Park (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chiwan Park closed FLINK-2840. -- Resolution: Duplicate Because of duplication, I close this issue. > KMeans library for Flink ML >

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

2015-10-09 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-2550. --- Resolution: Fixed This was addressed over to course of several commits. The last one is:

[jira] [Closed] (FLINK-2779) Update documentation to reflect new Stream/Window API

2015-10-09 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-2779. --- Resolution: Fixed Updated in

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

2015-10-09 Thread sachingoel0101
Github user sachingoel0101 commented on a diff in the pull request: https://github.com/apache/flink/pull/1236#discussion_r41619556 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala --- @@ -536,6 +536,11 @@ class JobManager( )

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

[jira] [Commented] (FLINK-2624) RabbitMQ source / sink should participate in checkpointing

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

[jira] [Commented] (FLINK-2840) KMeans library for Flink ML

2015-10-09 Thread Chiwan Park (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14950325#comment-14950325 ] Chiwan Park commented on FLINK-2840: Hi [~devangb], there is already a JIRA which covers kMeans

[jira] [Commented] (FLINK-2808) Rework / Extend the StatehandleProvider

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

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

[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-146831304 Tried out your changes it everything worked without quirks. The initial look is a bit odd when the charts haven't loaded yet but this is nothing that should prevent us from

[jira] [Closed] (FLINK-2794) Document exactly-once support for sources and sinks

2015-10-09 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-2794. --- Resolution: Fixed Added in

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

  1   2   3   >