Re: [DISCUSS] DockerHub repository maintainers

Hi team, I volunteer for the flink-kubernetes-operator repo. On Fri, May 6, 2022 at 1:42 PM Xintong Song wrote: > @Till, > > Thanks for volunteering. > > @Konstantin, > > From my experience, the effort that requires DockerHub access in the main > project release process is quite limited. I help

Re: [VOTE] Apache Flink Table Store 0.1.0, release candidate #2

Hi Jingsong, Thanks for driving the very first release of the flink-table-store! +1 (binding) for the RC. I verified the following: - the signature of the artifacts - the source jar does not contain binary files - no accidental distribution of other projects is included in the dist jar - went th

[jira] [Created] (FLINK-27539) support consuming update and delete changes In Windowing TVFs

hjw created FLINK-27539: --- Summary: support consuming update and delete changes In Windowing TVFs Key: FLINK-27539 URL: https://issues.apache.org/jira/browse/FLINK-27539 Project: Flink Issue Type: Impr

[jira] [Created] (FLINK-27540) Let FileStoreSource accept pre-planned manifest entries

Jane Chan created FLINK-27540: - Summary: Let FileStoreSource accept pre-planned manifest entries Key: FLINK-27540 URL: https://issues.apache.org/jira/browse/FLINK-27540 Project: Flink Issue Type:

Re: Edit Permissions for Flink Connector Template

Thanks for the info, Martijn. Jeremy, the permission is granted. Please have a try. Thank you~ Xintong Song On Sat, May 7, 2022 at 2:22 PM Martijn Visser wrote: > Hi all, > > For context, I've had an offline discussion with Jeremy on what's needed to > propose a new Flink connector. That's

RE: Re: How to support C#/dotNet ?

> Have a look at the Apache Beam I will look that,thanks On 2022/05/07 01:58:07 Cristian Constantinescu wrote: > Not exactly what you asked for, but... Have a look at the Apache Beam > project. > > Their goal is quite literally any language on any runner (including Flink). > > They recently rele

RE: Re: How to support C#/dotNet ?

I mean former purpose , I want to offer API for C# on Apache Flink same as [4]. On 2022/05/07 02:40:33 Yun Tang wrote: > Hi Tian, > > I am not sure whether you want to get such SDK or just want to refer some > other existing repos to try to implement your own. > For the former purpose, you

Re: [DISCUSS] FLIP-91: Support SQL Client Gateway

Hi Martijn. It seems we have reached consensus to support the Gateway inside the Flink code base. Hi, Echo. Thanks for your interest. > whether flink-sql-gateway should be retained in the Flink project. I think the discussion above is clear. It is the essential tool to provide out-of-box exper

Re: [DISCUSS] FLIP-91: Support SQL Client Gateway

Hi Shengkai, thanks for your reply. > REST API is the user interface. The REST API transforms the request to the invocation of the SQLGatewayService that is the one doing the work. We split the Gateway into the SQLGatewayService and Endpoint(REST API) and its benefit is that all the Endpoints shar

[jira] [Created] (FLINK-27541) Support distribute by For FlinkSql

Aiden created FLINK-27541: - Summary: Support distribute by For FlinkSql Key: FLINK-27541 URL: https://issues.apache.org/jira/browse/FLINK-27541 Project: Flink Issue Type: Improvement Compon

Re: [DISCUSS] FLIP-228: Support Within between events in CEP Pattern

Hi Nicholas, Thanks a lot for bringing up this discussion. If I recall it correctly, this feature has been requested many times by the users and is among one of the most requested features in CEP. So big +1 to this feature overall. Regarding the API, the name `partialWithin` sounds a little weird

Re: [VOTE] Apache Flink Table Store 0.1.0, release candidate #2

+1 (binding) - Checked release notes: *OK* - Checked sums and signatures: *OK* - Checked the jars in the staging repo: *OK* - Checked source distribution doesn't include binaries: *OK* - Maven clean install from source: *OK* - Checked version consistency in pom files: *OK* - Went through the quick

Re: Re: [ANNOUNCE] New Flink PMC member: Yang Wang

Congrats Yang! Regards, Dian On Sat, May 7, 2022 at 12:51 PM Jacky Lau wrote: > Congrats Yang and well Deserved! > > Best, > Jacky Lau > > Yun Gao 于2022年5月7日周六 10:44写道： > > > Congratulations Yang! > > > > Best, > > Yun Gao > > > > > > > > --Original Mail -- > >

Re: [VOTE] Apache Flink Table Store 0.1.0, release candidate #2

First of all, thanks for Jinsong to drive this. I checked the following: * Reviewed the PR of release note. * Build the package from the scratch: OK * Check that the README.md file does not have anything unexpected: *seems not OK* I noticed that current README actually does not give

[jira] [Created] (FLINK-27542) Add end to end tests for Hive to read external table store files

Caizhi Weng created FLINK-27542: --- Summary: Add end to end tests for Hive to read external table store files Key: FLINK-27542 URL: https://issues.apache.org/jira/browse/FLINK-27542 Project: Flink

Re: [Discuss] Creating an Apache Flink slack workspace

Thanks all for the valuable feedback. It seems most people are overall positive about using Slack for dev discussions, as long as they are properly reflected back to the MLs. - We definitely need a code of conduct that clearly specifies what people should / should not do. - Contributors pinging we

Re: [DISCUSS] FLIP-222: Support full query lifecycle statements in SQL client

Hi Paul, I think this FLIP has already in a good shape. I just left some additional thoughts: *1) the display of savepoint_path* Could the displayed savepoint_path include the scheme part? E.g. `hdfs:///flink-savepoints/savepoint-cca7bc-bb1e257f0dab` IIUC, the scheme part is omitted when it's a l

Re: [DISCUSS] FLIP-224: Blacklist Mechanism

Hi Lijie! *a) “Probably storing inside Zookeeper/Configmap might be helpfulhere.” Can you explain it in detail? I don't fully understand that. In myopinion, non-active and active are the same, and no special treatment isrequired.* Sorry this was a misunderstanding from my side. I thought we we

Re: [VOTE] Apache Flink Table Store 0.1.0, release candidate #2

Hi all, I have checked the LICENSE and NOTICE files but found that the uber jar (flink-table-store-dist) doesn't provide an appropriate NOTICE file to list the bundled dependencies. I checked the license guideline [1], and it says: > For Maven artifacts that DO bundle (usually through the maven-