[jira] [Updated] (FLINK-30076) hive join mysql error

2022-11-18 Thread zck (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zck updated FLINK-30076: Description: There is no problem when reading hive table parquet alone, but after doing join with MySQL table,

[jira] [Commented] (FLINK-30076) hive join mysql error

2022-11-18 Thread zck (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17635742#comment-17635742 ] zck commented on FLINK-30076: - use flink-1.14.4 not ok ,Same mistake > hive join mysql error >

[jira] [Updated] (FLINK-30076) hive join mysql error

2022-11-17 Thread zck (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zck updated FLINK-30076: Description: There is no problem when reading hive table parquet alone, but after doing join with MySQL table,

[jira] [Created] (FLINK-30076) hive join mysql error

2022-11-17 Thread zck (Jira)
zck created FLINK-30076: --- Summary: hive join mysql error Key: FLINK-30076 URL: https://issues.apache.org/jira/browse/FLINK-30076 Project: Flink Issue Type: Bug Components: Table SQL /

[jira] [Closed] (FLINK-29190) flink hive left join mysql error

2022-09-05 Thread zck (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zck closed FLINK-29190. --- Fix Version/s: 1.15.2 Release Note: https://issues.apache.org/jira/browse/FLINK-24761 Resolution: Fixed

[jira] [Commented] (FLINK-29190) flink hive left join mysql error

2022-09-05 Thread zck (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17600273#comment-17600273 ] zck commented on FLINK-29190: - tks jark,use 1.15.2 ok. > flink hive left join mysql error >

[jira] [Updated] (FLINK-29190) flink hive left join mysql error

2022-09-05 Thread zck (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zck updated FLINK-29190: Description: If I remove the custom function, it is working fine. select * from hive_table left join mysql_table

[jira] [Updated] (FLINK-29190) flink hive left join mysql error

2022-09-05 Thread zck (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zck updated FLINK-29190: Description: select * from hive_table left join mysql_table on hive_table.id=mysql_table .id where mysql_table

[jira] [Created] (FLINK-29190) flink hive left join mysql error

2022-09-05 Thread zck (Jira)
zck created FLINK-29190: --- Summary: flink hive left join mysql error Key: FLINK-29190 URL: https://issues.apache.org/jira/browse/FLINK-29190 Project: Flink Issue Type: Bug Components: Table

[jira] [Updated] (FLINK-28958) flink dataStream to table grows beyond 64 KB

2022-08-14 Thread zck (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zck updated FLINK-28958: Affects Version/s: 1.14.4 (was: 1.14.5) > flink dataStream to table grows beyond 64

[jira] [Created] (FLINK-28958) flink dataStream to table grows beyond 64 KB

2022-08-14 Thread zck (Jira)
zck created FLINK-28958: --- Summary: flink dataStream to table grows beyond 64 KB Key: FLINK-28958 URL: https://issues.apache.org/jira/browse/FLINK-28958 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-28819) The natural time of day TTL

2022-08-05 Thread zck (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17576122#comment-17576122 ] zck commented on FLINK-28819: - For example: I want to empty all states in the early morning every day, the

[jira] [Updated] (FLINK-28819) The natural time of day TTL

2022-08-04 Thread zck (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zck updated FLINK-28819: Description: When new energy vehicles are monitored for parts, in order to reduce the push of abnormal

[jira] [Updated] (FLINK-28819) The natural time of day TTL

2022-08-04 Thread zck (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zck updated FLINK-28819: Summary: The natural time of day TTL (was: state Time of day TTL ) > The natural time of day TTL >

[jira] [Created] (FLINK-28819) state Time of day TTL

2022-08-04 Thread zck (Jira)
zck created FLINK-28819: --- Summary: state Time of day TTL Key: FLINK-28819 URL: https://issues.apache.org/jira/browse/FLINK-28819 Project: Flink Issue Type: New Feature Components: API /

[jira] [Comment Edited] (FLINK-23545) Use new schema in SqlCreateTableConverter

2022-02-09 Thread zck (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17489934#comment-17489934 ] zck edited comment on FLINK-23545 at 2/10/22, 3:50 AM: --- I like this feature. 1.15 

[jira] [Commented] (FLINK-23545) Use new schema in SqlCreateTableConverter

2022-02-09 Thread zck (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17489934#comment-17489934 ] zck commented on FLINK-23545: - I like this feature. 1.15 Can you publish it? > Use new schema in

[jira] [Commented] (FLINK-21466) Make "embedded" parameter optional when start sql-client.sh

2021-03-14 Thread zck (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17301194#comment-17301194 ] zck commented on FLINK-21466: - this is my mr. https://github.com/apache/flink/pull/15203/commits its my

[jira] [Commented] (FLINK-21466) Make "embedded" parameter optional when start sql-client.sh

2021-03-14 Thread zck (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17301169#comment-17301169 ] zck commented on FLINK-21466: - Which branch to use? > Make "embedded" parameter optional when start

[jira] [Commented] (FLINK-21466) Make "embedded" parameter optional when start sql-client.sh

2021-03-13 Thread zck (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17300919#comment-17300919 ] zck commented on FLINK-21466: - [~jark]  plz check my thoughts. just set mode parameter as the default value

[jira] [Commented] (FLINK-21466) Make "embedded" parameter optional when start sql-client.sh

2021-03-12 Thread zck (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17300669#comment-17300669 ] zck commented on FLINK-21466: - [~jark] plz assign to me > Make "embedded" parameter optional when start

[jira] [Commented] (FLINK-21466) Make "embedded" parameter optional when start sql-client.sh

2021-03-12 Thread zck (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17300668#comment-17300668 ] zck commented on FLINK-21466: - plz assign to me > Make "embedded" parameter optional when start

[jira] [Closed] (FLINK-17185) Value of Row[] parameter of UDF is null in blink planner

2020-04-16 Thread zck (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zck closed FLINK-17185. --- Resolution: Invalid > Value of Row[] parameter of UDF is null in blink planner >

[jira] [Closed] (FLINK-17184) Flink webui does not display received records/bytes metric when graph contains single operator

2020-04-16 Thread zck (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zck closed FLINK-17184. --- > Flink webui does not display received records/bytes metric when graph > contains single operator >

[jira] [Created] (FLINK-17185) blink执行计划,自定义函数解析 array,参数为空元素

2020-04-16 Thread zck (Jira)
zck created FLINK-17185: --- Summary: blink执行计划,自定义函数解析 array,参数为空元素 Key: FLINK-17185 URL: https://issues.apache.org/jira/browse/FLINK-17185 Project: Flink Issue Type: Bug Components: Table SQL

[jira] [Created] (FLINK-17184) sink_ddl source_ddl query_sql webui没有指标数据

2020-04-16 Thread zck (Jira)
zck created FLINK-17184: --- Summary: sink_ddl source_ddl query_sql webui没有指标数据 Key: FLINK-17184 URL: https://issues.apache.org/jira/browse/FLINK-17184 Project: Flink Issue Type: Bug