[jira] [Comment Edited] (FLINK-34380) Strange RowKind and records about intermediate output when using minibatch join

2024-05-14 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846485#comment-17846485 ] xuyang edited comment on FLINK-34380 at 5/15/24 4:01 AM: - Sorry for this late

[jira] [Commented] (FLINK-34380) Strange RowKind and records about intermediate output when using minibatch join

2024-05-14 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846485#comment-17846485 ] xuyang commented on FLINK-34380: Sorry for this late reply. This commit for fix seems great.

[jira] [Commented] (FLINK-35327) SQL Explain show push down condition

2024-05-09 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17845189#comment-17845189 ] xuyang commented on FLINK-35327: Hi, I'd like to take this Jira and take a look at it. > SQL Explain

[jira] [Commented] (FLINK-35193) Support drop materialized table syntax and execution in continuous refresh mode

2024-05-06 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17844083#comment-17844083 ] xuyang commented on FLINK-35193: Hi, [~lsy] I'd like to take this task. > Support drop materialized

[jira] [Commented] (FLINK-35198) Support the execution of refresh materialized table

2024-05-06 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17844082#comment-17844082 ] xuyang commented on FLINK-35198: Hi, [~lsy] Can I take this jira? > Support the execution of refresh

[jira] [Created] (FLINK-35271) Add doc for syntax `describe job 'xxx'`

2024-04-29 Thread xuyang (Jira)
xuyang created FLINK-35271: -- Summary: Add doc for syntax `describe job 'xxx'` Key: FLINK-35271 URL: https://issues.apache.org/jira/browse/FLINK-35271 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-35194) Support describe job syntax and execution

2024-04-26 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17841113#comment-17841113 ] xuyang commented on FLINK-35194: Hi, can I take this jira? > Support describe job syntax and execution

[jira] [Commented] (FLINK-35081) CompileException when watermark definition contains coalesce and to_timestamp built-in functions

2024-04-17 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838424#comment-17838424 ] xuyang commented on FLINK-35081: I think this bug is same with FLINK-28693 > CompileException when

[jira] [Commented] (FLINK-34583) Bug for dynamic table option hints with multiple CTEs

2024-04-17 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838130#comment-17838130 ] xuyang commented on FLINK-34583: Hi, [~xccui] can you provide more details about this bug? I try to run

[jira] [Commented] (FLINK-34583) Bug for dynamic table option hints with multiple CTEs

2024-03-06 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17823973#comment-17823973 ] xuyang commented on FLINK-34583: [~lincoln.86xy]  Sure. > Bug for dynamic table option hints with

[jira] [Commented] (FLINK-34559) TVF Window Aggregations might get stuck

2024-03-03 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17823012#comment-17823012 ] xuyang commented on FLINK-34559: Hi, [~roman], I'm a little interested in how you would solve this

[jira] [Commented] (FLINK-34380) Strange RowKind and records about intermediate output when using minibatch join

2024-02-29 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17822401#comment-17822401 ] xuyang commented on FLINK-34380: Hi,  [~xu_shuai_] . Can you help check it again? > Strange RowKind and

[jira] [Commented] (FLINK-33989) Insert Statement With Filter Operation Generates Extra Tombstone using Upsert Kafka Connector

2024-02-29 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17822337#comment-17822337 ] xuyang commented on FLINK-33989: Agree with [~libenchao] . This is a behavior by design. > Insert

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

2024-02-29 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17822088#comment-17822088 ] xuyang commented on FLINK-34016: Thanks for your test! [~seb-pereira] (y) > Janino compile failed when

[jira] [Commented] (FLINK-34529) Projection cannot be pushed down through rank operator.

2024-02-29 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17822064#comment-17822064 ] xuyang commented on FLINK-34529: Hi, [~nilerzhou] . The plan to fix bug LGTM. IIUC, the fix is that

[jira] [Commented] (FLINK-34473) Migrate FlinkPruneEmptyRules

2024-02-28 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17821633#comment-17821633 ] xuyang commented on FLINK-34473: Hi, [~jackylau] . This Jira is a subtask instead of a bug, right? >

[jira] [Commented] (FLINK-34437) Typo in SQL Client - `s/succeed/succeeded`

2024-02-28 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17821615#comment-17821615 ] xuyang commented on FLINK-34437: Hi, [~jingge] . I see that this PR has been merged. Does this Jira need

[jira] [Commented] (FLINK-34517) environment configs ignored when calling procedure operation

2024-02-26 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34517?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17820947#comment-17820947 ] xuyang commented on FLINK-34517: Hi, [~JustinLee] . Do you mean there are some configs lost when

[jira] [Closed] (FLINK-34378) Minibatch join disrupted the original order of input records

2024-02-26 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuyang closed FLINK-34378. -- Resolution: Not A Problem > Minibatch join disrupted the original order of input records >

[jira] [Commented] (FLINK-34378) Minibatch join disrupted the original order of input records

2024-02-26 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17820924#comment-17820924 ] xuyang commented on FLINK-34378: Thanks for your answer, [~xu_shuai_]. That sounds good to me. I'll

[jira] [Resolved] (FLINK-33489) LISTAGG with generating partial-final agg will cause wrong result

2024-02-07 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuyang resolved FLINK-33489. Resolution: Resolved > LISTAGG with generating partial-final agg will cause wrong result >

[jira] [Commented] (FLINK-34348) Release Testing: Verify FLINK-20281 Window aggregation supports changelog stream input

2024-02-07 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17815480#comment-17815480 ] xuyang commented on FLINK-34348: Hi, [~hackergin]. Thanks for your detailed testing. Overall, it seems

[jira] [Commented] (FLINK-28693) Codegen failed if the watermark is defined on a columnByExpression

2024-02-06 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17815141#comment-17815141 ] xuyang commented on FLINK-28693: This bug is caused by that the code generated by codegen references the

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

2024-02-06 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17815140#comment-17815140 ] xuyang commented on FLINK-34016: Hi, [~wczhu] I have found the root bug and will try to fix it. You can

[jira] [Commented] (FLINK-34211) Filtering on Column names with ?s fails for JDBC lookup join.

2024-02-06 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17815118#comment-17815118 ] xuyang commented on FLINK-34211: Hi, [~davidradl] this Jira looks like an improvement, not a bug, right?

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

2024-02-06 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17815091#comment-17815091 ] xuyang commented on FLINK-34376: This bug is introduced by

[jira] [Commented] (FLINK-34378) Minibatch join disrupted the original order of input records

2024-02-06 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17815054#comment-17815054 ] xuyang commented on FLINK-34378: [~lsy] The situation is that although I set the parallelism is "1", but

[jira] [Updated] (FLINK-34378) Minibatch join disrupted the original order of input records

2024-02-06 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuyang updated FLINK-34378: --- Description: I'm not sure if it's a bug. The following case can re-produce this situation. {code:java} //

[jira] [Updated] (FLINK-34378) Minibatch join disrupted the original order of input records

2024-02-06 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuyang updated FLINK-34378: --- Description: I'm not sure if it's a bug. The following case can re-produce this situation. {code:java} //

[jira] [Updated] (FLINK-34378) Minibatch join disrupted the original order of input records

2024-02-06 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuyang updated FLINK-34378: --- Description: I'm not sure if it's a bug. The following case can re-produce this situation. {code:java} //

[jira] [Commented] (FLINK-34381) `RelDataType#getFullTypeString` should be used to print in `RelTreeWriterImpl` if `withRowType` is true instead of `Object#toString`

2024-02-06 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17814700#comment-17814700 ] xuyang commented on FLINK-34381: I will try to fix it if this makes sense indeed. >

[jira] [Updated] (FLINK-34372) Complete work for syntax `DESCRIBE CATALOG catalogName`

2024-02-06 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuyang updated FLINK-34372: --- Attachment: image-2024-02-06-16-38-24-085.png > Complete work for syntax `DESCRIBE CATALOG catalogName` >

[jira] [Updated] (FLINK-34372) Complete work for syntax `DESCRIBE CATALOG catalogName`

2024-02-06 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuyang updated FLINK-34372: --- Description: The public api changes are announced in Flip-69

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

2024-02-05 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17814636#comment-17814636 ] xuyang commented on FLINK-34373: I'll try to fix it. > Complete work for syntax `DESCRIBE DATABASE

[jira] [Created] (FLINK-34381) `RelDataType#getFullTypeString` should be used to print in `RelTreeWriterImpl` if `withRowType` is true instead of `Object#toString`

2024-02-05 Thread xuyang (Jira)
xuyang created FLINK-34381: -- Summary: `RelDataType#getFullTypeString` should be used to print in `RelTreeWriterImpl` if `withRowType` is true instead of `Object#toString` Key: FLINK-34381 URL:

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

2024-02-05 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17814623#comment-17814623 ] xuyang commented on FLINK-34370: [~337361...@qq.com] Thanks for your volunteering. > [Umbrella]

[jira] [Created] (FLINK-34380) Strange RowKind and records about intermediate output when using minibatch join

2024-02-05 Thread xuyang (Jira)
xuyang created FLINK-34380: -- Summary: Strange RowKind and records about intermediate output when using minibatch join Key: FLINK-34380 URL: https://issues.apache.org/jira/browse/FLINK-34380 Project: Flink

[jira] [Commented] (FLINK-34349) Release Testing: Verify FLINK-34219 Introduce a new join operator to support minibatch

2024-02-05 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17814612#comment-17814612 ] xuyang commented on FLINK-34349: Hi, I have finished this verification. Some unexpected behaviors such

[jira] [Updated] (FLINK-34378) Minibatch join disrupted the original order of input records

2024-02-05 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuyang updated FLINK-34378: --- Affects Version/s: 1.19.0 > Minibatch join disrupted the original order of input records >

[jira] [Updated] (FLINK-34378) Minibatch join disrupted the original order of input records

2024-02-05 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuyang updated FLINK-34378: --- Fix Version/s: 1.19.0 > Minibatch join disrupted the original order of input records >

[jira] [Updated] (FLINK-34378) Minibatch join disrupted the original order of input records

2024-02-05 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuyang updated FLINK-34378: --- Component/s: Table SQL / Runtime > Minibatch join disrupted the original order of input records >

[jira] [Commented] (FLINK-34378) Minibatch join disrupted the original order of input records

2024-02-05 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17814590#comment-17814590 ] xuyang commented on FLINK-34378: cc [~xu_shuai_]  > Minibatch join disrupted the original order of

[jira] [Updated] (FLINK-34378) Minibatch join disrupted the original order of input records

2024-02-05 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuyang updated FLINK-34378: --- Description: I'm not sure if it's a bug. The following case can re-produce this situation. {code:java} //

[jira] [Created] (FLINK-34378) Minibatch join disrupted the original order of input records

2024-02-05 Thread xuyang (Jira)
xuyang created FLINK-34378: -- Summary: Minibatch join disrupted the original order of input records Key: FLINK-34378 URL: https://issues.apache.org/jira/browse/FLINK-34378 Project: Flink Issue

[jira] [Commented] (FLINK-34372) Complete work for syntax `DESCRIBE CATALOG catalogName`

2024-02-05 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34372?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17814584#comment-17814584 ] xuyang commented on FLINK-34372: I'll try to do it. > Complete work for syntax `DESCRIBE CATALOG

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

2024-02-05 Thread xuyang (Jira)
xuyang created FLINK-34375: -- Summary: Complete work for syntax `DESCRIBE EXTENDED tableName` Key: FLINK-34375 URL: https://issues.apache.org/jira/browse/FLINK-34375 Project: Flink Issue Type:

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

2024-02-05 Thread xuyang (Jira)
xuyang created FLINK-34374: -- Summary: Complete work for syntax `DESCRIBE EXTENDED DATABASE databaseName` Key: FLINK-34374 URL: https://issues.apache.org/jira/browse/FLINK-34374 Project: Flink

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

2024-02-05 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuyang updated FLINK-34370: --- Description: This is a umbrella Jira for completing work for

[jira] [Created] (FLINK-34373) Complete work for syntax `DESCRIBE DATABASE databaseName`

2024-02-05 Thread xuyang (Jira)
xuyang created FLINK-34373: -- Summary: Complete work for syntax `DESCRIBE DATABASE databaseName` Key: FLINK-34373 URL: https://issues.apache.org/jira/browse/FLINK-34373 Project: Flink Issue Type:

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

2024-02-05 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuyang updated FLINK-34370: --- Description: This is a umbrella Jira for completing work for

[jira] [Created] (FLINK-34372) Complete work for syntax `DESCRIBE CATALOG catalogName`

2024-02-05 Thread xuyang (Jira)
xuyang created FLINK-34372: -- Summary: Complete work for syntax `DESCRIBE CATALOG catalogName` Key: FLINK-34372 URL: https://issues.apache.org/jira/browse/FLINK-34372 Project: Flink Issue Type:

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

2024-02-05 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuyang updated FLINK-34370: --- Summary: [Umbrella] Complete work and improve about enhanced Flink SQL DDL (was: [Umbrella] Complete work

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

2024-02-05 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuyang updated FLINK-34370: --- Description: This is a umbrella Jira for completing work for

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

2024-02-05 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuyang updated FLINK-34370: --- Description: This is a umbrella Jira for completing work for

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

2024-02-05 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuyang updated FLINK-34370: --- Affects Version/s: 1.19.0 > [Umbrella] Complete work about enhanced Flink SQL DDL >

[jira] [Closed] (FLINK-34254) `DESCRIBE` syntaxes like `DESCRIBE CATALOG xxx` throws strange exceptions

2024-02-05 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuyang closed FLINK-34254. -- Resolution: Duplicate > `DESCRIBE` syntaxes like `DESCRIBE CATALOG xxx` throws strange exceptions >

[jira] [Comment Edited] (FLINK-34254) `DESCRIBE` syntaxes like `DESCRIBE CATALOG xxx` throws strange exceptions

2024-02-05 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17814564#comment-17814564 ] xuyang edited comment on FLINK-34254 at 2/6/24 1:43 AM: I have created a Jira

[jira] [Commented] (FLINK-34254) `DESCRIBE` syntaxes like `DESCRIBE CATALOG xxx` throws strange exceptions

2024-02-05 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17814564#comment-17814564 ] xuyang commented on FLINK-34254: I have created a Jira linked this one to do the improvement. >

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

2024-02-05 Thread xuyang (Jira)
xuyang created FLINK-34370: -- Summary: [Umbrella] Complete work about enhanced Flink SQL DDL Key: FLINK-34370 URL: https://issues.apache.org/jira/browse/FLINK-34370 Project: Flink Issue Type:

[jira] [Commented] (FLINK-34353) A strange exception will be thrown if minibatch size is not set while using mini-batch join

2024-02-04 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17814061#comment-17814061 ] xuyang commented on FLINK-34353: I'll try to fix it. > A strange exception will be thrown if minibatch

[jira] [Updated] (FLINK-34353) A strange exception will be thrown if minibatch size is not set while using mini-batch join

2024-02-04 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuyang updated FLINK-34353: --- Description: {code:java} java.lang.IllegalArgumentException: maxCount must be greater than 0 at

[jira] [Created] (FLINK-34353) A strange exception will be thrown if minibatch size is not set while using mini-batch join

2024-02-04 Thread xuyang (Jira)
xuyang created FLINK-34353: -- Summary: A strange exception will be thrown if minibatch size is not set while using mini-batch join Key: FLINK-34353 URL: https://issues.apache.org/jira/browse/FLINK-34353

[jira] [Commented] (FLINK-34349) Release Testing: Verify FLINK-34219 Introduce a new join operator to support minibatch

2024-02-03 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17814047#comment-17814047 ] xuyang commented on FLINK-34349: Hi, I'd like to take this verification. > Release Testing: Verify

[jira] [Updated] (FLINK-34348) Release Testing: Verify FLINK-20281 Window aggregation supports changelog stream input

2024-02-03 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuyang updated FLINK-34348: --- Description: Window TVF aggregation supports changelog stream  is ready for testing. User can add a window

[jira] [Updated] (FLINK-34346) Release Testing: Verify FLINK-24024 Support session Window TVF

2024-02-03 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuyang updated FLINK-34346: --- Description: Session window TVF is ready. Users can use Session window TVF aggregation instead of using

[jira] [Created] (FLINK-34348) Release Testing: Verify FLINK-20281 Window aggregation supports changelog stream input

2024-02-03 Thread xuyang (Jira)
xuyang created FLINK-34348: -- Summary: Release Testing: Verify FLINK-20281 Window aggregation supports changelog stream input Key: FLINK-34348 URL: https://issues.apache.org/jira/browse/FLINK-34348 Project:

[jira] [Created] (FLINK-34346) Release Testing: Verify FLINK-24024 Support session Window TVF

2024-02-03 Thread xuyang (Jira)
xuyang created FLINK-34346: -- Summary: Release Testing: Verify FLINK-24024 Support session Window TVF Key: FLINK-34346 URL: https://issues.apache.org/jira/browse/FLINK-34346 Project: Flink Issue

[jira] [Comment Edited] (FLINK-33963) There is only one UDF instance after serializing the same task

2024-02-03 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17814014#comment-17814014 ] xuyang edited comment on FLINK-33963 at 2/4/24 2:34 AM: I agree that we should

[jira] [Commented] (FLINK-33963) There is only one UDF instance after serializing the same task

2024-02-03 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17814014#comment-17814014 ] xuyang commented on FLINK-33963: I agree that we should be more rigorous in our consideration of whether

[jira] [Commented] (FLINK-34301) Release Testing Instructions: Verify FLINK-20281 Window aggregation supports changelog stream input

2024-02-02 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17813595#comment-17813595 ] xuyang commented on FLINK-34301: Window TVF aggregation supports changelog stream  is ready for testing.

[jira] [Comment Edited] (FLINK-34300) Release Testing Instructions: Verify FLINK-24024 Support session Window TVF

2024-02-02 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17813590#comment-17813590 ] xuyang edited comment on FLINK-34300 at 2/2/24 9:29 AM: Session window TVF is

[jira] [Commented] (FLINK-34300) Release Testing Instructions: Verify FLINK-24024 Support session Window TVF

2024-02-02 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17813590#comment-17813590 ] xuyang commented on FLINK-34300: Session window TVF is ready. Users can use Session window TVF

[jira] [Created] (FLINK-34338) An exception is thrown when some named params change order when using window tvf

2024-02-01 Thread xuyang (Jira)
xuyang created FLINK-34338: -- Summary: An exception is thrown when some named params change order when using window tvf Key: FLINK-34338 URL: https://issues.apache.org/jira/browse/FLINK-34338 Project: Flink

[jira] [Created] (FLINK-34335) Query hints in RexSubQuery could not be printed

2024-02-01 Thread xuyang (Jira)
xuyang created FLINK-34335: -- Summary: Query hints in RexSubQuery could not be printed Key: FLINK-34335 URL: https://issues.apache.org/jira/browse/FLINK-34335 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-34335) Query hints in RexSubQuery could not be printed

2024-02-01 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17813470#comment-17813470 ] xuyang commented on FLINK-34335: I'll try to fix it. > Query hints in RexSubQuery could not be printed

[jira] [Commented] (FLINK-34272) AdaptiveSchedulerClusterITCase failure due to MiniCluster not running

2024-01-31 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17813001#comment-17813001 ] xuyang commented on FLINK-34272:

[jira] [Commented] (FLINK-34323) Session window tvf failed when using named params

2024-01-31 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17812698#comment-17812698 ] xuyang commented on FLINK-34323: I'll try to fix it. > Session window tvf failed when using named

[jira] [Created] (FLINK-34323) Session window tvf failed when using named params

2024-01-31 Thread xuyang (Jira)
xuyang created FLINK-34323: -- Summary: Session window tvf failed when using named params Key: FLINK-34323 URL: https://issues.apache.org/jira/browse/FLINK-34323 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-34271) Fix the potential failure test about GroupAggregateRestoreTest#AGG_WITH_STATE_TTL_HINT

2024-01-31 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17812664#comment-17812664 ] xuyang commented on FLINK-34271: [~dwysakowicz] I understand and agree with you. That's why I just work

[jira] [Commented] (FLINK-34272) AdaptiveSchedulerClusterITCase failure due to MiniCluster not running

2024-01-31 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17812592#comment-17812592 ] xuyang commented on FLINK-34272:

[jira] [Updated] (FLINK-34315) Temporarily force disabling window join, window rank and window deduplicate optimization when using session window tvf

2024-01-30 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuyang updated FLINK-34315: --- Summary: Temporarily force disabling window join, window rank and window deduplicate optimization when

[jira] [Created] (FLINK-34315) Forcibly disable window join, window rank and window deduplicate optimization when using session window tvf

2024-01-30 Thread xuyang (Jira)
xuyang created FLINK-34315: -- Summary: Forcibly disable window join, window rank and window deduplicate optimization when using session window tvf Key: FLINK-34315 URL: https://issues.apache.org/jira/browse/FLINK-34315

[jira] [Created] (FLINK-34313) Update doc about session window tvf

2024-01-30 Thread xuyang (Jira)
xuyang created FLINK-34313: -- Summary: Update doc about session window tvf Key: FLINK-34313 URL: https://issues.apache.org/jira/browse/FLINK-34313 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-34271) Fix the potential failure test about GroupAggregateRestoreTest#AGG_WITH_STATE_TTL_HINT

2024-01-30 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17812550#comment-17812550 ] xuyang commented on FLINK-34271: [~bvarghese] Okay. But we don’t have tests to cover potential changes

[jira] [Updated] (FLINK-34271) Fix the potential failure test about GroupAggregateRestoreTest#AGG_WITH_STATE_TTL_HINT

2024-01-30 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuyang updated FLINK-34271: --- Summary: Fix the potential failure test about GroupAggregateRestoreTest#AGG_WITH_STATE_TTL_HINT (was: Fix

[jira] [Commented] (FLINK-34271) Fix the unstable test about GroupAggregateRestoreTest#AGG_WITH_STATE_TTL_HINT

2024-01-30 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17812204#comment-17812204 ] xuyang commented on FLINK-34271: cc [~qingyue] [~dwysakowicz] [~bvarghese]  > Fix the unstable test

[jira] [Commented] (FLINK-34271) Fix the unstable test about GroupAggregateRestoreTest#AGG_WITH_STATE_TTL_HINT

2024-01-30 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17812197#comment-17812197 ] xuyang commented on FLINK-34271: BTW, I've noticed that the old tests for json plan changes (diff the

[jira] [Updated] (FLINK-34271) Fix the unstable test about GroupAggregateRestoreTest#AGG_WITH_STATE_TTL_HINT

2024-01-30 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuyang updated FLINK-34271: --- Description: The underlying reason is that a previous PR introduced a test with state TTL as follows in

[jira] [Created] (FLINK-34271) Fix the unstable test about GroupAggregateRestoreTest#AGG_WITH_STATE_TTL_HINT

2024-01-29 Thread xuyang (Jira)
xuyang created FLINK-34271: -- Summary: Fix the unstable test about GroupAggregateRestoreTest#AGG_WITH_STATE_TTL_HINT Key: FLINK-34271 URL: https://issues.apache.org/jira/browse/FLINK-34271 Project: Flink

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

2024-01-29 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17812134#comment-17812134 ] xuyang edited comment on FLINK-34016 at 1/30/24 3:38 AM: - Hi, [~wczhu] . +1

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

2024-01-29 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17812134#comment-17812134 ] xuyang commented on FLINK-34016: Hi, [~wczhu] . +1 Could not reproduce it on my local env. Can you try

[jira] [Commented] (FLINK-33989) Insert Statement With Filter Operation Generates Extra Tombstone using Upsert Kafka Connector

2024-01-29 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17812125#comment-17812125 ] xuyang commented on FLINK-33989: I speculate that even if the Upsert Kafka sink can accept upsert

[jira] [Commented] (FLINK-33989) Insert Statement With Filter Operation Generates Extra Tombstone using Upsert Kafka Connector

2024-01-29 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17812122#comment-17812122 ] xuyang commented on FLINK-33989: Hi, [~flaviu.cicio] . Could you help use `EXPLAIN PLAN_ADVICE` to print

[jira] [Commented] (FLINK-33963) There is only one UDF instance after serializing the same task

2024-01-29 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17812115#comment-17812115 ] xuyang commented on FLINK-33963: >From my personal perspective, the method of adding class member

[jira] [Commented] (FLINK-33963) There is only one UDF instance after serializing the same task

2024-01-29 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17811845#comment-17811845 ] xuyang commented on FLINK-33963: Hi, [~lifengchao] . This is because in the current implementation,

[jira] [Updated] (FLINK-34254) `DESCRIBE` syntaxes like `DESCRIBE CATALOG xxx` throws strange exceptions

2024-01-28 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuyang updated FLINK-34254: --- Description: Add the test following to CalcITCase to re-produce this bug. {code:java} @Test def test():

[jira] [Updated] (FLINK-34254) `DESCRIBE` syntaxes like `DESCRIBE CATALOG xxx` throws strange exceptions

2024-01-28 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuyang updated FLINK-34254: --- Description: Add the test following to CalcITCase to re-produce this bug.   {code:java} @Test def

[jira] [Updated] (FLINK-34254) `DESCRIBE` syntaxes like `DESCRIBE CATALOG xxx` throws strange exceptions

2024-01-28 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuyang updated FLINK-34254: --- Description: Add the test following to CalcITCase to re-produce this bug.   {code:java} @Test def

[jira] [Created] (FLINK-34254) `DESCRIBE` syntaxes like `DESCRIBE CATALOG xxx` throws strange exceptions

2024-01-28 Thread xuyang (Jira)
xuyang created FLINK-34254: -- Summary: `DESCRIBE` syntaxes like `DESCRIBE CATALOG xxx` throws strange exceptions Key: FLINK-34254 URL: https://issues.apache.org/jira/browse/FLINK-34254 Project: Flink

[jira] [Commented] (FLINK-34129) MiniBatchGlobalGroupAggFunction will make -D as +I then make +I as -U when state expired

2024-01-26 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17811167#comment-17811167 ] xuyang commented on FLINK-34129: If the upstream CDC data is incomplete, such as receiving UB before UA,

  1   2   3   >