[DISCUSS] Hive dialect shouldn't fall back to Flink's default dialect

Hi, community . I want to start the discussion about Hive dialect shouldn't fall back to Flink's default dialect. Currently, when the HiveParser fail to parse the sql in Hive dialect, it'll fall back to Flink's default parser[1] to handle flink-specific statements like "CREATE CATALOG xx wit

Re: [DISCUSS] FLIP-311: Support Call Stored Procedure

Thanks Yuxia for the proposal. > CALL [catalog_name.][database_name.]procedure_name ([ expression [, > expression]* ] ) The expression can be a function call. Does this need to be a function call? Do you have some example? > Procedure returns T[] Procedure looks like a TableFunction, do you co

[jira] [Created] (FLINK-32211) Supports row format in ExecutorImpl for jdbc driver

Fang Yong created FLINK-32211: - Summary: Supports row format in ExecutorImpl for jdbc driver Key: FLINK-32211 URL: https://issues.apache.org/jira/browse/FLINK-32211 Project: Flink Issue Type: Sub

Re: [DISCUSS] FLIP-315: Support Operator Fusion Codegen for Flink SQL

Thanks Ron for the proposal. Do you have some benchmark results for the performance improvement? I am more concerned about the improvement on Flink than the data in other papers. Best, Jingsong On Mon, May 29, 2023 at 2:16 PM liu ron wrote: > > Hi, dev > > I'd like to start a discussion about F

[DISCUSS] FLIP-311: Support Call Stored Procedure

Hi, everyone. I’d like to start a discussion about FLIP-311: Support Call Stored Procedure [1] Stored procedure provides a convenient way to encapsulate complex logic to perform data manipulation or administrative tasks in external storage systems. It's widely used in traditional databases a

[DISCUSS] FLIP-315: Support Operator Fusion Codegen for Flink SQL

Hi, dev I'd like to start a discussion about FLIP-315: Support Operator Fusion Codegen for Flink SQL[1] As main memory grows, query performance is more and more determined by the raw CPU costs of query processing itself, this is due to the query processing techniques based on interpreted executio

Re: [VOTE] Release flink-connector-jdbc v3.1.1, release candidate #1

+1 (non-binding) - checked sign and checksum - checked tag in github repository - compiled from source - checked the web PR BTW, please remember to update docs/jdbc.yaml for the v3.1 branch after the release is completed. Best regards, Weijie Jing Ge 于2023年5月29日周一 04:26写道： > +1 (non-binding

[DISCUSS] FLIP-307: Flink connector Redshift

Hello all , Context: Amazon Redshift [1] is a fully managed, petabyte-scale data warehouse service in the cloud. It allows analyzing data without all of the configurations of a provisioned data warehouse. Resources are automatically provisioned and data warehouse capacity is intelligently scaled t

Re: [ANNOUNCE] Apache Flink 1.16.2 released

Hi Jing, Thank you for caring about the releasing process. It has to be said that the entire process went smoothly. We have very comprehensive documentation[1] to guide my work, thanks to the contribution of previous release managers and the community. Regarding the obstacles, I actually only hav

Re: [DISCUSS] FLIP 295: Support persistence of Catalog configuration and asynchronous registration

Hi all, I would like to update you on the latest progress of the FLIP. Last week, Leonard Xu, HangRuan, Jing Ge, Shammon FY, ShengKai Fang and I had an offline discussion regarding the overall solution for Flink CatalogStore. We have reached a consensus and I have updated the final solution in FL

Re: Kryo Upgrade: Request FLIP page create access

Hi Kurt, The permission has been granted. Feel free to reach out if you have any questions. Looking forward to your FLIP! Best, Qingsheng On Mon, May 29, 2023 at 5:31 AM Kurt Ostfeld wrote: > Chesnay Schepler asked me to create a FLIP for this pull request: > https://github.com/apache/flink/p

Re: [DISCUSS] FLIP-313 Add support of User Defined AsyncTableFunction

Hi Jing, > "Do you mean to support the AyncTableFunction beyond the LookupTableSource?" Yes, I mean to support the AyncTableFunction beyond the LookupTableSource. The "AsyncTableFunction" is the function with ability to be executed async (with AsyncWaitOperator). The async lookup join is a one

Re: Kryo Upgrade: Request FLIP page create access

Hi Qingsheng, Could you grant Kurt rights for creating a new FLIP page? Thanks! @Kurt Thanks for reaching out. Please pay attention to the FLIP number you will pick up and keep "Next FLIP number" on [1] up to date. Thanks! Best regards, Jing [1] https://cwiki.apache.org/confluence/display/FLIN

Kryo Upgrade: Request FLIP page create access

Chesnay Schepler asked me to create a FLIP for this pull request: https://github.com/apache/flink/pull/22660 I created an account for the Flink Confluence site with username "kurto", but I don't have access to create pages, and therefore don't have access to create a FLIP. I see the FLIP docs sa

Re: [VOTE] Release flink-connector-jdbc v3.1.1, release candidate #1

+1 (non-binding) - checked sign - checked hash - checked repos - checked tag - compiled from source - check the web PR Best regards, Jing On Sun, May 28, 2023 at 4:00 PM Benchao Li wrote: > Thanks Martijn, > > - checked signature/checksum [OK] > - downloaded src, compiled from source [OK] > -

Re: [DISCUSS] FLIP-313 Add support of User Defined AsyncTableFunction

Hi Aitozi, Thanks for the clarification. The naming "Lookup" might suggest using it for table look up. But conceptually what the eval() method will do is to get a collection of results(Row, RowData) from the given keys. How it will be done depends on the implementation, i.e. you can implement your

Re: [VOTE] Release flink-connector-jdbc v3.1.1, release candidate #1

Thanks Martijn, - checked signature/checksum [OK] - downloaded src, compiled from source [OK] - diffed src and tag, no binary files [OK] - gone through nexus staging area, looks good [OK] - run with flink 1.7.1 [OK] One thing I spotted is that the version in `docs/data/jdbc.yml` is still 3.1.0, I