[jira] [Commented] (FLINK-20539) Type mismatch when using ROW in computed column

[ https://issues.apache.org/jira/browse/FLINK-20539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17859708#comment-17859708 ] xuyang commented on FLINK-20539: I'll take a look recently. > Type mismatch when using

[jira] [Commented] (FLINK-20539) Type mismatch when using ROW in computed column

[ https://issues.apache.org/jira/browse/FLINK-20539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17860506#comment-17860506 ] xuyang commented on FLINK-20539: 1. It looks like the original fix didn't fix it cleanly

[jira] [Comment Edited] (FLINK-20539) Type mismatch when using ROW in computed column

[ https://issues.apache.org/jira/browse/FLINK-20539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17860506#comment-17860506 ] xuyang edited comment on FLINK-20539 at 6/27/24 2:47 PM: - 1. It

[jira] [Created] (FLINK-35792) Sorting by proctime does not work in rank

xuyang created FLINK-35792: -- Summary: Sorting by proctime does not work in rank Key: FLINK-35792 URL: https://issues.apache.org/jira/browse/FLINK-35792 Project: Flink Issue Type: Bug Compo

[jira] [Commented] (FLINK-35782) Flink connector jdbc works wrong when using sql gateway

[ https://issues.apache.org/jira/browse/FLINK-35782?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864865#comment-17864865 ] xuyang commented on FLINK-35782: Hi, [~caiyi]. SqlGateway does not provide a driver by d

[jira] [Created] (FLINK-35829) StreamPhysicalWindowTableFunction doesn't always require watermark

xuyang created FLINK-35829: -- Summary: StreamPhysicalWindowTableFunction doesn't always require watermark Key: FLINK-35829 URL: https://issues.apache.org/jira/browse/FLINK-35829 Project: Flink Issue

[jira] [Commented] (FLINK-35792) Sorting by proctime does not work in rank

[ https://issues.apache.org/jira/browse/FLINK-35792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17865375#comment-17865375 ] xuyang commented on FLINK-35792: I'll try to fix it. > Sorting by proctime does not wor

[jira] [Commented] (FLINK-35826) [SQL] Sliding window may produce unstable calculations when processing changelog data.

[ https://issues.apache.org/jira/browse/FLINK-35826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17865412#comment-17865412 ] xuyang commented on FLINK-35826: [~martijnvisser] Thanks for this ping. I'll mark it and

[jira] [Commented] (FLINK-35826) [SQL] Sliding window may produce unstable calculations when processing changelog data.

[ https://issues.apache.org/jira/browse/FLINK-35826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17866216#comment-17866216 ] xuyang commented on FLINK-35826: Hi, let me try to explain the cause for this problem.

[jira] [Commented] (FLINK-35826) [SQL] Sliding window may produce unstable calculations when processing changelog data.

[ https://issues.apache.org/jira/browse/FLINK-35826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17866217#comment-17866217 ] xuyang commented on FLINK-35826: cc [~catyee] [~yunta] 👆 > [SQL] Sliding window may pro

[jira] [Commented] (FLINK-35826) [SQL] Sliding window may produce unstable calculations when processing changelog data.

[ https://issues.apache.org/jira/browse/FLINK-35826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17866220#comment-17866220 ] xuyang commented on FLINK-35826: I believe this is a more general problem, that is "how

[jira] [Created] (FLINK-35861) The dependency of kafka sql connector seems wrong

xuyang created FLINK-35861: -- Summary: The dependency of kafka sql connector seems wrong Key: FLINK-35861 URL: https://issues.apache.org/jira/browse/FLINK-35861 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-35861) The dependency of kafka sql connector seems wrong

[ https://issues.apache.org/jira/browse/FLINK-35861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17866923#comment-17866923 ] xuyang commented on FLINK-35861: I'm not sure if other connectors have this bugs in docu

[jira] [Commented] (FLINK-35885) proctime aggregate window triggered by watermark

[ https://issues.apache.org/jira/browse/FLINK-35885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868658#comment-17868658 ] xuyang commented on FLINK-35885: The bug is caused by the advancement of the watermark a

[jira] [Commented] (FLINK-35885) proctime aggregate window triggered by watermark

[ https://issues.apache.org/jira/browse/FLINK-35885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868659#comment-17868659 ] xuyang commented on FLINK-35885: I think this bug needs to be fixed although it only aff

[jira] [Comment Edited] (FLINK-35885) proctime aggregate window triggered by watermark

[ https://issues.apache.org/jira/browse/FLINK-35885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868659#comment-17868659 ] xuyang edited comment on FLINK-35885 at 7/25/24 12:24 PM: -- I th

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

[ https://issues.apache.org/jira/browse/FLINK-34378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17820924#comment-17820924 ] xuyang commented on FLINK-34378: Thanks for your answer, [~xu_shuai_]. That sounds good

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

[ 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-34517) environment configs ignored when calling procedure operation

[ https://issues.apache.org/jira/browse/FLINK-34517?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17820947#comment-17820947 ] xuyang commented on FLINK-34517: Hi, [~JustinLee] . Do you mean there are some configs l

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

[ https://issues.apache.org/jira/browse/FLINK-34437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17821615#comment-17821615 ] xuyang commented on FLINK-34437: Hi, [~jingge] . I see that this PR has been merged. Doe

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

[ https://issues.apache.org/jira/browse/FLINK-34473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17821633#comment-17821633 ] xuyang commented on FLINK-34473: Hi, [~jackylau] . This Jira is a subtask instead of a b

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

[ https://issues.apache.org/jira/browse/FLINK-34529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17822064#comment-17822064 ] xuyang commented on FLINK-34529: Hi, [~nilerzhou] . The plan to fix bug LGTM. IIUC, the

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

[ https://issues.apache.org/jira/browse/FLINK-34016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17822088#comment-17822088 ] xuyang commented on FLINK-34016: Thanks for your test! [~seb-pereira] (y) > Janino comp

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

[ https://issues.apache.org/jira/browse/FLINK-33989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17822337#comment-17822337 ] xuyang commented on FLINK-33989: Agree with [~libenchao] . This is a behavior by design.

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

[ https://issues.apache.org/jira/browse/FLINK-34380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17822401#comment-17822401 ] xuyang commented on FLINK-34380: Hi,  [~xu_shuai_] . Can you help check it again? > Str

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-34583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17823973#comment-17823973 ] xuyang commented on FLINK-34583: [~lincoln.86xy]  Sure. > Bug for dynamic table option

[jira] [Commented] (FLINK-33353) SQL fails because "TimestampType.kind" is not serialized

[ https://issues.apache.org/jira/browse/FLINK-33353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17779471#comment-17779471 ] xuyang commented on FLINK-33353: Hi, [~ferenc-csaky] . How can you serialize the tables,

[jira] [Created] (FLINK-33395) The join hint doesn't work when appears in subquery

xuyang created FLINK-33395: -- Summary: The join hint doesn't work when appears in subquery Key: FLINK-33395 URL: https://issues.apache.org/jira/browse/FLINK-33395 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-33395) The join hint doesn't work when appears in subquery

[ https://issues.apache.org/jira/browse/FLINK-33395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17780916#comment-17780916 ] xuyang commented on FLINK-33395: The root case is that the join hint is not propagated i

[jira] [Created] (FLINK-33396) The table alias when using join hints should be removed in the final plan

xuyang created FLINK-33396: -- Summary: The table alias when using join hints should be removed in the final plan Key: FLINK-33396 URL: https://issues.apache.org/jira/browse/FLINK-33396 Project: Flink

[jira] [Updated] (FLINK-33396) The table alias when using join hints should be removed in the final plan

[ https://issues.apache.org/jira/browse/FLINK-33396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuyang updated FLINK-33396: --- Description: See the existent test 'NestLoopJoinHintTest#testJoinHintWithJoinHintInCorrelateAndWithAgg', th

[jira] [Commented] (FLINK-33396) The table alias when using join hints should be removed in the final plan

[ https://issues.apache.org/jira/browse/FLINK-33396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17780919#comment-17780919 ] xuyang commented on FLINK-33396: The alias hints should be removed while visiting subque

[jira] [Updated] (FLINK-33396) The table alias should be removed in the final plan when using join hints

[ https://issues.apache.org/jira/browse/FLINK-33396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuyang updated FLINK-33396: --- Summary: The table alias should be removed in the final plan when using join hints (was: The table alias w

[jira] [Commented] (FLINK-33217) Flink SQL: UNNEST fails with on LEFT JOIN with NOT NULL type in array

[ https://issues.apache.org/jira/browse/FLINK-33217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17781259#comment-17781259 ] xuyang commented on FLINK-33217: This issue is related to FLINK-31830. The node 'unnest'

[jira] [Commented] (FLINK-33372) Cryptic exception for a sub query in a CompiledPlan

[ https://issues.apache.org/jira/browse/FLINK-33372?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17781280#comment-17781280 ] xuyang commented on FLINK-33372: Hi, [~dwysakowicz] . It seems related about CALCITE-452

[jira] [Commented] (FLINK-33397) FLIP-373: Support Configuring Different State TTLs using SQL Hint

[ https://issues.apache.org/jira/browse/FLINK-33397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17782453#comment-17782453 ] xuyang commented on FLINK-33397: Hi, [~qingyue] .I'd like to take this jira.  > FLIP-37

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

xuyang created FLINK-33489: -- Summary: LISTAGG with generating partial-final agg will case wrong result Key: FLINK-33489 URL: https://issues.apache.org/jira/browse/FLINK-33489 Project: Flink Issue T

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

[ https://issues.apache.org/jira/browse/FLINK-33489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17784273#comment-17784273 ] xuyang commented on FLINK-33489: For a quick fix, we can forbid generating final-partial

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

[ https://issues.apache.org/jira/browse/FLINK-33489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuyang updated FLINK-33489: --- Summary: LISTAGG with generating partial-final agg will cause wrong result (was: LISTAGG with generating pa

[jira] [Commented] (FLINK-32807) when i use emitUpdateWithRetract of udtagg,bug error

[ https://issues.apache.org/jira/browse/FLINK-32807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17784297#comment-17784297 ] xuyang commented on FLINK-32807: Hi, [~luca.yang] . I think this issue is duplicated wit

[jira] [Updated] (FLINK-32380) Support Java records

[ https://issues.apache.org/jira/browse/FLINK-32380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuyang updated FLINK-32380: --- Attachment: image-2023-11-13-10-19-06-035.png > Support Java records > > >

[jira] [Commented] (FLINK-32380) Support Java records

[ https://issues.apache.org/jira/browse/FLINK-32380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17785353#comment-17785353 ] xuyang commented on FLINK-32380: Hi, [~gyfora] Sorry for this noise. When I rebased mast

[jira] [Comment Edited] (FLINK-32380) Support Java records

[ https://issues.apache.org/jira/browse/FLINK-32380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17785353#comment-17785353 ] xuyang edited comment on FLINK-32380 at 11/13/23 2:21 AM: -- Hi,

[jira] [Commented] (FLINK-32380) Support Java records

[ https://issues.apache.org/jira/browse/FLINK-32380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17785396#comment-17785396 ] xuyang commented on FLINK-32380: [~gyfora] Thanks for your quick reply! I'll try it. >

[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=17786151#comment-17786151 ] xuyang commented on FLINK-31835: Hi, [~aitozi]. Sorry for this noise, can you check if t

[jira] [Commented] (FLINK-33547) SQL primitive array type after upgrading to Flink 1.18.0

[ https://issues.apache.org/jira/browse/FLINK-33547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17786159#comment-17786159 ] xuyang commented on FLINK-33547: Maybe caused by FLINK-31835.  > SQL primitive array ty

[jira] [Commented] (FLINK-33490) Validate the name conflicts when creating view

[ https://issues.apache.org/jira/browse/FLINK-33490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17786327#comment-17786327 ] xuyang commented on FLINK-33490: Hi, [~fsk119] , Can I take this jira? > Validate the n

[jira] [Commented] (FLINK-33397) FLIP-373: Support Configuring Different State TTLs using SQL Hint

[ https://issues.apache.org/jira/browse/FLINK-33397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17787002#comment-17787002 ] xuyang commented on FLINK-33397: Hi, [~caozhen1937] The work is on the way. The code is

[jira] [Created] (FLINK-33583) Support state ttl hint for join

xuyang created FLINK-33583: -- Summary: Support state ttl hint for join Key: FLINK-33583 URL: https://issues.apache.org/jira/browse/FLINK-33583 Project: Flink Issue Type: Sub-task Component

[jira] [Commented] (FLINK-33541) RAND_INTEGER can't be existed in a IF statement

[ https://issues.apache.org/jira/browse/FLINK-33541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17788263#comment-17788263 ] xuyang commented on FLINK-33541: The root cause is that in 1.14, the cast rule allow to

[jira] [Comment Edited] (FLINK-33541) RAND_INTEGER can't be existed in a IF statement

[ https://issues.apache.org/jira/browse/FLINK-33541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17788263#comment-17788263 ] xuyang edited comment on FLINK-33541 at 11/21/23 6:05 AM: -- The

[jira] [Comment Edited] (FLINK-33541) RAND_INTEGER can't be existed in a IF statement

[ https://issues.apache.org/jira/browse/FLINK-33541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17788263#comment-17788263 ] xuyang edited comment on FLINK-33541 at 11/21/23 6:06 AM: -- The

[jira] [Comment Edited] (FLINK-33541) RAND_INTEGER can't be existed in a IF statement

[ https://issues.apache.org/jira/browse/FLINK-33541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17788263#comment-17788263 ] xuyang edited comment on FLINK-33541 at 11/21/23 6:07 AM: -- The

[jira] [Commented] (FLINK-33541) RAND_INTEGER can't be existed in a IF statement

[ https://issues.apache.org/jira/browse/FLINK-33541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17788266#comment-17788266 ] xuyang commented on FLINK-33541: Maybe we should add the logic back in IfCallGen#generat

[jira] [Commented] (FLINK-33490) Validate the name conflicts when creating view

[ https://issues.apache.org/jira/browse/FLINK-33490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17788648#comment-17788648 ] xuyang commented on FLINK-33490: Hi, [~libenchao] .  I test the sql you provide and som

[jira] [Commented] (FLINK-33616) multi lookup join error

[ https://issues.apache.org/jira/browse/FLINK-33616?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17788776#comment-17788776 ] xuyang commented on FLINK-33616: Hi, [~luca.yang] . In the lookup join, if you have only

[jira] [Commented] (FLINK-33490) Validate the name conflicts when creating view

[ https://issues.apache.org/jira/browse/FLINK-33490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17788987#comment-17788987 ] xuyang commented on FLINK-33490: Hi, [~libenchao] [~fsk119] . I think we can pick some

[jira] [Commented] (FLINK-33541) RAND_INTEGER can't be existed in a IF statement

[ https://issues.apache.org/jira/browse/FLINK-33541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17788993#comment-17788993 ] xuyang commented on FLINK-33541: Hi, [~libenchao]  when I try to fix it and add tests, I

[jira] [Updated] (FLINK-33541) RAND_INTEGER can't be existed in a IF statement

[ https://issues.apache.org/jira/browse/FLINK-33541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuyang updated FLINK-33541: --- Attachment: image-2023-11-24-13-31-21-209.png > RAND_INTEGER can't be existed in a IF statement > -

[jira] [Commented] (FLINK-33541) RAND_INTEGER can't be existed in a IF statement

[ https://issues.apache.org/jira/browse/FLINK-33541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17789330#comment-17789330 ] xuyang commented on FLINK-33541: Hi, [~libenchao] , I checked the code again and sorry f

[jira] [Commented] (FLINK-33541) RAND_INTEGER can't be existed in a IF statement

[ https://issues.apache.org/jira/browse/FLINK-33541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17789383#comment-17789383 ] xuyang commented on FLINK-33541: You're right, sorry about typo for it. What I want to e

[jira] [Created] (FLINK-34048) Support Session Window Aggregate in table runtime

xuyang created FLINK-34048: -- Summary: Support Session Window Aggregate in table runtime Key: FLINK-34048 URL: https://issues.apache.org/jira/browse/FLINK-34048 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-34049) Refactor classes related to window TVF aggregation to prepare for non-aligned windows

xuyang created FLINK-34049: -- Summary: Refactor classes related to window TVF aggregation to prepare for non-aligned windows Key: FLINK-34049 URL: https://issues.apache.org/jira/browse/FLINK-34049 Project: Fl

[jira] [Updated] (FLINK-34048) Support Session Window Aggregate in table runtime instead of using legacy group window agg op

[ https://issues.apache.org/jira/browse/FLINK-34048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuyang updated FLINK-34048: --- Summary: Support Session Window Aggregate in table runtime instead of using legacy group window agg op (was

[jira] [Updated] (FLINK-34048) Support session window agg in table runtime instead of using legacy group window agg op

[ https://issues.apache.org/jira/browse/FLINK-34048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuyang updated FLINK-34048: --- Summary: Support session window agg in table runtime instead of using legacy group window agg op (was: Supp

[jira] [Commented] (FLINK-34053) Support state TTL hint for group aggregate

[ https://issues.apache.org/jira/browse/FLINK-34053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17805346#comment-17805346 ] xuyang commented on FLINK-34053: Hi, [~qingyue] Can I take this jira? > Support state T

[jira] [Commented] (FLINK-32530) array_position semantic should align with array_contains instead of spark

[ https://issues.apache.org/jira/browse/FLINK-32530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17805570#comment-17805570 ] xuyang commented on FLINK-32530: Hi, [~jackylau] . Thanks for pointing it! Have you loo

[jira] [Commented] (FLINK-34077) Sphinx version needs upgrade

[ https://issues.apache.org/jira/browse/FLINK-34077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17806581#comment-17806581 ] xuyang commented on FLINK-34077: https://dev.azure.com/apache-flink/apache-flink/_build/

[jira] [Created] (FLINK-34100) Support session window table function without pulling up with window agg

xuyang created FLINK-34100: -- Summary: Support session window table function without pulling up with window agg Key: FLINK-34100 URL: https://issues.apache.org/jira/browse/FLINK-34100 Project: Flink

[jira] [Updated] (FLINK-34100) Support session window table function without pulling up with window agg

[ https://issues.apache.org/jira/browse/FLINK-34100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuyang updated FLINK-34100: --- Description: This subtask resolves the session window agg with WindowAttachedWindowingStrategy. > Support s

[jira] [Updated] (FLINK-34048) Support session window agg in table runtime instead of using legacy group window agg op

[ https://issues.apache.org/jira/browse/FLINK-34048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuyang updated FLINK-34048: --- Description: We not only need FLINK-24024  to support session window agg in planner, but also need to suppo

[jira] [Updated] (FLINK-34100) Support session window table function without pulling up with window agg

[ https://issues.apache.org/jira/browse/FLINK-34100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuyang updated FLINK-34100: --- Description: This subtask resolves the session support in ExecWindowTableFunction. And then the session wind

[jira] [Commented] (FLINK-34133) Merge MiniBatchInterval when propagate traits to child block

[ https://issues.apache.org/jira/browse/FLINK-34133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17807963#comment-17807963 ] xuyang commented on FLINK-34133: Hi, can you attach the code and plan as text in the `co

[jira] [Comment Edited] (FLINK-34133) Merge MiniBatchInterval when propagate traits to child block

[ https://issues.apache.org/jira/browse/FLINK-34133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17807963#comment-17807963 ] xuyang edited comment on FLINK-34133 at 1/18/24 1:38 AM: - Hi, [~

[jira] [Created] (FLINK-34138) Improve the interface about MergeCallback in window

xuyang created FLINK-34138: -- Summary: Improve the interface about MergeCallback in window Key: FLINK-34138 URL: https://issues.apache.org/jira/browse/FLINK-34138 Project: Flink Issue Type: Improveme

[jira] [Created] (FLINK-34139) The window assigner should not reveal its event time or process time at the interface level.

xuyang created FLINK-34139: -- Summary: The window assigner should not reveal its event time or process time at the interface level. Key: FLINK-34139 URL: https://issues.apache.org/jira/browse/FLINK-34139 Proj

[jira] [Updated] (FLINK-34139) The window assigner should not reveal its event time or process time at the interface level.

[ https://issues.apache.org/jira/browse/FLINK-34139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuyang updated FLINK-34139: --- Description: Currently, there is a function  > The window assigner should not reveal its event time or proce

[jira] [Updated] (FLINK-34139) The slice assigner should not reveal its event time or process time at the interface level.

[ https://issues.apache.org/jira/browse/FLINK-34139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuyang updated FLINK-34139: --- Summary: The slice assigner should not reveal its event time or process time at the interface level. (was:

[jira] [Updated] (FLINK-34139) The slice assigner should not reveal its event time or process time at the interface level.

[ https://issues.apache.org/jira/browse/FLINK-34139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuyang updated FLINK-34139: --- Description: Currently, there is a function `boolean isEventTime()` to tell other that it is by event time o

[jira] [Updated] (FLINK-34138) Improve the interface about MergeCallback in window

[ https://issues.apache.org/jira/browse/FLINK-34138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuyang updated FLINK-34138: --- Description: As a merge method, the return value type is `void`, that is confusing. > Improve the interface

[jira] [Created] (FLINK-34140) Rename WindowContext in window

xuyang created FLINK-34140: -- Summary: Rename WindowContext in window Key: FLINK-34140 URL: https://issues.apache.org/jira/browse/FLINK-34140 Project: Flink Issue Type: Improvement Componen

[jira] [Updated] (FLINK-34140) Rename WindowContext in window

[ https://issues.apache.org/jira/browse/FLINK-34140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuyang updated FLINK-34140: --- Description: Currently, WindowContext not only contains a series of get methods to obtain context informati

[jira] [Updated] (FLINK-34140) Rename WindowContext and TriggerContext in window

[ https://issues.apache.org/jira/browse/FLINK-34140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuyang updated FLINK-34140: --- Description: Currently, WindowContext and TriggerContext not only contains a series of get methods to obtai

[jira] [Updated] (FLINK-34140) Rename WindowContext and TriggerContext in window

[ https://issues.apache.org/jira/browse/FLINK-34140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuyang updated FLINK-34140: --- Description: Currently, WindowContext and TriggerContext not only contains a series of get methods to obtai

[jira] [Updated] (FLINK-34140) Rename WindowContext and TriggerContext in window

[ https://issues.apache.org/jira/browse/FLINK-34140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuyang updated FLINK-34140: --- Summary: Rename WindowContext and TriggerContext in window (was: Rename WindowContext in window) > Rename

[jira] [Created] (FLINK-34141) Bash exited with code '143'

xuyang created FLINK-34141: -- Summary: Bash exited with code '143' Key: FLINK-34141 URL: https://issues.apache.org/jira/browse/FLINK-34141 Project: Flink Issue Type: Bug Components: Build S

[jira] [Updated] (FLINK-34141) Bash exited with code '143'

[ https://issues.apache.org/jira/browse/FLINK-34141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuyang updated FLINK-34141: --- Description: [https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=56544&view=logs&j=9cada

[jira] [Commented] (FLINK-34140) Rename WindowContext and TriggerContext in window

[ https://issues.apache.org/jira/browse/FLINK-34140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17808155#comment-17808155 ] xuyang commented on FLINK-34140: Hi, [~martijnvisser] . The all these classes are inner

[jira] [Comment Edited] (FLINK-34140) Rename WindowContext and TriggerContext in window

[ https://issues.apache.org/jira/browse/FLINK-34140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17808155#comment-17808155 ] xuyang edited comment on FLINK-34140 at 1/18/24 11:37 AM: -- Hi,

[jira] [Updated] (FLINK-34140) Rename WindowContext and TriggerContext in window

[ https://issues.apache.org/jira/browse/FLINK-34140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuyang updated FLINK-34140: --- Description: Currently, WindowContext and TriggerContext not only contains a series of get methods to obtai

[jira] [Created] (FLINK-34175) When meeting WindowedSliceAssigner, slice window agg registers an wrong timestamp timer

xuyang created FLINK-34175: -- Summary: When meeting WindowedSliceAssigner, slice window agg registers an wrong timestamp timer Key: FLINK-34175 URL: https://issues.apache.org/jira/browse/FLINK-34175 Project:

[jira] [Updated] (FLINK-34175) When meeting WindowedSliceAssigner, slice window agg registers an wrong timestamp timer

[ https://issues.apache.org/jira/browse/FLINK-34175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuyang updated FLINK-34175: --- Description: The following test added to SlicingWindowAggOperatorTest can re-produce this problem. {code:ja

[jira] [Commented] (FLINK-34141) Bash exited with code '143'

[ https://issues.apache.org/jira/browse/FLINK-34141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17809886#comment-17809886 ] xuyang commented on FLINK-34141: Thanks a lot for your fix [~mapohl] :D > Bash exited w

[jira] [Created] (FLINK-34235) Not using Optional as input arguments in QueryHintsResolver

xuyang created FLINK-34235: -- Summary: Not using Optional as input arguments in QueryHintsResolver Key: FLINK-34235 URL: https://issues.apache.org/jira/browse/FLINK-34235 Project: Flink Issue Type:

[jira] [Updated] (FLINK-34235) Not using Optional as input arguments in QueryHintsResolver

[ https://issues.apache.org/jira/browse/FLINK-34235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuyang updated FLINK-34235: --- Description: It also seems that we always can't get an empty left or right name from input. > Not using Opt

[jira] [Created] (FLINK-34238) In streaming mode, redundant exchange nodes can be optimally deleted in some cases

xuyang created FLINK-34238: -- Summary: In streaming mode, redundant exchange nodes can be optimally deleted in some cases Key: FLINK-34238 URL: https://issues.apache.org/jira/browse/FLINK-34238 Project: Flink

[jira] [Updated] (FLINK-34238) In streaming mode, redundant exchange nodes can be optimally deleted in some cases

[ https://issues.apache.org/jira/browse/FLINK-34238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuyang updated FLINK-34238: --- Description: Take the following plan as an example: {code:java} Calc(select=[window_start, window_end, a, EX

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

[ https://issues.apache.org/jira/browse/FLINK-34129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17811167#comment-17811167 ] xuyang commented on FLINK-34129: If the upstream CDC data is incomplete, such as receivi

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

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

  1   2   3   4   5   6   >