[jira] [Comment Edited] (FLINK-20255) Nested decorrelate failed

[ https://issues.apache.org/jira/browse/FLINK-20255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17684532#comment-17684532 ] Jianhui Dong edited comment on FLINK-20255 at 2/6/23 9:23 AM: -- Is there

[jira] [Commented] (FLINK-20255) Nested decorrelate failed

[ https://issues.apache.org/jira/browse/FLINK-20255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17684532#comment-17684532 ] Jianhui Dong commented on FLINK-20255: -- Is there anyone else following up on this issue? I found

[jira] [Closed] (FLINK-30849) udaf validated failed with TableEnvironment#executeSql but work correctly with StreamTableEnrivorment#registerFunction

[ https://issues.apache.org/jira/browse/FLINK-30849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jianhui Dong closed FLINK-30849. Resolution: Invalid > udaf validated failed with TableEnvironment#executeSql but work correctly

[jira] [Created] (FLINK-30849) udaf validated failed with TableEnvironment#executeSql but work correctly with StreamTableEnrivorment#registerFunction

Jianhui Dong created FLINK-30849: Summary: udaf validated failed with TableEnvironment#executeSql but work correctly with StreamTableEnrivorment#registerFunction Key: FLINK-30849 URL:

[jira] [Commented] (FLINK-20036) Join Has NoUniqueKey when using mini-batch

[ https://issues.apache.org/jira/browse/FLINK-20036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17654367#comment-17654367 ] Jianhui Dong commented on FLINK-20036: -- This issue is duplicated with Flink-27851. > Join Has

[jira] [Updated] (FLINK-30396) sql hint 'LOOKUP' which is defined in outer query block may take effect in inner query block

[ https://issues.apache.org/jira/browse/FLINK-30396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jianhui Dong updated FLINK-30396: - Description: As [flink

[jira] [Updated] (FLINK-30396) sql hint 'LOOKUP' which is defined in outer query block may take effect in inner query block

[ https://issues.apache.org/jira/browse/FLINK-30396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jianhui Dong updated FLINK-30396: - Description: As [flink

[jira] [Updated] (FLINK-30396) sql hint 'LOOKUP' which is defined in outer query block may take effect in inner query block

[ https://issues.apache.org/jira/browse/FLINK-30396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jianhui Dong updated FLINK-30396: - Description: As [flink

[jira] [Updated] (FLINK-30396) sql hint 'LOOKUP' which is defined in outer query block may take effect in inner query block

[ https://issues.apache.org/jira/browse/FLINK-30396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jianhui Dong updated FLINK-30396: - Description: As [flink

[jira] [Updated] (FLINK-30396) sql hint 'LOOKUP' which is defined in outer query block may take effect in inner query block

[ https://issues.apache.org/jira/browse/FLINK-30396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jianhui Dong updated FLINK-30396: - Description: As [flink

[jira] [Created] (FLINK-30396) sql hint 'LOOKUP' which is defined in outer query block may take effect in inner query block

Jianhui Dong created FLINK-30396: Summary: sql hint 'LOOKUP' which is defined in outer query block may take effect in inner query block Key: FLINK-30396 URL: https://issues.apache.org/jira/browse/FLINK-30396

[jira] [Commented] (FLINK-23687) Introduce partitioned lookup join to enforce input of LookupJoin to hash shuffle by lookup keys

[ https://issues.apache.org/jira/browse/FLINK-23687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17638049#comment-17638049 ] Jianhui Dong commented on FLINK-23687: -- Hello, I found one issue

[jira] [Commented] (FLINK-23687) Introduce partitioned lookup join to enforce input of LookupJoin to hash shuffle by lookup keys

[ https://issues.apache.org/jira/browse/FLINK-23687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17623631#comment-17623631 ] Jianhui Dong commented on FLINK-23687: -- Hello [~jingzhang] . I was trying to implement hash lookup

[jira] [Commented] (FLINK-24708) `ConvertToNotInOrInRule` has a bug which leads to wrong result

[ https://issues.apache.org/jira/browse/FLINK-24708?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17597605#comment-17597605 ] Jianhui Dong commented on FLINK-24708: -- hello, [~jingzhang], [~godfreyhe]  I had this problem

[jira] [Commented] (FLINK-26738) Default value of StateDescriptor is valid when enable state ttl config

[ https://issues.apache.org/jira/browse/FLINK-26738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17513252#comment-17513252 ] Jianhui Dong commented on FLINK-26738: -- [~yunta], resolved conflict, please check it agian. >

[jira] [Commented] (FLINK-26738) Default value of StateDescriptor is valid when enable state ttl config

[ https://issues.apache.org/jira/browse/FLINK-26738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17511865#comment-17511865 ] Jianhui Dong commented on FLINK-26738: -- [~yunta], this is the pr:

[jira] [Commented] (FLINK-26738) Default value of StateDescriptor is valid when enable state ttl config

[ https://issues.apache.org/jira/browse/FLINK-26738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17511704#comment-17511704 ] Jianhui Dong commented on FLINK-26738: -- [~yunta], thanks, I'd like to try it~ > Default value of

[jira] [Commented] (FLINK-26738) Default value of StateDescriptor is valid when enable state ttl config

[ https://issues.apache.org/jira/browse/FLINK-26738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17511616#comment-17511616 ] Jianhui Dong commented on FLINK-26738: -- [~yunta]thanks for your explanation, I think it's a good

[jira] [Comment Edited] (FLINK-26738) Default value of StateDescriptor is valid when enable state ttl config

[ https://issues.apache.org/jira/browse/FLINK-26738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17511616#comment-17511616 ] Jianhui Dong edited comment on FLINK-26738 at 3/24/22, 6:51 AM:

[jira] [Commented] (FLINK-26738) Default value of StateDescriptor is valid when enable state ttl config

[ https://issues.apache.org/jira/browse/FLINK-26738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17511363#comment-17511363 ] Jianhui Dong commented on FLINK-26738: -- And I think this is an issue worth discussing, from my

[jira] [Commented] (FLINK-26738) Default value of StateDescriptor is valid when enable state ttl config

[ https://issues.apache.org/jira/browse/FLINK-26738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17511354#comment-17511354 ] Jianhui Dong commented on FLINK-26738: -- sorry, I forget to add the ValueState#value() method,

[jira] [Comment Edited] (FLINK-26738) Default value of StateDescriptor is valid when enable state ttl config

[ https://issues.apache.org/jira/browse/FLINK-26738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17510267#comment-17510267 ] Jianhui Dong edited comment on FLINK-26738 at 3/23/22, 3:41 AM: "it will

[jira] [Commented] (FLINK-26738) Default value of StateDescriptor is valid when enable state ttl config

[ https://issues.apache.org/jira/browse/FLINK-26738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17510267#comment-17510267 ] Jianhui Dong commented on FLINK-26738: -- "it will always create another internl state descriptor and

[jira] [Updated] (FLINK-26738) Default value of StateDescriptor is valid when enable state ttl config

[ https://issues.apache.org/jira/browse/FLINK-26738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jianhui Dong updated FLINK-26738: - Description: Suppose we declare a ValueState like following: {code:java} ValueStateDescriptor>

[jira] [Updated] (FLINK-26738) Default value of StateDescriptor is valid when enable state ttl config

[ https://issues.apache.org/jira/browse/FLINK-26738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jianhui Dong updated FLINK-26738: - Priority: Critical (was: Blocker) > Default value of StateDescriptor is valid when enable

[jira] [Created] (FLINK-26738) Default value of StateDescriptor is valid when enable state ttl config

Jianhui Dong created FLINK-26738: Summary: Default value of StateDescriptor is valid when enable state ttl config Key: FLINK-26738 URL: https://issues.apache.org/jira/browse/FLINK-26738 Project:

[jira] [Commented] (FLINK-25273) Some doubts about the FLINK-22848

[ https://issues.apache.org/jira/browse/FLINK-25273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17464320#comment-17464320 ] Jianhui Dong commented on FLINK-25273: -- Hi, I've sent the email a week ago, but there is no

[jira] [Commented] (FLINK-25273) Some doubts about the FLINK-22848

[ https://issues.apache.org/jira/browse/FLINK-25273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17459691#comment-17459691 ] Jianhui Dong commented on FLINK-25273: -- Thank u. I sent an email about this issue to user-zh

[jira] [Closed] (FLINK-25272) Flink sql syntax analysis is inconsistent with the sql grammer declared now

[ https://issues.apache.org/jira/browse/FLINK-25272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jianhui Dong closed FLINK-25272. Resolution: Invalid > Flink sql syntax analysis is inconsistent with the sql grammer declared now

[jira] [Commented] (FLINK-25272) Flink sql syntax analysis is inconsistent with the sql grammer declared now

[ https://issues.apache.org/jira/browse/FLINK-25272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17459687#comment-17459687 ] Jianhui Dong commented on FLINK-25272: -- Thank you for your reply, I'm sorry that I misunderstood

[jira] [Created] (FLINK-25273) Some doubts about the FLINK-22848

Jianhui Dong created FLINK-25273: Summary: Some doubts about the FLINK-22848 Key: FLINK-25273 URL: https://issues.apache.org/jira/browse/FLINK-25273 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-25272) Flink sql syntax analysis is inconsistent with the sql grammer declared now

[ https://issues.apache.org/jira/browse/FLINK-25272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jianhui Dong updated FLINK-25272: - Description: Syntax analysis in the

[jira] [Created] (FLINK-25272) Flink sql syntax analysis is inconsistent with the sql grammer declared now

Jianhui Dong created FLINK-25272: Summary: Flink sql syntax analysis is inconsistent with the sql grammer declared now Key: FLINK-25272 URL: https://issues.apache.org/jira/browse/FLINK-25272 Project: