[jira] [Commented] (FLINK-34156) Move Flink Calcite rules from Scala to Java

[ https://issues.apache.org/jira/browse/FLINK-34156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17824223#comment-17824223 ] Yunhong Zheng commented on FLINK-34156: --- Thanks, [~Sergey Nuyanzin] . I will try to review these

[jira] [Commented] (FLINK-34156) Move Flink Calcite rules from Scala to Java

[ https://issues.apache.org/jira/browse/FLINK-34156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17818607#comment-17818607 ] Yunhong Zheng commented on FLINK-34156: --- Hi, [~Sergey Nuyanzin] . Since I have been continuously

[jira] [Commented] (FLINK-34374) Complete work for syntax `DESCRIBE EXTENDED DATABASE databaseName`

[ https://issues.apache.org/jira/browse/FLINK-34374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17814587#comment-17814587 ] Yunhong Zheng commented on FLINK-34374: --- Hi, [~xuyangzhong] . I want to take this issue, can u

[jira] [Commented] (FLINK-34375) Complete work for syntax `DESCRIBE EXTENDED tableName`

[ https://issues.apache.org/jira/browse/FLINK-34375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17814586#comment-17814586 ] Yunhong Zheng commented on FLINK-34375: --- Hi, [~xuyangzhong] . I worked on the DESCRIBE EXTENDED

[jira] [Commented] (FLINK-34376) FLINK SQL SUM() causes a precision error

[ https://issues.apache.org/jira/browse/FLINK-34376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17814582#comment-17814582 ] Yunhong Zheng commented on FLINK-34376: --- Hi, [~liufangliang] . Can you provide your SQL pattern?

[jira] (FLINK-34376) FLINK SQL SUM() causes a precision error

[ https://issues.apache.org/jira/browse/FLINK-34376 ] Yunhong Zheng deleted comment on FLINK-34376: --- was (Author: JIRAUSER287975): Hi, [~liufangliang] . Can you provide your SQL pattern? This would allow for a clearer description of the

[jira] [Commented] (FLINK-34147) TimestampData to/from LocalDateTime is ambiguous

[ https://issues.apache.org/jira/browse/FLINK-34147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17814566#comment-17814566 ] Yunhong Zheng commented on FLINK-34147: --- Hi, [~lirui]  and [~jark] . Can you assign this issue to

[jira] [Commented] (FLINK-34370) [Umbrella] Complete work about enhanced Flink SQL DDL

[ https://issues.apache.org/jira/browse/FLINK-34370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17814565#comment-17814565 ] Yunhong Zheng commented on FLINK-34370: --- Hi, [~xuyangzhong] .I hope I can also participate in the

[jira] [Commented] (FLINK-34362) Add argument to reuse connector docs cache in setup_docs.sh to improve build times

[ https://issues.apache.org/jira/browse/FLINK-34362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17814558#comment-17814558 ] Yunhong Zheng commented on FLINK-34362: --- Hi, [~qingyue]  and [~martijnvisser]. I'm looking forward

[jira] [Commented] (FLINK-33760) Group Window agg has different result when only consuming -D records while using or not using minibatch

[ https://issues.apache.org/jira/browse/FLINK-33760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17810625#comment-17810625 ] Yunhong Zheng commented on FLINK-33760: --- After offline discussion with [~lincoln.86xy]  and

[jira] [Commented] (FLINK-34016) Janino compile failed when watermark with column by udf

[ https://issues.apache.org/jira/browse/FLINK-34016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17810339#comment-17810339 ] Yunhong Zheng commented on FLINK-34016: --- Hi, [~wczhu] , I cann't reproduce this error in my local

[jira] [Commented] (FLINK-34147) TimestampData to/from LocalDateTime is ambiguous

[ https://issues.apache.org/jira/browse/FLINK-34147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17810300#comment-17810300 ] Yunhong Zheng commented on FLINK-34147: --- Hi, [~lirui] . I also think it ambiguous. IMO,

[jira] [Commented] (FLINK-33760) Group Window agg has different result when only consuming -D records while using or not using minibatch

[ https://issues.apache.org/jira/browse/FLINK-33760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17810232#comment-17810232 ] Yunhong Zheng commented on FLINK-33760: --- [~xuyangzhong]  It looks like a bug,  I want to take this

[jira] [Commented] (FLINK-33928) Should not throw exception while creating view with specify field names even if the query conflicts in field names

[ https://issues.apache.org/jira/browse/FLINK-33928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17805962#comment-17805962 ] Yunhong Zheng commented on FLINK-33928: --- Hi, [~xuyangzhong]. I want to take this issue. Thanks. >

[jira] [Updated] (FLINK-34066) LagFunction throw NPE when input argument are not null

[ https://issues.apache.org/jira/browse/FLINK-34066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yunhong Zheng updated FLINK-34066: -- Description: This issue is related to https://issues.apache.org/jira/browse/FLINK-31967. In

[jira] [Updated] (FLINK-34066) LagFunction throw NPE when input argument are not null

[ https://issues.apache.org/jira/browse/FLINK-34066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yunhong Zheng updated FLINK-34066: -- Description: This issue is related to  (was: LagFunction throw NPE when input argument are

[jira] [Commented] (FLINK-34066) LagFunction throw NPE when input argument are not null

[ https://issues.apache.org/jira/browse/FLINK-34066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17805938#comment-17805938 ] Yunhong Zheng commented on FLINK-34066: --- [~martijnvisser] ，Sorry for not adding more details, I

[jira] [Commented] (FLINK-34066) LagFunction throw NPE when input argument are not null

[ https://issues.apache.org/jira/browse/FLINK-34066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17805936#comment-17805936 ] Yunhong Zheng commented on FLINK-34066: --- Hi, [~martijnvisser] . The new test case has not

[jira] [Commented] (FLINK-34066) LagFunction throw NPE when input argument are not null

[ https://issues.apache.org/jira/browse/FLINK-34066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17805933#comment-17805933 ] Yunhong Zheng commented on FLINK-34066: --- hi, [~martijnvisser] . This is a related bug of

[jira] [Created] (FLINK-34066) LagFunction throw NPE when input argument are not null

Yunhong Zheng created FLINK-34066: - Summary: LagFunction throw NPE when input argument are not null Key: FLINK-34066 URL: https://issues.apache.org/jira/browse/FLINK-34066 Project: Flink

[jira] [Updated] (FLINK-33691) Support agg push down for 'count(*)/count(1)/count(column not null)'

[ https://issues.apache.org/jira/browse/FLINK-33691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yunhong Zheng updated FLINK-33691: -- Description: Now,  PushLocalAggIntoScanRule cannot push down 'count( *

[jira] [Created] (FLINK-33691) Support agg push down for 'count(*)/count(1)/count(column not null)'

Yunhong Zheng created FLINK-33691: - Summary: Support agg push down for 'count(*)/count(1)/count(column not null)' Key: FLINK-33691 URL: https://issues.apache.org/jira/browse/FLINK-33691 Project:

[jira] [Commented] (FLINK-22870) Grouping sets + case when + constant string throws AssertionError

[ https://issues.apache.org/jira/browse/FLINK-22870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17775662#comment-17775662 ] Yunhong Zheng commented on FLINK-22870: --- Hi, [~fsk119] . I want to get this tickets, can you

[jira] [Commented] (FLINK-26497) Cast Exception when use split agg with multiple filters

[ https://issues.apache.org/jira/browse/FLINK-26497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17773909#comment-17773909 ] Yunhong Zheng commented on FLINK-26497: --- This problem seems cannot be reproduce in master branch.

[jira] [Closed] (FLINK-33143) Wrongly throw error while temporary table join with invalidScan lookup source and selected as view

[ https://issues.apache.org/jira/browse/FLINK-33143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yunhong Zheng closed FLINK-33143. - Resolution: Resolved > Wrongly throw error while temporary table join with invalidScan lookup

[jira] [Commented] (FLINK-33143) Wrongly throw error while temporary table join with invalidScan lookup source and selected as view

[ https://issues.apache.org/jira/browse/FLINK-33143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17768969#comment-17768969 ] Yunhong Zheng commented on FLINK-33143: --- This fix way cannot cover all sql pattern, like subQuery,

[jira] [Commented] (FLINK-18356) flink-table-planner Exit code 137 returned from process

[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17768484#comment-17768484 ] Yunhong Zheng commented on FLINK-18356: --- Hi, [~Sergey Nuyanzin] , [~renqs]  [~mapohl] . I have

[jira] [Created] (FLINK-33143) Wrongly throw error while temporary table join with invalidScan lookup source and selected as view

Yunhong Zheng created FLINK-33143: - Summary: Wrongly throw error while temporary table join with invalidScan lookup source and selected as view Key: FLINK-33143 URL:

[jira] [Commented] (FLINK-22128) Window aggregation should have unique keys

[ https://issues.apache.org/jira/browse/FLINK-22128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17765504#comment-17765504 ] Yunhong Zheng commented on FLINK-22128: --- Hi, [~lzljs3620320] . Does this issue still need to be

[jira] [Commented] (FLINK-25593) A redundant scan could be skipped if it is an input of join and the other input is empty after partition prune

[ https://issues.apache.org/jira/browse/FLINK-25593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17764951#comment-17764951 ] Yunhong Zheng commented on FLINK-25593: --- Hi, [~jark] . I think the better final plan of this case

[jira] [Commented] (FLINK-25593) A redundant scan could be skipped if it is an input of join and the other input is empty after partition prune

[ https://issues.apache.org/jira/browse/FLINK-25593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17764949#comment-17764949 ] Yunhong Zheng commented on FLINK-25593: --- Hi, [~luoyuxia] .Is this still in progress? If not, could

[jira] [Commented] (FLINK-33083) SupportsReadingMetadata is not applied when loading a CompiledPlan

[ https://issues.apache.org/jira/browse/FLINK-33083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17764666#comment-17764666 ] Yunhong Zheng commented on FLINK-33083: --- It looks like this is a planner bug, and we don't have

[jira] [Created] (FLINK-33085) Improve the error message when the invalidate lookupTableSource without primary key is used as temporal join table

Yunhong Zheng created FLINK-33085: - Summary: Improve the error message when the invalidate lookupTableSource without primary key is used as temporal join table Key: FLINK-33085 URL:

[jira] [Created] (FLINK-33064) Improve the error message when the lookup source is used as the scan source

Yunhong Zheng created FLINK-33064: - Summary: Improve the error message when the lookup source is used as the scan source Key: FLINK-33064 URL: https://issues.apache.org/jira/browse/FLINK-33064

[jira] [Commented] (FLINK-33063) udaf with user defined pojo object throw error while generate record equaliser

[ https://issues.apache.org/jira/browse/FLINK-33063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17762932#comment-17762932 ] Yunhong Zheng commented on FLINK-33063: --- Hi, [~lincoln.86xy] . Can you assign this issue to me?

[jira] [Created] (FLINK-33063) udaf with user defined pojo object throw error while generate record equaliser

Yunhong Zheng created FLINK-33063: - Summary: udaf with user defined pojo object throw error while generate record equaliser Key: FLINK-33063 URL: https://issues.apache.org/jira/browse/FLINK-33063

[jira] [Commented] (FLINK-33010) NPE when using GREATEST() in Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-33010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17760852#comment-17760852 ] Yunhong Zheng commented on FLINK-33010: --- Hi, [~Sergey Nuyanzin], It looks like master branch also

[jira] [Commented] (FLINK-32997) [JUnit5 Migration] Module: flink-table-planner (StreamingTestBase)

[ https://issues.apache.org/jira/browse/FLINK-32997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17760342#comment-17760342 ] Yunhong Zheng commented on FLINK-32997: --- Hi, [~jiabao.sun] , thanks for your contribution. IMO,

[jira] [Commented] (FLINK-32993) Datagen connector produce unexpected Char type data

[ https://issues.apache.org/jira/browse/FLINK-32993?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17760234#comment-17760234 ] Yunhong Zheng commented on FLINK-32993: --- Hi, [~liyubin117] . it's a by design behavior. If you

[jira] [Commented] (FLINK-25242) UDF with primitive int argument does not accept int values even after a not null filter

[ https://issues.apache.org/jira/browse/FLINK-25242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17758873#comment-17758873 ] Yunhong Zheng commented on FLINK-25242: --- Hi, [~lincoln.86xy] . I find this case cannot reproduce

[jira] [Commented] (FLINK-28518) Exception: AssertionError: Cannot add expression of different type to set in sub-query with ROW type

[ https://issues.apache.org/jira/browse/FLINK-28518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17758872#comment-17758872 ] Yunhong Zheng commented on FLINK-28518: --- Hi, [~martijnvisser]  and [~KoylubaevNT] . This case

[jira] [Commented] (FLINK-30201) Function "unnest" can't process nesting JSON properly

[ https://issues.apache.org/jira/browse/FLINK-30201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17758852#comment-17758852 ] Yunhong Zheng commented on FLINK-30201: --- Hi, [~mooonzhang] . I think it's not a bug, you need to

[jira] [Commented] (FLINK-32940) Support projection pushdown to table source for column projections through UDTF

[ https://issues.apache.org/jira/browse/FLINK-32940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17758824#comment-17758824 ] Yunhong Zheng commented on FLINK-32940: --- Hi, [~vsowrirajan] . I think your idea is good, but the

[jira] [Updated] (FLINK-32952) Scan reuse with readable metadata and watermark push down will get wrong watermark

[ https://issues.apache.org/jira/browse/FLINK-32952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yunhong Zheng updated FLINK-32952: -- Description: Scan reuse with readable metadata and watermark push down will get wrong result.

[jira] [Updated] (FLINK-32952) Scan reuse with readable metadata and watermark push down will get wrong watermark

[ https://issues.apache.org/jira/browse/FLINK-32952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yunhong Zheng updated FLINK-32952: -- Summary: Scan reuse with readable metadata and watermark push down will get wrong watermark

[jira] [Created] (FLINK-32952) Source reuse with readable metadata and watermark push down will get wrong watermark

Yunhong Zheng created FLINK-32952: - Summary: Source reuse with readable metadata and watermark push down will get wrong watermark Key: FLINK-32952 URL: https://issues.apache.org/jira/browse/FLINK-32952

[jira] [Commented] (FLINK-25242) UDF with primitive int argument does not accept int values even after a not null filter

[ https://issues.apache.org/jira/browse/FLINK-25242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17758465#comment-17758465 ] Yunhong Zheng commented on FLINK-25242: --- Yes, [~lincoln.86xy] . Thank you for your reminder. I

[jira] (FLINK-32296) Flink SQL handle array of row incorrectly

[ https://issues.apache.org/jira/browse/FLINK-32296 ] Yunhong Zheng deleted comment on FLINK-32296: --- was (Author: JIRAUSER287975): Hi, [~Sergey Nuyanzin]. Sorry for I'm not checking whether there are same issue in jira at the beginning,

[jira] [Commented] (FLINK-32897) RowToRowCastRule will get wrong result while cast Array(Row()) type

[ https://issues.apache.org/jira/browse/FLINK-32897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17758324#comment-17758324 ] Yunhong Zheng commented on FLINK-32897: --- Hi, [~Sergey Nuyanzin]. Sorry for I'm not checking

[jira] [Commented] (FLINK-32296) Flink SQL handle array of row incorrectly

[ https://issues.apache.org/jira/browse/FLINK-32296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17758323#comment-17758323 ] Yunhong Zheng commented on FLINK-32296: --- Hi, [~Sergey Nuyanzin]. Sorry for I'm not checking

[jira] [Commented] (FLINK-32940) Support projection pushdown to table source for column projections through UDTF

[ https://issues.apache.org/jira/browse/FLINK-32940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17757996#comment-17757996 ] Yunhong Zheng commented on FLINK-32940: --- Sure, [~jark] . Please assign to me. Thanks! > Support

[jira] [Updated] (FLINK-32897) RowToRowCastRule will get wrong result while cast Array(Row()) type

[ https://issues.apache.org/jira/browse/FLINK-32897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yunhong Zheng updated FLINK-32897: -- Summary: RowToRowCastRule will get wrong result while cast Array(Row()) type (was: Kafka

[jira] [Commented] (FLINK-32897) Kafka with nested array row type will get wrong result

[ https://issues.apache.org/jira/browse/FLINK-32897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17756725#comment-17756725 ] Yunhong Zheng commented on FLINK-32897: --- Thanks, [~renqs] . Can you assign this issue to me, I

[jira] [Created] (FLINK-32897) Kafka with nested array row type will get wrong result

Yunhong Zheng created FLINK-32897: - Summary: Kafka with nested array row type will get wrong result Key: FLINK-32897 URL: https://issues.apache.org/jira/browse/FLINK-32897 Project: Flink

[jira] [Commented] (FLINK-32321) Temporal Join job missing condition after “ON”

[ https://issues.apache.org/jira/browse/FLINK-32321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17752710#comment-17752710 ] Yunhong Zheng commented on FLINK-32321: --- Hi, [~jark] . Could you assign this issue to me ? Thanks!

[jira] [Commented] (FLINK-27402) Unexpected boolean expression simplification for AND expression

[ https://issues.apache.org/jira/browse/FLINK-27402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17752024#comment-17752024 ] Yunhong Zheng commented on FLINK-27402: --- Currently, Flink does not have the ability to perform

[jira] (FLINK-20255) Nested decorrelate failed

[ https://issues.apache.org/jira/browse/FLINK-20255 ] Yunhong Zheng deleted comment on FLINK-20255: --- was (Author: JIRAUSER287975): Hi, [~jark] . After reading source code. I think this is not a bug cause by Flink, Could you help to close

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

[ https://issues.apache.org/jira/browse/FLINK-20255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17751959#comment-17751959 ] Yunhong Zheng commented on FLINK-20255: --- Hi, [~jark] . After reading source code. I think this is

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

[ https://issues.apache.org/jira/browse/FLINK-20255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17751957#comment-17751957 ] Yunhong Zheng commented on FLINK-20255: --- Hi [~lam167] . By design, your example cannot work. Now,

[jira] [Commented] (FLINK-18356) flink-table-planner Exit code 137 returned from process

[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17751907#comment-17751907 ] Yunhong Zheng commented on FLINK-18356: --- Thanks [~mapohl] . I will do this work. >

[jira] [Commented] (FLINK-32638) CI build failed because e2e_1_ci throw error Bash exited with code '1'

[ https://issues.apache.org/jira/browse/FLINK-32638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17745473#comment-17745473 ] Yunhong Zheng commented on FLINK-32638: ---

[jira] [Commented] (FLINK-18356) flink-table-planner Exit code 137 returned from process

[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17745356#comment-17745356 ] Yunhong Zheng commented on FLINK-18356: --- Hello, [~chesnay]. Could you please modify the JVM glibc

[jira] [Created] (FLINK-32638) CI build failed because e2e_1_ci throw error Bash exited with code '1'

Yunhong Zheng created FLINK-32638: - Summary: CI build failed because e2e_1_ci throw error Bash exited with code '1' Key: FLINK-32638 URL: https://issues.apache.org/jira/browse/FLINK-32638 Project:

[jira] [Commented] (FLINK-32579) The filter criteria on the lookup table of Lookup join has no effect

[ https://issues.apache.org/jira/browse/FLINK-32579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17743009#comment-17743009 ] Yunhong Zheng commented on FLINK-32579: --- Hi, [~jasonliangyc] . I got it. For question1: there is

[jira] [Updated] (FLINK-32577) Avoid memory fragmentation when running CI for flink-table-planner module

[ https://issues.apache.org/jira/browse/FLINK-32577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yunhong Zheng updated FLINK-32577: -- Description: This issue is a sub-issue of FLINK-18356.     was:This issue is a sub-issue

[jira] [Commented] (FLINK-32579) The filter criteria on the lookup table of Lookup join has no effect

[ https://issues.apache.org/jira/browse/FLINK-32579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17742728#comment-17742728 ] Yunhong Zheng commented on FLINK-32579: --- Hi [~jasonliangyc] . Are you using Flink version 1.17.0? 

[jira] [Updated] (FLINK-32579) The filter criteria on the lookup table of Lookup join has no effect

[ https://issues.apache.org/jira/browse/FLINK-32579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yunhong Zheng updated FLINK-32579: -- Attachment: image-2023-07-13-17-19-26-972.png > The filter criteria on the lookup table of

[jira] [Commented] (FLINK-32528) The RexCall a = a,if a's datatype is nullable, and when a is null, a = a is null, it isn't true in BinaryComparisonExprReducer

[ https://issues.apache.org/jira/browse/FLINK-32528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17741974#comment-17741974 ] Yunhong Zheng commented on FLINK-32528: --- Hi, [~shenlang] , can you provide a specific sql query as

[jira] [Updated] (FLINK-32577) Avoid memory fragmentation when running CI for flink-table-planner module

[ https://issues.apache.org/jira/browse/FLINK-32577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yunhong Zheng updated FLINK-32577: -- Description: This issue is a sub-issue of FLINK-18356. (was: This issue is a sub-issue of

[jira] [Updated] (FLINK-32577) Avoid memory fragmentation when running CI for flink-table-planner module

[ https://issues.apache.org/jira/browse/FLINK-32577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yunhong Zheng updated FLINK-32577: -- Description: This issue is a sub-issue of FLINK-18356. When I run mvn verify for flink

[jira] [Comment Edited] (FLINK-18356) flink-table-planner Exit code 137 returned from process

[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17741961#comment-17741961 ] Yunhong Zheng edited comment on FLINK-18356 at 7/11/23 11:55 AM: - Hi,

[jira] [Commented] (FLINK-18356) flink-table-planner Exit code 137 returned from process

[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17741963#comment-17741963 ] Yunhong Zheng commented on FLINK-18356: --- Hi [~chesnay] , could you take a look at this issue and

[jira] [Commented] (FLINK-18356) flink-table-planner Exit code 137 returned from process

[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17741961#comment-17741961 ] Yunhong Zheng commented on FLINK-18356: --- Hi, all. I think I found the root cause of table-planner

[jira] [Created] (FLINK-32577) Avoid memory fragmentation when running CI for flink-table-planner module

Yunhong Zheng created FLINK-32577: - Summary: Avoid memory fragmentation when running CI for flink-table-planner module Key: FLINK-32577 URL: https://issues.apache.org/jira/browse/FLINK-32577 Project:

[jira] [Updated] (FLINK-18356) flink-table-planner Exit code 137 returned from process

[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yunhong Zheng updated FLINK-18356: -- Attachment: image-2023-07-11-19-41-18-626.png > flink-table-planner Exit code 137 returned

[jira] [Updated] (FLINK-18356) flink-table-planner Exit code 137 returned from process

[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yunhong Zheng updated FLINK-18356: -- Attachment: image-2023-07-11-19-41-37-105.png > flink-table-planner Exit code 137 returned

[jira] [Updated] (FLINK-18356) flink-table-planner Exit code 137 returned from process

[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yunhong Zheng updated FLINK-18356: -- Attachment: image-2023-07-11-19-35-54-530.png > flink-table-planner Exit code 137 returned

[jira] [Updated] (FLINK-18356) flink-table-planner Exit code 137 returned from process

[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yunhong Zheng updated FLINK-18356: -- Attachment: image-2023-07-11-19-28-52-851.png > flink-table-planner Exit code 137 returned

[jira] [Commented] (FLINK-18356) flink-table-planner Exit code 137 returned from process

[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17740572#comment-17740572 ] Yunhong Zheng commented on FLINK-18356: --- Hi, all. The frequently occur of this error recently may

[jira] [Commented] (FLINK-32471) IS_NOT_NULL can add to SUITABLE_FILTER_TO_PUSH

[ https://issues.apache.org/jira/browse/FLINK-32471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17738939#comment-17738939 ] Yunhong Zheng commented on FLINK-32471: --- Hi, [~grandfisher] .  I agree with you, 'IS_NOT_NULL' is

[jira] [Updated] (FLINK-31273) Left join with IS_NULL filter be wrongly pushed down and get wrong join results

[ https://issues.apache.org/jira/browse/FLINK-31273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yunhong Zheng updated FLINK-31273: -- Fix Version/s: 1.17.0 (was: 1.17.1) > Left join with IS_NULL filter be

[jira] [Updated] (FLINK-31273) Left join with IS_NULL filter be wrongly pushed down and get wrong join results

[ https://issues.apache.org/jira/browse/FLINK-31273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yunhong Zheng updated FLINK-31273: -- Priority: Blocker (was: Major) > Left join with IS_NULL filter be wrongly pushed down and

[jira] [Created] (FLINK-31273) Left join with IS_NULL filter be wrongly pushed down and get wrong join results

Yunhong Zheng created FLINK-31273: - Summary: Left join with IS_NULL filter be wrongly pushed down and get wrong join results Key: FLINK-31273 URL: https://issues.apache.org/jira/browse/FLINK-31273

[jira] [Closed] (FLINK-31061) Release Testing: Verify FLINK-30376 Introduce a new flink bushy join reorder rule which based on greedy algorithm

[ https://issues.apache.org/jira/browse/FLINK-31061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yunhong Zheng closed FLINK-31061. - Resolution: Fixed > Release Testing: Verify FLINK-30376 Introduce a new flink bushy join

[jira] [Commented] (FLINK-31061) Release Testing: Verify FLINK-30376 Introduce a new flink bushy join reorder rule which based on greedy algorithm

[ https://issues.apache.org/jira/browse/FLINK-31061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17691961#comment-17691961 ] Yunhong Zheng commented on FLINK-31061: --- Thanks, [~JunRuiLi]  for your careful testing. no

[jira] [Commented] (FLINK-18356) flink-table-planner Exit code 137 returned from process

[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17689727#comment-17689727 ] Yunhong Zheng commented on FLINK-18356: --- !image-2023-02-16-20-18-09-431.png|width=628,height=261!

[jira] [Updated] (FLINK-18356) flink-table-planner Exit code 137 returned from process

[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yunhong Zheng updated FLINK-18356: -- Attachment: image-2023-02-16-20-18-09-431.png > flink-table-planner Exit code 137 returned

[jira] [Commented] (FLINK-18356) flink-table-planner Exit code 137 returned from process

[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17689724#comment-17689724 ] Yunhong Zheng commented on FLINK-18356: --- Hi, [~mapohl]  and [~martijnvisser] . I found that I

[jira] [Updated] (FLINK-31082) Setting maven property 'flink.resueForks' to false in table planner module

[ https://issues.apache.org/jira/browse/FLINK-31082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yunhong Zheng updated FLINK-31082: -- Description: This issue is created to alleviate the OOM problem mentioned in issue:

[jira] [Updated] (FLINK-31082) Setting maven property 'flink.resueForks' to false in table planner module

[ https://issues.apache.org/jira/browse/FLINK-31082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yunhong Zheng updated FLINK-31082: -- Description: This issue is created to alleviate the OOM problem mentioned in issue:

[jira] [Updated] (FLINK-31082) Setting maven property 'flink.resueForks' to false in table planner module

[ https://issues.apache.org/jira/browse/FLINK-31082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yunhong Zheng updated FLINK-31082: -- Description: This issue is created to alleviate the OOM problem mentioned in issue:

[jira] [Updated] (FLINK-31082) Setting maven property 'flink.resueForks' to false in table planner module

[ https://issues.apache.org/jira/browse/FLINK-31082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yunhong Zheng updated FLINK-31082: -- Description: This issue is created to alleviate the OOM problem mentioned in issue:

[jira] [Updated] (FLINK-31082) Setting maven property 'flink.resueForks' to false in table planner module

[ https://issues.apache.org/jira/browse/FLINK-31082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yunhong Zheng updated FLINK-31082: -- Description: This issue is created to alleviate the OOM problem mentioned in issue: [Exit

[jira] [Created] (FLINK-31082) Setting maven property 'flink.resueForks' to false in table planner module

Yunhong Zheng created FLINK-31082: - Summary: Setting maven property 'flink.resueForks' to false in table planner module Key: FLINK-31082 URL: https://issues.apache.org/jira/browse/FLINK-31082

[jira] [Commented] (FLINK-31079) Release Testing: Verify FLINK-29663 Further improvements of adaptive batch scheduler

[ https://issues.apache.org/jira/browse/FLINK-31079?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17688900#comment-17688900 ] Yunhong Zheng commented on FLINK-31079: --- I hope to get this ticket, [~wanglijie]  > Release

[jira] [Commented] (FLINK-18356) flink-table-planner Exit code 137 returned from process

[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17688791#comment-17688791 ] Yunhong Zheng commented on FLINK-18356: --- Hi all, we are still trying to solve this problem. We are

[jira] [Comment Edited] (FLINK-31059) Release Testing: Verify FLINK-29717 Supports hive udaf such as sum/count by native implementation

[ https://issues.apache.org/jira/browse/FLINK-31059?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17688435#comment-17688435 ] Yunhong Zheng edited comment on FLINK-31059 at 2/14/23 10:43 AM: - I hope

[jira] [Commented] (FLINK-31059) Release Testing: Verify FLINK-29717 Supports hive udaf such as sum/count by native implementation

[ https://issues.apache.org/jira/browse/FLINK-31059?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17688435#comment-17688435 ] Yunhong Zheng commented on FLINK-31059: --- I hope to get this tickets, [~lsy]  > Release Testing:

[jira] [Updated] (FLINK-31060) Release Testing: Verify FLINK-30542 Support adaptive local hash aggregate in runtime

[ https://issues.apache.org/jira/browse/FLINK-31060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yunhong Zheng updated FLINK-31060: -- Description: This issue aims to verify FLINK-30542: Support adaptive local hash aggregate in

[jira] [Updated] (FLINK-31060) Release Testing: Verify FLINK-30542 Support adaptive local hash aggregate in runtime

[ https://issues.apache.org/jira/browse/FLINK-31060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yunhong Zheng updated FLINK-31060: -- Description: This issue aims to verify FLINK-30542: [Support adaptive local hash aggregate in

  1   2   3   >