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

[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: -- Summary: Introduce SlotID, AllocationID, ResourceProfile (was: Introduce SlotID & ResourceProfile) >

[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=15418507#comment-15418507 ] ASF GitHub Bot commented on FLINK-4362: --- Github user tillrohrmann commented on the issue:

[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

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

[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

[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

[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

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

[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

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

[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

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

[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=15418581#comment-15418581 ] Robert Metzger commented on FLINK-4336: --- [~zhenzhongxu]: I gave you "Contributor" permissions in our

[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=15418576#comment-15418576 ] ASF GitHub Bot commented on FLINK-4366: --- Github user aljoscha commented on the issue:

[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

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

[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

[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=15418567#comment-15418567 ] ASF GitHub Bot commented on FLINK-4384: --- Github user tillrohrmann 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

[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-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=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 @@ + + + + + + + + + + + +

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

[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=15418485#comment-15418485 ] ASF GitHub Bot commented on FLINK-4273: --- Github user mxm commented on the issue:

[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

[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=15418505#comment-15418505 ] ASF GitHub Bot commented on FLINK-4382: --- Github user tillrohrmann commented on the issue:

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

[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

[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=15417953#comment-15417953 ] ASF GitHub Bot commented on FLINK-3318: --- Github user mushketyk commented on the issue:

[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

[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

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

[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

[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 #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) {

[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

[GitHub] flink issue #2275: FLINK-3929 Support for Kerberos Authentication with Keyta...

2016-08-12 Thread vijikarthi
Github user vijikarthi commented on the issue: https://github.com/apache/flink/pull/2275 Thanks Max. I have reorganized the secure test case and removed custom JRunner implementation for Kafka. Kept single secure test case for HDFS, Kafka and Yarn modules. Please take a look. ---

[jira] [Commented] (FLINK-3929) Support for Kerberos Authentication with Keytab Credential

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

[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

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

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

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

[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=15418522#comment-15418522 ] ASF GitHub Bot commented on FLINK-4253: --- Github user uce commented on the issue:

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

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

[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

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

[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

[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] [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=15418612#comment-15418612 ] ASF GitHub Bot commented on FLINK-4366: --- Github user StephanEwen commented on the issue:

[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=15418714#comment-15418714 ] Till Rohrmann commented on FLINK-4072: -- {{testTumblingWindow}} failed this time:

[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-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=15418738#comment-15418738 ] ASF GitHub Bot commented on FLINK-3318: --- Github user mushketyk commented on the issue:

[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

[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=15418743#comment-15418743 ] Stephan Ewen commented on FLINK-4177: - I am also seeing failures:

[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=15418779#comment-15418779 ] Chesnay Schepler commented on FLINK-4177: - I don't think this will fix the issue. While this

[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=15418609#comment-15418609 ] Aljoscha Krettek commented on FLINK-4282: - [~RenkaiGe] yes, this is more or less what I had in

[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=15418626#comment-15418626 ] Sajeev Ramakrishnan commented on FLINK-4377: Thanks Stephan. It worked. >

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

[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=15418758#comment-15418758 ] ASF GitHub Bot commented on FLINK-4253: --- Github user ramkrish86 commented on the issue:

[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

[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=15418752#comment-15418752 ] ramkrishna.s.vasudevan commented on FLINK-4388: --- I can take this up and come up with a patch

[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=15418763#comment-15418763 ] Stephan Ewen commented on FLINK-4388: - Hey, thanks for offering this, but the issue is already

[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

[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

[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

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

[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=15418762#comment-15418762 ] Ufuk Celebi commented on FLINK-4387: This could be related: https://github.com/netty/netty/issues/4357

[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=15418777#comment-15418777 ] ramkrishna.s.vasudevan commented on FLINK-4388: --- When I commented there I saw it as

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

[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=15418734#comment-15418734 ] Greg Hogan commented on FLINK-4326: --- Logging is configured through log4j / logback. > Flink start-up

[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=15418745#comment-15418745 ] Stephan Ewen commented on FLINK-4177: - [~Zentol] What is your take on this? >

[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

[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

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

2016-08-12 Thread Renkai Ge (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15419763#comment-15419763 ] Renkai Ge commented on FLINK-4282: -- Thanks,[~aljoscha].It's a brilliant idea,but the result might be

[GitHub] flink issue #2356: [FLINK-4378]Enable RollingSink to custom HDFS client conf...

2016-08-12 Thread wenlong88
Github user wenlong88 commented on the issue: https://github.com/apache/flink/pull/2356 the change is a little bigger than expected. because {{FileSystem}} will be cached once created ,to make sure the user defined configuration work, {{fs.%s.impl.disable.cache}} need to be set

[jira] [Created] (FLINK-4390) Add throws clause verification to RpcCompletenessTest

2016-08-12 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-4390: Summary: Add throws clause verification to RpcCompletenessTest Key: FLINK-4390 URL: https://issues.apache.org/jira/browse/FLINK-4390 Project: Flink Issue

[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

[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] [Commented] (FLINK-4378) Enable RollingSink to custom HDFS client configuration

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

[GitHub] flink pull request #2365: [FLINK-4383] [rpc] Eagerly serialize remote rpc in...

2016-08-12 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/2365 [FLINK-4383] [rpc] Eagerly serialize remote rpc invocation messages This PR introduces an eager serialization for remote rpc invocation messages. That way it is possible to check whether

[jira] [Commented] (FLINK-4383) Check parameters for serializability before sending a remote RpcInvocation message

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

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

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

[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] [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] [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] [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=15418820#comment-15418820 ] Chesnay Schepler commented on FLINK-4302: - PR can be found here:

  1   2   >