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

[ 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, th

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

[ https://issues.apache.org/jira/browse/FLINK-30076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17635742#comment-17635742 ] zck commented on FLINK-30076: - use flink-1.14.4 not ok ,Same mistake > hive join mysql erro

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

[ 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, th

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

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 / Runtime

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

[ 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

[ https://issues.apache.org/jira/browse/FLINK-29190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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

[ 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

[ 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

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 SQ

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

[ 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 KB

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

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 Compone

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

[ https://issues.apache.org/jira/browse/FLINK-28819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17576122#comment-17576122 ] zck commented on FLINK-28819: - For example: I want to empty all states in the early morning

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

[ 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 information

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

[ 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

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 / Data

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

[ https://issues.apache.org/jira/browse/FLINK-23545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17489934#comment-17489934 ] zck edited comment on FLINK-23545 at 2/10/22, 3:50 AM: --- I like thi

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

[ https://issues.apache.org/jira/browse/FLINK-23545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17489934#comment-17489934 ] zck commented on FLINK-23545: - I like this feature. 1.15 Can you publish it? > Use new sch

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

[ https://issues.apache.org/jira/browse/FLINK-21466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17301194#comment-17301194 ] zck commented on FLINK-21466: - this is my mr. https://github.com/apache/flink/pull/15203/com

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

[ https://issues.apache.org/jira/browse/FLINK-21466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17301169#comment-17301169 ] zck commented on FLINK-21466: - Which branch to use? > Make "embedded" parameter optional wh

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

[ https://issues.apache.org/jira/browse/FLINK-21466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17300919#comment-17300919 ] zck commented on FLINK-21466: - [~jark]  plz check my thoughts. just set mode parameter as t

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

[ https://issues.apache.org/jira/browse/FLINK-21466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17300669#comment-17300669 ] zck commented on FLINK-21466: - [~jark] plz assign to me > Make "embedded" parameter option

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

[ https://issues.apache.org/jira/browse/FLINK-21466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17300668#comment-17300668 ] zck commented on FLINK-21466: - plz assign to me > Make "embedded" parameter optional when s

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

[ 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

[ 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，参数为空元素

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没有指标数据

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 Components: