[jira] [Commented] (FLINK-33670) Public operators cannot be reused in multi sinks

2023-11-29 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17791426#comment-17791426 ] Lyn Zhang commented on FLINK-33670: --- Making "temporary view" as a real "common table e

[jira] [Updated] (FLINK-33670) Public operators cannot be reused in multi sinks

2023-11-28 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-33670: -- Description: Dear all:    I find that some public operators cannot be reused when submit a job with

[jira] [Updated] (FLINK-33670) Public operators cannot be reused in multi sinks

2023-11-28 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-33670: -- Description: Dear all:    I find that some public operators cannot be reused when submit a job with

[jira] [Updated] (FLINK-33670) Public operators cannot be reused in multi sinks

2023-11-28 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-33670: -- Description: Dear all:    I find that some public operators cannot be reused when submit a job with

[jira] [Updated] (FLINK-33670) Public operators cannot be reused in multi sinks

2023-11-28 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-33670: -- Description: Dear all:    I find that some public operators cannot be reused when submit a job with

[jira] [Updated] (FLINK-33670) Public operators cannot be reused in multi sinks

2023-11-28 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-33670: -- Description: Dear all:    I find that some public operators cannot be reused when submit a job with

[jira] [Created] (FLINK-33670) Public operators cannot be reused in multi sinks

2023-11-27 Thread Lyn Zhang (Jira)
Lyn Zhang created FLINK-33670: - Summary: Public operators cannot be reused in multi sinks Key: FLINK-33670 URL: https://issues.apache.org/jira/browse/FLINK-33670 Project: Flink Issue Type: Improv

[jira] [Closed] (FLINK-32969) IfCallGen NullPointException Bug

2023-08-27 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang closed FLINK-32969. - Fix Version/s: 1.18.0 Resolution: Fixed > IfCallGen NullPointException Bug >

[jira] [Commented] (FLINK-32969) IfCallGen NullPointException Bug

2023-08-27 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17759427#comment-17759427 ] Lyn Zhang commented on FLINK-32969: --- [~luoyuxia] looks like it has been fixed in 1.17.

[jira] [Updated] (FLINK-32969) IfCallGen NullPointException Bug

2023-08-27 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-32969: -- Description: If Function will cause NullPointException when the third param is other functions. h1. E

[jira] [Updated] (FLINK-32969) IfCallGen NullPointException Bug

2023-08-27 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-32969: -- Description: If Function will cause NullPointException when the third param is a udf. h1. Example: {co

[jira] [Updated] (FLINK-32969) IfCallGen NullPointException Bug

2023-08-27 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-32969: -- Description: If Function will cause NullPointException when the third param is other function. h1. Ex

[jira] [Updated] (FLINK-32969) IfCallGen NullPointException Bug

2023-08-27 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-32969: -- Attachment: image-2023-08-28-11-02-03-842.png > IfCallGen NullPointException Bug > ---

[jira] [Updated] (FLINK-32969) IfCallGen NullPointException Bug

2023-08-27 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-32969: -- Description: If Function will cause NullPointException when the third param is other function. h1. Ex

[jira] [Updated] (FLINK-32969) IfCallGen NullPointException Bug

2023-08-27 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-32969: -- Description: If Function will cause NullPointException when the third param is other function. h1. Ex

[jira] [Commented] (FLINK-32969) IfCallGen NullPointException Bug

2023-08-27 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17759423#comment-17759423 ] Lyn Zhang commented on FLINK-32969: --- [~jark] [~godfreyhe]  Please help to check this i

[jira] [Updated] (FLINK-32969) IfCallGen NullPointException Bug

2023-08-27 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-32969: -- Description: If Functions will cause NullPointException when the third param is other function. h1. E

[jira] [Updated] (FLINK-32969) IfCallGen NullPointException Bug

2023-08-27 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-32969: -- Description: If Functions will cause NullPointException when the third param is other function. h1. E

[jira] [Updated] (FLINK-32969) IfCallGen NullPointException Bug

2023-08-27 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-32969: -- Description: If Functions will cause NullPointException when the third param is other function. h1. E

[jira] [Updated] (FLINK-32969) IfCallGen NullPointException Bug

2023-08-27 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-32969: -- Description: If Functions will cause NullPointException when the third param is other function. h1. E

[jira] [Updated] (FLINK-32969) IfCallGen NullPointException Bug

2023-08-27 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-32969: -- Description: If Functions will cause NullPointException when the third param is other function. h1. E

[jira] [Updated] (FLINK-32969) IfCallGen NullPointException Bug

2023-08-27 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-32969: -- Attachment: image-2023-08-28-10-55-26-228.png if_function_codegen.java

[jira] [Created] (FLINK-32969) IfCallGen Bug

2023-08-27 Thread Lyn Zhang (Jira)
Lyn Zhang created FLINK-32969: - Summary: IfCallGen Bug Key: FLINK-32969 URL: https://issues.apache.org/jira/browse/FLINK-32969 Project: Flink Issue Type: Bug Reporter: Lyn Zhang

[jira] [Commented] (FLINK-18996) Avoid disorder for time interval join

2023-04-04 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17708345#comment-17708345 ] Lyn Zhang commented on FLINK-18996: --- [~lincoln.86xy]  I can't edit this issue, seems o

[jira] [Updated] (FLINK-18996) Avoid disorder for time interval join

2023-04-04 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-18996: -- Attachment: image-2023-04-04-18-04-36-497.png > Avoid disorder for time interval join > --

[jira] [Updated] (FLINK-18996) Avoid disorder for time interval join

2023-04-04 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-18996: -- Attachment: image-2023-04-04-18-02-45-202.png > Avoid disorder for time interval join > --

[jira] [Commented] (FLINK-18996) Avoid disorder for time interval join

2023-03-23 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17704410#comment-17704410 ] Lyn Zhang commented on FLINK-18996: --- [~lincoln.86xy] , I have updated [this PR|https:

[jira] [Commented] (FLINK-18996) Avoid disorder for time interval join

2023-03-22 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17703835#comment-17703835 ] Lyn Zhang commented on FLINK-18996: --- If need, I can modify [this PR|https://github.com

[jira] [Commented] (FLINK-18996) Avoid disorder for time interval join

2023-03-22 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17703834#comment-17703834 ] Lyn Zhang commented on FLINK-18996: --- [~lincoln.86xy] good solution. In our inner branc

[jira] [Commented] (FLINK-18996) Avoid disorder for time interval join

2023-03-21 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17703481#comment-17703481 ] Lyn Zhang commented on FLINK-18996: --- [~charles-tan] In my jobs, set minCleanUpInterval

[jira] [Comment Edited] (FLINK-18996) Avoid disorder for time interval join

2023-03-21 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17703445#comment-17703445 ] Lyn Zhang edited comment on FLINK-18996 at 3/22/23 2:21 AM:

[jira] [Commented] (FLINK-18996) Avoid disorder for time interval join

2023-03-21 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17703445#comment-17703445 ] Lyn Zhang commented on FLINK-18996: --- An interval join followed by a window aggregate i

[jira] [Comment Edited] (FLINK-18996) Avoid disorder for time interval join

2023-03-21 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17703443#comment-17703443 ] Lyn Zhang edited comment on FLINK-18996 at 3/22/23 2:15 AM:

[jira] [Comment Edited] (FLINK-18996) Avoid disorder for time interval join

2023-03-21 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17703443#comment-17703443 ] Lyn Zhang edited comment on FLINK-18996 at 3/22/23 2:14 AM:

[jira] [Commented] (FLINK-18996) Avoid disorder for time interval join

2023-03-21 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17703443#comment-17703443 ] Lyn Zhang commented on FLINK-18996: --- [~lincoln.86xy] [~charles-tan]  The watermark rep

[jira] [Updated] (FLINK-31212) Data lost on interval left join with window group

2023-02-25 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-31212: -- Description:   I have a case in [^test.sql] that records in table_1 left join fail will be discard b

[jira] [Updated] (FLINK-31212) Data lost on interval left join with window group

2023-02-24 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-31212: -- Summary: Data lost on interval left join with window group (was: Data lost if window group after inte

[jira] [Commented] (FLINK-31212) Data lost if window group after interval left join

2023-02-24 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17693130#comment-17693130 ] Lyn Zhang commented on FLINK-31212: --- [~martijnvisser]  I select the wrong version and

[jira] [Updated] (FLINK-31212) Data lost if window group after interval left join

2023-02-24 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-31212: -- Affects Version/s: 1.16.1 (was: 1.8.4) > Data lost if window group after in

[jira] [Updated] (FLINK-31212) Data lost if window group after interval left join

2023-02-24 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-31212: -- Description:   I have a case in [^test.sql] that records in table_1 left join fail will be discard b

[jira] [Updated] (FLINK-31212) Data lost if window group after interval left join

2023-02-24 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-31212: -- Description:   I have a case in [^test.sql] that records in table_1 left join fail will be discard b

[jira] [Updated] (FLINK-31212) Data lost if window group after interval left join

2023-02-24 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-31212: -- Description:   I have a case in [^test.sql] that records in table_1 left join fail will be discard b

[jira] [Updated] (FLINK-31212) Data lost if window group after interval left join

2023-02-24 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-31212: -- Description:   I have a case in [^test.sql] that records in table_1 left join fail will be discard b

[jira] [Updated] (FLINK-31212) Data lost if window group after interval left join

2023-02-24 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-31212: -- Description:   I have a case in [^test.sql] that records in table_1 left join fail will be discard b

[jira] [Updated] (FLINK-31212) Data lost if window group after interval left join

2023-02-24 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-31212: -- Description:   I have a case in [^test.sql] that records in table_1 left join fail will be discard b

[jira] [Updated] (FLINK-31212) Data lost if window group after interval left join

2023-02-24 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-31212: -- Affects Version/s: 1.8.4 > Data lost if window group after interval left join > --

[jira] [Updated] (FLINK-31212) Data lost if window group after interval left join

2023-02-24 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-31212: -- Description:   I have a case in [^test.sql] that records in table_1 left join fail will be discard b

[jira] [Updated] (FLINK-31212) Data lost if window group after interval left join

2023-02-24 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-31212: -- Description:   I have a case in [^test.sql] that records in table_1 left join fail will be discard b

[jira] [Updated] (FLINK-31212) Data lost if window group after interval left join

2023-02-24 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-31212: -- Description:   I have a case in [^test.sql] that records in table_1 left join fail will be discard b

[jira] [Updated] (FLINK-31212) Data lost if window group after interval left join

2023-02-24 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-31212: -- Description:   I have a case in [^test.sql] that records in table_1 left join fail will be discard b

[jira] [Updated] (FLINK-31212) Data lost if window group after interval left join

2023-02-24 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-31212: -- Description:   I have a case in [^test.sql] that records in table_1 left join fail will be discard b

[jira] [Updated] (FLINK-31212) Data lost if window group after interval left join

2023-02-24 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-31212: -- Description:   I have a case in [^test.sql] that some records in table_1 left join fail will be disc

[jira] [Created] (FLINK-31212) Data lost if window group after interval left join

2023-02-24 Thread Lyn Zhang (Jira)
Lyn Zhang created FLINK-31212: - Summary: Data lost if window group after interval left join Key: FLINK-31212 URL: https://issues.apache.org/jira/browse/FLINK-31212 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-25695) TemporalJoin cause state leak in some cases

2022-02-28 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499347#comment-17499347 ] Lyn Zhang commented on FLINK-25695: --- Hi [~wenlong.lwl] Actually we used FsStateBackend

[jira] [Commented] (FLINK-25695) TemporalJoin cause state leak in some cases

2022-02-23 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17497238#comment-17497238 ] Lyn Zhang commented on FLINK-25695: --- If we create a KeyedMapState and add some element

[jira] [Comment Edited] (FLINK-25695) TemporalJoin cause state leak in some cases

2022-01-28 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17484059#comment-17484059 ] Lyn Zhang edited comment on FLINK-25695 at 1/29/22, 3:12 AM: -

[jira] [Comment Edited] (FLINK-25695) TemporalJoin cause state leak in some cases

2022-01-28 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17484059#comment-17484059 ] Lyn Zhang edited comment on FLINK-25695 at 1/29/22, 3:12 AM: -

[jira] [Updated] (FLINK-25695) TemporalJoin cause state leak in some cases

2022-01-28 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-25695: -- Attachment: image-2022-01-29-11-11-31-967.png > TemporalJoin cause state leak in some cases >

[jira] [Updated] (FLINK-25695) TemporalJoin cause state leak in some cases

2022-01-28 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-25695: -- Attachment: image-2022-01-29-11-11-27-550.png > TemporalJoin cause state leak in some cases >

[jira] [Updated] (FLINK-25695) TemporalJoin cause state leak in some cases

2022-01-28 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-25695: -- Attachment: image-2022-01-29-11-11-11-705.png > TemporalJoin cause state leak in some cases >

[jira] [Commented] (FLINK-25695) TemporalJoin cause state leak in some cases

2022-01-28 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17484059#comment-17484059 ] Lyn Zhang commented on FLINK-25695: --- [~wenlong.lwl] We can debug the unit test on  Te

[jira] [Comment Edited] (FLINK-25695) TemporalJoin cause state leak in some cases

2022-01-19 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17478523#comment-17478523 ] Lyn Zhang edited comment on FLINK-25695 at 1/19/22, 10:14 AM:

[jira] [Comment Edited] (FLINK-25695) TemporalJoin cause state leak in some cases

2022-01-19 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17478523#comment-17478523 ] Lyn Zhang edited comment on FLINK-25695 at 1/19/22, 10:12 AM:

[jira] [Comment Edited] (FLINK-25695) TemporalJoin cause state leak in some cases

2022-01-19 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17478523#comment-17478523 ] Lyn Zhang edited comment on FLINK-25695 at 1/19/22, 10:11 AM:

[jira] [Commented] (FLINK-25695) TemporalJoin cause state leak in some cases

2022-01-19 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17478523#comment-17478523 ] Lyn Zhang commented on FLINK-25695: --- Because The operator only register the smallest e

[jira] [Commented] (FLINK-25695) TemporalJoin cause state leak in some cases

2022-01-19 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17478486#comment-17478486 ] Lyn Zhang commented on FLINK-25695: --- The sql like below and set table.exec.state.ttl =

[jira] [Updated] (FLINK-25695) TemporalJoin cause state leak in some cases

2022-01-19 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-25695: -- Attachment: test.sql > TemporalJoin cause state leak in some cases > -

[jira] [Updated] (FLINK-25695) TemporalJoin cause state leak in some cases

2022-01-18 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-25695: -- Priority: Critical (was: Major) > TemporalJoin cause state leak in some cases > -

[jira] [Updated] (FLINK-25695) TemporalJoin cause state leak in some cases

2022-01-18 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-25695: -- Priority: Major (was: Critical) > TemporalJoin cause state leak in some cases > -

[jira] [Updated] (FLINK-25695) TemporalJoin cause state leak in some cases

2022-01-18 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-25695: -- Description: Last year, I reported the similar bug of TemporalJoin cause state leak. Detail: FLINK-21

[jira] [Updated] (FLINK-25695) TemporalJoin cause state leak in some cases

2022-01-18 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-25695: -- Description: Last year, I reported the similar bug of TemporalJoin cause state leak. Detail: FLINK-21

[jira] [Updated] (FLINK-25695) TemporalJoin cause state leak in some cases

2022-01-18 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-25695: -- Description: Last year, I reported the similar bug of TemporalJoin cause state leak. Detail: FLINK-21

[jira] [Updated] (FLINK-25695) TemporalJoin cause state leak in some cases

2022-01-18 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-25695: -- Description: Last year, I reported the similar bug of TemporalJoin cause state leak. Detail: FLINK-21

[jira] [Updated] (FLINK-25695) TemporalJoin cause state leak in some cases

2022-01-18 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-25695: -- Summary: TemporalJoin cause state leak in some cases (was: TemporalJoin cause state leak in some case

[jira] [Commented] (FLINK-25695) TemporalJoin cause state leak in some case

2022-01-18 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17478316#comment-17478316 ] Lyn Zhang commented on FLINK-25695: --- [~jark] Please help to check this issue > Tempor

[jira] [Updated] (FLINK-25695) TemporalJoin cause state leak in some case

2022-01-18 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-25695: -- Description: Last year, I reported the similar bug of TemporalJoin cause state leak. Detail: [FLINK-2

[jira] [Updated] (FLINK-25695) TemporalJoin cause state leak in some case

2022-01-18 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-25695: -- Description: Last year, I reported the similar bug of TemporalJoin cause state leak. Detail: [https:/

[jira] [Updated] (FLINK-25695) TemporalJoin cause state leak in some case

2022-01-18 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-25695: -- Description: Last year, I reported the similar bug of TemporalJoin cause state leak. Detail: [https:/

[jira] [Commented] (FLINK-25695) TemporalJoin cause state leak in some case

2022-01-18 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17478314#comment-17478314 ] Lyn Zhang commented on FLINK-25695: --- PR: https://github.com/apache/flink/pull/18398 >

[jira] [Created] (FLINK-25695) TemporalJoin cause state leak in some case

2022-01-18 Thread Lyn Zhang (Jira)
Lyn Zhang created FLINK-25695: - Summary: TemporalJoin cause state leak in some case Key: FLINK-25695 URL: https://issues.apache.org/jira/browse/FLINK-25695 Project: Flink Issue Type: Bug

[jira] [Comment Edited] (FLINK-24610) Flink projection common expression elimination

2021-10-26 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17434275#comment-17434275 ] Lyn Zhang edited comment on FLINK-24610 at 10/27/21, 2:33 AM:

[jira] [Updated] (FLINK-24610) Flink projection common expression elimination

2021-10-26 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-24610: -- Description: Flink sql projection not support reusing common expression in code generator. For exampl

[jira] [Commented] (FLINK-24610) Flink projection common expression elimination

2021-10-26 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17434275#comment-17434275 ] Lyn Zhang commented on FLINK-24610: --- [~jark] Please help to review this issue if you a

[jira] [Updated] (FLINK-24610) Flink projection common expression elimination

2021-10-26 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-24610: -- Description: Flink sql projection not support reusing common expression in code generator. For exampl

[jira] [Updated] (FLINK-24610) Flink projection common expression elimination

2021-10-21 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-24610: -- Description: Flink sql projection can not reuse common expression in code generator. For example the

[jira] [Updated] (FLINK-24610) Flink projection common expression elimination

2021-10-21 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-24610: -- Description: Flink sql projection can not reuse common expression in runtime stage. For example the s

[jira] [Updated] (FLINK-24610) Flink projection common expression elimination

2021-10-21 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-24610: -- Description: Flink sql projection can not reuse common expression in runtime stage. For example the s

[jira] [Created] (FLINK-24610) Flink projection common expression elimination

2021-10-21 Thread Lyn Zhang (Jira)
Lyn Zhang created FLINK-24610: - Summary: Flink projection common expression elimination Key: FLINK-24610 URL: https://issues.apache.org/jira/browse/FLINK-24610 Project: Flink Issue Type: Improvem

[jira] [Closed] (FLINK-24504) Flink udf common expression elimination

2021-10-12 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang closed FLINK-24504. - Resolution: Later > Flink udf common expression elimination > --- >

[jira] [Updated] (FLINK-24504) Flink udf common expression elimination

2021-10-11 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-24504: -- Description: Flink sql user define function can not reuse common expression in runtime stage. For exa

[jira] [Updated] (FLINK-24504) Flink udf common expression elimination

2021-10-11 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-24504: -- Description: Flink sql user define function can not reuse common expression in runtime stage. For exa

[jira] [Issue Comment Deleted] (FLINK-24504) Flink udf common expression elimination

2021-10-11 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-24504: -- Comment: was deleted (was: https://github.com/apache/flink/pull/17449) > Flink udf common expression

[jira] [Commented] (FLINK-24504) Flink udf common expression elimination

2021-10-11 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17427048#comment-17427048 ] Lyn Zhang commented on FLINK-24504: --- https://github.com/apache/flink/pull/17449 > Fli

[jira] [Updated] (FLINK-24504) Flink udf common expression elimination

2021-10-11 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-24504: -- Description: Flink sql user define function can not reuse common expression. For example the sql: SEL

[jira] [Created] (FLINK-24504) Flink udf common expression elimination

2021-10-11 Thread Lyn Zhang (Jira)
Lyn Zhang created FLINK-24504: - Summary: Flink udf common expression elimination Key: FLINK-24504 URL: https://issues.apache.org/jira/browse/FLINK-24504 Project: Flink Issue Type: Improvement