[jira] [Updated] (FLINK-36736) DynamicTableSink.Context#getTargetColumns should contains all the columns that sink function will receive

[ https://issues.apache.org/jira/browse/FLINK-36736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-36736: Priority: Critical (was: Major) > DynamicTableSink.Context#getTargetColumns should contains all the colum

[jira] [Commented] (FLINK-36736) DynamicTableSink.Context#getTargetColumns should contains all the columns that sink function will receive

[ https://issues.apache.org/jira/browse/FLINK-36736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17898870#comment-17898870 ] Jark Wu commented on FLINK-36736: - cc [~lincoln.86xy] > DynamicTableSink.Context#getTar

[jira] [Updated] (FLINK-36735) SupportsRowLevelUpdate gives sink only the values of required columns when specifying RowLevelUpdateInfo#requiredColumns

[ https://issues.apache.org/jira/browse/FLINK-36735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-36735: Priority: Critical (was: Major) > SupportsRowLevelUpdate gives sink only the values of required columns w

[jira] [Commented] (FLINK-36735) SupportsRowLevelUpdate gives sink only the values of required columns when specifying RowLevelUpdateInfo#requiredColumns

[ https://issues.apache.org/jira/browse/FLINK-36735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17898869#comment-17898869 ] Jark Wu commented on FLINK-36735: - cc [~lincoln.86xy] > SupportsRowLevelUpdate gives si

[jira] [Created] (FLINK-36736) DynamicTableSink.Context#getTargetColumns should contains all the columns that sink function will receive

Jark Wu created FLINK-36736: --- Summary: DynamicTableSink.Context#getTargetColumns should contains all the columns that sink function will receive Key: FLINK-36736 URL: https://issues.apache.org/jira/browse/FLINK-36736

[jira] [Created] (FLINK-36735) SupportsRowLevelUpdate gives sink only the values of required columns when specifying RowLevelUpdateInfo#requiredColumns

Jark Wu created FLINK-36735: --- Summary: SupportsRowLevelUpdate gives sink only the values of required columns when specifying RowLevelUpdateInfo#requiredColumns Key: FLINK-36735 URL: https://issues.apache.org/jira/browse

[jira] [Commented] (FLINK-29739) [FLIP-265] Deprecate and remove Scala API support

[ https://issues.apache.org/jira/browse/FLINK-29739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17884214#comment-17884214 ] Jark Wu commented on FLINK-29739: - +1 for the approach proposed by [~xuyangzhong]. Besid

[jira] [Commented] (FLINK-36004) Flink SQL returns wrong results for Paimon tables with complex schemas

[ https://issues.apache.org/jira/browse/FLINK-36004?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17872257#comment-17872257 ] Jark Wu commented on FLINK-36004: - [~xuyangzhong] could you help have a look at this iss

[jira] [Closed] (FLINK-35877) Shade protobuf in flink

[ https://issues.apache.org/jira/browse/FLINK-35877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-35877. --- Resolution: Fixed This is fixed on master: 68d8174c996f05b2fbf9c50d0220a72f29e3a56b > Shade protobuf in fli

[jira] [Assigned] (FLINK-35877) Shade protobuf in flink

[ https://issues.apache.org/jira/browse/FLINK-35877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-35877: --- Assignee: zhuanshenbsj1 > Shade protobuf in flink > --- > > Key

[jira] [Updated] (FLINK-35877) Shade protobuf in flink

[ https://issues.apache.org/jira/browse/FLINK-35877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-35877: Fix Version/s: 2.0.0 (was: 1.19.2) > Shade protobuf in flink >

[jira] [Updated] (FLINK-35877) Shade protobuf in flink

[ https://issues.apache.org/jira/browse/FLINK-35877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-35877: Component/s: Formats (JSON, Avro, Parquet, ORC, SequenceFile) (was: BuildSystem / Shad

[jira] [Assigned] (FLINK-35353) Translate "Profiler" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-35353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-35353: --- Assignee: Juan Zifeng > Translate "Profiler" page into Chinese > -

[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&focusedCommentId=17834844#comment-17834844 ] Jark Wu edited comment on FLINK-33934 at 4/8/24 8:31 AM: - [~yunt

[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&focusedCommentId=17834844#comment-17834844 ] Jark Wu commented on FLINK-33934: - [~yunta] yes, I think the row format should avoid reu

[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&focusedCommentId=17823859#comment-17823859 ] Jark Wu commented on FLINK-20399: - [~lorenzo.affetti] Yes, I think so. Thank you for 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&focusedCommentId=17810723#comment-17810723 ] Jark Wu commented on FLINK-34147: - I agree it is ambiguous. Currently, {{TimestampData}}

[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 Feature

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

[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&focusedCommentId=17761195#comment-17761195 ] Jark Wu commented on FLINK-33015: - Maybe duplicated with https://issues.apache.org/jira/

[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&focusedCommentId=17760471#comment-17760471 ] Jark Wu commented on FLINK-32952: - Fixed in - master: 103de5bf136816ce1e520f372e17b162e

[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 > waterm

[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&focusedCommentId=17758000#comment-17758000 ] Jark Wu edited comment on FLINK-32905 at 8/24/23 11:22 AM: --- Fi

[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 > operator

[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&focusedCommentId=17758000#comment-17758000 ] Jark Wu commented on FLINK-32905: - Fixed in - master: 2cf32e82773254b79af4dad7ee317db4

[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 > op

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

[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&focusedCommentId=17757992#comment-17757992 ] Jark Wu edited comment on FLINK-32940 at 8/23/23 12:21 PM: --- Hi

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

[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: bff837622ddfd2c

[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: f500b593911614

[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. JsonPar

[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 deser

[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&focusedCommentId=17745130#comment-17745130 ] Jark Wu edited comment on FLINK-32632 at 7/20/23 3:26 PM: -- Anot

[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&focusedCommentId=17745130#comment-17745130 ] Jark Wu commented on FLINK-32632: - Another instance: https://dev.azure.com/apache-flink

[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&focusedCommentId=17745130#comment-17745130 ] Jark Wu edited comment on FLINK-32632 at 7/20/23 3:25 PM: -- Anot

[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: 02be55ab780186a

[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&focusedCommentId=17742454#comment-17742454 ] Jark Wu edited comment on FLINK-32278 at 7/12/23 2:55 PM: -- Fixe

[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 02be55ab78

[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: 3f48

[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&focusedCommentId=17738543#comment-17738543 ] Jark Wu commented on FLINK-32426: - [~lsy], do we need to fix it in 1.17.2 as well? If ye

[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&focusedCommentId=17737470#comment-17737470 ] Jark Wu commented on FLINK-32444: - cc [~lincoln.86xy], [~lsy], [~twalthr] what do you th

[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 Featu

[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&focusedCommentId=17736961#comment-17736961 ] Jark Wu edited comment on FLINK-32263 at 6/26/23 2:44 AM: -- You

[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&focusedCommentId=17736961#comment-17736961 ] Jark Wu commented on FLINK-32263: - You can follow the way of [{{jsonArrayAgg}}|https://

[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&focusedCommentId=17736954#comment-17736954 ] Jark Wu commented on FLINK-32426: - Could you add more description about what error will

[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 commu

[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&focusedCommentId=17736834#comment-17736834 ] Jark Wu commented on FLINK-28620: - Thank you for the validation. I will close it then.

[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&focusedCommentId=17736834#comment-17736834 ] Jark Wu edited comment on FLINK-28620 at 6/25/23 7:52 AM: -- [~Se

[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&focusedCommentId=17733390#comment-17733390 ] Jark Wu edited comment on FLINK-32332 at 6/16/23 8:11 AM: -- [~zj

[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&focusedCommentId=17733390#comment-17733390 ] Jark Wu commented on FLINK-32332: - [~zjureel], currently, the SHOW JARS are used to disp

[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&focusedCommentId=17732976#comment-17732976 ] Jark Wu commented on FLINK-19830: - Hi [~rmetzger], sorry for the late reply. Yes, your u

[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: a6adbdda0cdf90635f

[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&focusedCommentId=17731531#comment-17731531 ] Jark Wu commented on FLINK-32204: - ZooKeeperLeaderElectionTest.testZooKeeperReelection h

[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&focusedCommentId=17730339#comment-17730339 ] Jark Wu commented on FLINK-32276: - [~yesorno] it works as expected. Adding a condition f

[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&focusedCommentId=17729559#comment-17729559 ] Jark Wu commented on FLINK-32252: - [~tanjialiang] That works as expected. Currently, str

[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&focusedCommentId=17729559#comment-17729559 ] Jark Wu edited comment on FLINK-32252 at 6/6/23 2:43 AM: - [~tanj

[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 > Imp

[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&focusedCommentId=17729302#comment-17729302 ] Jark Wu commented on FLINK-32252: - Were you running in batch mode or streaming mode? >

[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&focusedCommentId=17726598#comment-17726598 ] Jark Wu commented on FLINK-32188: - But I'm also confused why the array constructor is no

[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&focusedCommentId=17726597#comment-17726597 ] Jark Wu commented on FLINK-32188: - Yes, I think your fix is fine. The function name "arr

[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&focusedCommentId=17724692#comment-17724692 ] Jark Wu commented on FLINK-31822: - Sounds good to me. What do you think [~fsk119] > Sup

[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&focusedCommentId=17724681#comment-17724681 ] Jark Wu commented on FLINK-31985: - Do you mean the return type of Table API {{currentDat

[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&focusedCommentId=17724680#comment-17724680 ] Jark Wu commented on FLINK-31960: - [~padavan], ROW/RANGE clause is not allowed for the L

[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&focusedCommentId=17724680#comment-17724680 ] Jark Wu edited comment on FLINK-31960 at 5/21/23 3:29 PM: -- [~pa

[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&focusedCommentId=17715699#comment-17715699 ] Jark Wu commented on FLINK-31902: - Thank you for the explanation. > cast expr to type

[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&focusedCommentId=17715684#comment-17715684 ] Jark Wu commented on FLINK-31908: - Why the return type shouldn't be {{ARRAY}}? > cast e

[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&focusedCommentId=17715658#comment-17715658 ] Jark Wu commented on FLINK-31835: - This sounds good to me. My only concern is the compat

[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&focusedCommentId=17715646#comment-17715646 ] Jark Wu commented on FLINK-31902: - What's the problem of supporting CAST to not null typ

[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&focusedCommentId=17715645#comment-17715645 ] Jark Wu commented on FLINK-31906: - What's the problem of returning data type with nullab

[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&focusedCommentId=17715607#comment-17715607 ] Jark Wu commented on FLINK-29692: - I think early fire / late arrival is a great feature,

[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&focusedCommentId=17715604#comment-17715604 ] Jark Wu commented on FLINK-29692: - Hi [~charles-tan], yes, they have some differences. G

[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&focusedCommentId=17715358#comment-17715358 ] Jark Wu commented on FLINK-31835: - Hi [~jeff-zou], thanks for reporting this. I think th

[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&focusedCommentId=17714995#comment-17714995 ] Jark Wu commented on FLINK-31848: - [~csq] do you have a simple case to reproduce the wro

[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&focusedCommentId=17714985#comment-17714985 ] Jark Wu commented on FLINK-29692: - Hi [~charles-tan], thank you for sharing your use cas

[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&focusedCommentId=17712857#comment-17712857 ] Jark Wu commented on FLINK-31777: - I closed the issue because this is a by-design behavi

[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&focusedCommentId=17712856#comment-17712856 ] Jark Wu commented on FLINK-31778: - [~soin08] sure, I assigned this issue to you. Looking

[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&focusedCommentId=17711852#comment-17711852 ] Jark Wu commented on FLINK-31788: - Thanks for pointing out this [~hackergin]. If it's tr

  1   2   3   4   5   6   7   8   9   10   >