[DISCUSS][FLINK-36547] Add option to retain `RowKind` sematics for cdc formats

Hi everyone, As official docs said, `RowKind` semantics have been changed after encode: -U -> -D, +D -> +I. In fact, we also have a demand to make it consistent in many scenarios, such as those that require different processing of -U/-D and +U/+I. I have taken advantage of the difference between

[jira] [Created] (FLINK-36547) Add option to retain `RowKind` sematics after serialization/deserialization

Yubin Li created FLINK-36547: Summary: Add option to retain `RowKind` sematics after serialization/deserialization Key: FLINK-36547 URL: https://issues.apache.org/jira/browse/FLINK-36547 Project: Flink

Re: [ANNOUNCE] Apache Flink 1.20.0 released

Congrats! Thanks to release managers and everyone involved for the excellent work ! Best, Yubin Li On Fri, Aug 2, 2024 at 5:41 PM Paul Lam wrote: > > Congrats! > > Best, > Paul Lam > > > 2024年8月2日 17:26，Ahmed Hamdy 写道： > > > > Congratulations! > > Than

Re: [VOTE] FLIP-465: Introduce DESCRIBE FUNCTION

+1 (non-binding) Best, Yubin On Fri, Jul 5, 2024 at 4:09 AM Ferenc Csaky wrote: > > +1 (non-binding) > > Best, > Ferenc > > > > > On Thursday, 4 July 2024 at 16:20, Feng Jin wrote: > > > > > > > +1 (non-binding) > > > > Best, > > Feng Jin > > > > On Thu, Jul 4, 2024 at 6:02 PM Martijn Visser ma

[jira] [Created] (FLINK-35663) Release Testing: FLIP-436: Introduce Catalog-related Syntax

Yubin Li created FLINK-35663: Summary: Release Testing: FLIP-436: Introduce Catalog-related Syntax Key: FLINK-35663 URL: https://issues.apache.org/jira/browse/FLINK-35663 Project: Flink Issue

Re: [ANNOUNCE] New Apache Flink Committer - Zhongqiang Gong

Congratulations Zhongqiang! Best Regards Yubin On Tue, Jun 18, 2024 at 12:21 AM Muhammet Orazov wrote: > > Congratulations Zhongqiang! Well deserved! > > Best, > Muhammet > >

Re: [ANNOUNCE] New Apache Flink Committer - Hang Ruan

Congratulations Hang! Best Regards Yubin On Tue, Jun 18, 2024 at 12:23 AM Muhammet Orazov wrote: > > Congratulations Hang! Well deserved! > > Best, > Muhammet

[jira] [Created] (FLINK-35597) Fix unstable LocatableSplitAssignerTest#testConcurrentSplitAssignmentForMultipleHosts

Yubin Li created FLINK-35597: Summary: Fix unstable LocatableSplitAssignerTest#testConcurrentSplitAssignmentForMultipleHosts Key: FLINK-35597 URL: https://issues.apache.org/jira/browse/FLINK-35597

[jira] [Created] (FLINK-35451) Support `ALTER CATALOG COMMENT` syntax

Yubin Li created FLINK-35451: Summary: Support `ALTER CATALOG COMMENT` syntax Key: FLINK-35451 URL: https://issues.apache.org/jira/browse/FLINK-35451 Project: Flink Issue Type: Sub-task

Re: [VOTE] FLIP-457: Improve Table/SQL Configuration for Flink 2.0

+1 (non-binding) Best, Yubin On Fri, May 24, 2024 at 2:04 PM Rui Fan <1996fan...@gmail.com> wrote: > > +1(binding) > > Best, > Rui > > On Fri, May 24, 2024 at 1:45 PM Leonard Xu wrote: > > > +1 > > > > Best, > > Leonard > > > > > 2024年5月24日 下午1:27，weijie guo 写道： > > > > > > +1(binding) > > > >

Re: [DISCUSSION] FLIP-457: Improve Table/SQL Configuration for Flink 2.0

Hi Jane, Thank Jane for driving this proposal ! This makes sense for users, +1 for that. Best, Yubin On Thu, May 16, 2024 at 3:17 PM Jark Wu wrote: > > Hi Jane, > > Thanks for the proposal. +1 from my side. > > > Best, > Jark > > On Thu, 16 May 2024 at 10:28, Xuannan Su wrote: > > > Hi Jane,

Re: [VOTE] FLIP-436: Introduce Catalog-related Syntax

2024 at 2:15 PM Benchao Li wrote: > > +1 (binding) > > gongzhongqiang 于2024年3月20日周三 11:40写道： > > > > +1 (non-binding) > > > > Best, > > Zhongqiang Gong > > > > Yubin Li 于2024年3月19日周二 18:03写道： > > > > > Hi everyone, > > >

[jira] [Created] (FLINK-35164) Support `ALTER CATALOG RESET` syntax

Yubin Li created FLINK-35164: Summary: Support `ALTER CATALOG RESET` syntax Key: FLINK-35164 URL: https://issues.apache.org/jira/browse/FLINK-35164 Project: Flink Issue Type: Sub-task

Re: [ANNOUNCE] New Apache Flink PMC Member - Lincoln Lee

Congratulations, well deserved! Best regards, Yubin On Fri, Apr 12, 2024 at 4:53 PM Geng Biao wrote: > > Congrats, Lincoln! > Best, > Biao Geng > > 发送自 Outlook for iOS > > 发件人: Samrat Deb > 发送时间: Friday, April 12, 2024 4:46:42 PM > 收件人: de

[jira] [Created] (FLINK-34918) Introduce the support of catalog for comments

Yubin Li created FLINK-34918: Summary: Introduce the support of catalog for comments Key: FLINK-34918 URL: https://issues.apache.org/jira/browse/FLINK-34918 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-34917) Support enhanced `CREATE CATALOG` syntax

Yubin Li created FLINK-34917: Summary: Support enhanced `CREATE CATALOG` syntax Key: FLINK-34917 URL: https://issues.apache.org/jira/browse/FLINK-34917 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-34916) Support `ALTER CATALOG` syntax

Yubin Li created FLINK-34916: Summary: Support `ALTER CATALOG` syntax Key: FLINK-34916 URL: https://issues.apache.org/jira/browse/FLINK-34916 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-34915) Introduce `DESCRIBE CATALOG` syntax

Yubin Li created FLINK-34915: Summary: Introduce `DESCRIBE CATALOG` syntax Key: FLINK-34915 URL: https://issues.apache.org/jira/browse/FLINK-34915 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-34914) FLIP-436: Introduce Catalog-related Syntax

Yubin Li created FLINK-34914: Summary: FLIP-436: Introduce Catalog-related Syntax Key: FLINK-34914 URL: https://issues.apache.org/jira/browse/FLINK-34914 Project: Flink Issue Type: New Feature

[RESULT][VOTE] FLIP-436: Introduce Catalog-related Syntax

Hi everyone, I'm happy to announce that FLIP-436: Introduce Catalog-related Syntax [1] has been accepted with 10 approving votes (5 binding) [2]: - Yuepeng Pan (non-binding) - Jark Wu (binding) - Ferenc Csaky (non-binding) - Feng Jin (non-binding) - Lincoln Lee (binding) - Leonard Xu (binding) -

Re: Re: [DISCUSS] FLIP-436: Introduce "SHOW CREATE CATALOG" Syntax

t; Thank you for detailed explaination! I overlooked `CatalogBaseTable`, in > > > fact > > > there is already a `String getComment();` interface similar to > > `database` > > > and `table`. > > > Can we continue the work on FLINK-21665 and complete its implementa

Re: Re: [DISCUSS] FLIP-436: Introduce "SHOW CREATE CATALOG" Syntax

onse! > > It would be better to support comments just like create `database` and > `table` with comment. > That is, add `String getComment();` to the current `Catalog` interface. > WDYT? > > Best, > Lincoln Lee > > > Yubin Li 于2024年3月19日周二 21:44写道： > > > Hi Li

Re: Re: [DISCUSS] FLIP-436: Introduce "SHOW CREATE CATALOG" Syntax

Hi Yubin, > > Big +1 for completing the catalog api! > There's a minor addition[1] which does not affect the vote could also be > considered. > > [1] https://issues.apache.org/jira/browse/FLINK-21665 > > > Best, > Lincoln Lee > > > Yubin Li 于2024年3月18日周一 1

[VOTE] FLIP-436: Introduce Catalog-related Syntax

Hi everyone, Thanks for all the feedback, I'd like to start a vote on the FLIP-436: Introduce Catalog-related Syntax [1]. The discussion thread is here [2]. The vote will be open for at least 72 hours unless there is an objection or insufficient votes. [1] https://cwiki.apache.org/confluence/di

Re: [ANNOUNCE] Apache Flink 1.19.0 released

Congratulations! Thanks to release managers and everyone involved. On Mon, Mar 18, 2024 at 5:55 PM Hangxiang Yu wrote: > > Congratulations! > Thanks release managers and all involved! > > On Mon, Mar 18, 2024 at 5:23 PM Hang Ruan wrote: > > > Congratulations! > > > > Best, > > Hang > > > > Paul

Re: Re: [DISCUSS] FLIP-436: Introduce "SHOW CREATE CATALOG" Syntax

+Catalog-related+Syntax On Mon, Mar 18, 2024 at 4:39 PM Jark Wu wrote: > > Hi Yubin, > > Thanks for the quick response. The suggestion sounds good to me! > > Best, > Jark > > On Mon, 18 Mar 2024 at 13:06, Yubin Li wrote: > > > Hi Jark, > > > > Good

Re: Re: [DISCUSS] FLIP-436: Introduce "SHOW CREATE CATALOG" Syntax

LOG xxx UNSET ('mykey')? This is > also very useful in ALTER TABLE. > > Best, > Jark > > [1]: > > https://docs.databricks.com/en/sql/language-manual/sql-ref-syntax-aux-describe-schema.html > > > > On Fri, 15 Mar 2024 at 12:06, Yubin Li wrote: > >

Re: Re: [DISCUSS] FLIP-436: Introduce "SHOW CREATE CATALOG" Syntax

69 in this > FLIP. WDYT? > > > [1] > https://cwiki.apache.org/confluence/display/FLINK/FLIP-69%3A+Flink+SQL+DDL+Enhancement > > > > -- > > Best！ > Xuyang > > > > > > At 2024-03-15 02:49:59, "Yubin Li" wrote: > >Hi folks, >

Re: [DISCUSS] FLIP-436: Introduce "SHOW CREATE CATALOG" Syntax

gt; > >>> Thanks for leading the discussion. I'm +1 for the FLIP. > >>> > >>> As Jark said, it's a good opportunity to enhance the syntax for Catalog > >>> from a more comprehensive perspective. So, I suggest expanding the > scope of >

Re: [DISCUSS] FLIP-436: Introduce "SHOW CREATE CATALOG" Syntax

5:31 PM Jingsong Li > > wrote: > > > > > +1 for this. > > > > > > We are missing a series of catalog related syntaxes. > > > Especially after the introduction of catalog store. [1] > > > > > > [1] > > > > > https://cwiki.apache.

[DISCUSS] FLIP-436: Introduce "SHOW CREATE CATALOG" Syntax

Hi devs, I'd like to start a discussion about FLIP-436: Introduce "SHOW CREATE CATALOG" Syntax [1]. At present, the `SHOW CREATE TABLE` statement provides strong support for users to easily reuse created tables. However, despite the increasing importance of the `Catalog` in user's business, there

[jira] [Created] (FLINK-33927) Cleanup usage of deprecated ExecutionConfigOptions#(TABLE_EXEC_SHUFFLE_MODE, TABLE_EXEC_LEGACY_TRANSFORMATION_UIDS)

Yubin Li created FLINK-33927: Summary: Cleanup usage of deprecated ExecutionConfigOptions#(TABLE_EXEC_SHUFFLE_MODE, TABLE_EXEC_LEGACY_TRANSFORMATION_UIDS) Key: FLINK-33927 URL: https://issues.apache.org/jira/browse

[jira] [Created] (FLINK-33921) Cleanup usage of deprecated IdleStateRetentionTime related method in org.apache.flink.table.api.TableConfig

Yubin Li created FLINK-33921: Summary: Cleanup usage of deprecated IdleStateRetentionTime related method in org.apache.flink.table.api.TableConfig Key: FLINK-33921 URL: https://issues.apache.org/jira/browse/FLINK

[jira] [Created] (FLINK-33780) Support to store default catalog in CatalogStore

Yubin Li created FLINK-33780: Summary: Support to store default catalog in CatalogStore Key: FLINK-33780 URL: https://issues.apache.org/jira/browse/FLINK-33780 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-33638) Support variable-length data generation for variable-length data types

Yubin Li created FLINK-33638: Summary: Support variable-length data generation for variable-length data types Key: FLINK-33638 URL: https://issues.apache.org/jira/browse/FLINK-33638 Project: Flink

Re: [DISCUSS][FLINK-32993] Datagen connector handles length-constrained fields according to the schema definition by default

Thank Jane for providing examples to make discussions clearer. Thank Lincoln and Xuyang for your feedback,I agree with you wholeheartedly that it is better to throw an error instead of ignoring it directly. Taking the example provided, For fixed-length data types, two DDLs which custom length sh

[jira] [Created] (FLINK-33571) Bump json-path from 2.7.0 to 2.8.0

Yubin Li created FLINK-33571: Summary: Bump json-path from 2.7.0 to 2.8.0 Key: FLINK-33571 URL: https://issues.apache.org/jira/browse/FLINK-33571 Project: Flink Issue Type: Bug Affects

[jira] [Created] (FLINK-33492) Fix unavailable links in connector download page

Yubin Li created FLINK-33492: Summary: Fix unavailable links in connector download page Key: FLINK-33492 URL: https://issues.apache.org/jira/browse/FLINK-33492 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-33379) Bump flink version on flink-connectors-elasticsearch

Yubin Li created FLINK-33379: Summary: Bump flink version on flink-connectors-elasticsearch Key: FLINK-33379 URL: https://issues.apache.org/jira/browse/FLINK-33379 Project: Flink Issue Type

[jira] [Created] (FLINK-32993) Datagen connector produce unexpected Char type data

Yubin Li created FLINK-32993: Summary: Datagen connector produce unexpected Char type data Key: FLINK-32993 URL: https://issues.apache.org/jira/browse/FLINK-32993 Project: Flink Issue Type

[jira] [Created] (FLINK-30435) `SHOW CREATE TABLE` shows column comment

Yubin Li created FLINK-30435: Summary: `SHOW CREATE TABLE` shows column comment Key: FLINK-30435 URL: https://issues.apache.org/jira/browse/FLINK-30435 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-29929) Correct conversions from ResolvedSchema to TableSchema

Yubin Li created FLINK-29929: Summary: Correct conversions from ResolvedSchema to TableSchema Key: FLINK-29929 URL: https://issues.apache.org/jira/browse/FLINK-29929 Project: Flink Issue Type

[jira] [Created] (FLINK-29829) align explain results in different platforms

Yubin Li created FLINK-29829: Summary: align explain results in different platforms Key: FLINK-29829 URL: https://issues.apache.org/jira/browse/FLINK-29829 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-29787) fix ci METHOD_NEW_DEFAULT issue

Yubin Li created FLINK-29787: Summary: fix ci METHOD_NEW_DEFAULT issue Key: FLINK-29787 URL: https://issues.apache.org/jira/browse/FLINK-29787 Project: Flink Issue Type: Bug Components

[jira] [Created] (FLINK-29679) DESCRIBE statement shows comment

Yubin Li created FLINK-29679: Summary: DESCRIBE statement shows comment Key: FLINK-29679 URL: https://issues.apache.org/jira/browse/FLINK-29679 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-29042) Support lookup join for es connector

Yubin Li created FLINK-29042: Summary: Support lookup join for es connector Key: FLINK-29042 URL: https://issues.apache.org/jira/browse/FLINK-29042 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-27207) Support built-in parquet format

Yubin Li created FLINK-27207: Summary: Support built-in parquet format Key: FLINK-27207 URL: https://issues.apache.org/jira/browse/FLINK-27207 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-27172) Support bulk based format provided by Flink

Yubin Li created FLINK-27172: Summary: Support bulk based format provided by Flink Key: FLINK-27172 URL: https://issues.apache.org/jira/browse/FLINK-27172 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-27100) Support parquet format in FileStore

Yubin Li created FLINK-27100: Summary: Support parquet format in FileStore Key: FLINK-27100 URL: https://issues.apache.org/jira/browse/FLINK-27100 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-26677) Make flink-connector-base dependency consistent

Yubin Li created FLINK-26677: Summary: Make flink-connector-base dependency consistent Key: FLINK-26677 URL: https://issues.apache.org/jira/browse/FLINK-26677 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-25631) Support enhanced `show tables` statement

Yubin Li created FLINK-25631: Summary: Support enhanced `show tables` statement Key: FLINK-25631 URL: https://issues.apache.org/jira/browse/FLINK-25631 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-25563) Support sink parallelism configuration to Elasticsearch connector

Yubin Li created FLINK-25563: Summary: Support sink parallelism configuration to Elasticsearch connector Key: FLINK-25563 URL: https://issues.apache.org/jira/browse/FLINK-25563 Project: Flink

[jira] [Created] (FLINK-25369) CatalogManager provide wrong tables or views in given catalog database name

Yubin Li created FLINK-25369: Summary: CatalogManager provide wrong tables or views in given catalog database name Key: FLINK-25369 URL: https://issues.apache.org/jira/browse/FLINK-25369 Project: Flink

[jira] [Created] (FLINK-24939) Support 'SHOW CREATE CATALOG' syntax

Yubin Li created FLINK-24939: Summary: Support 'SHOW CREATE CATALOG' syntax Key: FLINK-24939 URL: https://issues.apache.org/jira/browse/FLINK-24939 Project: Flink Issue Type: I

[jira] [Created] (FLINK-24730) Support prompt in SqlCli

Yubin Li created FLINK-24730: Summary: Support prompt in SqlCli Key: FLINK-24730 URL: https://issues.apache.org/jira/browse/FLINK-24730 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-24585) Print the change in the size of the compacted files

Yubin Li created FLINK-24585: Summary: Print the change in the size of the compacted files Key: FLINK-24585 URL: https://issues.apache.org/jira/browse/FLINK-24585 Project: Flink Issue Type

[jira] [Created] (FLINK-23661) Fix protobuf plugin proxy issue

Yubin Li created FLINK-23661: Summary: Fix protobuf plugin proxy issue Key: FLINK-23661 URL: https://issues.apache.org/jira/browse/FLINK-23661 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-23656) flink-sql-parser compile failed

Yubin Li created FLINK-23656: Summary: flink-sql-parser compile failed Key: FLINK-23656 URL: https://issues.apache.org/jira/browse/FLINK-23656 Project: Flink Issue Type: Bug Components

[jira] [Created] (FLINK-23442) FileSystemFactory refactor in flink-table-runtime

Yubin Li created FLINK-23442: Summary: FileSystemFactory refactor in flink-table-runtime Key: FLINK-23442 URL: https://issues.apache.org/jira/browse/FLINK-23442 Project: Flink Issue Type

[jira] [Created] (FLINK-18043) Translate "Scala API Extensions" page of "DataStream API" into Chinese

Yubin Li created FLINK-18043: Summary: Translate "Scala API Extensions" page of "DataStream API" into Chinese Key: FLINK-18043 URL: https://issues.apache.org/jira/browse/FLINK-18043

[jira] [Created] (FLINK-18007) Translate "Joins in Continuous Queries" page of "Streaming Concepts" into Chinese

Yubin Li created FLINK-18007: Summary: Translate "Joins in Continuous Queries" page of "Streaming Concepts" into Chinese Key: FLINK-18007 URL: https://issues.apache.org/jira/browse/FLINK-18007

[jira] [Created] (FLINK-17999) Translate "Query Configuration" page of "Streaming Concepts" into Chinese

Yubin Li created FLINK-17999: Summary: Translate "Query Configuration" page of "Streaming Concepts" into Chinese Key: FLINK-17999 URL: https://issues.apache.org/jira/browse/FLINK-17999