[jira] [Commented] (FLINK-16966) Convert InfluxDB reporter to plugin

[ https://issues.apache.org/jira/browse/FLINK-16966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17084497#comment-17084497 ] xingyuan cheng commented on FLINK-16966: I don't think anybody is working on thi

[jira] [Created] (FLINK-17304) Kafka two streams cannot use Flink SQL to query inner join

xingyuan cheng created FLINK-17304: -- Summary: Kafka two streams cannot use Flink SQL to query inner join Key: FLINK-17304 URL: https://issues.apache.org/jira/browse/FLINK-17304 Project: Flink

[jira] [Commented] (FLINK-17519) Add Java State Bootstrapping E2E test for Stateful Functions

[ https://issues.apache.org/jira/browse/FLINK-17519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17108700#comment-17108700 ] xingyuan cheng commented on FLINK-17519: Hello, further explanation. If I need t

[jira] [Commented] (FLINK-17737) KeyedStateCheckpointingITCase fails in UC mode

[ https://issues.apache.org/jira/browse/FLINK-17737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17108703#comment-17108703 ] xingyuan cheng commented on FLINK-17737: Hello, please explain further what the

[jira] [Commented] (FLINK-16966) Convert InfluxDB reporter to plugin

[ https://issues.apache.org/jira/browse/FLINK-16966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17092421#comment-17092421 ] xingyuan cheng commented on FLINK-16966: Before working overtime in the company,

[jira] [Commented] (FLINK-16966) Convert InfluxDB reporter to plugin

[ https://issues.apache.org/jira/browse/FLINK-16966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17092554#comment-17092554 ] xingyuan cheng commented on FLINK-16966: [[|https://issues.apache.org/jira/secur

[jira] [Commented] (FLINK-23486) Add monitoring/metrics for the ChangelogStateBackend

[ https://issues.apache.org/jira/browse/FLINK-23486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17388134#comment-17388134 ] xingyuan cheng commented on FLINK-23486: [~roman_khachatryan] Hello, it seems th

[jira] [Commented] (FLINK-23484) Add benchmarks for the ChangelogStateBackend

[ https://issues.apache.org/jira/browse/FLINK-23484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17388141#comment-17388141 ] xingyuan cheng commented on FLINK-23484: [~roman_khachatryan] I hope to particip

[jira] [Commented] (FLINK-23731) Streaming File Sink s3 end-to-end test fail due to timeout

[ https://issues.apache.org/jira/browse/FLINK-23731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17397760#comment-17397760 ] xingyuan cheng commented on FLINK-23731: > Streaming File Sink s3 end-to-end t

[jira] [Commented] (FLINK-23486) Add monitoring/metrics for the ChangelogStateBackend

[ https://issues.apache.org/jira/browse/FLINK-23486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17418415#comment-17418415 ] xingyuan cheng commented on FLINK-23486: Hello, it seems that we need to add som

[jira] [Commented] (FLINK-18202) Introduce Protobuf format

[ https://issues.apache.org/jira/browse/FLINK-18202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17443014#comment-17443014 ] xingyuan cheng commented on FLINK-18202: cc [~jark] [~maosuhan] [~libenchao]  H

[jira] [Commented] (FLINK-27815) Improve the join reorder strategy for batch sql job

[ https://issues.apache.org/jira/browse/FLINK-27815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17692447#comment-17692447 ] xingyuan cheng commented on FLINK-27815: Hello [~godfreyhe] , I have two questio

[jira] [Comment Edited] (FLINK-27815) Improve the join reorder strategy for batch sql job

[ https://issues.apache.org/jira/browse/FLINK-27815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17692447#comment-17692447 ] xingyuan cheng edited comment on FLINK-27815 at 2/23/23 2:12 AM: -

[jira] [Comment Edited] (FLINK-27815) Improve the join reorder strategy for batch sql job

[ https://issues.apache.org/jira/browse/FLINK-27815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17692447#comment-17692447 ] xingyuan cheng edited comment on FLINK-27815 at 2/23/23 2:15 AM: -

[jira] [Comment Edited] (FLINK-27815) Improve the join reorder strategy for batch sql job

[ https://issues.apache.org/jira/browse/FLINK-27815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17692447#comment-17692447 ] xingyuan cheng edited comment on FLINK-27815 at 2/23/23 2:15 AM: -

[jira] [Created] (FLINK-28009) Optimize data split

xingyuan cheng created FLINK-28009: -- Summary: Optimize data split Key: FLINK-28009 URL: https://issues.apache.org/jira/browse/FLINK-28009 Project: Flink Issue Type: Improvement Com

[jira] [Updated] (FLINK-28009) Optimize data split

[ https://issues.apache.org/jira/browse/FLINK-28009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xingyuan cheng updated FLINK-28009: --- Description: Optimizing split data logic for large data volumes using parallel streams http

[jira] [Commented] (FLINK-27845) Introduce Column Type Schema evolution

[ https://issues.apache.org/jira/browse/FLINK-27845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17553442#comment-17553442 ] xingyuan cheng commented on FLINK-27845: Can i ask to me some details? i want to

[jira] [Comment Edited] (FLINK-27845) Introduce Column Type Schema evolution

[ https://issues.apache.org/jira/browse/FLINK-27845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17553442#comment-17553442 ] xingyuan cheng edited comment on FLINK-27845 at 6/13/22 8:40 AM: -

[jira] [Comment Edited] (FLINK-27845) Introduce Column Type Schema evolution

[ https://issues.apache.org/jira/browse/FLINK-27845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17553442#comment-17553442 ] xingyuan cheng edited comment on FLINK-27845 at 6/13/22 8:41 AM: -

[jira] [Commented] (FLINK-27845) Introduce Column Type Schema evolution

[ https://issues.apache.org/jira/browse/FLINK-27845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17553485#comment-17553485 ] xingyuan cheng commented on FLINK-27845: Please assign me > Introduce Column Ty

[jira] [Commented] (FLINK-27708) Add background compaction task for append-only table when ingesting.

[ https://issues.apache.org/jira/browse/FLINK-27708?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17555851#comment-17555851 ] xingyuan cheng commented on FLINK-27708: I want to try to do this work. There ar

[jira] [Commented] (FLINK-28110) Table Store Hive Reader supports projection pushdown

[ https://issues.apache.org/jira/browse/FLINK-28110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17555878#comment-17555878 ] xingyuan cheng commented on FLINK-28110: Maybe we need to use FilterUtils.isReta

[jira] [Comment Edited] (FLINK-28110) Table Store Hive Reader supports projection pushdown

[ https://issues.apache.org/jira/browse/FLINK-28110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17555878#comment-17555878 ] xingyuan cheng edited comment on FLINK-28110 at 6/18/22 10:12 AM:

[jira] [Comment Edited] (FLINK-28110) Table Store Hive Reader supports projection pushdown

[ https://issues.apache.org/jira/browse/FLINK-28110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17555878#comment-17555878 ] xingyuan cheng edited comment on FLINK-28110 at 6/18/22 10:13 AM:

[jira] [Commented] (FLINK-28110) Table Store Hive Reader supports projection pushdown

[ https://issues.apache.org/jira/browse/FLINK-28110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17555881#comment-17555881 ] xingyuan cheng commented on FLINK-28110: I will try to perfect this feature > T

[jira] [Comment Edited] (FLINK-28110) Table Store Hive Reader supports projection pushdown

[ https://issues.apache.org/jira/browse/FLINK-28110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17555878#comment-17555878 ] xingyuan cheng edited comment on FLINK-28110 at 6/18/22 10:39 AM:

[jira] [Commented] (FLINK-28552) GenerateUtils#generateCompare supports MULTISET and MAP

[ https://issues.apache.org/jira/browse/FLINK-28552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17573336#comment-17573336 ] xingyuan cheng commented on FLINK-28552: I would like to try to tease out the ba

[jira] [Commented] (FLINK-26937) Introduce Leveled compression for LSM

[ https://issues.apache.org/jira/browse/FLINK-26937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17573335#comment-17573335 ] xingyuan cheng commented on FLINK-26937: I would like to try to tease out the ba

[jira] [Commented] (FLINK-22725) SlotManagers should unregister metrics at the start of suspend()

[ https://issues.apache.org/jira/browse/FLINK-22725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17348539#comment-17348539 ] xingyuan cheng commented on FLINK-22725: i can do it > SlotManagers should unre

[jira] [Commented] (FLINK-22726) Hive GROUPING__ID returns different value in older versions

[ https://issues.apache.org/jira/browse/FLINK-22726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17348591#comment-17348591 ] xingyuan cheng commented on FLINK-22726: i can do it > Hive GROUPING__ID return

[jira] [Issue Comment Deleted] (FLINK-22726) Hive GROUPING__ID returns different value in older versions

[ https://issues.apache.org/jira/browse/FLINK-22726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xingyuan cheng updated FLINK-22726: --- Comment: was deleted (was: i can do it) > Hive GROUPING__ID returns different value in olde

[jira] [Commented] (FLINK-22762) cannot use set table.sql-dialect=hive;

[ https://issues.apache.org/jira/browse/FLINK-22762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17350731#comment-17350731 ] xingyuan cheng commented on FLINK-22762: I will pay attention to this issue > c

[jira] [Created] (FLINK-22817) About flink1.13 hive integration Kafka SQL

xingyuan cheng created FLINK-22817: -- Summary: About flink1.13 hive integration Kafka SQL Key: FLINK-22817 URL: https://issues.apache.org/jira/browse/FLINK-22817 Project: Flink Issue Type: N

[jira] [Updated] (FLINK-22817) About flink1.13 hive integration Kafka SQL

[ https://issues.apache.org/jira/browse/FLINK-22817?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xingyuan cheng updated FLINK-22817: --- Description: Hello everyone At present, there are codes that depend on hive in many places

[jira] [Commented] (FLINK-22817) About flink1.13 hive integration Kafka SQL

[ https://issues.apache.org/jira/browse/FLINK-22817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17354985#comment-17354985 ] xingyuan cheng commented on FLINK-22817: [~joemoe] OK, I will migrate the propos

[jira] [Commented] (FLINK-23486) Add metrics for the ChangelogStateBackend

[ https://issues.apache.org/jira/browse/FLINK-23486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17427466#comment-17427466 ] xingyuan cheng commented on FLINK-23486: [~roman] 我可以理解这个要求类似于https://github.co

[jira] [Comment Edited] (FLINK-23486) Add metrics for the ChangelogStateBackend

[ https://issues.apache.org/jira/browse/FLINK-23486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17427466#comment-17427466 ] xingyuan cheng edited comment on FLINK-23486 at 10/14/21, 3:37 AM: ---

[jira] [Commented] (FLINK-31030) Support more binary classification evaluation metrics.

[ https://issues.apache.org/jira/browse/FLINK-31030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1776#comment-1776 ] xingyuan cheng commented on FLINK-31030: I am interested in this, and I will sta

[jira] [Created] (FLINK-31530) For currently commonly used databases, MySQL and Postgres have implemented catalogs. Currently, catalogs are implemented based on Oracle

xingyuan cheng created FLINK-31530: -- Summary: For currently commonly used databases, MySQL and Postgres have implemented catalogs. Currently, catalogs are implemented based on Oracle Key: FLINK-31530 URL: https:/

[jira] [Commented] (FLINK-31530) For currently commonly used databases, MySQL and Postgres have implemented catalogs. Currently, catalogs are implemented based on Oracle

[ https://issues.apache.org/jira/browse/FLINK-31530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17709170#comment-17709170 ] xingyuan cheng commented on FLINK-31530: [~jark] Hello, when we implement the CD

[jira] [Commented] (FLINK-31530) For currently commonly used databases, MySQL and Postgres have implemented catalogs. Currently, catalogs are implemented based on Oracle

[ https://issues.apache.org/jira/browse/FLINK-31530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17710849#comment-17710849 ] xingyuan cheng commented on FLINK-31530: [~martijnvisser] Thank you for telling

[jira] [Comment Edited] (FLINK-31530) For currently commonly used databases, MySQL and Postgres have implemented catalogs. Currently, catalogs are implemented based on Oracle

[ https://issues.apache.org/jira/browse/FLINK-31530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17710849#comment-17710849 ] xingyuan cheng edited comment on FLINK-31530 at 4/11/23 9:43 AM: -

[jira] [Comment Edited] (FLINK-31530) For currently commonly used databases, MySQL and Postgres have implemented catalogs. Currently, catalogs are implemented based on Oracle

[ https://issues.apache.org/jira/browse/FLINK-31530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17710849#comment-17710849 ] xingyuan cheng edited comment on FLINK-31530 at 4/11/23 10:03 AM:

[jira] [Commented] (FLINK-31530) For currently commonly used databases, MySQL and Postgres have implemented catalogs. Currently, catalogs are implemented based on Oracle

[ https://issues.apache.org/jira/browse/FLINK-31530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17711649#comment-17711649 ] xingyuan cheng commented on FLINK-31530: The use of OracleCatalog is similar to

[jira] [Created] (FLINK-31820) Support data source sub-database and sub-table

xingyuan cheng created FLINK-31820: -- Summary: Support data source sub-database and sub-table Key: FLINK-31820 URL: https://issues.apache.org/jira/browse/FLINK-31820 Project: Flink Issue Type

[jira] [Updated] (FLINK-31530) For currently commonly used databases, MySQL and Postgres have implemented catalogs. Currently, catalogs are implemented based on Oracle

[ https://issues.apache.org/jira/browse/FLINK-31530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xingyuan cheng updated FLINK-31530: --- Description: The use of OracleCatalog is similar to that of official PostgreSQL, you can re

[jira] [Updated] (FLINK-31820) Support data source sub-database and sub-table

[ https://issues.apache.org/jira/browse/FLINK-31820?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xingyuan cheng updated FLINK-31820: --- Description: At present, apache/flink-connector-jdbc does not support sub-database and table

[jira] [Commented] (FLINK-31820) Support data source sub-database and sub-table

[ https://issues.apache.org/jira/browse/FLINK-31820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17719641#comment-17719641 ] xingyuan cheng commented on FLINK-31820: [~martijnvisser] Hello, sorry for the l

[jira] [Comment Edited] (FLINK-31820) Support data source sub-database and sub-table

[ https://issues.apache.org/jira/browse/FLINK-31820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17719641#comment-17719641 ] xingyuan cheng edited comment on FLINK-31820 at 5/5/23 5:59 AM: --

[jira] [Comment Edited] (FLINK-31820) Support data source sub-database and sub-table

[ https://issues.apache.org/jira/browse/FLINK-31820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17719641#comment-17719641 ] xingyuan cheng edited comment on FLINK-31820 at 5/5/23 6:00 AM: --

[jira] [Comment Edited] (FLINK-31820) Support data source sub-database and sub-table

[ https://issues.apache.org/jira/browse/FLINK-31820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17719641#comment-17719641 ] xingyuan cheng edited comment on FLINK-31820 at 5/5/23 6:00 AM: --

[jira] [Comment Edited] (FLINK-31820) Support data source sub-database and sub-table

[ https://issues.apache.org/jira/browse/FLINK-31820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17719641#comment-17719641 ] xingyuan cheng edited comment on FLINK-31820 at 5/5/23 6:03 AM: --

[jira] [Commented] (FLINK-16713) Support source mode of elasticsearch connector

[ https://issues.apache.org/jira/browse/FLINK-16713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17721135#comment-17721135 ] xingyuan cheng commented on FLINK-16713: Hi, community. It seems that this issue

[jira] [Commented] (FLINK-25568) Add Elasticsearch 7 Source Connector

[ https://issues.apache.org/jira/browse/FLINK-25568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17721136#comment-17721136 ] xingyuan cheng commented on FLINK-25568: Hi, community. It seems that this issue