[GitHub] flink pull request #2332: [FLINK-2055] Implement Streaming HBaseSink

2016-08-12 Thread ramkrish86
Github user ramkrish86 commented on a diff in the pull request: https://github.com/apache/flink/pull/2332#discussion_r74549333 --- Diff: flink-streaming-connectors/flink-connector-hbase/src/main/java/org/apache/flink/streaming/connectors/hbase/MutationActionList.java --- @@ -0,0 +

[GitHub] flink pull request #2332: [FLINK-2055] Implement Streaming HBaseSink

2016-08-12 Thread ramkrish86
Github user ramkrish86 commented on a diff in the pull request: https://github.com/apache/flink/pull/2332#discussion_r74549521 --- Diff: flink-streaming-connectors/flink-connector-hbase/src/main/java/org/apache/flink/streaming/connectors/hbase/MutationActionList.java --- @@ -0,0 +

[GitHub] flink pull request #2332: [FLINK-2055] Implement Streaming HBaseSink

2016-08-12 Thread ramkrish86
Github user ramkrish86 commented on a diff in the pull request: https://github.com/apache/flink/pull/2332#discussion_r74549919 --- Diff: flink-streaming-connectors/flink-connector-hbase/src/main/java/org/apache/flink/streaming/connectors/hbase/MutationActionList.java --- @@ -0,0 +

[GitHub] flink pull request #2332: [FLINK-2055] Implement Streaming HBaseSink

2016-08-12 Thread ramkrish86
Github user ramkrish86 commented on a diff in the pull request: https://github.com/apache/flink/pull/2332#discussion_r74550242 --- Diff: flink-streaming-connectors/flink-connector-hbase/src/main/java/org/apache/flink/streaming/connectors/hbase/MutationActionList.java --- @@ -0,0 +

[jira] [Commented] (FLINK-2055) Implement Streaming HBaseSink

2016-08-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15418457#comment-15418457 ] ASF GitHub Bot commented on FLINK-2055: --- Github user ramkrish86 commented on a diff

[jira] [Commented] (FLINK-2055) Implement Streaming HBaseSink

2016-08-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15418459#comment-15418459 ] ASF GitHub Bot commented on FLINK-2055: --- Github user ramkrish86 commented on a diff

[GitHub] flink pull request #2332: [FLINK-2055] Implement Streaming HBaseSink

2016-08-12 Thread ramkrish86
Github user ramkrish86 commented on a diff in the pull request: https://github.com/apache/flink/pull/2332#discussion_r74550400 --- Diff: flink-streaming-connectors/flink-connector-hbase/src/main/java/org/apache/flink/streaming/connectors/hbase/MutationActionList.java --- @@ -0,0 +

[GitHub] flink pull request #2332: [FLINK-2055] Implement Streaming HBaseSink

2016-08-12 Thread ramkrish86
Github user ramkrish86 commented on a diff in the pull request: https://github.com/apache/flink/pull/2332#discussion_r74550914 --- Diff: flink-streaming-connectors/flink-connector-hbase/src/main/java/org/apache/flink/streaming/connectors/hbase/MutationActionList.java --- @@ -0,0 +

[jira] [Commented] (FLINK-2055) Implement Streaming HBaseSink

2016-08-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15418463#comment-15418463 ] ASF GitHub Bot commented on FLINK-2055: --- Github user ramkrish86 commented on a diff

[jira] [Commented] (FLINK-2055) Implement Streaming HBaseSink

2016-08-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15418465#comment-15418465 ] ASF GitHub Bot commented on FLINK-2055: --- Github user ramkrish86 commented on a diff

[GitHub] flink issue #2313: [FLINK-4273] Modify JobClient to attach to running jobs

2016-08-12 Thread mxm
Github user mxm commented on the issue: https://github.com/apache/flink/pull/2313 CC @rmetzger @tillrohrmann Could you please take a look? I would like to merge this. Tests are passing: https://travis-ci.org/mxm/flink/builds/151653198 --- If your project is set up for it, you can rep

[jira] [Commented] (FLINK-4273) Refactor JobClientActor to watch already submitted jobs

2016-08-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15418485#comment-15418485 ] ASF GitHub Bot commented on FLINK-4273: --- Github user mxm commented on the issue:

[GitHub] flink pull request #2357: [FLINK-4362] [rpc] Auto generate rpc gateways via ...

2016-08-12 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2357#discussion_r74554448 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rpc/RpcEndpoint.java --- @@ -172,6 +173,13 @@ public void runAsync(Runnable runnable) {

[jira] [Commented] (FLINK-4362) Auto generate message sender classes via Java Proxies

2016-08-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15418497#comment-15418497 ] ASF GitHub Bot commented on FLINK-4362: --- Github user tillrohrmann commented on a dif

[jira] [Commented] (FLINK-4366) Enforce parallelism=1 For AllWindowedStream

2016-08-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15418500#comment-15418500 ] ASF GitHub Bot commented on FLINK-4366: --- Github user wuchong commented on the issue:

[GitHub] flink issue #2354: [FLINK-4366] Enforce parallelism=1 For AllWindowedStream

2016-08-12 Thread wuchong
Github user wuchong commented on the issue: https://github.com/apache/flink/pull/2354 Hi @aljoscha @StephanEwen , I add a `forceNonParallel` method to `SingleOutputStreamOperator`. I think subclassing SingleOutputStreamOperator is a little unnecessary. --- If your project is set up

[GitHub] flink pull request #2357: [FLINK-4362] [rpc] Auto generate rpc gateways via ...

2016-08-12 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2357#discussion_r74555048 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rpc/RpcEndpoint.java --- @@ -172,6 +173,13 @@ public void runAsync(Runnable runnable) {

[jira] [Commented] (FLINK-4382) Buffer rpc calls until RpcEndpoint is properly started

2016-08-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15418505#comment-15418505 ] ASF GitHub Bot commented on FLINK-4382: --- Github user tillrohrmann commented on the i

[jira] [Commented] (FLINK-4362) Auto generate message sender classes via Java Proxies

2016-08-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15418506#comment-15418506 ] ASF GitHub Bot commented on FLINK-4362: --- Github user tillrohrmann commented on a dif

[GitHub] flink issue #2357: [FLINK-4362] [rpc] Auto generate rpc gateways via Java pr...

2016-08-12 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2357 Yes good point with the automatic computation of the gateway type. Will add it and then merge the PR. Thanks for your review @StephanEwen :-) --- If your project is set up for it, you can reply

[jira] [Commented] (FLINK-4362) Auto generate message sender classes via Java Proxies

2016-08-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15418507#comment-15418507 ] ASF GitHub Bot commented on FLINK-4362: --- Github user tillrohrmann commented on the i

[jira] [Updated] (FLINK-4387) Instability in KvStateClientTest.testClientServerIntegration()

2016-08-12 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-4387: -- Affects Version/s: 1.1.0 > Instability in KvStateClientTest.testClientServerIntegration() >

[jira] [Created] (FLINK-4387) Instability in KvStateClientTest.testClientServerIntegration()

2016-08-12 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-4387: - Summary: Instability in KvStateClientTest.testClientServerIntegration() Key: FLINK-4387 URL: https://issues.apache.org/jira/browse/FLINK-4387 Project: Flink

[jira] [Commented] (FLINK-4253) Rename "recovery.mode" config key to "high-availability"

2016-08-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15418522#comment-15418522 ] ASF GitHub Bot commented on FLINK-4253: --- Github user uce commented on the issue:

[GitHub] flink issue #2342: FLINK-4253 - Rename "recovery.mode" config key to "high-a...

2016-08-12 Thread uce
Github user uce commented on the issue: https://github.com/apache/flink/pull/2342 Regarding the priority: Yes, I think so. --- 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

[GitHub] flink pull request #2361: [FLINK-3318][cep] Add support for quantifiers to C...

2016-08-12 Thread mushketyk
GitHub user mushketyk reopened a pull request: https://github.com/apache/flink/pull/2361 [FLINK-3318][cep] Add support for quantifiers to CEP's pattern API Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into considera

[jira] [Commented] (FLINK-3318) Add support for quantifiers to CEP's pattern API

2016-08-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15417953#comment-15417953 ] ASF GitHub Bot commented on FLINK-3318: --- Github user mushketyk commented on the issu

[GitHub] flink issue #2361: [FLINK-3318][cep] Add support for quantifiers to CEP's pa...

2016-08-12 Thread mushketyk
Github user mushketyk commented on the issue: https://github.com/apache/flink/pull/2361 I've added support for zeroToMany, oneToMany, optional and count quantifiers in CEP patterns. I had to change logic of NFACompiler quite a bit to accommodate new --- If your project is set up

[jira] [Commented] (FLINK-3870) Add IntelliJ code style file

2016-08-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15418262#comment-15418262 ] ASF GitHub Bot commented on FLINK-3870: --- Github user wuchong commented on the issue:

[GitHub] flink pull request #1963: [FLINK-3870][docs] Added IntelliJ code style

2016-08-12 Thread wuchong
Github user wuchong commented on a diff in the pull request: https://github.com/apache/flink/pull/1963#discussion_r74537594 --- Diff: tools/FlinkCodeStyle.xml --- @@ -0,0 +1,75 @@ + + + + + + + + + + + + +

[jira] [Assigned] (FLINK-4347) Implement SlotManager for new ResourceManager

2016-08-12 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-4347: - Assignee: Kurt Young > Implement SlotManager for new ResourceManager > --

[jira] [Commented] (FLINK-2055) Implement Streaming HBaseSink

2016-08-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15418453#comment-15418453 ] ASF GitHub Bot commented on FLINK-2055: --- Github user ramkrish86 commented on a diff

[jira] [Commented] (FLINK-2055) Implement Streaming HBaseSink

2016-08-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15418452#comment-15418452 ] ASF GitHub Bot commented on FLINK-2055: --- Github user ramkrish86 commented on a diff

[jira] [Updated] (FLINK-4373) Introduce SlotID, AllocationID, ResourceProfile

2016-08-12 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-4373: -- Description: For the new version of cluster management, we need some more basic data structures: * Slo

[GitHub] flink issue #2342: FLINK-4253 - Rename "recovery.mode" config key to "high-a...

2016-08-12 Thread ramkrish86
Github user ramkrish86 commented on the issue: https://github.com/apache/flink/pull/2342 > Can you add such a test? Sure I can. The existing test cases helped to ensure that if there are no old configs we are able to fetch from the new config. I can add a test case to ensure

[GitHub] flink issue #2244: [FLINK-3874] Add a Kafka TableSink with JSON serializatio...

2016-08-12 Thread mushketyk
Github user mushketyk commented on the issue: https://github.com/apache/flink/pull/2244 @twalthr Thank you for your detailed review. I am very new to Apache Flink at the moment so I made some absurd changes. I'll try to avoid this in the future. I'll update the PR according t

[GitHub] flink pull request #2332: [FLINK-2055] Implement Streaming HBaseSink

2016-08-12 Thread ramkrish86
Github user ramkrish86 commented on a diff in the pull request: https://github.com/apache/flink/pull/2332#discussion_r74551046 --- Diff: flink-streaming-connectors/flink-connector-hbase/src/main/java/org/apache/flink/streaming/connectors/hbase/HBaseClient.java --- @@ -0,0 +1,69 @@

[GitHub] flink pull request #2353: [FLINK-4355] [cluster management] Implement TaskMa...

2016-08-12 Thread wenlong88
Github user wenlong88 commented on a diff in the pull request: https://github.com/apache/flink/pull/2353#discussion_r74533793 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rpc/taskexecutor/TaskExecutorToResourceManagerConnection.java --- @@ -0,0 +1,80 @@ +/*

[jira] [Commented] (FLINK-4384) Add a "scheduleRunAsync()" feature to the RpcEndpoint

2016-08-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15418562#comment-15418562 ] ASF GitHub Bot commented on FLINK-4384: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request #2360: [FLINK-4384] [rpc] Add "scheduleRunAsync()" to the...

2016-08-12 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2360#discussion_r74561951 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rpc/MainThreadExecutor.java --- @@ -52,4 +52,13 @@ * @return Future of the calla

[GitHub] flink issue #2342: FLINK-4253 - Rename "recovery.mode" config key to "high-a...

2016-08-12 Thread ramkrish86
Github user ramkrish86 commented on the issue: https://github.com/apache/flink/pull/2342 Just a query, If there are both old and new configs available - we should give priority to the new one right? Even if the value for the old and new configs are different? --- If your proje

[GitHub] flink pull request #2360: [FLINK-4384] [rpc] Add "scheduleRunAsync()" to the...

2016-08-12 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2360#discussion_r74562511 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rpc/MainThreadExecutor.java --- @@ -52,4 +52,13 @@ * @return Future of the callab

[jira] [Commented] (FLINK-4384) Add a "scheduleRunAsync()" feature to the RpcEndpoint

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

[GitHub] flink pull request #2360: [FLINK-4384] [rpc] Add "scheduleRunAsync()" to the...

2016-08-12 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2360#discussion_r74562696 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/rpc/akka/AsyncCallsTest.java --- @@ -0,0 +1,178 @@ +/* + * Licensed to the Apache

[jira] [Commented] (FLINK-4384) Add a "scheduleRunAsync()" feature to the RpcEndpoint

2016-08-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15418566#comment-15418566 ] ASF GitHub Bot commented on FLINK-4384: --- Github user tillrohrmann commented on a dif

[GitHub] flink issue #2360: [FLINK-4384] [rpc] Add "scheduleRunAsync()" to the RpcEnd...

2016-08-12 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2360 Great addition @StephanEwen. +1 for merging. Things are getting in shape :-) --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as we

[jira] [Commented] (FLINK-4384) Add a "scheduleRunAsync()" feature to the RpcEndpoint

2016-08-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15418567#comment-15418567 ] ASF GitHub Bot commented on FLINK-4384: --- Github user tillrohrmann commented on the i

[GitHub] flink issue #2358: [FLINK-4382] Buffer rpc calls until the RpcEndpoint has b...

2016-08-12 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2358 Dropping is also a solution. I think this will also happen implicitly if the mailbox grows too big. Stashing has the advantage that we try (on a best effort basis) to answer early reque

[jira] [Commented] (FLINK-2055) Implement Streaming HBaseSink

2016-08-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15418455#comment-15418455 ] ASF GitHub Bot commented on FLINK-2055: --- Github user ramkrish86 commented on a diff

[GitHub] flink pull request #2360: [FLINK-4384] [rpc] Add "scheduleRunAsync()" to the...

2016-08-12 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2360#discussion_r74563211 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rpc/MainThreadExecutor.java --- @@ -52,4 +52,13 @@ * @return Future of the calla

[GitHub] flink pull request #2332: [FLINK-2055] Implement Streaming HBaseSink

2016-08-12 Thread ramkrish86
Github user ramkrish86 commented on a diff in the pull request: https://github.com/apache/flink/pull/2332#discussion_r74549599 --- Diff: flink-streaming-connectors/flink-connector-hbase/src/main/java/org/apache/flink/streaming/connectors/hbase/MutationActionList.java --- @@ -0,0 +

[jira] [Commented] (FLINK-4384) Add a "scheduleRunAsync()" feature to the RpcEndpoint

2016-08-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15418570#comment-15418570 ] ASF GitHub Bot commented on FLINK-4384: --- Github user tillrohrmann commented on a dif

[jira] [Commented] (FLINK-4366) Enforce parallelism=1 For AllWindowedStream

2016-08-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15418576#comment-15418576 ] ASF GitHub Bot commented on FLINK-4366: --- Github user aljoscha commented on the issue

[GitHub] flink issue #2354: [FLINK-4366] Enforce parallelism=1 For AllWindowedStream

2016-08-12 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/2354 IMHO this looks good to merge now. 👍 @StephanEwen what do you think? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If y

[jira] [Assigned] (FLINK-4385) Union on Timestamp fields does not work

2016-08-12 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-4385: -- Assignee: Jark Wu > Union on Timestamp fields does not work > --- >

[jira] [Commented] (FLINK-4336) Expose ability to take a savepoint from job manager

2016-08-12 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15418581#comment-15418581 ] Robert Metzger commented on FLINK-4336: --- [~zhenzhongxu]: I gave you "Contributor" pe

[jira] [Created] (FLINK-4388) Race condition during initialization of MemorySegmentFactory

2016-08-12 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-4388: --- Summary: Race condition during initialization of MemorySegmentFactory Key: FLINK-4388 URL: https://issues.apache.org/jira/browse/FLINK-4388 Project: Flink Iss

[jira] [Commented] (FLINK-4282) Add Offset Parameter to WindowAssigners

2016-08-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15418609#comment-15418609 ] Aljoscha Krettek commented on FLINK-4282: - [~RenkaiGe] yes, this is more or less w

[jira] [Commented] (FLINK-4366) Enforce parallelism=1 For AllWindowedStream

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

[GitHub] flink issue #2354: [FLINK-4366] Enforce parallelism=1 For AllWindowedStream

2016-08-12 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2354 Yes, this is good, thanks! +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 have

[GitHub] flink issue #2360: [FLINK-4384] [rpc] Add "scheduleRunAsync()" to the RpcEnd...

2016-08-12 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2360 Will address the comments and 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 have this featur

[GitHub] flink pull request #2360: [FLINK-4384] [rpc] Add "scheduleRunAsync()" to the...

2016-08-12 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2360#discussion_r74568505 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/rpc/akka/AsyncCallsTest.java --- @@ -0,0 +1,178 @@ +/* + * Licensed to the Apache

[jira] [Commented] (FLINK-4384) Add a "scheduleRunAsync()" feature to the RpcEndpoint

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

[jira] [Commented] (FLINK-4384) Add a "scheduleRunAsync()" feature to the RpcEndpoint

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

[jira] [Commented] (FLINK-4377) akka.remote.OversizedPayloadException: Discarding oversized payload

2016-08-12 Thread Sajeev Ramakrishnan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15418626#comment-15418626 ] Sajeev Ramakrishnan commented on FLINK-4377: Thanks Stephan. It worked. > akk

[GitHub] flink pull request #2362: [FLINK-4385] [table] Union on Timestamp fields doe...

2016-08-12 Thread wuchong
GitHub user wuchong opened a pull request: https://github.com/apache/flink/pull/2362 [FLINK-4385] [table] Union on Timestamp fields does not work Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consideration.

[jira] [Commented] (FLINK-4385) Union on Timestamp fields does not work

2016-08-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15418670#comment-15418670 ] ASF GitHub Bot commented on FLINK-4385: --- GitHub user wuchong opened a pull request:

[jira] [Updated] (FLINK-4221) Show metrics in WebFrontend

2016-08-12 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-4221: Assignee: (was: Chesnay Schepler) > Show metrics in WebFrontend > --

[GitHub] flink pull request #2357: [FLINK-4362] [rpc] Auto generate rpc gateways via ...

2016-08-12 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2357 --- 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-4362) Auto generate message sender classes via Java Proxies

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

[jira] [Resolved] (FLINK-4362) Auto generate message sender classes via Java Proxies

2016-08-12 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-4362. -- Resolution: Done Added via 4cde59141688dc12713cd0f41e21b27cd6fa3657 > Auto generate message sen

[jira] [Updated] (FLINK-4384) Add a "scheduleRunAsync()" feature to the RpcEndpoint

2016-08-12 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-4384: - Assignee: Stephan Ewen > Add a "scheduleRunAsync()" feature to the RpcEndpoint > -

[jira] [Updated] (FLINK-4384) Add a "scheduleRunAsync()" feature to the RpcEndpoint

2016-08-12 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-4384: - Assignee: Stephan Ewen (was: Till Rohrmann) > Add a "scheduleRunAsync()" feature to the RpcEndpoi

[jira] [Commented] (FLINK-4072) EventTimeWindowCheckpointingITCase.testSlidingTimeWindow fails on Travis

2016-08-12 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15418714#comment-15418714 ] Till Rohrmann commented on FLINK-4072: -- {{testTumblingWindow}} failed this time: htt

[jira] [Created] (FLINK-4389) Expose metrics to Webfrontend

2016-08-12 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-4389: --- Summary: Expose metrics to Webfrontend Key: FLINK-4389 URL: https://issues.apache.org/jira/browse/FLINK-4389 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-4326) Flink start-up scripts should optionally start services on the foreground

2016-08-12 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15418734#comment-15418734 ] Greg Hogan commented on FLINK-4326: --- Logging is configured through log4j / logback. > F

[jira] [Commented] (FLINK-3318) Add support for quantifiers to CEP's pattern API

2016-08-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15418738#comment-15418738 ] ASF GitHub Bot commented on FLINK-3318: --- Github user mushketyk commented on the issu

[GitHub] flink issue #2361: [FLINK-3318][cep] Add support for quantifiers to CEP's pa...

2016-08-12 Thread mushketyk
Github user mushketyk commented on the issue: https://github.com/apache/flink/pull/2361 @tillrohrmann , could you please take a look at this PR? --- 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 ha

[jira] [Commented] (FLINK-4177) CassandraConnectorTest.testCassandraCommitter causing unstable builds

2016-08-12 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15418745#comment-15418745 ] Stephan Ewen commented on FLINK-4177: - [~Zentol] What is your take on this? > Cassand

[jira] [Commented] (FLINK-4177) CassandraConnectorTest.testCassandraCommitter causing unstable builds

2016-08-12 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15418743#comment-15418743 ] Stephan Ewen commented on FLINK-4177: - I am also seeing failures: https://s3.amazonaw

[jira] [Commented] (FLINK-4388) Race condition during initialization of MemorySegmentFactory

2016-08-12 Thread ramkrishna.s.vasudevan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15418752#comment-15418752 ] ramkrishna.s.vasudevan commented on FLINK-4388: --- I can take this up and come

[jira] [Assigned] (FLINK-4387) Instability in KvStateClientTest.testClientServerIntegration()

2016-08-12 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi reassigned FLINK-4387: -- Assignee: Ufuk Celebi > Instability in KvStateClientTest.testClientServerIntegration() > --

[GitHub] flink issue #2342: FLINK-4253 - Rename "recovery.mode" config key to "high-a...

2016-08-12 Thread ramkrish86
Github user ramkrish86 commented on the issue: https://github.com/apache/flink/pull/2342 Updated PR request. Handles all other configs and renames them from 'recovery.* to 'high-availability.*'. Also added test case and suitably modified code to ensure that if there are both old a

[jira] [Commented] (FLINK-4253) Rename "recovery.mode" config key to "high-availability"

2016-08-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15418758#comment-15418758 ] ASF GitHub Bot commented on FLINK-4253: --- Github user ramkrish86 commented on the iss

[jira] [Commented] (FLINK-4387) Instability in KvStateClientTest.testClientServerIntegration()

2016-08-12 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15418762#comment-15418762 ] Ufuk Celebi commented on FLINK-4387: This could be related: https://github.com/netty/n

[jira] [Commented] (FLINK-4388) Race condition during initialization of MemorySegmentFactory

2016-08-12 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15418763#comment-15418763 ] Stephan Ewen commented on FLINK-4388: - Hey, thanks for offering this, but the issue is

[GitHub] flink pull request #2363: [FLINK-4389] Expose metrics to WebFrontend

2016-08-12 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/2363 [FLINK-4389] Expose metrics to WebFrontend This PR exposes metrics to the Webfrontend, as proposed in [FLIP-7](https://cwiki.apache.org/confluence/display/FLINK/FLIP-7%3A+Expose+metrics+to+WebInterfa

[jira] [Commented] (FLINK-4389) Expose metrics to Webfrontend

2016-08-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15418767#comment-15418767 ] ASF GitHub Bot commented on FLINK-4389: --- GitHub user zentol opened a pull request:

[jira] [Commented] (FLINK-4388) Race condition during initialization of MemorySegmentFactory

2016-08-12 Thread ramkrishna.s.vasudevan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15418777#comment-15418777 ] ramkrishna.s.vasudevan commented on FLINK-4388: --- When I commented there I sa

[jira] [Commented] (FLINK-4177) CassandraConnectorTest.testCassandraCommitter causing unstable builds

2016-08-12 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15418779#comment-15418779 ] Chesnay Schepler commented on FLINK-4177: - I don't think this will fix the issue.

[jira] [Assigned] (FLINK-4293) Malformatted Apache Headers

2016-08-12 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-4293: --- Assignee: Chesnay Schepler > Malformatted Apache Headers > --

[GitHub] flink pull request #2364: [FLINK-4293] Fix malformatted license headers

2016-08-12 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/2364 [FLINK-4293] Fix malformatted license headers Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consideration. If your changes

[jira] [Commented] (FLINK-4293) Malformatted Apache Headers

2016-08-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15418811#comment-15418811 ] ASF GitHub Bot commented on FLINK-4293: --- GitHub user zentol opened a pull request:

[jira] [Closed] (FLINK-4365) [metrics] MetricConfig has no documentation

2016-08-12 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-4365. --- Resolution: Duplicate > [metrics] MetricConfig has no documentation >

[jira] [Assigned] (FLINK-4302) Add JavaDocs to MetricConfig

2016-08-12 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-4302: --- Assignee: Chesnay Schepler > Add JavaDocs to MetricConfig > -

[jira] [Commented] (FLINK-4302) Add JavaDocs to MetricConfig

2016-08-12 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15418820#comment-15418820 ] Chesnay Schepler commented on FLINK-4302: - PR can be found here: https://github.co

[jira] [Commented] (FLINK-4048) Remove Hadoop dependencies from ExecutionEnvironment

2016-08-12 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15418825#comment-15418825 ] Chesnay Schepler commented on FLINK-4048: - isn't this issue contained by FLINK-431

[jira] [Closed] (FLINK-4310) Move BinaryCompatibility Check plugin to relevant projects

2016-08-12 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-4310. --- Resolution: Fixed Fix Version/s: 1.2.0 Implemented in e629b2e8eb21b6223335a8a0c2ff1a4d6

[jira] [Updated] (FLINK-4310) Move BinaryCompatibility Check plugin to relevant projects

2016-08-12 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-4310: Assignee: Stephan Ewen > Move BinaryCompatibility Check plugin to relevant projects > --

[jira] [Updated] (FLINK-4236) Flink Dashboard stops showing list of uploaded jars if main method cannot be looked up

2016-08-12 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-4236: Assignee: Maximilian Michels > Flink Dashboard stops showing list of uploaded jars if main m

  1   2   >