[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&focusedCommentId=14950043#comment-14950043 ] Maximilian Michels commented on FLINK-2611: --- The user ran {{flink run -m yarn-cl

[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&focusedCommentId=14950047#comment-14950047 ] ASF GitHub Bot commented on FLINK-2576: --- Github user fhueske commented on the pull r

[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&focusedCommentId=14950060#comment-14950060 ] Matthias J. Sax commented on FLINK-2831: It's a stupid test and it does have an is

[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-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=14950088#comment-14950088 ] 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-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. I

[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&focusedCommentId=14950096#comment-14950096 ] Maximilian Michels commented on FLINK-2834: --- +1 > Global round-robin for tempor

[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&focusedCommentId=14950060#comment-14950060 ] Matthias J. Sax edited comment on FLINK-2831 at 10/9/15 9:14 AM: ---

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

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

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

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

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

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

[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&focusedCommentId=14950166#comment-14950166 ] ASF GitHub Bot commented on FLINK-2780: --- Github user aljoscha closed the pull reques

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

[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 https://github.com/apache/flink/commit/0c1141abcd0f58dcf2ec9abcc

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

[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&focusedCommentId=14950170#comment-14950170 ] ASF GitHub Bot commented on FLINK-2779: --- Github user aljoscha commented on the pull

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

[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 https://github.com/apache/flink/commit/c9088a491a459e44be41b0740

[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-146829953 @asfgit didn't close it automatically, could you please close it @ktzoumas . --- If your project is set up for it, you can reply to this email and have your reply appea

[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&focusedCommentId=14950180#comment-14950180 ] ASF GitHub Bot commented on FLINK-2779: --- Github user aljoscha commented on the pull

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

[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&focusedCommentId=14950182#comment-14950182 ] ASF GitHub Bot commented on FLINK-2808: --- Github user mbalassi commented on the pull

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

[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_r41617865 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/TaskManagersHandler.java --- @@ -54,10 +58,22 @@ public String handleReque

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

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

[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=14950191#comment-14950191 ] 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-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 https://github.com/apache/flink/commit/c9088a491a459e44be41b074054

[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&focusedCommentId=14950200#comment-14950200 ] Matthias J. Sax commented on FLINK-2831: Fixed via 998be1bbbc823e1299dcb6bfe56774e

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

[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-146832468 The initial look is a bit weird, I agree. There is a potential fix, by fetching the usage upto the point when someone clicks on the `metrics` tab, however, that c

[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=14950202#comment-14950202 ] 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 a diff in the pull request: https://github.com/apache/flink/pull/1236#discussion_r41618643 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/TaskManagersHandler.java --- @@ -54,10 +58,22 @@ public String

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

[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&focusedCommentId=14950217#comment-14950217 ] ASF GitHub Bot commented on FLINK-2730: --- Github user sachingoel0101 commented on a d

[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&focusedCommentId=14950225#comment-14950225 ] ASF GitHub Bot commented on FLINK-2576: --- Github user fhueske commented on the pull r

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

[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

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

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

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

[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&focusedCommentId=14950312#comment-14950312 ] ASF GitHub Bot commented on FLINK-2624: --- GitHub user HilmiYildirim opened a pull req

[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&focusedCommentId=14950318#comment-14950318 ] ASF GitHub Bot commented on FLINK-2779: --- Github user ktzoumas closed the pull reques

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

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

[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&focusedCommentId=14950325#comment-14950325 ] Chiwan Park commented on FLINK-2840: Hi [~devangb], there is already a JIRA which cove

[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] [Created] (FLINK-2841) Broken roadmap link in FlinkML contribution guide

2015-10-09 Thread Chiwan Park (JIRA)
Chiwan Park created FLINK-2841: -- Summary: Broken roadmap link in FlinkML contribution guide Key: FLINK-2841 URL: https://issues.apache.org/jira/browse/FLINK-2841 Project: Flink Issue Type: Bug

[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=14950377#comment-14950377 ] 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-146871440 Looks good to merge now. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this f

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

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

[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=14950397#comment-14950397 ] 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-146874010 Before interactive programs were allowed, the detached mode would have been worked fine because a single JobGraph would have been transferred to the job manager and executed

[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-146875588 I think it would be fine to not have HA for interactive programs. After all, Flink need no client/master interactivity for streaming and iterations, which is where t

[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=14950410#comment-14950410 ] 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-146876057 Having a dedicated executor on the JobManager seems like a very big thing, for a not so important issue. Why not just fail when someone tries to submit a interactive

[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=14950412#comment-14950412 ] 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 mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/1214#issuecomment-146877512 +1 for now, just let submission fail for detached interactive programs (with a nice exception) @sachingoel0101 Could you change the PR accordingly? This would also

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

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

2015-10-09 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-2842: Summary: S3FileSystem is broken Key: FLINK-2842 URL: https://issues.apache.org/jira/browse/FLINK-2842 Project: Flink Issue Type: Bug Affects Versions: 0.

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

2015-10-09 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2842?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14950430#comment-14950430 ] Robert Metzger commented on FLINK-2842: --- Can you also document how to use Hadoop's S

[jira] [Comment Edited] (FLINK-2842) S3FileSystem is broken

2015-10-09 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2842?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14950435#comment-14950435 ] Fabian Hueske edited comment on FLINK-2842 at 10/9/15 2:05 PM: -

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

2015-10-09 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2842?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14950435#comment-14950435 ] Fabian Hueske commented on FLINK-2842: -- Doesn't it work out of the box if I remove th

[jira] [Commented] (FLINK-2716) Checksum method for DataSet and Graph

2015-10-09 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14950446#comment-14950446 ] Greg Hogan commented on FLINK-2716: --- {{TaskConfig}} has {{getInputSerializer(int, ClassL

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

2015-10-09 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2842?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14950452#comment-14950452 ] Aljoscha Krettek commented on FLINK-2842: - Yes, but you also need configuration fo

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

2015-10-09 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2842?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14950453#comment-14950453 ] Fabian Hueske commented on FLINK-2842: -- So basically extend this one here: https://ci

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

2015-10-09 Thread fhueske
GitHub user fhueske opened a pull request: https://github.com/apache/flink/pull/1244 [FLINK-2784] Remove deprecated configuration keys and updated documentation You can merge this pull request into a Git repository by running: $ git pull https://github.com/fhueske/flink deprCo

[GitHub] flink pull request: [FLINK-2818] [runtime] Corrected javadocs of *...

2015-10-09 Thread chiwanpark
Github user chiwanpark commented on the pull request: https://github.com/apache/flink/pull/1224#issuecomment-146885004 I'll merge this with addressing @StephanEwen's comment. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well

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

2015-10-09 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/1244#issuecomment-146885012 +1 looks good to merge! --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this fe

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

[jira] [Commented] (FLINK-2818) The *ReduceDriver classes have incorrect javadocs

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

[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&focusedCommentId=14950457#comment-14950457 ] ASF GitHub Bot commented on FLINK-2576: --- Github user asfgit closed the pull request

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

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

[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&focusedCommentId=14950461#comment-14950461 ] ASF GitHub Bot commented on FLINK-2576: --- Github user fhueske commented on the pull r

[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_r41635292 --- Diff: flink-java/src/main/java/org/apache/flink/api/java/typeutils/ValueTypeInfo.java --- @@ -51,7 +51,18 @@ public class ValueTypeInfo extends Ty

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

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

2015-10-09 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-2843: Summary: Add documentation for DataSet outer joins Key: FLINK-2843 URL: https://issues.apache.org/jira/browse/FLINK-2843 Project: Flink Issue Type: Bug

[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=14950465#comment-14950465 ] ASF GitHub Bot commented on FLINK-2725: --- Github user greghogan commented on a diff i

[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&focusedCommentId=14950467#comment-14950467 ] ASF GitHub Bot commented on FLINK-2576: --- Github user fhueske commented on the pull r

[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-146886307 Thank you very much @jkovacs and @r-pogalz for adding outer joins to Flink! --- If your project is set up for it, you can reply to this email and have your reply appear

[GitHub] flink pull request: [FLINK-2818] [runtime] Corrected javadocs of *...

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

[jira] [Commented] (FLINK-2818) The *ReduceDriver classes have incorrect javadocs

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

[jira] [Closed] (FLINK-2818) The *ReduceDriver classes have incorrect javadocs

2015-10-09 Thread Chiwan Park (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chiwan Park closed FLINK-2818. -- Resolution: Fixed Fixed via 48f614cb77cbd9723db076df80e36b38e20f913f. Thanks for contribution! :) > Th

[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-146885685 Oh, just realized we did not update the documentation. I will open a JIRA for that and add it later today. --- If your project is set up for it, you can reply to thi

[jira] [Commented] (FLINK-2613) Print usage information for Scala Shell

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

[jira] [Commented] (FLINK-2613) Print usage information for Scala Shell

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

[GitHub] flink pull request: [FLINK-2613] Print usage information for Scala...

2015-10-09 Thread chiwanpark
Github user chiwanpark commented on the pull request: https://github.com/apache/flink/pull/1106#issuecomment-146891099 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 does not have this feature

[GitHub] flink pull request: [FLINK-2613] Print usage information for Scala...

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

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

2015-10-09 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2842?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14950489#comment-14950489 ] Aljoscha Krettek commented on FLINK-2842: - I hope so, yes. [~rmetzger] recently re

[jira] [Closed] (FLINK-2613) Print usage information for Scala Shell

2015-10-09 Thread Chiwan Park (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chiwan Park closed FLINK-2613. -- Resolution: Implemented Implemented via 7750a1f29e231f16cbbea4d91dbe530b1f92f192. Thanks for contributi

[jira] [Commented] (FLINK-2156) Scala modules cannot create logging file

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

[GitHub] flink pull request: [FLINK-2156] Scala modules cannot create loggi...

2015-10-09 Thread chiwanpark
Github user chiwanpark commented on the pull request: https://github.com/apache/flink/pull/1234#issuecomment-146891720 Merging this... --- 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 fea

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

2015-10-09 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2842?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14950494#comment-14950494 ] Robert Metzger commented on FLINK-2842: --- It only works for file systems which have a

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

2015-10-09 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2842?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14950499#comment-14950499 ] Robert Metzger commented on FLINK-2842: --- Yes. I tried it for the StackOverflow answe

  1   2   3   >