[jira] [Created] (FLINK-33871) Reduce getTable call for hive client and optimize graph generation time

hehuiyuan created FLINK-33871: - Summary: Reduce getTable call for hive client and optimize graph generation time Key: FLINK-33871 URL: https://issues.apache.org/jira/browse/FLINK-33871 Project: Flink

[jira] [Commented] (FLINK-23860) Conversion to relational algebra failed to preserve datatypes

[ https://issues.apache.org/jira/browse/FLINK-23860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767927#comment-17767927 ] hehuiyuan commented on FLINK-23860: --- [~jark]   > Conversion to relational algebra fai

[jira] [Commented] (FLINK-23860) Conversion to relational algebra failed to preserve datatypes

[ https://issues.apache.org/jira/browse/FLINK-23860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767926#comment-17767926 ] hehuiyuan commented on FLINK-23860: --- +1 > Conversion to relational algebra failed to

[jira] (FLINK-23810) Print sql when parse failed , which is convenient to find error sql from multiple executed sql

[ https://issues.apache.org/jira/browse/FLINK-23810 ] hehuiyuan deleted comment on FLINK-23810: --- was (Author: hehuiyuan): [~jark] ,[~twalthr]  , I can try to do it if necessary. > Print sql when parse failed , which is convenient to find error

[jira] [Commented] (FLINK-23810) Print sql when parse failed , which is convenient to find error sql from multiple executed sql

[ https://issues.apache.org/jira/browse/FLINK-23810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17692531#comment-17692531 ] hehuiyuan commented on FLINK-23810: --- Hi [~jark]  [~twalthr] , whether to add the detai

[jira] [Commented] (FLINK-28375) Whether to consider adding other data type to support for last_value function

[ https://issues.apache.org/jira/browse/FLINK-28375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17690108#comment-17690108 ] hehuiyuan commented on FLINK-28375: --- Hi [~martijnvisser]  , both CHAR and TIMESTAMP ar

[jira] [Created] (FLINK-31086) [DOC]update connector lable for blackhole and kafka

hehuiyuan created FLINK-31086: - Summary: [DOC]update connector lable for blackhole and kafka Key: FLINK-31086 URL: https://issues.apache.org/jira/browse/FLINK-31086 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-30679) Can not load the data of hive dim table when project-push-down is introduced

[ https://issues.apache.org/jira/browse/FLINK-30679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hehuiyuan updated FLINK-30679: -- Description: 维表project push down优化引入： https://issues.apache.org/jira/browse/FLINK-29138 hive维表的两个问题：

[jira] [Updated] (FLINK-30679) Can not load the data of hive dim table when project-push-down is introduced

[ https://issues.apache.org/jira/browse/FLINK-30679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hehuiyuan updated FLINK-30679: -- Description: 维表project push down优化引入： https://issues.apache.org/jira/browse/FLINK-29138 hive维表的两个问题：

[jira] [Commented] (FLINK-30679) Can not load the data of hive dim table when project-push-down is introduced

[ https://issues.apache.org/jira/browse/FLINK-30679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17677107#comment-17677107 ] hehuiyuan commented on FLINK-30679: --- [~luoyuxia] ,hi Take a look when you have time

[jira] [Updated] (FLINK-30679) Can not load the data of hive dim table when project-push-down is introduced

[ https://issues.apache.org/jira/browse/FLINK-30679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hehuiyuan updated FLINK-30679: -- Description:   Can not load the data of hive dim table when project-push-down is introduced. The pro

[jira] [Updated] (FLINK-30679) Can not load the data of hive dim table when project-push-down is introduced

[ https://issues.apache.org/jira/browse/FLINK-30679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hehuiyuan updated FLINK-30679: -- Description:   Can not load the data of hive dim table when project-push-down is introduced. The pro

[jira] [Updated] (FLINK-30679) Can not load the data of hive dim table when project-push-down is introduced

[ https://issues.apache.org/jira/browse/FLINK-30679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hehuiyuan updated FLINK-30679: -- Description: The project push down optimize:https://github.com/apache/flink/pull/21311   vectorize r

[jira] [Updated] (FLINK-30679) Can not load the data of hive dim table when project-push-down is introduced

[ https://issues.apache.org/jira/browse/FLINK-30679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hehuiyuan updated FLINK-30679: -- Affects Version/s: 1.14.6 > Can not load the data of hive dim table when project-push-down is introduc

[jira] [Updated] (FLINK-30679) Can not load the data of hive dim table when project-push-down is introduced

[ https://issues.apache.org/jira/browse/FLINK-30679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hehuiyuan updated FLINK-30679: -- Component/s: Connectors / Hive > Can not load the data of hive dim table when project-push-down is int

[jira] [Created] (FLINK-30679) Can not load the data of hive dim table when project-push-down is introduced

hehuiyuan created FLINK-30679: - Summary: Can not load the data of hive dim table when project-push-down is introduced Key: FLINK-30679 URL: https://issues.apache.org/jira/browse/FLINK-30679 Project: Flink

[jira] [Created] (FLINK-29553) Support UNIX_TIMESTAMP in Table API

hehuiyuan created FLINK-29553: - Summary: Support UNIX_TIMESTAMP in Table API Key: FLINK-29553 URL: https://issues.apache.org/jira/browse/FLINK-29553 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-29052) Support TO_TIMESTAMP built-in function in Table API

hehuiyuan created FLINK-29052: - Summary: Support TO_TIMESTAMP built-in function in Table API Key: FLINK-29052 URL: https://issues.apache.org/jira/browse/FLINK-29052 Project: Flink Issue Type: Im

[jira] [Updated] (FLINK-28750) Whether to add field comment for hive table

[ https://issues.apache.org/jira/browse/FLINK-28750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hehuiyuan updated FLINK-28750: -- Affects Version/s: 1.14.5 > Whether to add field comment for hive table >

[jira] [Updated] (FLINK-28750) Whether to add field comment for hive table

[ https://issues.apache.org/jira/browse/FLINK-28750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hehuiyuan updated FLINK-28750: -- Attachment: image-2022-07-30-16-36-37-032.png > Whether to add field comment for hive table >

[jira] [Updated] (FLINK-28750) Whether to add field comment for hive table

[ https://issues.apache.org/jira/browse/FLINK-28750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hehuiyuan updated FLINK-28750: -- Description: Currently,  I have a hive ddl，as follows {code:java} "set table.sql-dialect=hive;\n" + "C

[jira] [Updated] (FLINK-28750) Whether to add field comment for hive table

[ https://issues.apache.org/jira/browse/FLINK-28750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hehuiyuan updated FLINK-28750: -- Summary: Whether to add field comment for hive table (was: Whether to add comment for hive table) >

[jira] [Updated] (FLINK-28750) Whether to add comment for hive table

[ https://issues.apache.org/jira/browse/FLINK-28750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hehuiyuan updated FLINK-28750: -- Priority: Minor (was: Major) > Whether to add comment for hive table > --

[jira] [Updated] (FLINK-28750) Whether to add comment for hive table

[ https://issues.apache.org/jira/browse/FLINK-28750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hehuiyuan updated FLINK-28750: -- Description: Currently,  I have a hive ddl，as follows {code:java} "set table.sql-dialect=hive;\n" + "C

[jira] [Updated] (FLINK-28750) Whether to add comment for hive table

[ https://issues.apache.org/jira/browse/FLINK-28750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hehuiyuan updated FLINK-28750: -- Description: Currently,  I have a hive ddl，as follows {code:java} "set table.sql-dialect=hive;\n" + "C

[jira] [Updated] (FLINK-28750) Whether to add comment for hive table

[ https://issues.apache.org/jira/browse/FLINK-28750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hehuiyuan updated FLINK-28750: -- Attachment: image-2022-07-30-15-53-03-754.png > Whether to add comment for hive table > --

[jira] [Updated] (FLINK-28750) Whether to add comment for hive table

[ https://issues.apache.org/jira/browse/FLINK-28750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hehuiyuan updated FLINK-28750: -- Description: Currently,  I have a hive ddl，as follows {code:java} "set table.sql-dialect=hive;\n" + "C

[jira] [Updated] (FLINK-28750) Whether to add comment for hive table

[ https://issues.apache.org/jira/browse/FLINK-28750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hehuiyuan updated FLINK-28750: -- Description: Currently,  I have a hive ddl，as follows {code:java} "set table.sql-dialect=hive;\n" + "C

[jira] [Updated] (FLINK-28750) Whether to add comment for hive table

[ https://issues.apache.org/jira/browse/FLINK-28750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hehuiyuan updated FLINK-28750: -- Description: Currently,  I have a hive ddl，as follows {code:java} "set table.sql-dialect=hive;\n" + "C

[jira] [Created] (FLINK-28750) Whether to add comment for hive table

hehuiyuan created FLINK-28750: - Summary: Whether to add comment for hive table Key: FLINK-28750 URL: https://issues.apache.org/jira/browse/FLINK-28750 Project: Flink Issue Type: Improvement

[jira] (FLINK-28716) uploading multiple files/form datas fail randomly when use rest api

[ https://issues.apache.org/jira/browse/FLINK-28716 ] hehuiyuan deleted comment on FLINK-28716: --- was (Author: hehuiyuan): [~chesnay] , The upgrading workload is relatively large , because we have secondary deveployment for flink , I can try to up

[jira] [Comment Edited] (FLINK-28716) uploading multiple files/form datas fail randomly when use rest api

[ https://issues.apache.org/jira/browse/FLINK-28716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17571862#comment-17571862 ] hehuiyuan edited comment on FLINK-28716 at 7/27/22 11:33 AM: -

[jira] [Commented] (FLINK-28716) uploading multiple files/form datas fail randomly when use rest api

[ https://issues.apache.org/jira/browse/FLINK-28716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17571862#comment-17571862 ] hehuiyuan commented on FLINK-28716: --- [~chesnay] , The upgrading workload is relatively

[jira] [Comment Edited] (FLINK-28716) uploading multiple files/form datas fail randomly when use rest api

[ https://issues.apache.org/jira/browse/FLINK-28716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17571854#comment-17571854 ] hehuiyuan edited comment on FLINK-28716 at 7/27/22 11:30 AM: -

[jira] [Commented] (FLINK-28716) uploading multiple files/form datas fail randomly when use rest api

[ https://issues.apache.org/jira/browse/FLINK-28716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17571854#comment-17571854 ] hehuiyuan commented on FLINK-28716: --- Hi [~chesnay] , flink1.14 > uploading multiple

[jira] [Updated] (FLINK-28716) uploading multiple files/form datas fail randomly when use rest api

[ https://issues.apache.org/jira/browse/FLINK-28716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hehuiyuan updated FLINK-28716: -- Description: It can happen error randomly when use `jars/upload` rest api. [https://github.com/eclips

[jira] [Created] (FLINK-28716) uploading multiple files/form datas fail randomly when use rest api

hehuiyuan created FLINK-28716: - Summary: uploading multiple files/form datas fail randomly when use rest api Key: FLINK-28716 URL: https://issues.apache.org/jira/browse/FLINK-28716 Project: Flink

[jira] [Commented] (FLINK-26848) JDBC don't flush data when disable flush-max-rows and flush-interval

[ https://issues.apache.org/jira/browse/FLINK-26848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17563552#comment-17563552 ] hehuiyuan commented on FLINK-26848: --- Hi [~jark]  , have time to look at this issues?

[jira] [Comment Edited] (FLINK-28375) Whether to consider adding other data type to support for last_value function

[ https://issues.apache.org/jira/browse/FLINK-28375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17562481#comment-17562481 ] hehuiyuan edited comment on FLINK-28375 at 7/5/22 8:56 AM: --- [~

[jira] [Commented] (FLINK-28375) Whether to consider adding other data type to support for last_value function

[ https://issues.apache.org/jira/browse/FLINK-28375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17562481#comment-17562481 ] hehuiyuan commented on FLINK-28375: --- [~martijnvisser]  ok , thanks > Whether to consi

[jira] [Comment Edited] (FLINK-28375) Whether to consider adding other data type to support for last_value function

[ https://issues.apache.org/jira/browse/FLINK-28375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17562173#comment-17562173 ] hehuiyuan edited comment on FLINK-28375 at 7/4/22 12:39 PM:

[jira] [Commented] (FLINK-28375) Whether to consider adding other data type to support for last_value function

[ https://issues.apache.org/jira/browse/FLINK-28375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17562173#comment-17562173 ] hehuiyuan commented on FLINK-28375: --- Hi [~martijnvisser]  , we have some business  whi

[jira] [Updated] (FLINK-28375) Whether to consider adding other data type to support for last_value function

[ https://issues.apache.org/jira/browse/FLINK-28375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hehuiyuan updated FLINK-28375: -- Attachment: image-2022-07-04-16-44-02-720.png > Whether to consider adding other data type to support

[jira] [Updated] (FLINK-28375) Whether to consider adding other data type to support for last_value function

[ https://issues.apache.org/jira/browse/FLINK-28375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hehuiyuan updated FLINK-28375: -- Description:   {code:java} CREATE TABLE kafkaTableSource ( keyField INTEGER, timestampField INTEGER,

[jira] [Updated] (FLINK-28375) Whether to consider adding other data type to support for last_value function

[ https://issues.apache.org/jira/browse/FLINK-28375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hehuiyuan updated FLINK-28375: -- Attachment: image-2022-07-04-16-42-31-399.png > Whether to consider adding other data type to support

[jira] [Updated] (FLINK-28375) Whether to consider adding other data type to support for last_value function

[ https://issues.apache.org/jira/browse/FLINK-28375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hehuiyuan updated FLINK-28375: -- Description:   {code:java} CREATE TABLE kafkaTableSource ( keyField INTEGER, timestampField INTEGER

[jira] [Updated] (FLINK-28375) Whether to consider adding other data type to support for last_value function

[ https://issues.apache.org/jira/browse/FLINK-28375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hehuiyuan updated FLINK-28375: -- Description:   {code:java} CREATE TABLE kafkaTableSource ( keyField INTEGER, timestampField INTEGER,

[jira] [Created] (FLINK-28375) Whether to consider adding other data type to support for last_value function

hehuiyuan created FLINK-28375: - Summary: Whether to consider adding other data type to support for last_value function Key: FLINK-28375 URL: https://issues.apache.org/jira/browse/FLINK-28375 Project: Flin

[jira] [Updated] (FLINK-27238) Whether the HiveGenericUDTF and HiveScalarFunction should support primitive array and element type may be` not null` attribute ，for example Array Array .

[ https://issues.apache.org/jira/browse/FLINK-27238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hehuiyuan updated FLINK-27238: -- Summary: Whether the HiveGenericUDTF and HiveScalarFunction should support primitive array and element

[jira] [Updated] (FLINK-27238) Whether the HiveGenericUDTF and HiveScalarFunction should support primitive array and element type may be not null ，for example Array Array ...

[ https://issues.apache.org/jira/browse/FLINK-27238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hehuiyuan updated FLINK-27238: -- Description: Whether the HiveGenericUDTF and HiveScalarFunction should support primitive array and el

[jira] [Updated] (FLINK-27238) Whether the HiveGenericUDTF and HiveScalarFunction should support primitive array and element type may be not null ，for example Array Array ...

[ https://issues.apache.org/jira/browse/FLINK-27238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hehuiyuan updated FLINK-27238: -- Description: !image-2022-04-14-10-27-50-340.png|width=381,height=260!       {code:java} Caused by:

[jira] [Updated] (FLINK-27238) Whether the HiveGenericUDTF and HiveScalarFunction should support primitive array and element type may be not null ，for example Array Array ...

[ https://issues.apache.org/jira/browse/FLINK-27238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hehuiyuan updated FLINK-27238: -- Attachment: image-2022-04-14-15-43-07-544.png > Whether the HiveGenericUDTF and HiveScalarFunction sho

[jira] [Updated] (FLINK-27238) Whether the HiveGenericUDTF and HiveScalarFunction should support primitive array and element type may be not null ，for example Array Array ...

[ https://issues.apache.org/jira/browse/FLINK-27238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hehuiyuan updated FLINK-27238: -- Summary: Whether the HiveGenericUDTF and HiveScalarFunction should support primitive array and element

[jira] [Reopened] (FLINK-27238) The HiveGenericUDTF and HiveScalarFunction should support primitive array，for example Array Array ...

[ https://issues.apache.org/jira/browse/FLINK-27238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hehuiyuan reopened FLINK-27238: --- > The HiveGenericUDTF and HiveScalarFunction should support primitive array，for > example Array Array .

[jira] [Closed] (FLINK-27238) The HiveGenericUDTF and HiveScalarFunction should support primitive array，for example Array Array ...

[ https://issues.apache.org/jira/browse/FLINK-27238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hehuiyuan closed FLINK-27238. - Resolution: Invalid > The HiveGenericUDTF and HiveScalarFunction should support primitive array，for > e

[jira] [Updated] (FLINK-27238) The HiveGenericUDTF and HiveScalarFunction should support primitive array，for example Array Array ...

[ https://issues.apache.org/jira/browse/FLINK-27238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hehuiyuan updated FLINK-27238: -- Description: !image-2022-04-14-10-27-50-340.png|width=381,height=260!   If argTypes[0] is Array ,it

[jira] [Updated] (FLINK-27238) The HiveGenericUDTF and HiveScalarFunction should support primitive array，for example Array Array ...

[ https://issues.apache.org/jira/browse/FLINK-27238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hehuiyuan updated FLINK-27238: -- Summary: The HiveGenericUDTF and HiveScalarFunction should support primitive array，for example Array A

[jira] [Updated] (FLINK-27238) The HiveGenericUDTF should support primitive array，for example Array Array ...

[ https://issues.apache.org/jira/browse/FLINK-27238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hehuiyuan updated FLINK-27238: -- Description: !image-2022-04-14-10-27-50-340.png|width=381,height=260!   If argTypes[0] is Array ,it

[jira] [Created] (FLINK-27238) The HiveGenericUDTF should support primitive array，for example Array Array ...

hehuiyuan created FLINK-27238: - Summary: The HiveGenericUDTF should support primitive array，for example Array Array ... Key: FLINK-27238 URL: https://issues.apache.org/jira/browse/FLINK-27238 Project: Fli

[jira] [Updated] (FLINK-27194) Whether to consider adding the configuration of ignore when data deserialization failed for avro fromat.

[ https://issues.apache.org/jira/browse/FLINK-27194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hehuiyuan updated FLINK-27194: -- Summary: Whether to consider adding the configuration of ignore when data deserialization failed for a

[jira] [Updated] (FLINK-27194) Whether to consider adding the configuration of ignore when data deserialization failed for avro format.

[ https://issues.apache.org/jira/browse/FLINK-27194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hehuiyuan updated FLINK-27194: -- Summary: Whether to consider adding the configuration of ignore when data deserialization failed for a

[jira] [Created] (FLINK-27194) Whether to consider adding the configuration of ignore when data deserialization failed.

hehuiyuan created FLINK-27194: - Summary: Whether to consider adding the configuration of ignore when data deserialization failed. Key: FLINK-27194 URL: https://issues.apache.org/jira/browse/FLINK-27194 Pr

[jira] [Updated] (FLINK-26848) JDBC don't flush data when disable flush-max-rows and flush-interval

[ https://issues.apache.org/jira/browse/FLINK-26848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hehuiyuan updated FLINK-26848: -- Description: ||h5. sink.buffer-flush.interval||The flush interval mills, over this time, asynchronous

[jira] [Updated] (FLINK-26848) JDBC don't flush data when disable flush-max-rows and flush-interval

[ https://issues.apache.org/jira/browse/FLINK-26848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hehuiyuan updated FLINK-26848: -- Attachment: image-2022-03-24-22-05-23-717.png > JDBC don't flush data when disable flush-max-rows and

[jira] [Created] (FLINK-26848) JDBC don't flush data when disable flush-max-rows and flush-interval

hehuiyuan created FLINK-26848: - Summary: JDBC don't flush data when disable flush-max-rows and flush-interval Key: FLINK-26848 URL: https://issues.apache.org/jira/browse/FLINK-26848 Project: Flink

[jira] [Comment Edited] (FLINK-26565) Use lateTrigger when the window maxtimestap of data is less than currentwatermark and it is not discarded because the allow latency parameter

[ https://issues.apache.org/jira/browse/FLINK-26565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17509148#comment-17509148 ] hehuiyuan edited comment on FLINK-26565 at 3/23/22, 6:16 AM: -

[jira] (FLINK-26565) Use lateTrigger when the window maxtimestap of data is less than currentwatermark and it is not discarded because the allow latency parameter

[ https://issues.apache.org/jira/browse/FLINK-26565 ] hehuiyuan deleted comment on FLINK-26565: --- was (Author: hehuiyuan):  [~jark] , okay. > Use lateTrigger when the window maxtimestap of data is less than > currentwatermark and it is not disca

[jira] [Commented] (FLINK-26565) Use lateTrigger when the window maxtimestap of data is less than currentwatermark and it is not discarded because the allow latency parameter

[ https://issues.apache.org/jira/browse/FLINK-26565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17509148#comment-17509148 ] hehuiyuan commented on FLINK-26565: --- Hi [~jark]  ,  done . You can review this pr,   

[jira] [Commented] (FLINK-24862) The user-defined hive udaf/udtf cannot be used normally in hive dialect

[ https://issues.apache.org/jira/browse/FLINK-24862?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17507306#comment-17507306 ] hehuiyuan commented on FLINK-24862: --- [~jingzhang]  [~jark] , are there any plans to me

[jira] [Commented] (FLINK-26498) The window result may not have been emitted when use window emit feature and set allow-latency

[ https://issues.apache.org/jira/browse/FLINK-26498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17506813#comment-17506813 ] hehuiyuan commented on FLINK-26498: --- Thanks   [~jark] [~paul8263] , learned knowledge

[jira] [Commented] (FLINK-26565) Use lateTrigger when the window maxtimestap of data is less than currentwatermark and it is not discarded because the allow latency parameter

[ https://issues.apache.org/jira/browse/FLINK-26565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17505981#comment-17505981 ] hehuiyuan commented on FLINK-26565: ---  [~jark] , okay. > Use lateTrigger when the wind

[jira] [Commented] (FLINK-26565) Use lateTrigger when the window maxtimestap of data is less than currentwatermark and it is not discarded because the allow latency parameter

[ https://issues.apache.org/jira/browse/FLINK-26565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17505187#comment-17505187 ] hehuiyuan commented on FLINK-26565: --- If it is a new window when a latency data that is

[jira] [Comment Edited] (FLINK-19254) Invalid UTF-8 start byte exception

[ https://issues.apache.org/jira/browse/FLINK-19254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17504720#comment-17504720 ] hehuiyuan edited comment on FLINK-19254 at 3/11/22, 4:40 AM: -

[jira] [Commented] (FLINK-19254) Invalid UTF-8 start byte exception

[ https://issues.apache.org/jira/browse/FLINK-19254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17504720#comment-17504720 ] hehuiyuan commented on FLINK-19254: --- Hi [~xtsong]  , it is fixed? Can you give  a comm

[jira] [Updated] (FLINK-26565) Use lateTrigger when the window maxtimestap of data is less than currentwatermark and it is not discarded because the allow latency parameter

[ https://issues.apache.org/jira/browse/FLINK-26565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hehuiyuan updated FLINK-26565: -- Description: Use lateTrigger when the window maxtimestap of data is less than currentwatermark . The

[jira] [Updated] (FLINK-26565) Use lateTrigger when the window maxtimestap of data is less than currentwatermark and it is not discarded because the allow latency parameter

[ https://issues.apache.org/jira/browse/FLINK-26565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hehuiyuan updated FLINK-26565: -- Description: Use lateTrigger when the window maxtimestap of data is less than currentwatermark and  i

[jira] [Created] (FLINK-26565) Use lateTrigger when the window maxtimestap of data is less than currentwatermark and it is not discarded because the allow latency parameter

hehuiyuan created FLINK-26565: - Summary: Use lateTrigger when the window maxtimestap of data is less than currentwatermark and it is not discarded because the allow latency parameter Key: FLINK-26565 URL: https://i

[jira] [Comment Edited] (FLINK-26498) The window result may not have been emitted when use window emit feature and set allow-latency

[ https://issues.apache.org/jira/browse/FLINK-26498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17503699#comment-17503699 ] hehuiyuan edited comment on FLINK-26498 at 3/9/22, 4:24 PM:

[jira] [Updated] (FLINK-26498) The window result may not have been emitted when use window emit feature and set allow-latency

[ https://issues.apache.org/jira/browse/FLINK-26498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hehuiyuan updated FLINK-26498: -- Description: the sql of job : {code:java} CREATE TABLE tableSource( name string, age int not n

[jira] [Comment Edited] (FLINK-26498) The window result may not have been emitted when use window emit feature and set allow-latency

[ https://issues.apache.org/jira/browse/FLINK-26498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17503699#comment-17503699 ] hehuiyuan edited comment on FLINK-26498 at 3/9/22, 4:23 PM:

[jira] [Commented] (FLINK-26498) The window result may not have been emitted when use window emit feature and set allow-latency

[ https://issues.apache.org/jira/browse/FLINK-26498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17503699#comment-17503699 ] hehuiyuan commented on FLINK-26498: ---  The `00:59:20.100` record are late  but  the tim

[jira] [Commented] (FLINK-26498) The window result may not have been emitted when use window emit feature and set allow-latency

[ https://issues.apache.org/jira/browse/FLINK-26498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17503475#comment-17503475 ] hehuiyuan commented on FLINK-26498: --- lateness and  out-of-order  , i got it.   [~jar

[jira] [Comment Edited] (FLINK-26498) The window result may not have been emitted when use window emit feature and set allow-latency

[ https://issues.apache.org/jira/browse/FLINK-26498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17503348#comment-17503348 ] hehuiyuan edited comment on FLINK-26498 at 3/9/22, 8:03 AM:

[jira] [Comment Edited] (FLINK-26498) The window result may not have been emitted when use window emit feature and set allow-latency

[ https://issues.apache.org/jira/browse/FLINK-26498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17503348#comment-17503348 ] hehuiyuan edited comment on FLINK-26498 at 3/9/22, 8:03 AM:

[jira] [Comment Edited] (FLINK-26498) The window result may not have been emitted when use window emit feature and set allow-latency

[ https://issues.apache.org/jira/browse/FLINK-26498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17503348#comment-17503348 ] hehuiyuan edited comment on FLINK-26498 at 3/9/22, 7:50 AM:

[jira] [Comment Edited] (FLINK-26498) The window result may not have been emitted when use window emit feature and set allow-latency

[ https://issues.apache.org/jira/browse/FLINK-26498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17503348#comment-17503348 ] hehuiyuan edited comment on FLINK-26498 at 3/9/22, 7:42 AM:

[jira] [Commented] (FLINK-26498) The window result may not have been emitted when use window emit feature and set allow-latency

[ https://issues.apache.org/jira/browse/FLINK-26498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17503348#comment-17503348 ] hehuiyuan commented on FLINK-26498: --- [~jark] , It is time for cleanupTimer but laterTr

[jira] (FLINK-26498) The window result may not have been emitted when use window emit feature and set allow-latency

[ https://issues.apache.org/jira/browse/FLINK-26498 ] hehuiyuan deleted comment on FLINK-26498: --- was (Author: hehuiyuan): [~jark]  ,        Hi [~paul8263] I can fix by myself. > The window result may not have been emitted when use window emit f

[jira] [Updated] (FLINK-26498) The window result may not have been emitted when use window emit feature and set allow-latency

[ https://issues.apache.org/jira/browse/FLINK-26498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hehuiyuan updated FLINK-26498: -- External issue URL: https://github.com/apache/flink/pull/18995 > The window result may not have been

[jira] [Updated] (FLINK-26498) The window result may not have been emitted when use window emit feature and set allow-latency

[ https://issues.apache.org/jira/browse/FLINK-26498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hehuiyuan updated FLINK-26498: -- External issue URL: (was: https://github.com/apache/flink/pull/18995) > The window result may not ha

[jira] [Updated] (FLINK-26498) The window result may not have been emitted when use window emit feature and set allow-latency

[ https://issues.apache.org/jira/browse/FLINK-26498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hehuiyuan updated FLINK-26498: -- Summary: The window result may not have been emitted when use window emit feature and set allow-laten

[jira] [Commented] (FLINK-26498) The window result may not have been emitted when use window emit feature and use lateTrigger.

[ https://issues.apache.org/jira/browse/FLINK-26498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17502164#comment-17502164 ] hehuiyuan commented on FLINK-26498: --- [~jark]  ,        Hi [~paul8263] I can fix by my

[jira] [Updated] (FLINK-26498) The window result may not have been emitted when use window emit feature and use lateTrigger.

[ https://issues.apache.org/jira/browse/FLINK-26498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hehuiyuan updated FLINK-26498: -- Description: the sql of job : {code:java} CREATE TABLE tableSource( name string, age int not n

[jira] [Updated] (FLINK-26498) The window result may not have been emitted when use window emit feature and use lateTrigger.

[ https://issues.apache.org/jira/browse/FLINK-26498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hehuiyuan updated FLINK-26498: -- Description: the sql of job : {code:java} CREATE TABLE tableSource( name string, age int not n

[jira] [Updated] (FLINK-26498) The window result may not have been emitted when use window emit feature and use lateTrigger.

[ https://issues.apache.org/jira/browse/FLINK-26498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hehuiyuan updated FLINK-26498: -- Description: the sql of job : {code:java} CREATE TABLE tableSource( name string, age int not n

[jira] [Updated] (FLINK-26498) The window result may not have been emitted when use window emit feature and use lateTrigger.

[ https://issues.apache.org/jira/browse/FLINK-26498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hehuiyuan updated FLINK-26498: -- Description: the sql of job :   {code:java} CREATE TABLE tableSource( name string, age int no

[jira] [Commented] (FLINK-26498) The window result may not have been emitted when use window emit feature and use lateTrigger.

[ https://issues.apache.org/jira/browse/FLINK-26498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17501763#comment-17501763 ] hehuiyuan commented on FLINK-26498: --- Hi [~jark] ， have time to look at this problem.

[jira] [Updated] (FLINK-26498) The window result may not have been emitted when use window emit feature and use lateTrigger.

[ https://issues.apache.org/jira/browse/FLINK-26498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hehuiyuan updated FLINK-26498: -- Description: the sql of job :   {code:java} CREATE TABLE tableSource( name string, age int no

[jira] [Created] (FLINK-26498) The window result may not have been emitted when use window emit feature and use lateTrigger.

hehuiyuan created FLINK-26498: - Summary: The window result may not have been emitted when use window emit feature and use lateTrigger. Key: FLINK-26498 URL: https://issues.apache.org/jira/browse/FLINK-26498

[jira] [Commented] (FLINK-26320) Update hive doc for 1 m->1 min

[ https://issues.apache.org/jira/browse/FLINK-26320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17497998#comment-17497998 ] hehuiyuan commented on FLINK-26320: --- [~jark] ,fix > Update hive doc for 1 m->1 min >

  1   2   3   4   >