[jira] [Updated] (FLINK-34964) ScheduledTask leak in registering the processing timer

2024-03-29 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zoucao updated FLINK-34964: --- Description: I have come across a problem regarding a leak in the 'ScheduledTask' while registering the

[jira] [Updated] (FLINK-34964) ScheduledTask leak in registering the processing timer

2024-03-29 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zoucao updated FLINK-34964: --- Description: I have come across a problem regarding a leak in the 'ScheduledTask' while registering the

[jira] [Updated] (FLINK-34964) ScheduledTask leak in registering the processing timer

2024-03-29 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zoucao updated FLINK-34964: --- Description: I have come across a problem regarding a leak in the 'ScheduledTask' while registering the

[jira] [Updated] (FLINK-34964) ScheduledTask leak in registering the processing timer

2024-03-29 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zoucao updated FLINK-34964: --- Description: I have come across a problem regarding a leak in the 'ScheduledTask' while registering the

[jira] [Updated] (FLINK-34964) ScheduledTask leak in registering the processing timer

2024-03-29 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zoucao updated FLINK-34964: --- Description: I have come across a problem regarding a leak in the 'ScheduledTask' while registering the

[jira] [Created] (FLINK-34964) ScheduledTask leak in registering the processing timer

2024-03-29 Thread zoucao (Jira)
zoucao created FLINK-34964: -- Summary: ScheduledTask leak in registering the processing timer Key: FLINK-34964 URL: https://issues.apache.org/jira/browse/FLINK-34964 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-28414) Using flink to query the hive table, an exception occurred, SQL validation failed. Failed to get table schema from deserializer

2022-07-06 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17562986#comment-17562986 ] zoucao commented on FLINK-28414: Hi, could you check whether the dependency of

[jira] [Commented] (FLINK-27953) using the original order to add the primary key in PushProjectIntoTableSourceScanRule

2022-06-20 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17556639#comment-17556639 ] zoucao commented on FLINK-27953: Hi [~xuyangzhong], thanks for your feedback, I have just started to

[jira] [Commented] (FLINK-27898) fix PartitionPushDown in streaming mode for hive source

2022-06-20 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17556225#comment-17556225 ] zoucao commented on FLINK-27898: Hi [~luoyuxia], I think you're right, if we choose the second way, a

[jira] [Comment Edited] (FLINK-27953) using the original order to add the primary key in PushProjectIntoTableSourceScanRule

2022-06-15 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17554894#comment-17554894 ] zoucao edited comment on FLINK-27953 at 6/16/22 3:57 AM: - Hi [~godfreyhe], could

[jira] [Commented] (FLINK-27953) using the original order to add the primary key in PushProjectIntoTableSourceScanRule

2022-06-15 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17554894#comment-17554894 ] zoucao commented on FLINK-27953: Hi [~godfrey], could you have time to take a look? > using the

[jira] [Commented] (FLINK-27898) fix PartitionPushDown in streaming mode for hive source

2022-06-09 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17552520#comment-17552520 ] zoucao commented on FLINK-27898: Hi, [~luoyuxia], before opening a pr, I think we should discuss how to

[jira] [Created] (FLINK-27953) using the original order to add the primary key in PushProjectIntoTableSourceScanRule

2022-06-08 Thread zoucao (Jira)
zoucao created FLINK-27953: -- Summary: using the original order to add the primary key in PushProjectIntoTableSourceScanRule Key: FLINK-27953 URL: https://issues.apache.org/jira/browse/FLINK-27953 Project:

[jira] [Comment Edited] (FLINK-27898) fix PartitionPushDown in streaming mode for hive source

2022-06-07 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17551373#comment-17551373 ] zoucao edited comment on FLINK-27898 at 6/8/22 3:26 AM: Hi [~luoyuxia], I think

[jira] [Commented] (FLINK-27898) fix PartitionPushDown in streaming mode for hive source

2022-06-07 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17551373#comment-17551373 ] zoucao commented on FLINK-27898: Hi [~luoyuxia], I think this problem only exists in the hive source for

[jira] [Updated] (FLINK-27911) Set HDFS LEASE_TIMEOUT as user-configurable

2022-06-07 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zoucao updated FLINK-27911: --- Component/s: FileSystems > Set HDFS LEASE_TIMEOUT as user-configurable >

[jira] [Updated] (FLINK-27898) fix PartitionPushDown in streaming mode for hive source

2022-06-07 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zoucao updated FLINK-27898: --- Description: In hive source, the PartitionPushDown will cause some problems in streaming-mode, we can add

[jira] [Updated] (FLINK-27911) Set HDFS LEASE_TIMEOUT as user-configurable

2022-06-06 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zoucao updated FLINK-27911: --- Affects Version/s: 1.14.4 > Set HDFS LEASE_TIMEOUT as user-configurable >

[jira] [Created] (FLINK-27911) Set HDFS LEASE_TIMEOUT as user-configurable

2022-06-06 Thread zoucao (Jira)
zoucao created FLINK-27911: -- Summary: Set HDFS LEASE_TIMEOUT as user-configurable Key: FLINK-27911 URL: https://issues.apache.org/jira/browse/FLINK-27911 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-27898) fix PartitionPushDown in streaming mode for hive source

2022-06-05 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17550282#comment-17550282 ] zoucao commented on FLINK-27898: cc [~luoyuxia], [~lzljs3620320], plz help me to confirm it, and if the

[jira] [Updated] (FLINK-27898) fix PartitionPushDown in streaming mode for hive source

2022-06-05 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zoucao updated FLINK-27898: --- Description: In hive source, the PartitionPushDown will cause some problems in streaming-mode, we can add

[jira] [Created] (FLINK-27898) fix PartitionPushDown in streaming mode for hive source

2022-06-05 Thread zoucao (Jira)
zoucao created FLINK-27898: -- Summary: fix PartitionPushDown in streaming mode for hive source Key: FLINK-27898 URL: https://issues.apache.org/jira/browse/FLINK-27898 Project: Flink Issue Type: Bug

[jira] [Closed] (FLINK-26355) VarCharType was not be considered in HiveTableSqlFunction

2022-06-05 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zoucao closed FLINK-26355. -- Resolution: Fixed > VarCharType was not be considered in HiveTableSqlFunction >

[jira] [Commented] (FLINK-26355) VarCharType was not be considered in HiveTableSqlFunction

2022-06-05 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17550279#comment-17550279 ] zoucao commented on FLINK-26355: Thanks for your reminder, [~luoyuxia] > VarCharType was not be

[jira] [Commented] (FLINK-26761) Fix the cast exception thrown by PreValidateReWriter when insert into/overwrite a partitioned table.

2022-04-12 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17520941#comment-17520941 ] zoucao commented on FLINK-26761: Sure, [~godfreyhe], plz assign it to me. > Fix the cast exception

[jira] [Commented] (FLINK-27151) Group By Aggregation With Sorted Data

2022-04-10 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17520268#comment-17520268 ] zoucao commented on FLINK-27151: Do you mean ’agg_udf(field) WITHIN GROUP (ORDER BY field [ASC | DESC])‘

[jira] [Comment Edited] (FLINK-26982) strike a balance between reuse the same RelNode and project/filter/limit/partition push down

2022-04-01 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516221#comment-17516221 ] zoucao edited comment on FLINK-26982 at 4/2/22 5:25 AM: I think we can optimize

[jira] [Commented] (FLINK-26982) strike a balance between reuse the same RelNode and project/filter/limit/partition push down

2022-04-01 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516221#comment-17516221 ] zoucao commented on FLINK-26982: I think we can optimize it in 2 ways: 1). add a new method in Supports

[jira] [Commented] (FLINK-26945) Add DATE_SUB supported in SQL & Table API

2022-04-01 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516197#comment-17516197 ] zoucao commented on FLINK-26945: Looking forward to it, It is very useful. > Add DATE_SUB supported in

[jira] [Commented] (FLINK-26988) Better error reporting when format fails

2022-04-01 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17515883#comment-17515883 ] zoucao commented on FLINK-26988: Hi, [~slinkydeveloper], I'm interested in this ticket, would you mind

[jira] [Updated] (FLINK-26982) strike a balance between reuse the same RelNode and project/filter/limit/partition push down

2022-04-01 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zoucao updated FLINK-26982: --- Description: Now, Flink has effective reuse logic to reuse the same RelNode and subplan, but it will lose

[jira] [Created] (FLINK-26982) strike a balance between reuse the same RelNode and project/filter/limit/partition push down

2022-04-01 Thread zoucao (Jira)
zoucao created FLINK-26982: -- Summary: strike a balance between reuse the same RelNode and project/filter/limit/partition push down Key: FLINK-26982 URL: https://issues.apache.org/jira/browse/FLINK-26982

[jira] [Commented] (FLINK-26761) Fix the cast exception thrown by PreValidateReWriter when insert into/overwrite a partitioned table.

2022-03-25 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17512274#comment-17512274 ] zoucao commented on FLINK-26761: cc [~Leonard] , could you help me to confirm it, maybe Jack is too busy

[jira] [Commented] (FLINK-26726) Remove the unregistered task from readersAwaitingSplit

2022-03-21 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17509918#comment-17509918 ] zoucao commented on FLINK-26726: Hi, [~lzljs3620320] , I will fix it as soon as possiable. > Remove the

[jira] [Commented] (FLINK-26761) Fix the cast exception thrown by PreValidateReWriter when insert into/overwrite a partitioned table.

2022-03-21 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17509641#comment-17509641 ] zoucao commented on FLINK-26761: cc [~jark], could you help me to confirm it? > Fix the cast exception

[jira] [Created] (FLINK-26761) Fix the cast exception thrown by PreValidateReWriter when insert into/overwrite a partitioned table.

2022-03-21 Thread zoucao (Jira)
zoucao created FLINK-26761: -- Summary: Fix the cast exception thrown by PreValidateReWriter when insert into/overwrite a partitioned table. Key: FLINK-26761 URL: https://issues.apache.org/jira/browse/FLINK-26761

[jira] [Commented] (FLINK-26726) Remove the unregistered task from readersAwaitingSplit

2022-03-21 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17509628#comment-17509628 ] zoucao commented on FLINK-26726: Hi, [~lzljs3620320] , It is really fixed in

[jira] [Commented] (FLINK-26726) Remove the unregistered task from readersAwaitingSplit

2022-03-20 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17509555#comment-17509555 ] zoucao commented on FLINK-26726: Gentle ping [~lzljs3620320], could you help me to confirm it? The

[jira] [Commented] (FLINK-26723) Fix the content of exception in SourceCoordinatorContext

2022-03-18 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17508776#comment-17508776 ] zoucao commented on FLINK-26723: hi, [~becket_qin] , sure, I'd like to do it. > Fix the content of

[jira] [Comment Edited] (FLINK-26723) Fix the content of exception in SourceCoordinatorContext

2022-03-18 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17508657#comment-17508657 ] zoucao edited comment on FLINK-26723 at 3/18/22, 9:03 AM: -- Hi [~becket_qin],

[jira] [Commented] (FLINK-26723) Fix the content of exception in SourceCoordinatorContext

2022-03-18 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17508657#comment-17508657 ] zoucao commented on FLINK-26723: Hi [~jqin] , could you help me to confirm it? > Fix the content of

[jira] [Created] (FLINK-26726) Remove the unregistered task from readersAwaitingSplit

2022-03-18 Thread zoucao (Jira)
zoucao created FLINK-26726: -- Summary: Remove the unregistered task from readersAwaitingSplit Key: FLINK-26726 URL: https://issues.apache.org/jira/browse/FLINK-26726 Project: Flink Issue Type:

[jira] [Created] (FLINK-26723) Fix the content of exception in SourceCoordinatorContext

2022-03-18 Thread zoucao (Jira)
zoucao created FLINK-26723: -- Summary: Fix the content of exception in SourceCoordinatorContext Key: FLINK-26723 URL: https://issues.apache.org/jira/browse/FLINK-26723 Project: Flink Issue Type:

[jira] [Commented] (FLINK-26401) improve the compatibility for hive catalogView

2022-03-02 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26401?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17500103#comment-17500103 ] zoucao commented on FLINK-26401: Hi [~luoyuxia], I know the hive dialect can resolve it, but if we use

[jira] [Commented] (FLINK-26422) Update Chinese documentation with the new TablePipeline docs

2022-03-01 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17499898#comment-17499898 ] zoucao commented on FLINK-26422: Hi [~slinkydeveloper], I'm willing to fix it, could you assign the

[jira] [Commented] (FLINK-26401) improve the compatibility for hive catalogView

2022-02-28 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26401?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17499351#comment-17499351 ] zoucao commented on FLINK-26401: Hi [~luoyuxia], I just pick 'date' at random, If we just want to

[jira] [Commented] (FLINK-26401) improve the compatibility for hive catalogView

2022-02-28 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26401?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17499275#comment-17499275 ] zoucao commented on FLINK-26401: cc [~luoyuxia] > improve the compatibility for hive catalogView >

[jira] [Updated] (FLINK-26401) improve the compatibility for hive catalogView

2022-02-28 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zoucao updated FLINK-26401: --- Description: For now, many reserved keywords were kept for FlinkSQL[1], and some of them are different

[jira] [Updated] (FLINK-26401) improve the compatibility for hive catalogView

2022-02-28 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zoucao updated FLINK-26401: --- Description: For now, many reserved keywords were kept for FlinkSQL[1], and some of them are different

[jira] [Created] (FLINK-26401) improve the compatibility for hive catalogView

2022-02-28 Thread zoucao (Jira)
zoucao created FLINK-26401: -- Summary: improve the compatibility for hive catalogView Key: FLINK-26401 URL: https://issues.apache.org/jira/browse/FLINK-26401 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-26355) VarCharType was not be considered in HiveTableSqlFunction

2022-02-25 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17498018#comment-17498018 ] zoucao commented on FLINK-26355: Thanks for your attention [~luoyuxia], the problem proposed in this

[jira] [Commented] (FLINK-26355) VarCharType was not be considered in HiveTableSqlFunction

2022-02-25 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17498000#comment-17498000 ] zoucao commented on FLINK-26355: [~luoyuxia] I just want to notice, it seems won't bring any bother

[jira] [Commented] (FLINK-26355) VarCharType was not be considered in HiveTableSqlFunction

2022-02-24 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497918#comment-17497918 ] zoucao commented on FLINK-26355: I use default dialect with hive module rather than hive dialect. Is it

[jira] [Commented] (FLINK-26355) VarCharType was not be considered in HiveTableSqlFunction

2022-02-24 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497885#comment-17497885 ] zoucao commented on FLINK-26355: Hi, [~luoyuxia], I found this problem in the process of driving the

[jira] [Commented] (FLINK-26355) VarCharType was not be considered in HiveTableSqlFunction

2022-02-24 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497412#comment-17497412 ] zoucao commented on FLINK-26355: cc [~lzljs3620320], Hi Jingsong, could you please help to confirm this

[jira] [Created] (FLINK-26355) VarCharType was not be considered in HiveTableSqlFunction

2022-02-24 Thread zoucao (Jira)
zoucao created FLINK-26355: -- Summary: VarCharType was not be considered in HiveTableSqlFunction Key: FLINK-26355 URL: https://issues.apache.org/jira/browse/FLINK-26355 Project: Flink Issue Type:

[jira] [Commented] (FLINK-25476) CharType lost in the creation of MaxAggFunction & MinAggFunction

2021-12-30 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17466828#comment-17466828 ] zoucao commented on FLINK-25476: Hi, [~twalthr],Thank you for your reply, some users want to get the max

[jira] [Commented] (FLINK-25476) CharType lost in the creation of MaxAggFunction & MinAggFunction

2021-12-29 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17466700#comment-17466700 ] zoucao commented on FLINK-25476: cc [~twalthr]  > CharType lost in the creation of MaxAggFunction &

[jira] [Created] (FLINK-25476) CharType lost in the creation of MaxAggFunction & MinAggFunction

2021-12-29 Thread zoucao (Jira)
zoucao created FLINK-25476: -- Summary: CharType lost in the creation of MaxAggFunction & MinAggFunction Key: FLINK-25476 URL: https://issues.apache.org/jira/browse/FLINK-25476 Project: Flink Issue

[jira] [Commented] (FLINK-24528) Flink HBase Asyc Lookup throw NPE if rowkey is null

2021-12-10 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17456984#comment-17456984 ] zoucao commented on FLINK-24528: +1, the same problem we occurred. > Flink HBase Asyc Lookup throw NPE

[jira] [Commented] (FLINK-24958) correct the example and link for temporal table function documentation

2021-11-18 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24958?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17446284#comment-17446284 ] zoucao commented on FLINK-24958: Thanks for your reminder, [~leonard], the change is minor and simple,

[jira] [Commented] (FLINK-24958) correct the example and link for temporal table function documentation

2021-11-18 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24958?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17446273#comment-17446273 ] zoucao commented on FLINK-24958: cc [~Leonard] > correct the example and link for temporal table

[jira] [Created] (FLINK-24958) correct the example and link for temporal table function documentation

2021-11-18 Thread zoucao (Jira)
zoucao created FLINK-24958: -- Summary: correct the example and link for temporal table function documentation Key: FLINK-24958 URL: https://issues.apache.org/jira/browse/FLINK-24958 Project: Flink

[jira] [Commented] (FLINK-11747) Elasticsearch 6 connector - Expose RestHighLevelClient to allow for custom sniffing

2021-10-11 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17426992#comment-17426992 ] zoucao commented on FLINK-11747: Hi all, it is good point to support sniffer in es connector for

[jira] [Comment Edited] (FLINK-23865) Class cast error caused by nested Pojo in legacy outputConversion

2021-08-25 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17404212#comment-17404212 ] zoucao edited comment on FLINK-23865 at 8/25/21, 1:29 PM: -- Recently, I use the

[jira] [Commented] (FLINK-23865) Class cast error caused by nested Pojo in legacy outputConversion

2021-08-25 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17404212#comment-17404212 ] zoucao commented on FLINK-23865: Recently, I use the new interface proposed by

[jira] [Updated] (FLINK-23865) Class cast error caused by nested Pojo in legacy outputConversion

2021-08-18 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zoucao updated FLINK-23865: --- Description: code: {code:java} Table table = tbEnv.fromValues(DataTypes.ROW(

[jira] [Created] (FLINK-23865) Class cast error caused by nested Pojo in legacy outputConversion

2021-08-18 Thread zoucao (Jira)
zoucao created FLINK-23865: -- Summary: Class cast error caused by nested Pojo in legacy outputConversion Key: FLINK-23865 URL: https://issues.apache.org/jira/browse/FLINK-23865 Project: Flink Issue

[jira] [Created] (FLINK-23777) Support dynamic parameters for sink table in multiple connectors

2021-08-15 Thread zoucao (Jira)
zoucao created FLINK-23777: -- Summary: Support dynamic parameters for sink table in multiple connectors Key: FLINK-23777 URL: https://issues.apache.org/jira/browse/FLINK-23777 Project: Flink Issue

[jira] [Commented] (FLINK-23613) debezium and canal support read medata op and type

2021-08-05 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17393755#comment-17393755 ] zoucao commented on FLINK-23613: Hi [~jark], sorry for the late reply, most of the changlog stream comes

[jira] [Commented] (FLINK-23613) debezium and canal support read medata op and type

2021-08-04 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17393337#comment-17393337 ] zoucao commented on FLINK-23613: I agree with your idea and suggestion, Jack. In fact, consuming

[jira] [Commented] (FLINK-23613) debezium and canal support read medata op and type

2021-08-04 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17392998#comment-17392998 ] zoucao commented on FLINK-23613: Hi [~jark] , I think users may wan to do something dependening on 'op',

[jira] [Updated] (FLINK-23597) support 'add jar' in table api

2021-08-03 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zoucao updated FLINK-23597: --- Component/s: Table SQL / API Description: Now, sql-client has supported 'add jar' semantic, I think we

[jira] [Updated] (FLINK-23597) support 'add jar' in table api

2021-08-03 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zoucao updated FLINK-23597: --- Summary: support 'add jar' in table api (was: support Add Jar in Table api) > support 'add jar' in table

[jira] [Created] (FLINK-23597) support Add Jar in Table api

2021-08-03 Thread zoucao (Jira)
zoucao created FLINK-23597: -- Summary: support Add Jar in Table api Key: FLINK-23597 URL: https://issues.apache.org/jira/browse/FLINK-23597 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-21905) Hive streaming source should use FIFO FileSplitAssigner instead of LIFO

2021-08-02 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17391548#comment-17391548 ] zoucao commented on FLINK-21905: Hi [~jark], if no one have time to do this, I am happy to try. > Hive

[jira] [Commented] (FLINK-23511) Fix the location error in metric page.

2021-07-28 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17388486#comment-17388486 ] zoucao commented on FLINK-23511: cc [~jark] > Fix the location error in metric page. >

[jira] [Created] (FLINK-23511) Fix the location error in metric page.

2021-07-27 Thread zoucao (Jira)
zoucao created FLINK-23511: -- Summary: Fix the location error in metric page. Key: FLINK-23511 URL: https://issues.apache.org/jira/browse/FLINK-23511 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-23510) add a new metric to show the max usage of inputExclusiveBuffer for each inputChannel

2021-07-27 Thread zoucao (Jira)
zoucao created FLINK-23510: -- Summary: add a new metric to show the max usage of inputExclusiveBuffer for each inputChannel Key: FLINK-23510 URL: https://issues.apache.org/jira/browse/FLINK-23510 Project:

[jira] [Commented] (FLINK-5463) RocksDB.disposeInternal does not react to interrupts, blocks task cancellation

2021-07-25 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-5463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17387030#comment-17387030 ] zoucao commented on FLINK-5463: --- I found the same problem in Flink 1.11, because of disk broken, task hang

[jira] [Commented] (FLINK-23426) Support changelog processing in batch mode

2021-07-20 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17383826#comment-17383826 ] zoucao commented on FLINK-23426: Hi [~jark], [~twalthr], should we support this materialize operator in

[jira] [Commented] (FLINK-23156) Change the reference of 'docs/dev/table/sql/queries'

2021-06-29 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17371808#comment-17371808 ] zoucao commented on FLINK-23156: hi [~jark], i do some fix in

[jira] [Updated] (FLINK-23156) Change the reference of 'docs/dev/table/sql/queries'

2021-06-25 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zoucao updated FLINK-23156: --- Description: The ref of

[jira] [Created] (FLINK-23156) Change the reference of 'docs/dev/table/sql/queries'

2021-06-25 Thread zoucao (Jira)
zoucao created FLINK-23156: -- Summary: Change the reference of 'docs/dev/table/sql/queries' Key: FLINK-23156 URL: https://issues.apache.org/jira/browse/FLINK-23156 Project: Flink Issue Type:

[jira] [Commented] (FLINK-22437) Miss adding parallesim for filter operator in batch mode

2021-05-20 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17348127#comment-17348127 ] zoucao commented on FLINK-22437: hi [~godfreyhe], thanks for your reply, I am glad to take it. By the

[jira] [Commented] (FLINK-22437) Miss adding parallesim for filter operator in batch mode

2021-05-20 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17348093#comment-17348093 ] zoucao commented on FLINK-22437: hi [~wenlong.lwl], this problem had been fixed in 1.13 beacuse the

[jira] [Updated] (FLINK-22437) Miss adding parallesim for filter operator in batch mode

2021-04-24 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zoucao updated FLINK-22437: --- Description: when I execute batch sql as follow in flink-1.12.2, I found lots of small files in hdfs. In

[jira] [Updated] (FLINK-22437) Miss adding parallesim for filter operator in batch mode

2021-04-23 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zoucao updated FLINK-22437: --- Description: when I execute batch sql as follow in flink-1.12.2, I found lots of small files in hdfs. In

[jira] [Comment Edited] (FLINK-22437) Miss adding parallesim for filter operator in batch mode

2021-04-23 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17330904#comment-17330904 ] zoucao edited comment on FLINK-22437 at 4/23/21, 4:36 PM: -- == Abstract Syntax

[jira] [Commented] (FLINK-22437) Miss adding parallesim for filter operator in batch mode

2021-04-23 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17330904#comment-17330904 ] zoucao commented on FLINK-22437: == Abstract Syntax Tree ==

[jira] [Created] (FLINK-22437) Miss adding parallesim for filter operator in batch mode

2021-04-23 Thread zoucao (Jira)
zoucao created FLINK-22437: -- Summary: Miss adding parallesim for filter operator in batch mode Key: FLINK-22437 URL: https://issues.apache.org/jira/browse/FLINK-22437 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-22299) should remind users to ignoreParseErrors option when parser failed

2021-04-18 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17324664#comment-17324664 ] zoucao commented on FLINK-22299: Hi [~lzljs3620320], I think FLINK-20795 is same ticket as this, but no

[jira] [Commented] (FLINK-21742) Support REMOVE JAR statement in SQL Client

2021-04-01 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21742?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17313541#comment-17313541 ] zoucao commented on FLINK-21742: hi [~jark], could you assign to me, if 'support add jar command in sql

[jira] [Commented] (FLINK-22065) Beautify the parse error exception when input invalid command in the sql client

2021-03-31 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17312306#comment-17312306 ] zoucao commented on FLINK-22065: hi [~fsk119], I think we should ignore the class info(org.apache.*),

[jira] [Commented] (FLINK-21464) Support ADD JAR command in sql client

2021-03-22 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17306305#comment-17306305 ] zoucao commented on FLINK-21464: hi [~fsk119] and [~jark], in FLIP-163, only local jar is considered,

[jira] [Commented] (FLINK-21738) reduce unnecessary method calls in ModuleManager

2021-03-12 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17300239#comment-17300239 ] zoucao commented on FLINK-21738: Hi [~qingyue], thanks for your advice(y), I found this DML as an

[jira] [Commented] (FLINK-21738) reduce unnecessary method calls in ModuleManager

2021-03-11 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17300058#comment-17300058 ] zoucao commented on FLINK-21738: hi [~qingyue] and [~jark], thanks for your quick reply, I agree with

[jira] [Created] (FLINK-21738) reduce unnecessary method calls in ModuleManager

2021-03-11 Thread zoucao (Jira)
zoucao created FLINK-21738: -- Summary: reduce unnecessary method calls in ModuleManager Key: FLINK-21738 URL: https://issues.apache.org/jira/browse/FLINK-21738 Project: Flink Issue Type:

[jira] [Commented] (FLINK-20701) print connector supports outputting seriailzed record

2021-01-27 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17272816#comment-17272816 ] zoucao commented on FLINK-20701: maybe you are right, it is not a good motivation, after considering

[jira] [Commented] (FLINK-20701) print connector supports outputting seriailzed record

2021-01-26 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17272585#comment-17272585 ] zoucao commented on FLINK-20701: When I designed a new format or do some changes in the current format,

  1   2   >