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

2015-09-23 Thread ankurcha
Github user ankurcha commented on the pull request: https://github.com/apache/flink/pull/948#issuecomment-142825340 Hi @rmetzger, This completely got buried in scheduler but i think i have finally worked out the kinks. Thanks for spending the time to try it out. I th

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

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

[jira] [Commented] (FLINK-2754) FixedLengthRecordSorter can not write to output cross MemorySegments.

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

[GitHub] flink pull request: [FLINK-2754] FixedLengthRecordSorter can not w...

2015-09-23 Thread ChengXiangLi
GitHub user ChengXiangLi opened a pull request: https://github.com/apache/flink/pull/1178 [FLINK-2754] FixedLengthRecordSorter can not write to output cross MemorySegments. The issue happens while call FixedLengthRecordSorter::WriteToOutput with non-zero offset and write record acr

[jira] [Created] (FLINK-2754) FixedLengthRecordSorter can not write to output cross MemorySegments.

2015-09-23 Thread Chengxiang Li (JIRA)
Chengxiang Li created FLINK-2754: Summary: FixedLengthRecordSorter can not write to output cross MemorySegments. Key: FLINK-2754 URL: https://issues.apache.org/jira/browse/FLINK-2754 Project: Flink

[GitHub] flink pull request: [FLINK-2549] add topK operator to DataSet.

2015-09-23 Thread ChengXiangLi
Github user ChengXiangLi commented on a diff in the pull request: https://github.com/apache/flink/pull/1161#discussion_r40280217 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/operators/sort/FixedLengthRecordSorter.java --- @@ -447,11 +447,13 @@ public void writeTo

[jira] [Commented] (FLINK-2549) Add topK operator for DataSet

2015-09-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14905686#comment-14905686 ] ASF GitHub Bot commented on FLINK-2549: --- Github user ChengXiangLi commented on a dif

[jira] [Commented] (FLINK-2549) Add topK operator for DataSet

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

[GitHub] flink pull request: [FLINK-2549] add topK operator to DataSet.

2015-09-23 Thread ChengXiangLi
Github user ChengXiangLi commented on the pull request: https://github.com/apache/flink/pull/1161#issuecomment-142782327 Thanks, @StephanEwen , I'm totally agree with you about the memory allocation. Actually i tried to understand the memory allocation logic and make UDF consumer part

[GitHub] flink pull request: [FLINK-2743] Add XORShfitRandom and use it in ...

2015-09-23 Thread ChengXiangLi
Github user ChengXiangLi commented on the pull request: https://github.com/apache/flink/pull/1170#issuecomment-142780685 Yes, that make sense, i've created the [new benchmark module PR|https://github.com/apache/flink/pull/1177], and i would update this PR after 1177 got merged. ---

[jira] [Commented] (FLINK-2743) Add new RNG based on XORShift algorithm

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

[GitHub] flink pull request: [FLINK-2754] Add a new module for micro benchm...

2015-09-23 Thread ChengXiangLi
GitHub user ChengXiangLi opened a pull request: https://github.com/apache/flink/pull/1177 [FLINK-2754] Add a new module for micro benchmark. Add flink-benchmark module, and add JMH dependeny in pom. You can merge this pull request into a Git repository by running: $ git pull ht

[GitHub] flink pull request: [FLINK-2751] [Documentation] Add quickstart me...

2015-09-23 Thread rerngvit
GitHub user rerngvit opened a pull request: https://github.com/apache/flink/pull/1176 [FLINK-2751] [Documentation] Add quickstart menu to the navigation bar Add quickstart menu to the navigation bar for Flink documentation You can merge this pull request into a Git repository by run

[GitHub] flink pull request: [FLINK-2651] Add Netty to dependency managemen...

2015-09-23 Thread hsaputra
Github user hsaputra commented on the pull request: https://github.com/apache/flink/pull/1174#issuecomment-142755444 That is good to know because I did similar thing in other project to make sure we have the right Netty version. But no shading involve either. Agree about Guava

[jira] [Commented] (FLINK-2651) Failing NettyServerLowAndHighWatermarkTest

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

[jira] [Commented] (FLINK-2751) Quickstart is in documentation but only linked through the Flink homepage

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

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

2015-09-23 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1138#issuecomment-142754122 Agreed with Fabian. For now, let's require join functions. Future work would be to use Tuples with Options in Scala. In Java, we should probably add an optio

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

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

[jira] [Commented] (FLINK-2651) Failing NettyServerLowAndHighWatermarkTest

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

[GitHub] flink pull request: [FLINK-2651] Add Netty to dependency managemen...

2015-09-23 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1174#issuecomment-142753142 @hsaputra I think the wiki page is not correct any more. Netty was discussed to be shaded, but was never added to the relocated artifacts. That was a good de

[jira] [Commented] (FLINK-2751) Quickstart is in documentation but only linked through the Flink homepage

2015-09-23 Thread rerngvit yanggratoke (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14905408#comment-14905408 ] rerngvit yanggratoke commented on FLINK-2751: - I would like to help work on th

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

2015-09-23 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1138#issuecomment-142723198 Hi @jkovacs, thanks for all your efforts to make the projection work. Going for a `GenericeTypeInfo` would work in many cases but unfortunately not in all. For example `

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

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

[jira] [Commented] (FLINK-2616) Failing Test: ZooKeeperLeaderElectionTest

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

[GitHub] flink pull request: [FLINK-2616] [test-stability] Fixes ZooKeeperL...

2015-09-23 Thread uce
Github user uce commented on the pull request: https://github.com/apache/flink/pull/1173#issuecomment-142714852 +1 feel free to merge Travis log file changes are good as well. --- If your project is set up for it, you can reply to this email and have your reply appear on GitH

[GitHub] flink pull request: [FLINK-2651] Add Netty to dependency managemen...

2015-09-23 Thread uce
Github user uce commented on the pull request: https://github.com/apache/flink/pull/1174#issuecomment-142714383 Adjusted LICENSE in bc21de2. --- 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 th

[jira] [Commented] (FLINK-2651) Failing NettyServerLowAndHighWatermarkTest

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

[jira] [Commented] (FLINK-2651) Failing NettyServerLowAndHighWatermarkTest

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

[GitHub] flink pull request: [FLINK-2651] Add Netty to dependency managemen...

2015-09-23 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/1174#issuecomment-142707891 Please update the license file in flink-dist accordingly. On Sep 23, 2015 9:26 PM, "Robert Metzger" wrote: > I agree. The build is working, for all hado

[GitHub] flink pull request: [FLINK-2651] Add Netty to dependency managemen...

2015-09-23 Thread hsaputra
Github user hsaputra commented on the pull request: https://github.com/apache/flink/pull/1174#issuecomment-142707617 But we do shade netty in the flink-shaded-hadoop module [1], don't we? By explicit pulling specific Netty version I think it would just mean it will shade that parti

[jira] [Commented] (FLINK-2651) Failing NettyServerLowAndHighWatermarkTest

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

[jira] [Commented] (FLINK-2675) Add utilities for scheduled triggers

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

[GitHub] flink pull request: [FLINK-2675] [streaming] Add utilities for sch...

2015-09-23 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1133#issuecomment-142704647 Merged and subsumed by #1147 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not

[jira] [Commented] (FLINK-2675) Add utilities for scheduled triggers

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

[GitHub] flink pull request: [FLINK-2675] [streaming] Add utilities for sch...

2015-09-23 Thread StephanEwen
Github user StephanEwen closed the pull request at: https://github.com/apache/flink/pull/1133 --- 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-2753] [streaming] [api breaking] Add fi...

2015-09-23 Thread StephanEwen
GitHub user StephanEwen opened a pull request: https://github.com/apache/flink/pull/1175 [FLINK-2753] [streaming] [api breaking] Add first parts of new window API for key grouped windows This follows the API design outlined in https://cwiki.apache.org/confluence/display/FLINK/Strea

[jira] [Commented] (FLINK-2753) Add new window API to streaming API

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

[jira] [Commented] (FLINK-2651) Failing NettyServerLowAndHighWatermarkTest

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

[GitHub] flink pull request: [FLINK-2651] Add Netty to dependency managemen...

2015-09-23 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/1174#issuecomment-142704120 I agree. The build is working, for all hadoop versions, so I seems to work. --- If your project is set up for it, you can reply to this email and have your reply appear

[jira] [Resolved] (FLINK-2675) Add utilities for scheduled triggers

2015-09-23 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2675. - Resolution: Done Done in 7ad210316fe22441761351e9943cdc31570d5407 and 717d54c826577fa0e1bb6c9a0e7

[jira] [Closed] (FLINK-2675) Add utilities for scheduled triggers

2015-09-23 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2675. --- > Add utilities for scheduled triggers > > > Key: FLI

[GitHub] flink pull request: [FLINK-2651] Add Netty to dependency managemen...

2015-09-23 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1174#issuecomment-142701270 I think the comments is wrong (I stumbled across it a while back as well). It came from the time when we were discussing to shade netty as well (which we don't do)..

[jira] [Commented] (FLINK-2651) Failing NettyServerLowAndHighWatermarkTest

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

[jira] [Commented] (FLINK-2651) Failing NettyServerLowAndHighWatermarkTest

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

[GitHub] flink pull request: [FLINK-2675] [streaming] Integrate Timer Servi...

2015-09-23 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1165 --- 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-2675) Add utilities for scheduled triggers

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

[GitHub] flink pull request: [FLINK-2651] Add Netty to dependency managemen...

2015-09-23 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/1174#issuecomment-142700908 Let me check the implications tomorrow: I've put a comment there which explicitly says that putting netty there is dangerous ;) ```xml

[jira] [Comment Edited] (FLINK-2732) Add access to the TaskManagers' log file and out file in the web dashboard.

2015-09-23 Thread Piotr Godek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14905046#comment-14905046 ] Piotr Godek edited comment on FLINK-2732 at 9/23/15 7:05 PM: -

[jira] [Commented] (FLINK-2732) Add access to the TaskManagers' log file and out file in the web dashboard.

2015-09-23 Thread Piotr Godek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14905046#comment-14905046 ] Piotr Godek commented on FLINK-2732: great. Here's what I propose in terms of request

[jira] [Closed] (FLINK-2683) Add utilities for heap-backed keyed state in time panes

2015-09-23 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2683. --- > Add utilities for heap-backed keyed state in time panes > --

[jira] [Resolved] (FLINK-2682) Add a dedicated processing time aligned keyed window operator

2015-09-23 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2682. - Resolution: Implemented Implemented in b8f58fab56c727b8d44d2a90bbb389ab7544989e > Add a dedicated

[jira] [Closed] (FLINK-2682) Add a dedicated processing time aligned keyed window operator

2015-09-23 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2682. --- > Add a dedicated processing time aligned keyed window operator >

[jira] [Resolved] (FLINK-2683) Add utilities for heap-backed keyed state in time panes

2015-09-23 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2683. - Resolution: Implemented Implemented in b8f58fab56c727b8d44d2a90bbb389ab7544989e > Add utilities f

[jira] [Created] (FLINK-2753) Add new window API to streaming API

2015-09-23 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-2753: --- Summary: Add new window API to streaming API Key: FLINK-2753 URL: https://issues.apache.org/jira/browse/FLINK-2753 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-2752) Documentation is not easily differentiable from the Flink homepage

2015-09-23 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14904985#comment-14904985 ] Maximilian Michels commented on FLINK-2752: --- Sounds great. Thanks :) > Document

[jira] [Commented] (FLINK-2732) Add access to the TaskManagers' log file and out file in the web dashboard.

2015-09-23 Thread Martin Liesenberg (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14904961#comment-14904961 ] Martin Liesenberg commented on FLINK-2732: -- Works for me. > Add access to the T

[jira] [Commented] (FLINK-2017) Add predefined required parameters to ParameterTool

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

[GitHub] flink pull request: [FLINK-2017] Add predefined required parameter...

2015-09-23 Thread mliesenberg
Github user mliesenberg commented on the pull request: https://github.com/apache/flink/pull/1097#issuecomment-142684451 The test failure seems unrelated to my changes. It's connected to the YARNSessionFIFOITCase test. FLINK-2700 has been opened a couple of days ago with the sa

[jira] [Commented] (FLINK-2750) FileStateHandleTest fails when building for Hadoop 2.6.0

2015-09-23 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14904947#comment-14904947 ] Stephan Ewen commented on FLINK-2750: - The test is also in package {{org.apache.flink.

[GitHub] flink pull request: [FLINK-2675] [streaming] Integrate Timer Servi...

2015-09-23 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1165#issuecomment-142681527 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 fe

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

2015-09-23 Thread uce
Github user uce commented on the pull request: https://github.com/apache/flink/pull/1153#issuecomment-142681544 @tillrohrmann I've rebased this on the current master and fixed two issues (the two new commits). Session management has been added recently to the master. I don't t

[jira] [Commented] (FLINK-2675) Add utilities for scheduled triggers

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

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

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

[jira] [Commented] (FLINK-2675) Add utilities for scheduled triggers

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

[GitHub] flink pull request: [FLINK-2675] [streaming] Integrate Timer Servi...

2015-09-23 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1165#issuecomment-142681373 I think this is good. In the long run, I would like to change that all functionality is currently pushed into the StreamRuntimeContext (it gets overloaded an

[jira] [Commented] (FLINK-2651) Failing NettyServerLowAndHighWatermarkTest

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

[GitHub] flink pull request: [FLINK-2651] Add Netty to dependency managemen...

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

[GitHub] flink pull request: [FLINK-2651] Add Netty to dependency managemen...

2015-09-23 Thread uce
Github user uce commented on the pull request: https://github.com/apache/flink/pull/1174#issuecomment-142676424 OK, I will merge this then. Thanks for the reviews. I will remove the variable. --- If your project is set up for it, you can reply to this email and have your reply appear

[jira] [Commented] (FLINK-2651) Failing NettyServerLowAndHighWatermarkTest

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

[jira] [Commented] (FLINK-2549) Add topK operator for DataSet

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

[GitHub] flink pull request: [FLINK-2549] add topK operator to DataSet.

2015-09-23 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1161#issuecomment-142672766 This looks super impressive and very well tested. The way that the operator is integrated into the system needs some improvement, though. The problem is main

[jira] [Commented] (FLINK-2549) Add topK operator for DataSet

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

[GitHub] flink pull request: [FLINK-2549] add topK operator to DataSet.

2015-09-23 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/1161#discussion_r40230604 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/operators/sort/FixedLengthRecordSorter.java --- @@ -447,11 +447,13 @@ public void writeToO

[jira] [Commented] (FLINK-2651) Failing NettyServerLowAndHighWatermarkTest

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

[jira] [Commented] (FLINK-2683) Add utilities for heap-backed keyed state in time panes

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

[GitHub] flink pull request: [FLINK-2683] [runtime] Add dedicated operator ...

2015-09-23 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1147#issuecomment-142667187 Manually merged in b8f58fab56c727b8d44d2a90bbb389ab7544989e --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as

[jira] [Commented] (FLINK-2683) Add utilities for heap-backed keyed state in time panes

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

[GitHub] flink pull request: [FLINK-2683] [runtime] Add dedicated operator ...

2015-09-23 Thread StephanEwen
Github user StephanEwen closed the pull request at: https://github.com/apache/flink/pull/1147 --- 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-2651] Add Netty to dependency managemen...

2015-09-23 Thread hsaputra
Github user hsaputra commented on the pull request: https://github.com/apache/flink/pull/1174#issuecomment-142667072 +1 --- 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 an

[jira] [Commented] (FLINK-2651) Failing NettyServerLowAndHighWatermarkTest

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

[GitHub] flink pull request: [FLINK-2651] Add Netty to dependency managemen...

2015-09-23 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1174#issuecomment-142664975 Good fix. I think it is a bit overkill to define a Maven variable for a dependency used only in one place, so why not directly state the version in the depen

[jira] [Commented] (FLINK-2732) Add access to the TaskManagers' log file and out file in the web dashboard.

2015-09-23 Thread Piotr Godek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14904812#comment-14904812 ] Piotr Godek commented on FLINK-2732: [~rmetzger] well apart from the simple handler in

[jira] [Commented] (FLINK-2752) Documentation is not easily differentiable from the Flink homepage

2015-09-23 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14904808#comment-14904808 ] Ufuk Celebi commented on FLINK-2752: I was playing around last week with changes to th

[jira] [Commented] (FLINK-2743) Add new RNG based on XORShift algorithm

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

[GitHub] flink pull request: [FLINK-2743] Add XORShfitRandom and use it in ...

2015-09-23 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1170#issuecomment-142657503 Looks good. You also proposed to add a dedicated project for the microbenchmarks. Should that be created first, so the XORShift benchmark can go in there as

[GitHub] flink pull request: [FLINK-2616] [test-stability] Fixes ZooKeeperL...

2015-09-23 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1173#issuecomment-142656921 Very nice, +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 does not

[jira] [Commented] (FLINK-2651) Failing NettyServerLowAndHighWatermarkTest

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

[GitHub] flink pull request: [FLINK-2651] Add Netty to dependency managemen...

2015-09-23 Thread uce
GitHub user uce opened a pull request: https://github.com/apache/flink/pull/1174 [FLINK-2651] Add Netty to dependency management Hadoop 2.7.0 pulls in an older Netty version, which clashes with our version. This makes sure to only pull in our version. To test this, you have

[jira] [Commented] (FLINK-2616) Failing Test: ZooKeeperLeaderElectionTest

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

[jira] [Resolved] (FLINK-2742) Broken link in setup quickstart

2015-09-23 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-2742. --- Resolution: Fixed Fixed via {{ca6e224}} on the {{release-0.9}} branch. Documentation i

[jira] [Created] (FLINK-2752) Documentation is not easily differentiable from the Flink homepage

2015-09-23 Thread Maximilian Michels (JIRA)
Maximilian Michels created FLINK-2752: - Summary: Documentation is not easily differentiable from the Flink homepage Key: FLINK-2752 URL: https://issues.apache.org/jira/browse/FLINK-2752 Project: F

[jira] [Created] (FLINK-2751) Quickstart is in documentation but only linked through the Flink homepage

2015-09-23 Thread Maximilian Michels (JIRA)
Maximilian Michels created FLINK-2751: - Summary: Quickstart is in documentation but only linked through the Flink homepage Key: FLINK-2751 URL: https://issues.apache.org/jira/browse/FLINK-2751 Pro

[jira] [Updated] (FLINK-2742) Broken link in setup quickstart

2015-09-23 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-2742: -- Component/s: Documentation > Broken link in setup quickstart > -

[GitHub] flink pull request: [FLINK-2723] CopyableValue method to copy into...

2015-09-23 Thread greghogan
Github user greghogan commented on the pull request: https://github.com/apache/flink/pull/1169#issuecomment-142649055 @uce Updated with comments and cleaner test code per your recommendation. --- If your project is set up for it, you can reply to this email and have your reply appear

[jira] [Updated] (FLINK-2742) Broken link in setup quickstart

2015-09-23 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-2742: -- Affects Version/s: 0.9 > Broken link in setup quickstart > -

[jira] [Updated] (FLINK-2742) Broken link in setup quickstart

2015-09-23 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-2742: -- Fix Version/s: 0.9 > Broken link in setup quickstart > --- >

[jira] [Commented] (FLINK-2723) CopyableValue method to copy into new instance

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

[jira] [Commented] (FLINK-2742) Broken link in setup quickstart

2015-09-23 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2742?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14904693#comment-14904693 ] Maximilian Michels commented on FLINK-2742: --- Thanks for pointing out the broken

[jira] [Assigned] (FLINK-2742) Broken link in setup quickstart

2015-09-23 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned FLINK-2742: - Assignee: Maximilian Michels > Broken link in setup quickstart >

[jira] [Updated] (FLINK-1526) Add Minimum Spanning Tree library method and example

2015-09-23 Thread Andra Lungu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andra Lungu updated FLINK-1526: --- Assignee: (was: Andra Lungu) > Add Minimum Spanning Tree library method and example >

  1   2   3   >