[jira] [Commented] (FLINK-6388) Add support for DISTINCT into Code Generated Aggregations

[ https://issues.apache.org/jira/browse/FLINK-6388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16454891#comment-16454891 ] ASF GitHub Bot commented on FLINK-6388: --- Github user asfgit closed the pull request

[jira] [Closed] (FLINK-6388) Add support for DISTINCT into Code Generated Aggregations

[ https://issues.apache.org/jira/browse/FLINK-6388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-6388. Resolution: Duplicate Fix Version/s: 1.6.0 Implemented via FLINK-8689 > Add support for DIST

[jira] [Closed] (FLINK-6249) Distinct Aggregates for OVER window

[ https://issues.apache.org/jira/browse/FLINK-6249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-6249. Resolution: Duplicate Fix Version/s: 1.6.0 Implemented via FLINK-8689 > Distinct Aggregates

[GitHub] flink issue #4607: [FLINK-6306][connectors] Sink for eventually consistent f...

Github user narayaruna commented on the issue: https://github.com/apache/flink/pull/4607 @aljoscha can we merge this PR. This is very helpful to ingest data to S3 in a more reliable way. BucketingSink writing to S3 errors out making the data ingestion less reliable. ---

[jira] [Commented] (FLINK-6306) Sink for eventually consistent file systems

[ https://issues.apache.org/jira/browse/FLINK-6306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16455591#comment-16455591 ] ASF GitHub Bot commented on FLINK-6306: --- Github user narayaruna commented on the iss

[GitHub] flink issue #5860: [FLINK-9138][filesystem-connectors] Implement time based ...

Github user narayaruna commented on the issue: https://github.com/apache/flink/pull/5860 @glaksh100 If you are using BucketingSink with S3, you might be interested in this [PR](https://github.com/apache/flink/pull/4607) as well. ---

[jira] [Commented] (FLINK-9138) Enhance BucketingSink to also flush data by time interval

[ https://issues.apache.org/jira/browse/FLINK-9138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16455598#comment-16455598 ] ASF GitHub Bot commented on FLINK-9138: --- Github user narayaruna commented on the iss

[GitHub] flink pull request #5924: [hotfix][README.md] Update building prerequisites

GitHub user W4anD0eR96 opened a pull request: https://github.com/apache/flink/pull/5924 [hotfix][README.md] Update building prerequisites You can merge this pull request into a Git repository by running: $ git pull https://github.com/W4anD0eR96/flink patch-1 Alternatively yo

[jira] [Commented] (FLINK-9178) Add rate control for kafka source

[ https://issues.apache.org/jira/browse/FLINK-9178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16455677#comment-16455677 ] buptljy commented on FLINK-9178: [~app-tarush] I think so, and there is another option is

[GitHub] flink issue #5892: [FLINK-9214] YarnClient should be stopped in YARNSessionC...

Github user tedyu commented on the issue: https://github.com/apache/flink/pull/5892 lgtm ---

[jira] [Comment Edited] (FLINK-7795) Utilize error-prone to discover common coding mistakes

[ https://issues.apache.org/jira/browse/FLINK-7795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16345955#comment-16345955 ] Ted Yu edited comment on FLINK-7795 at 4/27/18 3:29 AM: error-pron

[jira] [Commented] (FLINK-9214) YarnClient should be stopped in YARNSessionCapacitySchedulerITCase#testDetachedPerJobYarnClusterInternal

[ https://issues.apache.org/jira/browse/FLINK-9214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16455703#comment-16455703 ] ASF GitHub Bot commented on FLINK-9214: --- Github user tedyu commented on the issue:

[GitHub] flink issue #5916: [hotfix][tests] remove redundant rebalance in SuccessAfte...

Github user zhijiangW commented on the issue: https://github.com/apache/flink/pull/5916 LGTM :) ---

[jira] [Commented] (FLINK-8986) End-to-end test: REST

[ https://issues.apache.org/jira/browse/FLINK-8986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16455771#comment-16455771 ] Rong Rong commented on FLINK-8986: -- Hi [~Zentol], I addressed most of your comments and c

[GitHub] flink issue #5834: [FLINK-9153] TaskManagerRunner should support rpc port ra...

Github user yanghua commented on the issue: https://github.com/apache/flink/pull/5834 cc @zentol refactored based on your suggestion, please review it again ---

[jira] [Commented] (FLINK-9153) TaskManagerRunner should support rpc port range

[ https://issues.apache.org/jira/browse/FLINK-9153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16456016#comment-16456016 ] ASF GitHub Bot commented on FLINK-9153: --- Github user yanghua commented on the issue:

<    1   2