[GitHub] flink pull request: [FLINK-2111] Add "stop" signal to cleanly shut...

2015-08-02 Thread hsaputra
Github user hsaputra commented on a diff in the pull request: https://github.com/apache/flink/pull/750#discussion_r36059148 --- Diff: flink-clients/src/main/java/org/apache/flink/client/CliFrontend.java --- @@ -517,7 +522,70 @@ public int compare(JobStatusMessage o1, JobStatusMess

[jira] [Commented] (FLINK-2111) Add "stop" signal to cleanly shutdown streaming jobs

2015-08-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14651500#comment-14651500 ] ASF GitHub Bot commented on FLINK-2111: --- Github user hsaputra commented on a diff in

[jira] [Commented] (FLINK-2111) Add "stop" signal to cleanly shutdown streaming jobs

2015-08-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14651499#comment-14651499 ] ASF GitHub Bot commented on FLINK-2111: --- Github user hsaputra commented on a diff in

[GitHub] flink pull request: [FLINK-2111] Add "stop" signal to cleanly shut...

2015-08-02 Thread hsaputra
Github user hsaputra commented on a diff in the pull request: https://github.com/apache/flink/pull/750#discussion_r36059082 --- Diff: docs/apis/cli.md --- @@ -176,6 +180,18 @@ Action "list" lists running and scheduled programs. -s,--scheduledShow only sched

[jira] [Commented] (FLINK-2425) Give access to TaskManager config and hostname in the Runtime Environment

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

[GitHub] flink pull request: [FLINK-2425]Provide access to task manager con...

2015-08-02 Thread sachingoel0101
Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/952#issuecomment-127139227 > ...have it actually wrap the configuration, and have all the "getX()" methods delegate to the config, > while all the "setX()" methods fail with an exceptio

[jira] [Commented] (FLINK-2456) The flink-hbase module dependencies hadoop-2 specifies a repository ID

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

[GitHub] flink pull request: [FLINK-2456][fix]add a repository ID for hadoo...

2015-08-02 Thread HuangWHWHW
Github user HuangWHWHW commented on the pull request: https://github.com/apache/flink/pull/969#issuecomment-127105581 This is just a method to solve the problem that some modules' dependencies cannot be downloaded from central maven repository. You can specify every module dependen

[jira] [Commented] (FLINK-2166) Add fromCsvFile() to TableEnvironment

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

[GitHub] flink pull request: FLINK-2166. Add fromCsvFile() method to TableE...

2015-08-02 Thread jamescao
Github user jamescao commented on the pull request: https://github.com/apache/flink/pull/939#issuecomment-127090230 It seems that [FLINK-2167](https://issues.apache.org/jira/browse/FLINK-2167?jql=project%20%3D%20FLINK%20AND%20resolution%20%3D%20Unresolved%20AND%20text%20~%20%22hcatalog

[jira] [Resolved] (FLINK-2433) Jekyll on windows for building local documentation

2015-08-02 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2433. - Resolution: Fixed Assignee: Sachin Goel Fix Version/s: 0.10 Added in 416ff589e8f7d

[jira] [Closed] (FLINK-2433) Jekyll on windows for building local documentation

2015-08-02 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2433. --- > Jekyll on windows for building local documentation > --

[jira] [Commented] (FLINK-2425) Give access to TaskManager config and hostname in the Runtime Environment

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

[GitHub] flink pull request: [FLINK-2425]Provide access to task manager con...

2015-08-02 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/952#issuecomment-127077814 For the test it is important that it catches the case where someone adds a method (for example "setStringArray()") to the base class and does not override it in the s

[jira] [Commented] (FLINK-2425) Give access to TaskManager config and hostname in the Runtime Environment

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

[GitHub] flink pull request: [FLINK-2425]Provide access to task manager con...

2015-08-02 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/952#issuecomment-127077747 I think that silently failing is not a good idea in this case. Silent failures always keep people wondering why things don't behave like they expect. It needs to fail

[jira] [Commented] (FLINK-2464) BufferSpillerTest sometimes fails

2015-08-02 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14651206#comment-14651206 ] Stephan Ewen commented on FLINK-2464: - I have seen a similar failure as well. It seems

[jira] [Commented] (FLINK-2322) Unclosed stream may leak resource

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

[GitHub] flink pull request: FLINK-2322 Unclosed stream may leak resource

2015-08-02 Thread tedyu
Github user tedyu commented on the pull request: https://github.com/apache/flink/pull/928#issuecomment-127074789 I looked at https://travis-ci.org/apache/flink/jobs/73803261 but couldn't figure out which test failed. --- If your project is set up for it, you can reply to this email a

[jira] [Comment Edited] (FLINK-2166) Add fromCsvFile() to TableEnvironment

2015-08-02 Thread Chiwan Park (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14642017#comment-14642017 ] Chiwan Park edited comment on FLINK-2166 at 8/2/15 9:37 PM: Hi

[jira] [Commented] (FLINK-2425) Give access to TaskManager config and hostname in the Runtime Environment

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

[GitHub] flink pull request: [FLINK-2425]Provide access to task manager con...

2015-08-02 Thread sachingoel0101
Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/952#issuecomment-127071830 Added test to verify all setter methods are overridden by the `UnmodifiableConfiguration` class. --- If your project is set up for it, you can reply to this email

[jira] [Resolved] (FLINK-2436) Make ByteStreamStateHandles more robust

2015-08-02 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-2436. --- Resolution: Fixed > Make ByteStreamStateHandles more robust > ---

[jira] [Created] (FLINK-2464) BufferSpillerTest sometimes fails

2015-08-02 Thread Gyula Fora (JIRA)
Gyula Fora created FLINK-2464: - Summary: BufferSpillerTest sometimes fails Key: FLINK-2464 URL: https://issues.apache.org/jira/browse/FLINK-2464 Project: Flink Issue Type: Bug Component

[jira] [Commented] (FLINK-2436) Make ByteStreamStateHandles more robust

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

[GitHub] flink pull request: [FLINK-2436] [streaming] Make ByteStreamStateH...

2015-08-02 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/958 --- 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 enabl

[GitHub] flink pull request: [FLINK-2459][cli]Cli API and doc fixes.

2015-08-02 Thread sachingoel0101
Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/971#issuecomment-127055248 @StephanEwen, I've force pushed this branch to only contain the name change. You can merge this again. --- If your project is set up for it, you can reply to this

[jira] [Commented] (FLINK-2459) Failure on recently added Client side logging test

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

[jira] [Commented] (FLINK-2425) Give access to TaskManager config and hostname in the Runtime Environment

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

[GitHub] flink pull request: [FLINK-2425]Provide access to task manager con...

2015-08-02 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/952#issuecomment-127053317 If we want to unmodifiable configuration to be usable like any other configuration, it needs to be a subclass that overrides all mutating methods. To make sur

[jira] [Closed] (FLINK-2463) Chow execution config in dashboard

2015-08-02 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2463. --- > Chow execution config in dashboard > -- > > Key: FLINK-2

[jira] [Commented] (FLINK-2459) Failure on recently added Client side logging test

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

[jira] [Commented] (FLINK-2459) Failure on recently added Client side logging test

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

[GitHub] flink pull request: [FLINK-2459][cli]Cli API and doc fixes.

2015-08-02 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/971#issuecomment-127052994 The push to rename it to "quiet" came after the merge, so it did not get in... --- If your project is set up for it, you can reply to this email and have your reply

[GitHub] flink pull request: [FLINK-2459][cli]Cli API and doc fixes.

2015-08-02 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/971#issuecomment-127053005 Can you make a separate patch for 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 projec

[jira] [Resolved] (FLINK-2463) Chow execution config in dashboard

2015-08-02 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2463. - Resolution: Fixed Fixed via b3dc3f050c125978f4fb14ccef230938e60a9198 Thank you for the patch! >

[jira] [Closed] (FLINK-2434) org.apache.hadoop:hadoop-yarn-common:jar with value 'jersey-test-framework-grizzly2+' does not match a valid id pattern

2015-08-02 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2434. --- > org.apache.hadoop:hadoop-yarn-common:jar with value > 'jersey-test-framework-grizzly2+' does not match

[jira] [Resolved] (FLINK-2434) org.apache.hadoop:hadoop-yarn-common:jar with value 'jersey-test-framework-grizzly2+' does not match a valid id pattern

2015-08-02 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2434. - Resolution: Fixed Fix Version/s: 0.10 Fixed in d73cb7369f2259e0e3a07221c659ceffa67230d5 Th

[GitHub] flink pull request: FLINK-2434:org.apache.hadoop:hadoop-yarn-commo...

2015-08-02 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/955 --- 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 enabl

[GitHub] flink pull request: [FLINK-2357] [web dashboard] Shows job configu...

2015-08-02 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/953 --- 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 enabl

[GitHub] flink pull request: [FLINK-2459][cli]Cli API and doc fixes.

2015-08-02 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/971 --- 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 enabl

[jira] [Commented] (FLINK-2459) Failure on recently added Client side logging test

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

[jira] [Commented] (FLINK-2357) New JobManager Runtime Web Frontend

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

[jira] [Commented] (FLINK-2434) org.apache.hadoop:hadoop-yarn-common:jar with value 'jersey-test-framework-grizzly2+' does not match a valid id pattern

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

[jira] [Commented] (FLINK-2436) Make ByteStreamStateHandles more robust

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

[GitHub] flink pull request: [FLINK-2436] [streaming] Make ByteStreamStateH...

2015-08-02 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/958#issuecomment-127050990 Looks good! --- 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: Stale Synchronous Parallel Iterations

2015-08-02 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/967#issuecomment-127050940 Wow, impressive contribution! I would very much like to add SSP to Flink. This is quite a lot, so it may take a bit to review and merge. Here are some

[jira] [Commented] (FLINK-2409) Old JM web interface is sending cancel messages w/o leader ID

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

[GitHub] flink pull request: [FLINK-2409] [webserver] Replaces ActorRefs wi...

2015-08-02 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/959#issuecomment-127048697 Looks good. +1 to merge 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

[jira] [Commented] (FLINK-1665) Add optional annotations for POJOs to specify the order of fields

2015-08-02 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14651103#comment-14651103 ] Stephan Ewen commented on FLINK-1665: - Hmm, not sure I am a bit fan of that. We are en

[jira] [Commented] (FLINK-2166) Add fromCsvFile() to TableEnvironment

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

[GitHub] flink pull request: FLINK-2166. Add fromCsvFile() method to TableE...

2015-08-02 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/939#issuecomment-127048597 +1 to move it --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this featu

[jira] [Commented] (FLINK-2450) IndexOutOfBoundsException in KryoSerializer

2015-08-02 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14651101#comment-14651101 ] Stephan Ewen commented on FLINK-2450: - I this a Kryo issue, or is the byte stream corr

[jira] [Commented] (FLINK-2444) Add tests for HadoopInputFormats

2015-08-02 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14651098#comment-14651098 ] Stephan Ewen commented on FLINK-2444: - Yes, big +1 to that > Add tests for HadoopInpu

[jira] [Commented] (FLINK-1984) Integrate Flink with Apache Mesos

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

[GitHub] flink pull request: [FLINK-1984] Integrate Flink with Apache Mesos

2015-08-02 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/948#issuecomment-127048248 Here is the thread where the discussion started: http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/add-some-new-api-to-the-scheduler-in-the-job-manager-td

[jira] [Commented] (FLINK-2105) Implement Sort-Merge Outer Join algorithm

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

[GitHub] flink pull request: [FLINK-2105] Implement Sort-Merge Outer Join a...

2015-08-02 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/907#issuecomment-127047952 For most other tests that we have added/reworked in the past, we moved away from using `Record` for the tests. The `Record` was the core element of the old record API

[jira] [Commented] (FLINK-2437) TypeExtractor.analyzePojo has some problems around the default constructor detection

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

[GitHub] flink pull request: [FLINK-2437] Fix default constructor detection...

2015-08-02 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/960#issuecomment-127046830 Why are you changing all messages in this pull request? They were not wrong before... --- If your project is set up for it, you can reply to this email and have your

[jira] [Commented] (FLINK-2428) Clean up unused properties in StreamConfig

2015-08-02 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14651089#comment-14651089 ] Stephan Ewen commented on FLINK-2428: - No, it has not. That commit only introduced a l

[jira] [Commented] (FLINK-2351) Deprecate config builders in InputFormats and Output formats

2015-08-02 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14651088#comment-14651088 ] Stephan Ewen commented on FLINK-2351: - Exactly. The record API classes are deprecated

[jira] [Commented] (FLINK-2435) Add support for custom CSV field parsers

2015-08-02 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14651086#comment-14651086 ] Stephan Ewen commented on FLINK-2435: - for (2), is this going to hook into the CSV inp

[jira] [Commented] (FLINK-2433) Jekyll on windows for building local documentation

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

[GitHub] flink pull request: [FLINK-2433][docs]Add script to build local do...

2015-08-02 Thread sachingoel0101
Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/954#issuecomment-127042540 Ah. Yes, actually. I tried running the webclient on cygwin once and it didn't work [I was ignorant to the fact that I had to add those two lines in the bash pro

[GitHub] flink pull request: [FLINK-2238][scala api]Add env.fromCollection(...

2015-08-02 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/956#issuecomment-127042179 No problem, it happens ;-) Good idea to put it in 0.10 but not in 0.9.1. I think there is no API change list yet. Should we start one in the wiki? --- If

[jira] [Commented] (FLINK-2238) Scala ExecutionEnvironment.fromCollection does not work with Sets

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

[jira] [Commented] (FLINK-2434) org.apache.hadoop:hadoop-yarn-common:jar with value 'jersey-test-framework-grizzly2+' does not match a valid id pattern

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

[GitHub] flink pull request: FLINK-2434:org.apache.hadoop:hadoop-yarn-commo...

2015-08-02 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/955#issuecomment-127041880 Good catch. +1 to merge --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have

[jira] [Commented] (FLINK-2433) Jekyll on windows for building local documentation

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

[GitHub] flink pull request: [FLINK-2433][docs]Add script to build local do...

2015-08-02 Thread sachingoel0101
Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/954#issuecomment-127041808 Yes. --- 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 en

[GitHub] flink pull request: [FLINK-2433][docs]Add script to build local do...

2015-08-02 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/954#issuecomment-127041807 If the libraries are available, this is a good addition, as far as I am concerned... --- If your project is set up for it, you can reply to this email and have your

[jira] [Commented] (FLINK-2433) Jekyll on windows for building local documentation

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

[jira] [Commented] (FLINK-2433) Jekyll on windows for building local documentation

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

[GitHub] flink pull request: [FLINK-2433][docs]Add script to build local do...

2015-08-02 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/954#issuecomment-127041664 Are all the dependencies (jekyll + libraries) available on windows as well? --- If your project is set up for it, you can reply to this email and have your reply appe

[jira] [Commented] (FLINK-2459) Failure on recently added Client side logging test

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

[GitHub] flink pull request: [FLINK-2459][cli]Cli API and doc fixes.

2015-08-02 Thread sachingoel0101
Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/971#issuecomment-127040180 Pushed a fix for changing the name to `quiet` --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If yo

[jira] [Created] (FLINK-2463) Chow execution config in dashboard

2015-08-02 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-2463: --- Summary: Chow execution config in dashboard Key: FLINK-2463 URL: https://issues.apache.org/jira/browse/FLINK-2463 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-2357) New JobManager Runtime Web Frontend

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

[GitHub] flink pull request: [FLINK-2357] [web dashboard] Shows job configu...

2015-08-02 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/953#issuecomment-127039738 I'll create a dedicated subtask for this. Easier to track than in the main issue... --- If your project is set up for it, you can reply to this email and have your r

[jira] [Commented] (FLINK-2357) New JobManager Runtime Web Frontend

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

[GitHub] flink pull request: [FLINK-2357] [web dashboard] Shows job configu...

2015-08-02 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/953#issuecomment-127039563 Looks very nice! Happy to see that people are picking up the new web dashboard. +1 to merge --- If your project is set up for it, you can reply to this emai

[jira] [Commented] (FLINK-2322) Unclosed stream may leak resource

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

[GitHub] flink pull request: FLINK-2322 Unclosed stream may leak resource

2015-08-02 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/928#issuecomment-127039256 The CI builds still fail for this patch, have a look at the Travis report. All tests and checks need to pass before merging a change. --- If your project is set u

[jira] [Commented] (FLINK-1819) Allow access to RuntimeContext from Input and OutputFormats

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

[GitHub] flink pull request: [FLINK-1819][core]Allow access to RuntimeConte...

2015-08-02 Thread sachingoel0101
Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/966#issuecomment-127037112 @StephanEwen, it would be much simpler to have an interface. But then we leave the part about implementing the `setRuntimeContext` and `getRuntimeContext` to the u

[jira] [Commented] (FLINK-2459) Failure on recently added Client side logging test

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

[jira] [Commented] (FLINK-2459) Failure on recently added Client side logging test

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

[GitHub] flink pull request: [FLINK-2459][cli]Cli API and doc fixes.

2015-08-02 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/971#issuecomment-127036785 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

[GitHub] flink pull request: [FLINK-2459][cli]Cli API and doc fixes.

2015-08-02 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/971#issuecomment-127036783 This looks good, thanks you! One followup issue: The flag to suppress the logging is `-q` or `--sysoutLogging`. The long version seems inconsistent with "q".

[jira] [Commented] (FLINK-2456) The flink-hbase module dependencies hadoop-2 specifies a repository ID

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

[jira] [Resolved] (FLINK-2461) RemoteExecutorHostnameResolutionTest and ClientHostnameResolutionTest

2015-08-02 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2461. - Resolution: Fixed Fixed via 645d7cd9e437d3de301ca0ce5c9cdc87bcce494b > RemoteExecutorHostnameReso

[jira] [Closed] (FLINK-2461) RemoteExecutorHostnameResolutionTest and ClientHostnameResolutionTest

2015-08-02 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2461. --- > RemoteExecutorHostnameResolutionTest and ClientHostnameResolutionTest >

[GitHub] flink pull request: [FLINK-2456][fix]add a repository ID for hadoo...

2015-08-02 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/969#issuecomment-127036573 Thanks for providing this path! Can you help us understand this fix a bit? Why is this extra repository entry required for the HBase module, and not for any other

[jira] [Commented] (FLINK-2455) Misleading I/O manager error log messages

2015-08-02 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14651049#comment-14651049 ] Stephan Ewen commented on FLINK-2455: - I see. Asynchronous channels are flushed when c

[jira] [Resolved] (FLINK-2393) Add a "stateless at-least-once" mode for streaming

2015-08-02 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2393. - Resolution: Implemented Assignee: Stephan Ewen Fix Version/s: 0.10 All subtasks do

[jira] [Closed] (FLINK-2393) Add a "stateless at-least-once" mode for streaming

2015-08-02 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2393. --- > Add a "stateless at-least-once" mode for streaming > --

[jira] [Closed] (FLINK-2427) Allow the BarrierBuffer to maintain multiple queues of blocked inputs

2015-08-02 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2427. --- > Allow the BarrierBuffer to maintain multiple queues of blocked inputs >

[jira] [Resolved] (FLINK-2427) Allow the BarrierBuffer to maintain multiple queues of blocked inputs

2015-08-02 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2427. - Resolution: Fixed Fixed via 9311b9a9da57796e1eb91aa0ec5fa8948b732a47 > Allow the BarrierBuffer to

[GitHub] flink pull request: [FLINK-2442] [fix] FieldPositionKeys support P...

2015-08-02 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/963#issuecomment-127036020 I like the fix. There is a followup issue that I think will become important: Allowing POJOs and other types to generate normalized keys. --- If your projec

  1   2   >