[jira] [Commented] (FLINK-27548) Improve quick-start of table store

[ https://issues.apache.org/jira/browse/FLINK-27548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17694284#comment-17694284 ] ZhuoYu Chen commented on FLINK-27548: - hi [~lzljs3620320] ,please assign to me; thx。 > Improve

[jira] [Updated] (FLINK-26999) Introduce ClickHouse Connector

[ https://issues.apache.org/jira/browse/FLINK-26999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ZhuoYu Chen updated FLINK-26999: Description:

[jira] [Created] (FLINK-26999) Introduce ClickHouse Connector

ZhuoYu Chen created FLINK-26999: --- Summary: Introduce ClickHouse Connector Key: FLINK-26999 URL: https://issues.apache.org/jira/browse/FLINK-26999 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-26999) Introduce ClickHouse Connector

[ https://issues.apache.org/jira/browse/FLINK-26999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ZhuoYu Chen updated FLINK-26999: Issue Type: New Feature (was: Improvement) > Introduce ClickHouse Connector >

[jira] [Commented] (FLINK-24351) translate "JSON Function" pages into Chinese

[ https://issues.apache.org/jira/browse/FLINK-24351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17513850#comment-17513850 ] ZhuoYu Chen commented on FLINK-24351: - hi [~gaoyunhaii]  I would be happy to complete some follow-up

[jira] [Commented] (FLINK-25716) Translate "Streaming Concepts" page of "Application Development > Table API & SQL" to Chinese

[ https://issues.apache.org/jira/browse/FLINK-25716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17479529#comment-17479529 ] ZhuoYu Chen commented on FLINK-25716: - Hi [~MartijnVisser]  I am very interested in this，and I want

[jira] [Commented] (FLINK-24351) translate "JSON Function" pages into Chinese

[ https://issues.apache.org/jira/browse/FLINK-24351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17479525#comment-17479525 ] ZhuoYu Chen commented on FLINK-24351: - hi [~jark]  [~liliwei] The `pr` has been completed, please

[jira] [Commented] (FLINK-25559) SQL JOIN causes data loss

[ https://issues.apache.org/jira/browse/FLINK-25559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17475100#comment-17475100 ] ZhuoYu Chen commented on FLINK-25559: - Hi [~Ashulin]    I am very interested in this，and I want do

[jira] [Commented] (FLINK-25595) Specify hash/sort aggregate strategy in SQL hint

[ https://issues.apache.org/jira/browse/FLINK-25595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17474534#comment-17474534 ] ZhuoYu Chen commented on FLINK-25595: - Hi [~jingzhang]     I am very interested in this，and I want

[jira] [Commented] (FLINK-25600) Support new statement set syntax in sql client and update docs

[ https://issues.apache.org/jira/browse/FLINK-25600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17474536#comment-17474536 ] ZhuoYu Chen commented on FLINK-25600: - Hi [~wenlong.lwl]   I am very interested in this，and I want

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

[ https://issues.apache.org/jira/browse/FLINK-25631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17474529#comment-17474529 ] ZhuoYu Chen edited comment on FLINK-25631 at 1/12/22, 1:39 PM: --- Hi

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

[ https://issues.apache.org/jira/browse/FLINK-25631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17474529#comment-17474529 ] ZhuoYu Chen commented on FLINK-25631: - 嗨， [~liyubin117]  我对这个很感兴趣，我想为 flink 做一些工作，我可以帮忙做吗？ >

[jira] [Comment Edited] (FLINK-24456) Support bounded offset in the Kafka table connector

[ https://issues.apache.org/jira/browse/FLINK-24456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17472973#comment-17472973 ] ZhuoYu Chen edited comment on FLINK-24456 at 1/11/22, 5:33 PM: --- Hi

[jira] [Commented] (FLINK-24456) Support bounded offset in the Kafka table connector

[ https://issues.apache.org/jira/browse/FLINK-24456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17472973#comment-17472973 ] ZhuoYu Chen commented on FLINK-24456: - Hi [~MartijnVisser] *I have finished this pr, could you

[jira] [Commented] (FLINK-24456) Support bounded offset in the Kafka table connector

[ https://issues.apache.org/jira/browse/FLINK-24456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17472536#comment-17472536 ] ZhuoYu Chen commented on FLINK-24456: - [~MartijnVisser] I think the basic logic is done, there are

[jira] [Commented] (FLINK-24900) Support to run multiple shuffle plugins in one session cluster

[ https://issues.apache.org/jira/browse/FLINK-24900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17468528#comment-17468528 ] ZhuoYu Chen commented on FLINK-24900: - I'm glad to see your message. https

[jira] [Commented] (FLINK-15571) Create a Redis Streams Connector for Flink

[ https://issues.apache.org/jira/browse/FLINK-15571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17467441#comment-17467441 ] ZhuoYu Chen commented on FLINK-15571: - Hello, I have already started to implement and expect to

[jira] [Updated] (FLINK-25397) support grouped_execution

[ https://issues.apache.org/jira/browse/FLINK-25397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ZhuoYu Chen updated FLINK-25397: Description: Performing data bucketing execution: two tables (orders, orders_item), divided into

[jira] [Updated] (FLINK-25397) support grouped_execution

[ https://issues.apache.org/jira/browse/FLINK-25397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ZhuoYu Chen updated FLINK-25397: Summary: support grouped_execution (was: grouped_execution) > support grouped_execution >

[jira] [Updated] (FLINK-25397) support grouped_execution

[ https://issues.apache.org/jira/browse/FLINK-25397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ZhuoYu Chen updated FLINK-25397: Description: Performing data bucketing execution: two tables (orders, orders_item), divided into

[jira] [Created] (FLINK-25397) grouped_execution

ZhuoYu Chen created FLINK-25397: --- Summary: grouped_execution Key: FLINK-25397 URL: https://issues.apache.org/jira/browse/FLINK-25397 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-24483) Document what is Public API and what compatibility guarantees Flink is providing

[ https://issues.apache.org/jira/browse/FLINK-24483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17462626#comment-17462626 ] ZhuoYu Chen commented on FLINK-24483: - [~trohrmann] @PublicEvolving is to show that the current

[jira] [Commented] (FLINK-24483) Document what is Public API and what compatibility guarantees Flink is providing

[ https://issues.apache.org/jira/browse/FLINK-24483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17461454#comment-17461454 ] ZhuoYu Chen commented on FLINK-24483: - Hi [~trohrmann]    I am very interested in this，and I want do

[jira] [Commented] (FLINK-24456) Support bounded offset in the Kafka table connector

[ https://issues.apache.org/jira/browse/FLINK-24456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17461307#comment-17461307 ] ZhuoYu Chen commented on FLINK-24456: - [~dragonpic] kafka his characteristic is unbounded, the

[jira] [Created] (FLINK-25361) Support bounded timestamp in kafka table connector

ZhuoYu Chen created FLINK-25361: --- Summary: Support bounded timestamp in kafka table connector Key: FLINK-25361 URL: https://issues.apache.org/jira/browse/FLINK-25361 Project: Flink Issue Type:

[jira] [Commented] (FLINK-24456) Support bounded offset in the Kafka table connector

[ https://issues.apache.org/jira/browse/FLINK-24456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17461291#comment-17461291 ] ZhuoYu Chen commented on FLINK-24456: - [~dragonpic] This problem I think can be added to two: 1. is

[jira] [Commented] (FLINK-7129) Support dynamically changing CEP patterns

[ https://issues.apache.org/jira/browse/FLINK-7129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17460504#comment-17460504 ] ZhuoYu Chen commented on FLINK-7129: Hello [~MartijnVisser] I saw the email about the discussion and

[jira] [Updated] (FLINK-7129) Support dynamically changing CEP patterns

[ https://issues.apache.org/jira/browse/FLINK-7129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ZhuoYu Chen updated FLINK-7129: --- Attachment: image-2021-12-16-16-59-22-133.png > Support dynamically changing CEP patterns >

[jira] [Comment Edited] (FLINK-7129) Support dynamically changing CEP patterns

[ https://issues.apache.org/jira/browse/FLINK-7129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17460488#comment-17460488 ] ZhuoYu Chen edited comment on FLINK-7129 at 12/16/21, 8:31 AM: ---  

[jira] [Comment Edited] (FLINK-7129) Support dynamically changing CEP patterns

[ https://issues.apache.org/jira/browse/FLINK-7129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17460488#comment-17460488 ] ZhuoYu Chen edited comment on FLINK-7129 at 12/16/21, 8:28 AM: --- Hi

[jira] [Commented] (FLINK-7129) Support dynamically changing CEP patterns

[ https://issues.apache.org/jira/browse/FLINK-7129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17460488#comment-17460488 ] ZhuoYu Chen commented on FLINK-7129: Hi [~MartijnVisser] You will assign it to me, and I will have

[jira] [Commented] (FLINK-25286) Improve connector testing framework to support more scenarios

[ https://issues.apache.org/jira/browse/FLINK-25286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17460438#comment-17460438 ] ZhuoYu Chen commented on FLINK-25286: - Hi [~renqs], I've done a lot of custom work on connectors at

[jira] [Commented] (FLINK-25218) Performance issues with lookup join accessing external dimension tables

[ https://issues.apache.org/jira/browse/FLINK-25218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17456397#comment-17456397 ] ZhuoYu Chen commented on FLINK-25218: - [~MartijnVisser] Hello, please wait a moment, in the next few

[jira] [Created] (FLINK-25232) flink sql supports fine-grained state configuration

ZhuoYu Chen created FLINK-25232: --- Summary: flink sql supports fine-grained state configuration Key: FLINK-25232 URL: https://issues.apache.org/jira/browse/FLINK-25232 Project: Flink Issue

[jira] [Updated] (FLINK-25218) Performance issues with lookup join accessing external dimension tables

[ https://issues.apache.org/jira/browse/FLINK-25218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ZhuoYu Chen updated FLINK-25218: Affects Version/s: 1.15.0 > Performance issues with lookup join accessing external dimension

[jira] [Created] (FLINK-25218) Performance issues with lookup join accessing external dimension tables

ZhuoYu Chen created FLINK-25218: --- Summary: Performance issues with lookup join accessing external dimension tables Key: FLINK-25218 URL: https://issues.apache.org/jira/browse/FLINK-25218 Project:

[jira] [Commented] (FLINK-25213) Add @Public annotations to flink-table-common

[ https://issues.apache.org/jira/browse/FLINK-25213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17454598#comment-17454598 ] ZhuoYu Chen commented on FLINK-25213: - @[~twalthr] Hello, assign this sub-question to me and I will

[jira] [Created] (FLINK-25213) Add @Public annotations to flink-table-common

ZhuoYu Chen created FLINK-25213: --- Summary: Add @Public annotations to flink-table-common Key: FLINK-25213 URL: https://issues.apache.org/jira/browse/FLINK-25213 Project: Flink Issue Type:

[jira] [Comment Edited] (FLINK-21884) Reduce TaskManager failure detection time

[ https://issues.apache.org/jira/browse/FLINK-21884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17454589#comment-17454589 ] ZhuoYu Chen edited comment on FLINK-21884 at 12/7/21, 11:16 AM:

[jira] [Comment Edited] (FLINK-21884) Reduce TaskManager failure detection time

[ https://issues.apache.org/jira/browse/FLINK-21884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17454589#comment-17454589 ] ZhuoYu Chen edited comment on FLINK-21884 at 12/7/21, 11:16 AM:

[jira] [Commented] (FLINK-21884) Reduce TaskManager failure detection time

[ https://issues.apache.org/jira/browse/FLINK-21884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17454589#comment-17454589 ] ZhuoYu Chen commented on FLINK-21884: - [~trohrmann]  HDFS cluster with the growth of time, there

[jira] [Commented] (FLINK-21373) Port RabbitMQ Sink to FLIP-143 API

[ https://issues.apache.org/jira/browse/FLINK-21373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17454587#comment-17454587 ] ZhuoYu Chen commented on FLINK-21373: - [~westphal-jan] Hello, I would like to know how is the

[jira] [Commented] (FLINK-24483) Document what is Public API and what compatibility guarantees Flink is providing

[ https://issues.apache.org/jira/browse/FLINK-24483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17454581#comment-17454581 ] ZhuoYu Chen commented on FLINK-24483: - [~trohrmann] Is this current issue to be a document? >

[jira] [Commented] (FLINK-25187) Apply padding for BINARY()

[ https://issues.apache.org/jira/browse/FLINK-25187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17454543#comment-17454543 ] ZhuoYu Chen commented on FLINK-25187: - Hi [~matriv]   I am very interested in this，and I want do

[jira] [Commented] (FLINK-7129) Support dynamically changing CEP patterns

[ https://issues.apache.org/jira/browse/FLINK-7129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17454527#comment-17454527 ] ZhuoYu Chen commented on FLINK-7129: Hi Dawid Wysakowicz , I'm interested to see the question you

[jira] [Created] (FLINK-25208) AsyncSink\Source lock of documentation or Blog

ZhuoYu Chen created FLINK-25208: --- Summary: AsyncSink\Source lock of documentation or Blog Key: FLINK-25208 URL: https://issues.apache.org/jira/browse/FLINK-25208 Project: Flink Issue Type:

[jira] [Commented] (FLINK-25196) Add Documentation for Data Sink

[ https://issues.apache.org/jira/browse/FLINK-25196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17454511#comment-17454511 ] ZhuoYu Chen commented on FLINK-25196: - [~MartijnVisser]  The sink part is missing > Add

[jira] [Comment Edited] (FLINK-25196) Add Documentation for Data Sink

[ https://issues.apache.org/jira/browse/FLINK-25196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17454509#comment-17454509 ] ZhuoYu Chen edited comment on FLINK-25196 at 12/7/21, 9:51 AM: ---

[jira] [Comment Edited] (FLINK-25196) Add Documentation for Data Sink

[ https://issues.apache.org/jira/browse/FLINK-25196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17454509#comment-17454509 ] ZhuoYu Chen edited comment on FLINK-25196 at 12/7/21, 9:49 AM: ---

[jira] [Commented] (FLINK-25196) Add Documentation for Data Sink

[ https://issues.apache.org/jira/browse/FLINK-25196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17454509#comment-17454509 ] ZhuoYu Chen commented on FLINK-25196: - [~MartijnVisser]  > Add Documentation for Data Sink >

[jira] [Commented] (FLINK-25158) Fix formatting for true, false and null to uppercase

[ https://issues.apache.org/jira/browse/FLINK-25158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17454072#comment-17454072 ] ZhuoYu Chen commented on FLINK-25158: - Hi [~slinkydeveloper] I am very interested in this，and I want

[jira] [Commented] (FLINK-25187) Apply padding for BINARY()

[ https://issues.apache.org/jira/browse/FLINK-25187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17454069#comment-17454069 ] ZhuoYu Chen commented on FLINK-25187: - [~matriv] Can you briefly describe the problem?   > Apply

[jira] [Commented] (FLINK-25154) FLIP-193: Snapshots ownership

[ https://issues.apache.org/jira/browse/FLINK-25154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17454067#comment-17454067 ] ZhuoYu Chen commented on FLINK-25154: - Hi [~dwysakowicz]  , I was interested to see the question you

[jira] [Comment Edited] (FLINK-25152) FLIP-188: Introduce Built-in Dynamic Table Storage

[ https://issues.apache.org/jira/browse/FLINK-25152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17454064#comment-17454064 ] ZhuoYu Chen edited comment on FLINK-25152 at 12/6/21, 3:07 PM: --- Hi

[jira] [Commented] (FLINK-25152) FLIP-188: Introduce Built-in Dynamic Table Storage

[ https://issues.apache.org/jira/browse/FLINK-25152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17454064#comment-17454064 ] ZhuoYu Chen commented on FLINK-25152: - Hello [~lzljs3620320] , I was interested to see the issues

[jira] [Commented] (FLINK-25173) Introduce CatalogLock

[ https://issues.apache.org/jira/browse/FLINK-25173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17454061#comment-17454061 ] ZhuoYu Chen commented on FLINK-25173: - Hi [~lzljs3620320]  I am very interested in this，and I want

[jira] [Commented] (FLINK-25169) CsvFileSystemFormatFactory#CsvInputFormat supports recursion

[ https://issues.apache.org/jira/browse/FLINK-25169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17454059#comment-17454059 ] ZhuoYu Chen commented on FLINK-25169: - [~Bo Cui] By recursive support, are you recursively reading

[jira] [Updated] (FLINK-25196) Add Documentation for Data Sink

[ https://issues.apache.org/jira/browse/FLINK-25196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ZhuoYu Chen updated FLINK-25196: Description: FLIP-143 ：Unified Sink API Documentataion h1. > Add Documentation for Data Sink >

[jira] [Created] (FLINK-25196) Add Documentation for Data Sink

ZhuoYu Chen created FLINK-25196: --- Summary: Add Documentation for Data Sink Key: FLINK-25196 URL: https://issues.apache.org/jira/browse/FLINK-25196 Project: Flink Issue Type: Improvement

[jira] [Comment Edited] (FLINK-20188) Add Documentation for new File Source

[ https://issues.apache.org/jira/browse/FLINK-20188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17454003#comment-17454003 ] ZhuoYu Chen edited comment on FLINK-20188 at 12/6/21, 12:58 PM:

[jira] [Commented] (FLINK-20188) Add Documentation for new File Source

[ https://issues.apache.org/jira/browse/FLINK-20188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17454003#comment-17454003 ] ZhuoYu Chen commented on FLINK-20188: - Then let's set the 15th of December, do you think it's okay?

[jira] [Commented] (FLINK-25170) cep supports dynamic rule updates

[ https://issues.apache.org/jira/browse/FLINK-25170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17454000#comment-17454000 ] ZhuoYu Chen commented on FLINK-25170: - [~nicholasjiang] I have always believed that flink's cep is

[jira] [Commented] (FLINK-25170) cep supports dynamic rule updates

[ https://issues.apache.org/jira/browse/FLINK-25170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17453999#comment-17453999 ] ZhuoYu Chen commented on FLINK-25170: - [~nicholasjiang] If there is a need, I am willing to help

[jira] [Commented] (FLINK-20188) Add Documentation for new File Source

[ https://issues.apache.org/jira/browse/FLINK-20188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17453995#comment-17453995 ] ZhuoYu Chen commented on FLINK-20188: - [~MartijnVisser] I hope you can give me your advice. I will

[jira] [Commented] (FLINK-25170) cep supports dynamic rule updates

[ https://issues.apache.org/jira/browse/FLINK-25170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17453768#comment-17453768 ] ZhuoYu Chen commented on FLINK-25170: - The application of flink in the business layer has a broad

[jira] [Updated] (FLINK-25170) cep supports dynamic rule updates

[ https://issues.apache.org/jira/browse/FLINK-25170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ZhuoYu Chen updated FLINK-25170: Description: External loading: Usually the rule engine has a special rule management module to

[jira] [Updated] (FLINK-25170) cep supports dynamic rule updates

[ https://issues.apache.org/jira/browse/FLINK-25170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ZhuoYu Chen updated FLINK-25170: Description: External loading: Usually the rule engine has a special rule management module to

[jira] [Updated] (FLINK-25170) cep supports dynamic rule updates

[ https://issues.apache.org/jira/browse/FLINK-25170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ZhuoYu Chen updated FLINK-25170: Description: External loading: Usually the rule engine has a special rule management module to

[jira] [Created] (FLINK-25170) cep supports dynamic rule updates

ZhuoYu Chen created FLINK-25170: --- Summary: cep supports dynamic rule updates Key: FLINK-25170 URL: https://issues.apache.org/jira/browse/FLINK-25170 Project: Flink Issue Type: New Feature

[jira] [Commented] (FLINK-13395) Add source and sink connector for Alibaba Log Service

[ https://issues.apache.org/jira/browse/FLINK-13395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17452771#comment-17452771 ] ZhuoYu Chen commented on FLINK-13395: - Hi [~liketic]  I am very interested in this，and I want do

[jira] [Commented] (FLINK-24152) Exactly-once semantics should be configurable through Flink configuration only

[ https://issues.apache.org/jira/browse/FLINK-24152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17452768#comment-17452768 ] ZhuoYu Chen commented on FLINK-24152: - Hi [~mapohl]  I am very interested in this，and I want do some

[jira] [Commented] (FLINK-24396) Add @Public annotations to Table & SQL API classes

[ https://issues.apache.org/jira/browse/FLINK-24396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17452765#comment-17452765 ] ZhuoYu Chen commented on FLINK-24396: - [~twalthr] One module, one subtask? > Add @Public

[jira] [Updated] (FLINK-24959) Add a BitMap function to FlinkSQL

[ https://issues.apache.org/jira/browse/FLINK-24959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ZhuoYu Chen updated FLINK-24959: Description: BITMAP_AND :{color:#33}Computes the intersection of two input bitmaps and

[jira] [Updated] (FLINK-24959) Add a BitMap function to FlinkSQL

[ https://issues.apache.org/jira/browse/FLINK-24959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ZhuoYu Chen updated FLINK-24959: Description: BITMAP_AND :{color:#33}Computes the intersection of two input bitmaps and

[jira] [Comment Edited] (FLINK-24959) Add a BitMap function to FlinkSQL

[ https://issues.apache.org/jira/browse/FLINK-24959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17452755#comment-17452755 ] ZhuoYu Chen edited comment on FLINK-24959 at 12/3/21, 5:12 AM: --- hi [~jark]

[jira] [Commented] (FLINK-24959) Add a BitMap function to FlinkSQL

[ https://issues.apache.org/jira/browse/FLINK-24959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17452755#comment-17452755 ] ZhuoYu Chen commented on FLINK-24959: - hi [~jark] clickhouse，starRocks，doris all support bitmap

[jira] [Commented] (FLINK-20873) Upgrade Calcite version to 1.27

[ https://issues.apache.org/jira/browse/FLINK-20873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17452753#comment-17452753 ] ZhuoYu Chen commented on FLINK-20873: - [~jark] Are there still plans for this to go ahead? If there

[jira] [Commented] (FLINK-12429) Translate the "Generating Timestamps / Watermarks" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-12429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17452752#comment-17452752 ] ZhuoYu Chen commented on FLINK-12429: - Hi [~jark]   I am very interested in this，and I want do some

[jira] [Commented] (FLINK-17203) Add metrics for ClickHouse sink

[ https://issues.apache.org/jira/browse/FLINK-17203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17452747#comment-17452747 ] ZhuoYu Chen commented on FLINK-17203: - Hi [~csbliss]  I am very interested in this，and I want do

[jira] [Commented] (FLINK-17202) Add SQL for ClickHouse connector

[ https://issues.apache.org/jira/browse/FLINK-17202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17452745#comment-17452745 ] ZhuoYu Chen commented on FLINK-17202: - Hi [~csbliss]  I am very interested in this，and I want do

[jira] [Commented] (FLINK-17201) Implement Streaming ClickHouseSink

[ https://issues.apache.org/jira/browse/FLINK-17201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17452746#comment-17452746 ] ZhuoYu Chen commented on FLINK-17201: - Hi [~csbliss]  I am very interested in this，and I want do

[jira] [Comment Edited] (FLINK-24103) Create time-based LAST_VALUE / FIRST_VALUE

[ https://issues.apache.org/jira/browse/FLINK-24103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17452738#comment-17452738 ] ZhuoYu Chen edited comment on FLINK-24103 at 12/3/21, 4:21 AM: --- Hi

[jira] [Commented] (FLINK-24103) Create time-based LAST_VALUE / FIRST_VALUE

[ https://issues.apache.org/jira/browse/FLINK-24103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17452738#comment-17452738 ] ZhuoYu Chen commented on FLINK-24103: - [~twalthr]  我对这个非常感兴趣，我想为flink做一些工作，我可以帮助做吗？ 谢谢你 > Create

[jira] [Commented] (FLINK-24900) Support to run multiple shuffle plugins in one session cluster

[ https://issues.apache.org/jira/browse/FLINK-24900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17452737#comment-17452737 ] ZhuoYu Chen commented on FLINK-24900: - Hi [~kevin.cyj]  I am very interested in this，and I want do

[jira] [Comment Edited] (FLINK-24103) Create time-based LAST_VALUE / FIRST_VALUE

[ https://issues.apache.org/jira/browse/FLINK-24103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17452738#comment-17452738 ] ZhuoYu Chen edited comment on FLINK-24103 at 12/3/21, 4:20 AM: ---

[jira] [Commented] (FLINK-24103) Create time-based LAST_VALUE / FIRST_VALUE

[ https://issues.apache.org/jira/browse/FLINK-24103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17452736#comment-17452736 ] ZhuoYu Chen commented on FLINK-24103: - [~twalthr] Is there a result of the discussion now? > Create

[jira] [Commented] (FLINK-24910) Propagate the Calcite parser config to SQL Client

[ https://issues.apache.org/jira/browse/FLINK-24910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17452734#comment-17452734 ] ZhuoYu Chen commented on FLINK-24910: - Hi [~Sergey Nuyanzin] I am very interested in this，and I want

[jira] [Commented] (FLINK-20188) Add Documentation for new File Source

[ https://issues.apache.org/jira/browse/FLINK-20188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17452250#comment-17452250 ] ZhuoYu Chen commented on FLINK-20188: - [~MartijnVisser] I am very sorry that I just started this

[jira] [Commented] (FLINK-15571) Create a Redis Streams Connector for Flink

[ https://issues.apache.org/jira/browse/FLINK-15571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17448391#comment-17448391 ] ZhuoYu Chen commented on FLINK-15571: - [~yunta] Thank you for your reply, I think you can assign

[jira] [Commented] (FLINK-24396) Add @Public annotations to Table & SQL API classes

[ https://issues.apache.org/jira/browse/FLINK-24396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17448377#comment-17448377 ] ZhuoYu Chen commented on FLINK-24396: - Hi [~twalthr] I am very interested in this，and I want do some

[jira] [Commented] (FLINK-24429) Port FileSystemTableSink to new Unified Sink API (FLIP-143)

[ https://issues.apache.org/jira/browse/FLINK-24429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17448376#comment-17448376 ] ZhuoYu Chen commented on FLINK-24429: - Hi [~alexanderpreuss] I am very interested in this，and I want

[jira] [Commented] (FLINK-24959) Add a BitMap function to FlinkSQL

[ https://issues.apache.org/jira/browse/FLINK-24959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17448374#comment-17448374 ] ZhuoYu Chen commented on FLINK-24959: - Hi [~jark] I am very interested in this，and I want do some

[jira] [Commented] (FLINK-15571) Create a Redis Streams Connector for Flink

[ https://issues.apache.org/jira/browse/FLINK-15571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17448340#comment-17448340 ] ZhuoYu Chen commented on FLINK-15571: - Hi [~yunta]，[~tgrall]  I am very interested in this，and I

[jira] [Commented] (FLINK-12941) Translate "Amazon AWS Kinesis Streams Connector" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-12941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17447787#comment-17447787 ] ZhuoYu Chen commented on FLINK-12941: - Hi [~jark] I am very interested in this，and I want do some

[jira] [Commented] (FLINK-24696) Translate how to configure unaligned checkpoints into Chinese

[ https://issues.apache.org/jira/browse/FLINK-24696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17447786#comment-17447786 ] ZhuoYu Chen commented on FLINK-24696: - Hi [~pnowojski]  , I am very interested in this，and I want do

[jira] [Commented] (FLINK-24456) Support bounded offset in the Kafka table connector

[ https://issues.apache.org/jira/browse/FLINK-24456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17446832#comment-17446832 ] ZhuoYu Chen commented on FLINK-24456: - [~wheat9] Hello, I have started to modify the code. Due to

[jira] [Created] (FLINK-24959) Add a BitMap function to FlinkSQL

ZhuoYu Chen created FLINK-24959: --- Summary: Add a BitMap function to FlinkSQL Key: FLINK-24959 URL: https://issues.apache.org/jira/browse/FLINK-24959 Project: Flink Issue Type: New Feature

[jira] [Commented] (FLINK-6573) Flink MongoDB Connector

[ https://issues.apache.org/jira/browse/FLINK-6573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17445175#comment-17445175 ] ZhuoYu Chen commented on FLINK-6573: {color:#4a90e2}[~arvid]  {color:#33}Ok, I will submit the

[jira] [Commented] (FLINK-20188) Add Documentation for new File Source

[ https://issues.apache.org/jira/browse/FLINK-20188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17445174#comment-17445174 ] ZhuoYu Chen commented on FLINK-20188: - {color:#33}[~sewen] Thank you for sharing, I am currently

[jira] [Commented] (FLINK-20188) Add Documentation for new File Source

[ https://issues.apache.org/jira/browse/FLINK-20188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17444257#comment-17444257 ] ZhuoYu Chen commented on FLINK-20188: - !image-2021-11-16-11-42-32-957.png! Is it the document that 

  1   2   >