Re: [DISCUSS] FLIP-44: Support Local Aggregation in Flink

Hi Jark, *About local keyed state:* I object to moving it out of this FLIP. It's one of the ways we support Local aggregation on the implementation of operator level, though not the only one. I guess you have misunderstood my last reply. I just tell you the difference between `DataStream#process

Re: [DISCUSS] META-FLIP: Sticking (or not) to a strict FLIP voting process

Thanks a lot for bringing this up, Aljoscha. +1 for sticking to the "lazy majority" vote process. In my opinion, after the "lazy majority" vote process, we will have a community consensus about the accepted FLIP. Best, Congxian Becket Qin 于2019年6月28日周五 上午10:06写道： > Thanks a lot for bringing

Re: [DISCUSS] META-FLIP: Sticking (or not) to a strict FLIP voting process

Thanks a lot for bringing this up, Aljoscha. Big +1 to the following: 1. Stick to a strict FLIP voting process. In practice, I rarely see a FLIP with a voting thread. In fact, the search in mail archive

[jira] [Created] (FLINK-13025) Elasticsearch 7.x support

Keegan Standifer created FLINK-13025: Summary: Elasticsearch 7.x support Key: FLINK-13025 URL: https://issues.apache.org/jira/browse/FLINK-13025 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-13024) integrate FunctionCatalog with CatalogManager

Bowen Li created FLINK-13024: Summary: integrate FunctionCatalog with CatalogManager Key: FLINK-13024 URL: https://issues.apache.org/jira/browse/FLINK-13024 Project: Flink Issue Type: Sub-task

Re: [DISCUSS] Adopting a Code Style and Quality Guide

+1. Thanks for working on the guide. It's very thorough and a good resource to learn good practices from. I would like use this thread as a placeholder for a couple of topics that may be deserving of further discussion on different threads: - What's the best way to keep track of checkstyle versi

[jira] [Created] (FLINK-13023) Generate HiveTableSource from from a Hive table

Xuefu Zhang created FLINK-13023: --- Summary: Generate HiveTableSource from from a Hive table Key: FLINK-13023 URL: https://issues.apache.org/jira/browse/FLINK-13023 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-13022) unify catalog function implementations

Bowen Li created FLINK-13022: Summary: unify catalog function implementations Key: FLINK-13022 URL: https://issues.apache.org/jira/browse/FLINK-13022 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-13021) unify catalog partition implementations

Bowen Li created FLINK-13021: Summary: unify catalog partition implementations Key: FLINK-13021 URL: https://issues.apache.org/jira/browse/FLINK-13021 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-13020) UT Failure: ChainLengthDecreaseTest

Bowen Li created FLINK-13020: Summary: UT Failure: ChainLengthDecreaseTest Key: FLINK-13020 URL: https://issues.apache.org/jira/browse/FLINK-13020 Project: Flink Issue Type: Improvement

Re: [VOTE] Release 1.8.1, release candidate #1

Hi Jincheng, Thanks a lot for the release which contains so many fixes! I have done the following checks: Local Tests - Built from source archive successfully. - Signatures and hash are correct. - All artifacts have been deployed to the maven central repository. - Run WordCount(batch&str

Re: [DISCUSS] META-FLIP: Sticking (or not) to a strict FLIP voting process

+1 to re-think the FLIP process a bit. I think more explicit approval is certainly a good idea. Who can vote on FLIPs is a question to be answered, though. I think PMCs only would be a bit too strict. On Thu, Jun 27, 2019 at 11:38 AM Hequn Cheng wrote: > Hi all, > > Thanks for raising the nice

[jira] [Created] (FLINK-13019) IT test for fine-grained recovery

Andrey Zagrebin created FLINK-13019: --- Summary: IT test for fine-grained recovery Key: FLINK-13019 URL: https://issues.apache.org/jira/browse/FLINK-13019 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-13018) Serving docs locally with jekyll fails with inotify limit

Nico Kruber created FLINK-13018: --- Summary: Serving docs locally with jekyll fails with inotify limit Key: FLINK-13018 URL: https://issues.apache.org/jira/browse/FLINK-13018 Project: Flink Issue

Re: [DISCUSS] FLIP-44: Support Local Aggregation in Flink

Hi Vino, So the difference between `DataStream.localKeyBy().process()` with `DataStream.process()` is that the former can access keyed state and the latter can only access operator state. I think it's out of the scope of designing a local aggregation API. It might be an extension of state API, i.e

[jira] [Created] (FLINK-13017) Broken and irreproducible dockerized docs build

Nico Kruber created FLINK-13017: --- Summary: Broken and irreproducible dockerized docs build Key: FLINK-13017 URL: https://issues.apache.org/jira/browse/FLINK-13017 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-13016) StreamTaskNetworkInput can linger records for longer period of times

Piotr Nowojski created FLINK-13016: -- Summary: StreamTaskNetworkInput can linger records for longer period of times Key: FLINK-13016 URL: https://issues.apache.org/jira/browse/FLINK-13016 Project: Fli

[jira] [Created] (FLINK-13015) Create validators, strategies and transformations required for porting logical expressions

Dawid Wysakowicz created FLINK-13015: Summary: Create validators, strategies and transformations required for porting logical expressions Key: FLINK-13015 URL: https://issues.apache.org/jira/browse/FLINK-13015

[jira] [Created] (FLINK-13014) ChainBreakTest failed on Travis

Haibo Sun created FLINK-13014: - Summary: ChainBreakTest failed on Travis Key: FLINK-13014 URL: https://issues.apache.org/jira/browse/FLINK-13014 Project: Flink Issue Type: Bug Reporte

[jira] [Created] (FLINK-13013) Make sure that SingleInputGate can always request partitions

Piotr Nowojski created FLINK-13013: -- Summary: Make sure that SingleInputGate can always request partitions Key: FLINK-13013 URL: https://issues.apache.org/jira/browse/FLINK-13013 Project: Flink

Re: [DISCUSS] META-FLIP: Sticking (or not) to a strict FLIP voting process

Hi all, Thanks for raising the nice discussion @Aljoscha. +1 to sticking to the "lazy majority" voting process. It is good to get more people involved in the design discussion and get enough binding votes. As for the scope of the FLIP, previous replies show a lot of good thoughts. On the other h

Re: [DISCUSS] META-FLIP: Sticking (or not) to a strict FLIP voting process

Hi community, Thanks Aljoscha for bringing us this discussion. As Aljoscha said, "lazy majority" is always the voting rule of FLIP. It seems that people just ignored or didn't realized this rule. My concern is that what we can do to make sure developers will obey the rules. I think Kurt has given

Re: [DISCUSS] solve unstable build capacity problem on TravisCI

see https://issues.apache.org/jira/browse/INFRA-18533 for the overall degradation of Travis capacity. On 26/06/2019 21:50, Bowen wrote: just elaborate a bit more on why slow build is ok but no resource is not: Say I submit a build request at PST 9am, no other requests exist and mine is the qu

[jira] [Created] (FLINK-13012) Handle default partition name of Hive table

Rui Li created FLINK-13012: -- Summary: Handle default partition name of Hive table Key: FLINK-13012 URL: https://issues.apache.org/jira/browse/FLINK-13012 Project: Flink Issue Type: Sub-task