[jira] [Commented] (FLINK-4557) Table API Stream Aggregations

2016-09-17 Thread shijinkui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15500099#comment-15500099 ] shijinkui commented on FLINK-4557: -- Does this plan started? What's the progress now? thanks > Table

[jira] [Comment Edited] (FLINK-4557) Table API Stream Aggregations

2016-09-17 Thread shijinkui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15500099#comment-15500099 ] shijinkui edited comment on FLINK-4557 at 9/18/16 2:52 AM: --- Does this plan

[jira] [Closed] (FLINK-4598) Support NULLIF in Table API

2016-09-17 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-4598. -- Resolution: Won't Fix > Support NULLIF in Table API > > > Key:

[jira] [Commented] (FLINK-4589) Fix Merging of Covering Window in MergingWindowSet

2016-09-17 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15498512#comment-15498512 ] Aljoscha Krettek commented on FLINK-4589: - Ah good, I saw that you also put this on the 1.1

[jira] [Resolved] (FLINK-4589) Fix Merging of Covering Window in MergingWindowSet

2016-09-17 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek resolved FLINK-4589. - Resolution: Fixed Fixed on master and release 1.1 branch. > Fix Merging of Covering

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

2016-09-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15498937#comment-15498937 ] ASF GitHub Bot commented on FLINK-3322: --- Github user ggevay commented on the issue:

[jira] [Commented] (FLINK-4629) Kafka v 0.10 Support

2016-09-17 Thread Simone Robutti (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15498948#comment-15498948 ] Simone Robutti commented on FLINK-4629: --- There's already an issue that covers the update to Kafka

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

2016-09-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15498928#comment-15498928 ] ASF GitHub Bot commented on FLINK-3322: --- Github user ggevay commented on the issue:

[GitHub] flink issue #2495: FLINK-3322 - Make sorters to reuse the memory pages alloc...

2016-09-17 Thread ggevay
Github user ggevay commented on the issue: https://github.com/apache/flink/pull/2495 The tests that are failing are in `flink-gelly-examples`, for example `SingleSourceShortestPathsITCase`. They have error msgs that indicate memory management errors, e.g. `Caused by:

[GitHub] flink issue #2495: FLINK-3322 - Make sorters to reuse the memory pages alloc...

2016-09-17 Thread ggevay
Github user ggevay commented on the issue: https://github.com/apache/flink/pull/2495 Btw. before submitting a pull request, it is good practice to run `mvn clean verify` locally (or do a Travis build), and make sure that there are no test failures (or, at least no test failures

[jira] [Commented] (FLINK-4280) New Flink-specific option to set starting position of Kafka consumer without respecting external offsets in ZK / Broker

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

[GitHub] flink pull request #2509: [FLINK-4280][kafka-connector] Explicit start posit...

2016-09-17 Thread tzulitai
GitHub user tzulitai opened a pull request: https://github.com/apache/flink/pull/2509 [FLINK-4280][kafka-connector] Explicit start position configuration for Kafka Consumer This PR adds the following new explicit setter methods to configure the starting position for the Kafka

[jira] [Updated] (FLINK-4499) Introduce findbugs maven plugin

2016-09-17 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-4499: -- Description: As suggested by Stephan in FLINK-4482, this issue is to add findbugs-maven-plugin into the build

[jira] [Updated] (FLINK-4482) numUnsuccessfulCheckpointsTriggers is accessed without holding triggerLock

2016-09-17 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-4482: -- Description: In CheckpointCoordinator#stopCheckpointScheduler() : {code} synchronized (lock) { ...