[jira] [Assigned] (FLINK-3841) RocksDB statebackend creates empty dbs for stateless operators

2016-09-27 Thread MaGuowei (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3841?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] MaGuowei reassigned FLINK-3841: --- Assignee: MaGuowei > RocksDB statebackend creates empty dbs for stateless operators > ---

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

2016-09-27 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2332 Thanks for these discussions @delding and @ramkrish86. I think this is getting a bit hard to follow. What do you think about writing a design doc that describes the supported HBase features and consi

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

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

[GitHub] flink pull request #2540: [FLINK-4606] [cluster management] Integrate the ne...

2016-09-27 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2540#discussion_r80642652 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java --- @@ -66,15 +67,16 @@ * {@link #requestSlot(SlotR

[jira] [Commented] (FLINK-4630) add netty tcp/restful pushed source support

2016-09-27 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15525483#comment-15525483 ] Till Rohrmann commented on FLINK-4630: -- Hi Shijinkui, what do you wanna use this sour

[jira] [Commented] (FLINK-4606) Integrate the new ResourceManager with the existing FlinkResourceManager

2016-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15525486#comment-15525486 ] ASF GitHub Bot commented on FLINK-4606: --- Github user mxm commented on a diff in the

[GitHub] flink pull request #2549: [FLINK-4671] [table] Table API can not be built

2016-09-27 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2549 --- 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] [Assigned] (FLINK-4686) Add possibility to get column names

2016-09-27 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-4686: -- Assignee: Jark Wu > Add possibility to get column names > --- > >

[jira] [Resolved] (FLINK-4671) Table API can not be built

2016-09-27 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4671?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-4671. - Resolution: Fixed Fix Version/s: 1.2.0 Fixed in e5d62da2c98ad9c6a5ca9c0782a7fea8a01d639a.

[jira] [Commented] (FLINK-4671) Table API can not be built

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

[jira] [Created] (FLINK-4691) Add group-windows for streaming tables

2016-09-27 Thread Timo Walther (JIRA)
Timo Walther created FLINK-4691: --- Summary: Add group-windows for streaming tables Key: FLINK-4691 URL: https://issues.apache.org/jira/browse/FLINK-4691 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-4692) Add tumbling and sliding group-windows for batch tables

2016-09-27 Thread Timo Walther (JIRA)
Timo Walther created FLINK-4692: --- Summary: Add tumbling and sliding group-windows for batch tables Key: FLINK-4692 URL: https://issues.apache.org/jira/browse/FLINK-4692 Project: Flink Issue Typ

[jira] [Created] (FLINK-4693) Add session group-windows for batch tables

2016-09-27 Thread Timo Walther (JIRA)
Timo Walther created FLINK-4693: --- Summary: Add session group-windows for batch tables Key: FLINK-4693 URL: https://issues.apache.org/jira/browse/FLINK-4693 Project: Flink Issue Type: Su

[jira] [Created] (FLINK-4694) Add wait for termination function to RpcEndpoints

2016-09-27 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-4694: Summary: Add wait for termination function to RpcEndpoints Key: FLINK-4694 URL: https://issues.apache.org/jira/browse/FLINK-4694 Project: Flink Issue Type: S

[GitHub] flink issue #2461: [FLINK-4505][Cluster Management] Implement TaskManagerFac...

2016-09-27 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2461 Thanks for your contribution @wangzhijiang999. I'll merge it. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does

[GitHub] flink pull request #2553: [FLINK-4686] [table] Add possibility to get column...

2016-09-27 Thread wuchong
GitHub user wuchong opened a pull request: https://github.com/apache/flink/pull/2553 [FLINK-4686] [table] Add possibility to get column names Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consideration. If y

[jira] [Commented] (FLINK-4686) Add possibility to get column names

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

[jira] [Commented] (FLINK-3674) Add an interface for Time aware User Functions

2016-09-27 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15525561#comment-15525561 ] Aljoscha Krettek commented on FLINK-3674: - I want to implement this using two new

[jira] [Commented] (FLINK-2765) Upgrade hbase version for hadoop-2 to 1.2 release

2016-09-27 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15525685#comment-15525685 ] Stephan Ewen commented on FLINK-2765: - [~nielsbasjes] What are your thoughts on this?

[jira] [Updated] (FLINK-3398) Flink Kafka consumer should support auto-commit opt-outs

2016-09-27 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-3398: Priority: Blocker (was: Major) > Flink Kafka consumer should support auto-commit opt-outs >

[jira] [Commented] (FLINK-2765) Upgrade hbase version for hadoop-2 to 1.2 release

2016-09-27 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15525712#comment-15525712 ] Fabian Hueske commented on FLINK-2765: -- At the moment, we have two open PRs that use

[jira] [Commented] (FLINK-4563) [metrics] scope caching not adjusted for multiple reporters

2016-09-27 Thread Anton Mushin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15525713#comment-15525713 ] Anton Mushin commented on FLINK-4563: - Hello. Do I correct undestand this issue, what

[jira] [Commented] (FLINK-4684) Remove obsolete classloader from CheckpointCoordinator

2016-09-27 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15525715#comment-15525715 ] Aljoscha Krettek commented on FLINK-4684: - I think this one is tricky because we m

[GitHub] flink pull request #2540: [FLINK-4606] [cluster management] Integrate the ne...

2016-09-27 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2540#discussion_r80663028 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java --- @@ -324,6 +337,158 @@ public void handleError(final Excep

[jira] [Commented] (FLINK-4606) Integrate the new ResourceManager with the existing FlinkResourceManager

2016-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15525719#comment-15525719 ] ASF GitHub Bot commented on FLINK-4606: --- Github user mxm commented on a diff in the

[jira] [Commented] (FLINK-4684) Remove obsolete classloader from CheckpointCoordinator

2016-09-27 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15525871#comment-15525871 ] Stephan Ewen commented on FLINK-4684: - I think that savepoints are loaded and added to

[GitHub] flink issue #2551: [FLINK-4687] [rpc] Add getAddress to RpcService

2016-09-27 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2551 Travis passed locally. Will merge 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 have this feat

[jira] [Commented] (FLINK-4687) Add getAddress method to RpcService

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

[jira] [Closed] (FLINK-4687) Add getAddress method to RpcService

2016-09-27 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-4687. Resolution: Fixed Added via 93775cef67b1903a8f462da924f97df5ae6819c4 > Add getAddress method to Rpc

[GitHub] flink pull request #2554: [FLINK-4361] Introduce Flink's own future abstract...

2016-09-27 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/2554 [FLINK-4361] Introduce Flink's own future abstraction Flink's future abstraction whose API is similar to Java 8's CompletableFuture. That's in order to ease a future transition to this clas

[jira] [Commented] (FLINK-4361) Introduce Flink's own future abstraction

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

[jira] [Commented] (FLINK-4554) Add support for array types

2016-09-27 Thread Kirill Morozov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15525968#comment-15525968 ] Kirill Morozov commented on FLINK-4554: --- [~twalthr], I'am sorry. Please, give me a c

[jira] [Commented] (FLINK-3674) Add an interface for Time aware User Functions

2016-09-27 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15525983#comment-15525983 ] Stephan Ewen commented on FLINK-3674: - I assume {{TimeDomain}} is "processing time" or

[jira] [Created] (FLINK-4695) Separate configuration parsing from MetricRegistry

2016-09-27 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-4695: Summary: Separate configuration parsing from MetricRegistry Key: FLINK-4695 URL: https://issues.apache.org/jira/browse/FLINK-4695 Project: Flink Issue Type:

[GitHub] flink pull request #2555: [FLINK-4695] Introduce MetricRegistryConfiguration...

2016-09-27 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/2555 [FLINK-4695] Introduce MetricRegistryConfiguration to encapsulate MetricRegistry parameters In order to decouple the MetricRegistry object instantiation from the global configuration the M

[GitHub] flink pull request #2551: [FLINK-4687] [rpc] Add getAddress to RpcService

2016-09-27 Thread tillrohrmann
Github user tillrohrmann closed the pull request at: https://github.com/apache/flink/pull/2551 --- 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 i

[jira] [Commented] (FLINK-4687) Add getAddress method to RpcService

2016-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15526007#comment-15526007 ] ASF GitHub Bot commented on FLINK-4687: --- Github user tillrohrmann closed the pull re

[jira] [Commented] (FLINK-4695) Separate configuration parsing from MetricRegistry

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

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

2016-09-27 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15526016#comment-15526016 ] Stephan Ewen commented on FLINK-4387: - Is this fixed now? > Instability in KvStateCli

[jira] [Commented] (FLINK-2600) Failing ElasticsearchSinkITCase.testNodeClient test case

2016-09-27 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15526018#comment-15526018 ] Stephan Ewen commented on FLINK-2600: - This seems to not have occurred in a while. Any

[GitHub] flink issue #2552: [FLINK-4690] Replace SlotAllocationFuture with flink's ow...

2016-09-27 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2552 Changes look good to me. Thanks for your contribution @KurtYoung. Will merge it first with the master branch and then I will rebase the flip-6 branch. --- If your project is set up for it, you

[jira] [Created] (FLINK-4696) Limit the number of Akka Dispatcher Threads in LocalMiniCluster

2016-09-27 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-4696: --- Summary: Limit the number of Akka Dispatcher Threads in LocalMiniCluster Key: FLINK-4696 URL: https://issues.apache.org/jira/browse/FLINK-4696 Project: Flink

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

2016-09-27 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-4387. -- Resolution: Fixed Fix Version/s: 1.2.0 Fixed in f791680 (forgot to close the issue before). > In

[jira] [Updated] (FLINK-3154) Update Kryo version from 2.24.0 to 3.0.3

2016-09-27 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-3154: Description: Flink's Kryo version is outdated and could be updated to a newer version, e.g. kryo-3.

[jira] [Commented] (FLINK-4690) Replace SlotAllocationFuture with flink's own future

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

[jira] [Commented] (FLINK-4684) Remove obsolete classloader from CheckpointCoordinator

2016-09-27 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15526054#comment-15526054 ] Stephan Ewen commented on FLINK-4684: - This was actually merged yesterday already. I t

[jira] [Resolved] (FLINK-4684) Remove obsolete classloader from CheckpointCoordinator

2016-09-27 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4684. - Resolution: Fixed Fixed in 70e71c16177b40c2418e6a8ca0838bf117f6a926 > Remove obsolete classloader

[jira] [Closed] (FLINK-4684) Remove obsolete classloader from CheckpointCoordinator

2016-09-27 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4684. --- > Remove obsolete classloader from CheckpointCoordinator > ---

[GitHub] flink issue #2510: FLINK-3322 Allow drivers and iterators to reuse the memor...

2016-09-27 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2510 There are a bunch of quite pressing issues (hard requirements for some use cases) that I am working on these weeks. I'll try to come back to this after we have gotten those done... --- If your

[jira] [Commented] (FLINK-3322) MemoryManager creates too much GC pressure with iterative jobs

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

[jira] [Commented] (FLINK-3674) Add an interface for Time aware User Functions

2016-09-27 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15526083#comment-15526083 ] Aljoscha Krettek commented on FLINK-3674: - Correct, we could also have {{onProcess

[GitHub] flink issue #2555: [FLINK-4695] Introduce MetricRegistryConfiguration to enc...

2016-09-27 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/2555 I don't really see the benefit here. Instead of the MetricRegistry being coupled got the globalconfig the MetricRegistryConfiguration now is. This looks a lot like moving code around for the sake of m

[jira] [Commented] (FLINK-4695) Separate configuration parsing from MetricRegistry

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

[GitHub] flink pull request #2555: [FLINK-4695] Introduce MetricRegistryConfiguration...

2016-09-27 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2555#discussion_r80688384 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/metrics/MetricRegistryConfiguration.java --- @@ -0,0 +1,168 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-4695) Separate configuration parsing from MetricRegistry

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

[GitHub] flink issue #2554: [FLINK-4361] Introduce Flink's own future abstraction

2016-09-27 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2554 This is very nice, +1 to merge this. Will come in very handy! I like that this is pretty much aligned with the Java 8 futures. --- If your project is set up for it, you can reply to

[jira] [Commented] (FLINK-4361) Introduce Flink's own future abstraction

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

[GitHub] flink pull request #2555: [FLINK-4695] Introduce MetricRegistryConfiguration...

2016-09-27 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2555#discussion_r80695131 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/metrics/MetricRegistryConfiguration.java --- @@ -0,0 +1,168 @@ +/* + * Licensed t

[jira] [Commented] (FLINK-4695) Separate configuration parsing from MetricRegistry

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

[GitHub] flink pull request #2102: [FLINK-4068] [tableAPI] Move constant computations...

2016-09-27 Thread wuchong
Github user wuchong closed the pull request at: https://github.com/apache/flink/pull/2102 --- 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 ena

[jira] [Commented] (FLINK-4068) Move constant computations out of code-generated `flatMap` functions.

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

[jira] [Commented] (FLINK-4695) Separate configuration parsing from MetricRegistry

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

[GitHub] flink issue #2555: [FLINK-4695] Introduce MetricRegistryConfiguration to enc...

2016-09-27 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2555 True, the benefit of this is only marginal in the current master. It is actually part of the `TaskManager` services start up logic in Flip-6. In this branch, the services will be generated by pr

[jira] [Commented] (FLINK-4218) Sporadic "java.lang.RuntimeException: Error triggering a checkpoint..." causes task restarting

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

[jira] [Commented] (FLINK-4554) Add support for array types

2016-09-27 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15526259#comment-15526259 ] Timo Walther commented on FLINK-4554: - [~kirill-morozov-epam] thanks for your interest

[jira] [Commented] (FLINK-4218) Sporadic "java.lang.RuntimeException: Error triggering a checkpoint..." causes task restarting

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

[GitHub] flink pull request #2544: [FLINK-4218] [checkpoints] Do not rely on FileSyst...

2016-09-27 Thread StephanEwen
Github user StephanEwen closed the pull request at: https://github.com/apache/flink/pull/2544 --- 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 issue #2544: [FLINK-4218] [checkpoints] Do not rely on FileSystem to d...

2016-09-27 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2544 Manually merged in 95e9004e36fffae755eab7aa3d5d0d5e8bfb7113 --- 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 no

[jira] [Commented] (FLINK-4573) Potential resource leak due to unclosed RandomAccessFile in TaskManagerLogHandler

2016-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15526276#comment-15526276 ] ASF GitHub Bot commented on FLINK-4573: --- GitHub user lw-lin opened a pull request:

[GitHub] flink pull request #2556: [FLINK-4573] Fix potential resource leak due to un...

2016-09-27 Thread lw-lin
GitHub user lw-lin opened a pull request: https://github.com/apache/flink/pull/2556 [FLINK-4573] Fix potential resource leak due to unclosed RandomAccess… …File in TaskManagerLogHandler -- Thanks for contributing to Apache Flink. Before you open your pull reques

[GitHub] flink pull request #2557: [FLINK-3734] Close stream state handles after stat...

2016-09-27 Thread lw-lin
GitHub user lw-lin opened a pull request: https://github.com/apache/flink/pull/2557 [FLINK-3734] Close stream state handles after state restorations Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consideration.

[jira] [Commented] (FLINK-3734) Unclosed DataInputView in AbstractAlignedProcessingTimeWindowOperator#restoreState()

2016-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15526278#comment-15526278 ] ASF GitHub Bot commented on FLINK-3734: --- GitHub user lw-lin opened a pull request:

[GitHub] flink pull request #2557: [FLINK-3734] Close stream state handles after stat...

2016-09-27 Thread lw-lin
Github user lw-lin commented on a diff in the pull request: https://github.com/apache/flink/pull/2557#discussion_r80704455 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java --- @@ -568,8 +568,8 @@ public void setInitialState(Cha

[jira] [Commented] (FLINK-3734) Unclosed DataInputView in AbstractAlignedProcessingTimeWindowOperator#restoreState()

2016-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15526303#comment-15526303 ] ASF GitHub Bot commented on FLINK-3734: --- Github user lw-lin commented on a diff in t

[jira] [Commented] (FLINK-4630) add netty tcp/restful pushed source support

2016-09-27 Thread shijinkui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15526424#comment-15526424 ] shijinkui commented on FLINK-4630: -- Some business system such as risk online management.

[jira] [Resolved] (FLINK-4696) Limit the number of Akka Dispatcher Threads in LocalMiniCluster

2016-09-27 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4696. - Resolution: Fixed Fixed via 6ea9284d29ec79576f073441a5de681019720ab0 > Limit the number of Akka D

[jira] [Created] (FLINK-4697) Gather more detailed checkpoint stats in CheckpointStatsTracker

2016-09-27 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-4697: --- Summary: Gather more detailed checkpoint stats in CheckpointStatsTracker Key: FLINK-4697 URL: https://issues.apache.org/jira/browse/FLINK-4697 Project: Flink

[jira] [Closed] (FLINK-4696) Limit the number of Akka Dispatcher Threads in LocalMiniCluster

2016-09-27 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4696. --- > Limit the number of Akka Dispatcher Threads in LocalMiniCluster > --

[jira] [Closed] (FLINK-4685) Gather operator checkpoint durations data sizes from the runtime

2016-09-27 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4685. --- > Gather operator checkpoint durations data sizes from the runtime > -

[jira] [Resolved] (FLINK-4685) Gather operator checkpoint durations data sizes from the runtime

2016-09-27 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4685. - Resolution: Implemented Implemented in b1642e32c2f69c60c2b212260c3479feb66a9165 > Gather operator

[jira] [Created] (FLINK-4698) Visualize additional checkpoint information

2016-09-27 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-4698: --- Summary: Visualize additional checkpoint information Key: FLINK-4698 URL: https://issues.apache.org/jira/browse/FLINK-4698 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-4677) Jars with no job executions produces NullPointerException in ClusterClient

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

[GitHub] flink issue #2548: [FLINK-4677] fail if user jar contains no executions

2016-09-27 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2548 Looks good to me, +1 to merge --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled an

[jira] [Created] (FLINK-4699) Convert Kafka TableSource/TableSink tests to unit tests

2016-09-27 Thread Timo Walther (JIRA)
Timo Walther created FLINK-4699: --- Summary: Convert Kafka TableSource/TableSink tests to unit tests Key: FLINK-4699 URL: https://issues.apache.org/jira/browse/FLINK-4699 Project: Flink Issue Typ

[jira] [Commented] (FLINK-4677) Jars with no job executions produces NullPointerException in ClusterClient

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

[GitHub] flink issue #2548: [FLINK-4677] fail if user jar contains no executions

2016-09-27 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/2548 Do we have a standard way for user programs to print usage and exit without triggering this message? This is certainly preferable to the `NullPointerException`. --- If your project is set up for

[jira] [Created] (FLINK-4700) Harden the TimeProvider test

2016-09-27 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-4700: - Summary: Harden the TimeProvider test Key: FLINK-4700 URL: https://issues.apache.org/jira/browse/FLINK-4700 Project: Flink Issue Type: Bug Compon

[jira] [Closed] (FLINK-4583) NullPointerException in CliFrontend

2016-09-27 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-4583. - Resolution: Duplicate > NullPointerException in CliFrontend > --- > >

[GitHub] flink pull request #2541: [FLINK-4669] scala api createLocalEnvironment() fu...

2016-09-27 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2541#discussion_r80730795 --- Diff: flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/StreamExecutionEnvironment.scala --- @@ -124,7 +125,7 @@ class Stream

[jira] [Commented] (FLINK-4669) scala api createLocalEnvironment() function add default Configuration parameter

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

[GitHub] flink issue #2552: [FLINK-4690] Replace SlotAllocationFuture with flink's ow...

2016-09-27 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2552 I've merged it into the master branch. You can close the 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

[jira] [Commented] (FLINK-4690) Replace SlotAllocationFuture with flink's own future

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

[GitHub] flink pull request #2554: [FLINK-4361] Introduce Flink's own future abstract...

2016-09-27 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2554 --- 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-4690) Replace SlotAllocationFuture with flink's own future

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

[jira] [Commented] (FLINK-4361) Introduce Flink's own future abstraction

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

[jira] [Commented] (FLINK-4361) Introduce Flink's own future abstraction

2016-09-27 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15526671#comment-15526671 ] Till Rohrmann commented on FLINK-4361: -- Added to the master via f8138f4b74332ecb4ef0d

[jira] [Resolved] (FLINK-4690) Replace SlotAllocationFuture with flink's own future

2016-09-27 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-4690. -- Resolution: Fixed Added via 84672c22f8088a70caf35b54d74eee458bf600dd > Replace SlotAllocationFu

[GitHub] flink pull request #2552: [FLINK-4690] Replace SlotAllocationFuture with fli...

2016-09-27 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2552 --- 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 #2550: [FLINK-4657] Implement HighAvailabilityServices ba...

2016-09-27 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2550#discussion_r80742192 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java --- @@ -467,6 +487,128 @@ public void registerAtResourceManager(f

[GitHub] flink pull request #2550: [FLINK-4657] Implement HighAvailabilityServices ba...

2016-09-27 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2550#discussion_r80740727 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java --- @@ -467,6 +487,128 @@ public void registerAtResourceManager(f

  1   2   >