[jira] [Assigned] (FLINK-20400) Migrate test_streaming_sql.sh

[ https://issues.apache.org/jira/browse/FLINK-20400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-20400: --- Assignee: Muhammet Orazov > Migrate test_streaming_sql.sh > - > >

[jira] [Comment Edited] (FLINK-33934) Flink SQL Source use raw format maybe lead to data lost

[ https://issues.apache.org/jira/browse/FLINK-33934?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17834844#comment-17834844 ] Jark Wu edited comment on FLINK-33934 at 4/8/24 8:31 AM: - [~yunta] yes, I think

[jira] [Commented] (FLINK-33934) Flink SQL Source use raw format maybe lead to data lost

[ https://issues.apache.org/jira/browse/FLINK-33934?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17834844#comment-17834844 ] Jark Wu commented on FLINK-33934: - [~yunta] yes, I think the row format should avoid reuse RowData just

[jira] [Created] (FLINK-34654) Add "Special Thanks" Page on the Flink Website

Jark Wu created FLINK-34654: --- Summary: Add "Special Thanks" Page on the Flink Website Key: FLINK-34654 URL: https://issues.apache.org/jira/browse/FLINK-34654 Project: Flink Issue Type: New Feature

[jira] [Closed] (FLINK-20399) Migrate test_sql_client.sh

[ https://issues.apache.org/jira/browse/FLINK-20399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-20399. --- Assignee: (was: Lorenzo Affetti) Resolution: Fixed > Migrate test_sql_client.sh >

[jira] [Commented] (FLINK-20399) Migrate test_sql_client.sh

[ https://issues.apache.org/jira/browse/FLINK-20399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17823859#comment-17823859 ] Jark Wu commented on FLINK-20399: - [~lorenzo.affetti] Yes, I think so. Thank you for the reminder. >

[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=17810723#comment-17810723 ] Jark Wu commented on FLINK-34147: - I agree it is ambiguous. Currently, {{TimestampData}} represents both

[jira] [Assigned] (FLINK-27331) Support Avro microsecond precision for TIME

[ https://issues.apache.org/jira/browse/FLINK-27331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-27331: --- Assignee: Peter Huang > Support Avro microsecond precision for TIME >

[jira] [Assigned] (FLINK-24939) Support 'SHOW CREATE CATALOG' syntax

[ https://issues.apache.org/jira/browse/FLINK-24939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-24939: --- Assignee: Yubin Li > Support 'SHOW CREATE CATALOG' syntax > >

[jira] [Assigned] (FLINK-20281) Window aggregation supports changelog stream input

[ https://issues.apache.org/jira/browse/FLINK-20281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-20281: --- Assignee: xuyang > Window aggregation supports changelog stream input >

[jira] [Created] (FLINK-33600) Print cost time for batch queries in SQL Client

Jark Wu created FLINK-33600: --- Summary: Print cost time for batch queries in SQL Client Key: FLINK-33600 URL: https://issues.apache.org/jira/browse/FLINK-33600 Project: Flink Issue Type: New

[jira] [Updated] (FLINK-20281) Window aggregation supports changelog stream input

[ https://issues.apache.org/jira/browse/FLINK-20281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20281: Priority: Major (was: Not a Priority) > Window aggregation supports changelog stream input >

[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=17763319#comment-17763319 ] Jark Wu commented on FLINK-33063: - Fixed in - master: 01cb6ef008273100718cd8a8cfd921c02b8b8caa -

[jira] [Updated] (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:all-tabpanel ] Jark Wu updated FLINK-33063: Fix Version/s: 1.19.0 > udaf with user defined pojo object throw error while generate record equaliser >

[jira] [Commented] (FLINK-33015) TableAggregateFunction codegen does not eval emitUpdateWithRetract

[ https://issues.apache.org/jira/browse/FLINK-33015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761195#comment-17761195 ] Jark Wu commented on FLINK-33015: - Maybe duplicated with

[jira] [Commented] (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:comment-tabpanel=17760471#comment-17760471 ] Jark Wu commented on FLINK-32952: - Fixed in - master: 103de5bf136816ce1e520f372e17b162e4aa2ba7 -

[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 ] Jark Wu updated FLINK-32952: Fix Version/s: 1.19.0 > Scan reuse with readable metadata and watermark push down will get wrong >

[jira] [Assigned] (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 ] Jark Wu reassigned FLINK-32952: --- Assignee: Yunhong Zheng > Scan reuse with readable metadata and watermark push down will get wrong

[jira] [Comment Edited] (FLINK-32905) Fix the bug of broadcast hash join doesn't support spill to disk when enable operator fusion codegn

[ https://issues.apache.org/jira/browse/FLINK-32905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17758000#comment-17758000 ] Jark Wu edited comment on FLINK-32905 at 8/24/23 11:22 AM: --- Fixed in -

[jira] [Closed] (FLINK-32905) Fix the bug of broadcast hash join doesn't support spill to disk when enable operator fusion codegn

[ https://issues.apache.org/jira/browse/FLINK-32905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-32905. --- Resolution: Fixed > Fix the bug of broadcast hash join doesn't support spill to disk when enable >

[jira] [Commented] (FLINK-32905) Fix the bug of broadcast hash join doesn't support spill to disk when enable operator fusion codegn

[ https://issues.apache.org/jira/browse/FLINK-32905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17758000#comment-17758000 ] Jark Wu commented on FLINK-32905: - Fixed in - master: 2cf32e82773254b79af4dad7ee317db4878d6f8a -

[jira] [Updated] (FLINK-32905) Fix the bug of broadcast hash join doesn't support spill to disk when enable operator fusion codegn

[ https://issues.apache.org/jira/browse/FLINK-32905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-32905: Fix Version/s: 1.19.0 > Fix the bug of broadcast hash join doesn't support spill to disk when enable >

[jira] [Assigned] (FLINK-32905) Fix the bug of broadcast hash join doesn't support spill to disk when enable operator fusion codegn

[ https://issues.apache.org/jira/browse/FLINK-32905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-32905: --- Assignee: dalongliu > Fix the bug of broadcast hash join doesn't support spill to disk when enable

[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=17757993#comment-17757993 ] Jark Wu commented on FLINK-32940: - [~337361...@qq.com] do you have time to help take a look? > Support

[jira] [Comment Edited] (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=17757992#comment-17757992 ] Jark Wu edited comment on FLINK-32940 at 8/23/23 12:21 PM: --- Hi [~vsowrirajan],

[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=17757992#comment-17757992 ] Jark Wu commented on FLINK-32940: - Hi [~vsowrirajan], thank you for reporting this problem. Which Flink

[jira] [Closed] (FLINK-32279) Shuffle HashJoin support spill to disk when enable operator fusion codegen

[ https://issues.apache.org/jira/browse/FLINK-32279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-32279. --- Fix Version/s: 1.18.0 Assignee: dalongliu Resolution: Fixed Fixed in master:

[jira] [Closed] (FLINK-32280) HashAgg support operator fusion codegen

[ https://issues.apache.org/jira/browse/FLINK-32280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-32280. --- Fix Version/s: 1.18.0 Assignee: dalongliu Resolution: Fixed Fixed in master:

[jira] [Updated] (FLINK-32610) JSON format supports projection push down

[ https://issues.apache.org/jira/browse/FLINK-32610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-32610: Release Note: The JSON format introduced JsonParser as a new default way to deserialize JSON data.

[jira] [Closed] (FLINK-32610) JSON format supports projection push down

[ https://issues.apache.org/jira/browse/FLINK-32610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-32610. --- Fix Version/s: 1.18.0 Release Note: The JSON format introduced JsonParser as a new default way to

[jira] [Comment Edited] (FLINK-32632) Run Kubernetes test is unstable on AZP

[ https://issues.apache.org/jira/browse/FLINK-32632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17745130#comment-17745130 ] Jark Wu edited comment on FLINK-32632 at 7/20/23 3:26 PM: -- Another instance:

[jira] [Commented] (FLINK-32632) Run Kubernetes test is unstable on AZP

[ https://issues.apache.org/jira/browse/FLINK-32632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17745130#comment-17745130 ] Jark Wu commented on FLINK-32632: - Another instance:

[jira] [Comment Edited] (FLINK-32632) Run Kubernetes test is unstable on AZP

[ https://issues.apache.org/jira/browse/FLINK-32632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17745130#comment-17745130 ] Jark Wu edited comment on FLINK-32632 at 7/20/23 3:25 PM: -- Another instance:

[jira] [Updated] (FLINK-30559) May get wrong result for `if` expression if it's string data type

[ https://issues.apache.org/jira/browse/FLINK-30559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-30559: Fix Version/s: 1.18.0 1.16.3 1.17.2 > May get wrong result for `if`

[jira] [Resolved] (FLINK-30559) May get wrong result for `if` expression if it's string data type

[ https://issues.apache.org/jira/browse/FLINK-30559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu resolved FLINK-30559. - Resolution: Duplicate > May get wrong result for `if` expression if it's string data type >

[jira] [Reopened] (FLINK-30559) May get wrong result for `if` expression if it's string data type

[ https://issues.apache.org/jira/browse/FLINK-30559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reopened FLINK-30559: - > May get wrong result for `if` expression if it's string data type >

[jira] [Closed] (FLINK-32277) Introduce operator fusion codegen basic framework

[ https://issues.apache.org/jira/browse/FLINK-32277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-32277. --- Fix Version/s: 1.18.0 Assignee: dalongliu Resolution: Fixed Fixed in master:

[jira] [Comment Edited] (FLINK-32278) HashJoin support operator fusion codegen

[ https://issues.apache.org/jira/browse/FLINK-32278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17742454#comment-17742454 ] Jark Wu edited comment on FLINK-32278 at 7/12/23 2:55 PM: -- Fixed in master with

[jira] [Closed] (FLINK-32278) HashJoin support operator fusion codegen

[ https://issues.apache.org/jira/browse/FLINK-32278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-32278. --- Fix Version/s: 1.18.0 Assignee: dalongliu Resolution: Fixed Fixed in master with

[jira] [Closed] (FLINK-32426) Fix adaptive local hash agg can't work when auxGrouping exist

[ https://issues.apache.org/jira/browse/FLINK-32426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-32426. --- Fix Version/s: (was: 1.17.2) Assignee: dalongliu Resolution: Fixed Fixed in master:

[jira] [Commented] (FLINK-32426) Fix adaptive local hash agg can't work when auxGrouping exist

[ https://issues.apache.org/jira/browse/FLINK-32426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17738543#comment-17738543 ] Jark Wu commented on FLINK-32426: - [~lsy], do we need to fix it in 1.17.2 as well? If yes, could you

[jira] [Commented] (FLINK-32444) Enable object reuse for Flink SQL jobs by default

[ https://issues.apache.org/jira/browse/FLINK-32444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17737470#comment-17737470 ] Jark Wu commented on FLINK-32444: - cc [~lincoln.86xy], [~lsy], [~twalthr] what do you think? > Enable

[jira] [Created] (FLINK-32444) Enable object reuse for Flink SQL jobs by default

Jark Wu created FLINK-32444: --- Summary: Enable object reuse for Flink SQL jobs by default Key: FLINK-32444 URL: https://issues.apache.org/jira/browse/FLINK-32444 Project: Flink Issue Type: New

[jira] [Comment Edited] (FLINK-32263) Add ELT support in SQL & Table API

[ https://issues.apache.org/jira/browse/FLINK-32263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17736961#comment-17736961 ] Jark Wu edited comment on FLINK-32263 at 6/26/23 2:44 AM: -- You can follow the

[jira] [Commented] (FLINK-32263) Add ELT support in SQL & Table API

[ https://issues.apache.org/jira/browse/FLINK-32263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17736961#comment-17736961 ] Jark Wu commented on FLINK-32263: - You can follow the way of

[jira] [Commented] (FLINK-32426) Fix adaptive local hash can't work when auxGrouping exist

[ https://issues.apache.org/jira/browse/FLINK-32426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17736954#comment-17736954 ] Jark Wu commented on FLINK-32426: - Could you add more description about what error will be thrown in

[jira] [Closed] (FLINK-32434) missing s3 config by catalog

[ https://issues.apache.org/jira/browse/FLINK-32434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-32434. --- Resolution: Invalid This is an exception thrown by Paimon Catalog, please report this issue to paimon

[jira] [Closed] (FLINK-28620) SQL Client doesn't properly print values of INTERVAL type

[ https://issues.apache.org/jira/browse/FLINK-28620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-28620. --- Fix Version/s: (was: 1.18.0) Assignee: (was: Jark Wu) Resolution: Cannot Reproduce

[jira] [Commented] (FLINK-28620) SQL Client doesn't properly print values of INTERVAL type

[ https://issues.apache.org/jira/browse/FLINK-28620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17736834#comment-17736834 ] Jark Wu commented on FLINK-28620: - Thank you for the validation. I will close it then. > SQL Client

[jira] [Comment Edited] (FLINK-28620) SQL Client doesn't properly print values of INTERVAL type

[ https://issues.apache.org/jira/browse/FLINK-28620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17736834#comment-17736834 ] Jark Wu edited comment on FLINK-28620 at 6/25/23 7:52 AM: -- [~Sergey Nuyanzin]

[jira] [Comment Edited] (FLINK-32332) Jar files for catalog function are not listed correctly

[ https://issues.apache.org/jira/browse/FLINK-32332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17733390#comment-17733390 ] Jark Wu edited comment on FLINK-32332 at 6/16/23 8:11 AM: -- [~zjureel],

[jira] [Commented] (FLINK-32332) Jar files for catalog function are not listed correctly

[ https://issues.apache.org/jira/browse/FLINK-32332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17733390#comment-17733390 ] Jark Wu commented on FLINK-32332: - [~zjureel], currently, the SHOW JARS are used to display the added

[jira] [Commented] (FLINK-19830) Properly implements processing-time temporal table join

[ https://issues.apache.org/jira/browse/FLINK-19830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17732976#comment-17732976 ] Jark Wu commented on FLINK-19830: - Hi [~rmetzger], sorry for the late reply. Yes, your understanding of

[jira] [Closed] (FLINK-31835) DataTypeHint don't support Row>

[ https://issues.apache.org/jira/browse/FLINK-31835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-31835. --- Fix Version/s: 1.18.0 Assignee: Aitozi Resolution: Fixed Fixed in master:

[jira] [Commented] (FLINK-32204) ZooKeeperLeaderElectionTest.testZooKeeperReelectionWithReplacement fails with The ExecutorService is shut down already. No Callables can be executed on AZP

[ https://issues.apache.org/jira/browse/FLINK-32204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17731531#comment-17731531 ] Jark Wu commented on FLINK-32204: - ZooKeeperLeaderElectionTest.testZooKeeperReelection

[jira] [Commented] (FLINK-32276) After adding the where condition to the flink lookup left join, the joinType becomes innerJoin

[ https://issues.apache.org/jira/browse/FLINK-32276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17730339#comment-17730339 ] Jark Wu commented on FLINK-32276: - [~yesorno] it works as expected. Adding a condition for {{dim.age >

[jira] [Commented] (FLINK-32252) SELECT COUNT(*) will return nothing when source no data return

[ https://issues.apache.org/jira/browse/FLINK-32252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17729559#comment-17729559 ] Jark Wu commented on FLINK-32252: - [~tanjialiang] That works as expected. Currently, streaming mode

[jira] [Comment Edited] (FLINK-32252) SELECT COUNT(*) will return nothing when source no data return

[ https://issues.apache.org/jira/browse/FLINK-32252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17729559#comment-17729559 ] Jark Wu edited comment on FLINK-32252 at 6/6/23 2:43 AM: - [~tanjialiang] That

[jira] [Closed] (FLINK-32220) Improving the adaptive local hash agg code to avoid get value from RowData repeatedly

[ https://issues.apache.org/jira/browse/FLINK-32220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-32220. --- Assignee: dalongliu Resolution: Fixed Fixed in master: 3046875c7aa0501f9a67f280034a74ea107315e3 >

[jira] [Updated] (FLINK-32251) flink jdbc catalog cannot add parameters to url

[ https://issues.apache.org/jira/browse/FLINK-32251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-32251: Component/s: Connectors / JDBC > flink jdbc catalog cannot add parameters to url >

[jira] [Commented] (FLINK-32252) SELECT COUNT(*) will return nothing when source no data return

[ https://issues.apache.org/jira/browse/FLINK-32252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17729302#comment-17729302 ] Jark Wu commented on FLINK-32252: - Were you running in batch mode or streaming mode? > SELECT COUNT(*)

[jira] [Updated] (FLINK-32219) SQL client hangs when executing EXECUTE PLAN

[ https://issues.apache.org/jira/browse/FLINK-32219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-32219: Component/s: Table SQL / Client > SQL client hangs when executing EXECUTE PLAN >

[jira] [Commented] (FLINK-32188) Does the custom connector not support pushing down "where" query predicates to query fields of array type？

[ https://issues.apache.org/jira/browse/FLINK-32188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17726598#comment-17726598 ] Jark Wu commented on FLINK-32188: - But I'm also confused why the array constructor is not evaluated into

[jira] [Commented] (FLINK-32188) Does the custom connector not support pushing down "where" query predicates to query fields of array type？

[ https://issues.apache.org/jira/browse/FLINK-32188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17726597#comment-17726597 ] Jark Wu commented on FLINK-32188: - Yes, I think your fix is fine. The function name "array" in

[jira] [Updated] (FLINK-32043) SqlClient session unrecoverable once one wrong setting occurred

[ https://issues.apache.org/jira/browse/FLINK-32043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-32043: Priority: Critical (was: Major) > SqlClient session unrecoverable once one wrong setting occurred >

[jira] [Commented] (FLINK-31822) Support configure maxRows when fetch result

[ https://issues.apache.org/jira/browse/FLINK-31822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17724692#comment-17724692 ] Jark Wu commented on FLINK-31822: - Sounds good to me. What do you think [~fsk119] > Support configure

[jira] [Commented] (FLINK-31985) The currentDate() get transformed to TIMESTAMP_LTZ(3) instead of DATE()

[ https://issues.apache.org/jira/browse/FLINK-31985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17724681#comment-17724681 ] Jark Wu commented on FLINK-31985: - Do you mean the return type of Table API {{currentDate()}} doesn't

[jira] [Commented] (FLINK-31960) SQL OverBy. Error on a code that does not exist

[ https://issues.apache.org/jira/browse/FLINK-31960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17724680#comment-17724680 ] Jark Wu commented on FLINK-31960: - [~padavan], ROW/RANGE clause is not allowed for the LEAD/LAG

[jira] [Comment Edited] (FLINK-31960) SQL OverBy. Error on a code that does not exist

[ https://issues.apache.org/jira/browse/FLINK-31960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17724680#comment-17724680 ] Jark Wu edited comment on FLINK-31960 at 5/21/23 3:29 PM: -- [~padavan],

[jira] [Commented] (FLINK-31902) cast expr to type with not null should throw exception like calcite

[ https://issues.apache.org/jira/browse/FLINK-31902?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17715699#comment-17715699 ] Jark Wu commented on FLINK-31902: - Thank you for the explanation. > cast expr to type with not null

[jira] [Commented] (FLINK-31908) cast expr to type with not null should not change nullable of expr

[ https://issues.apache.org/jira/browse/FLINK-31908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17715684#comment-17715684 ] Jark Wu commented on FLINK-31908: - Why the return type shouldn't be {{ARRAY}}? > cast expr to type with

[jira] [Updated] (FLINK-31908) cast expr to type with not null should not change nullable of expr

[ https://issues.apache.org/jira/browse/FLINK-31908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-31908: Component/s: Table SQL / API > cast expr to type with not null should not change nullable of expr >

[jira] [Commented] (FLINK-31835) DataTypeHint don't support Row>

[ https://issues.apache.org/jira/browse/FLINK-31835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17715658#comment-17715658 ] Jark Wu commented on FLINK-31835: - This sounds good to me. My only concern is the compatibility problem.

[jira] [Commented] (FLINK-31902) cast expr to type with not null should throw exception like calcite

[ https://issues.apache.org/jira/browse/FLINK-31902?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17715646#comment-17715646 ] Jark Wu commented on FLINK-31902: - What's the problem of supporting CAST to not null types? > cast expr

[jira] [Commented] (FLINK-31906) typeof should only return type exclude nullable

[ https://issues.apache.org/jira/browse/FLINK-31906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17715645#comment-17715645 ] Jark Wu commented on FLINK-31906: - What's the problem of returning data type with nullability? We

[jira] [Updated] (FLINK-31906) typeof should only return type exclude nullable

[ https://issues.apache.org/jira/browse/FLINK-31906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-31906: Component/s: Table SQL / API > typeof should only return type exclude nullable >

[jira] [Commented] (FLINK-29692) Support early/late fires for Windowing TVFs

[ https://issues.apache.org/jira/browse/FLINK-29692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17715607#comment-17715607 ] Jark Wu commented on FLINK-29692: - I think early fire / late arrival is a great feature, but I just want

[jira] [Commented] (FLINK-29692) Support early/late fires for Windowing TVFs

[ https://issues.apache.org/jira/browse/FLINK-29692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17715604#comment-17715604 ] Jark Wu commented on FLINK-29692: - Hi [~charles-tan], yes, they have some differences. Group Aggregate

[jira] [Commented] (FLINK-31835) DataTypeHint don't support Row>

[ https://issues.apache.org/jira/browse/FLINK-31835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17715358#comment-17715358 ] Jark Wu commented on FLINK-31835: - Hi [~jeff-zou], thanks for reporting this. I think this is expected.

[jira] [Commented] (FLINK-31848) And Operator has side effect when operands have udf

[ https://issues.apache.org/jira/browse/FLINK-31848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17714995#comment-17714995 ] Jark Wu commented on FLINK-31848: - [~csq] do you have a simple case to reproduce the wrong result (and

[jira] [Updated] (FLINK-31874) Support truncate table statement in batch mode

[ https://issues.apache.org/jira/browse/FLINK-31874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-31874: Fix Version/s: 1.18.0 > Support truncate table statement in batch mode >

[jira] [Commented] (FLINK-29692) Support early/late fires for Windowing TVFs

[ https://issues.apache.org/jira/browse/FLINK-29692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17714985#comment-17714985 ] Jark Wu commented on FLINK-29692: - Hi [~charles-tan], thank you for sharing your use case. I'm just

[jira] [Commented] (FLINK-31777) Upsert Kafka use Avro Confluent, key is ok, but all values are null.

[ https://issues.apache.org/jira/browse/FLINK-31777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17712857#comment-17712857 ] Jark Wu commented on FLINK-31777: - I closed the issue because this is a by-design behavior. Feel free to

[jira] [Closed] (FLINK-31777) Upsert Kafka use Avro Confluent, key is ok, but all values are null.

[ https://issues.apache.org/jira/browse/FLINK-31777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-31777. --- Resolution: Not A Problem > Upsert Kafka use Avro Confluent, key is ok, but all values are null. >

[jira] [Assigned] (FLINK-31778) Casting array of rows produces incorrect result

[ https://issues.apache.org/jira/browse/FLINK-31778?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-31778: --- Assignee: Ilya Soin > Casting array of rows produces incorrect result >

[jira] [Commented] (FLINK-31778) Casting array of rows produces incorrect result

[ https://issues.apache.org/jira/browse/FLINK-31778?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17712856#comment-17712856 ] Jark Wu commented on FLINK-31778: - [~soin08] sure, I assigned this issue to you. Looking forward to the

[jira] [Commented] (FLINK-31788) Add back Support emitValueWithRetract for TableAggregateFunction

[ https://issues.apache.org/jira/browse/FLINK-31788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17711852#comment-17711852 ] Jark Wu commented on FLINK-31788: - Thanks for pointing out this [~hackergin]. If it's true, I think it

[jira] [Commented] (FLINK-31777) Upsert Kafka use Avro Confluent, key is ok, but all values are null.

[ https://issues.apache.org/jira/browse/FLINK-31777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17711820#comment-17711820 ] Jark Wu commented on FLINK-31777: - Hi [~ge.bugman], "upsert-kafka" doesn't support JSON or AVRO in

[jira] [Updated] (FLINK-31777) Upsert Kafka use Avro Confluent, key is ok, but all values are null.

[ https://issues.apache.org/jira/browse/FLINK-31777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-31777: Component/s: Connectors / Kafka (was: kafka) > Upsert Kafka use Avro Confluent, key

[jira] [Commented] (FLINK-31778) Casting array of rows produces incorrect result

[ https://issues.apache.org/jira/browse/FLINK-31778?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17711809#comment-17711809 ] Jark Wu commented on FLINK-31778: - Hi [~soin08], nice catch! However, constructing BinaryRowWriter and

[jira] [Commented] (FLINK-16868) Table/SQL doesn't support custom trigger

[ https://issues.apache.org/jira/browse/FLINK-16868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17711805#comment-17711805 ] Jark Wu commented on FLINK-16868: - Hi [~charles-tan], yes, the configuraitons just work on the legacy

[jira] [Commented] (FLINK-31788) Add back Support emitValueWithRetract for TableAggregateFunction

[ https://issues.apache.org/jira/browse/FLINK-31788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17711802#comment-17711802 ] Jark Wu commented on FLINK-31788: - Hi [~hackergin], it seems the {{emitValueWithRetract}} was never

[jira] [Updated] (FLINK-31754) Build flink master error with Error in ASM processing class org/apache/calcite/sql/validate/SqlValidatorImpl$NavigationExpander.class: 19

[ https://issues.apache.org/jira/browse/FLINK-31754?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-31754: Description: maven 3.25 jdk 1.8 scala 2.12 window 10

[jira] [Commented] (FLINK-31686) Filesystem connector should replace the shallow copy with deep copy

[ https://issues.apache.org/jira/browse/FLINK-31686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17709887#comment-17709887 ] Jark Wu commented on FLINK-31686: - I think you are right. The current implementation has some problems.

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

[ https://issues.apache.org/jira/browse/FLINK-29541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17709884#comment-17709884 ] Jark Wu commented on FLINK-29541: - Considering migrating for flink-table-planner is a huge effort, I

[jira] [Updated] (FLINK-31674) [JUnit5 Migration] Module: flink-table-planner (BatchAbstractTestBase)

[ https://issues.apache.org/jira/browse/FLINK-31674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-31674: Parent Issue: FLINK-29541 (was: FLINK-25325) > [JUnit5 Migration] Module: flink-table-planner

[jira] [Updated] (FLINK-29541) [JUnit5 Migration] Module: flink-table-planner

[ https://issues.apache.org/jira/browse/FLINK-29541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-29541: Parent: (was: FLINK-25325) Issue Type: Technical Debt (was: Sub-task) > [JUnit5 Migration]

[jira] [Commented] (FLINK-6757) Investigate Apache Atlas integration

[ https://issues.apache.org/jira/browse/FLINK-6757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17709883#comment-17709883 ] Jark Wu commented on FLINK-6757: Hi [~litiliu], [~fangyong] is working on FLIP-294[1], which is designed

[jira] [Commented] (FLINK-31661) Add parity between `ROW` value function and it's type declaration

[ https://issues.apache.org/jira/browse/FLINK-31661?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17709881#comment-17709881 ] Jark Wu commented on FLINK-31661: - This can be a big effort because we need to contribute this feature

[jira] [Updated] (FLINK-31661) Add parity between `ROW` value function and it's type declaration

[ https://issues.apache.org/jira/browse/FLINK-31661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-31661: Component/s: Table SQL / API (was: API / DataSet) > Add parity between `ROW` value

  1   2   3   4   5   6   7   8   9   10   >