[jira] [Commented] (FLINK-34914) FLIP-436: Introduce Catalog-related Syntax

[ https://issues.apache.org/jira/browse/FLINK-34914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17861064#comment-17861064 ] Yubin Li commented on FLINK-34914: -- [~Weijie Guo] Surely, I will make it as soon as possible:) >

[jira] [Assigned] (FLINK-35679) [Release-1.20] Cross team testing

[ https://issues.apache.org/jira/browse/FLINK-35679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-35679: --- Assignee: Rui Fan > [Release-1.20] Cross team testing > - > >

[jira] [Assigned] (FLINK-35678) [Release-1.20] Review and update documentation

[ https://issues.apache.org/jira/browse/FLINK-35678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-35678: --- Assignee: Rui Fan > [Release-1.20] Review and update documentation >

[jira] [Commented] (FLINK-34914) FLIP-436: Introduce Catalog-related Syntax

[ https://issues.apache.org/jira/browse/FLINK-34914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17861060#comment-17861060 ] Weijie Guo commented on FLINK-34914: Hi [~liyubin117], could you add the release note for this

[jira] [Updated] (FLINK-35734) Not override the user-defined checkpoint interval in continuous mode.

[ https://issues.apache.org/jira/browse/FLINK-35734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Feng Jin updated FLINK-35734: - Component/s: Table SQL / API Table SQL / Gateway Fix Version/s: 1.20.0 > Not

[jira] [Created] (FLINK-35734) Not override the user-defined checkpoint interval in continuous mode.

Feng Jin created FLINK-35734: Summary: Not override the user-defined checkpoint interval in continuous mode. Key: FLINK-35734 URL: https://issues.apache.org/jira/browse/FLINK-35734 Project: Flink

[jira] [Assigned] (FLINK-35665) Release Testing: FLIP-441: Show the JobType and remove Execution Mode on Flink WebUI

[ https://issues.apache.org/jira/browse/FLINK-35665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan reassigned FLINK-35665: --- Assignee: Zakelly Lan > Release Testing: FLIP-441: Show the JobType and remove Execution

[jira] [Commented] (FLINK-35733) Change org.jetbrains.annotations.NotNull to javax.annotation.Nonnull

[ https://issues.apache.org/jira/browse/FLINK-35733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17861059#comment-17861059 ] RocMarshal commented on FLINK-35733: I'd like to contribute for the ticket. May I get the ticket ?

[jira] [Created] (FLINK-35733) Change org.jetbrains.annotations.NotNull to javax.annotation.Nonnull

RocMarshal created FLINK-35733: -- Summary: Change org.jetbrains.annotations.NotNull to javax.annotation.Nonnull Key: FLINK-35733 URL: https://issues.apache.org/jira/browse/FLINK-35733 Project: Flink

[jira] [Commented] (FLINK-35690) Release Testing: Verify FLIP-459: Support Flink hybrid shuffle integration with Apache Celeborn

[ https://issues.apache.org/jira/browse/FLINK-35690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17861058#comment-17861058 ] Rui Fan commented on FLINK-35690: - Hi [~tanyuxin] [~chalixar] , I see that both of you have features

[jira] [Assigned] (FLINK-35624) Release Testing: Verify FLIP-306 Unified File Merging Mechanism for Checkpoints

[ https://issues.apache.org/jira/browse/FLINK-35624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-35624: --- Assignee: Rui Fan > Release Testing: Verify FLIP-306 Unified File Merging Mechanism for >

[jira] [Closed] (FLINK-35685) Some metrics in the MetricStore are duplicated when increasing or decreasing task parallelism

[ https://issues.apache.org/jira/browse/FLINK-35685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] elon_X closed FLINK-35685. -- Resolution: Fixed > Some metrics in the MetricStore are duplicated when increasing or decreasing > task

[jira] [Commented] (FLINK-35611) Release Testing Instructions: Verify [FLIP-453] Promote Unified Sink API V2 to Public and Deprecate SinkFunction

[ https://issues.apache.org/jira/browse/FLINK-35611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17861054#comment-17861054 ] Rui Fan commented on FLINK-35611: - Hi [~martijnvisser] , could you please confirm whether FLINK-35378

[jira] [Commented] (FLINK-35663) Release Testing: FLIP-436: Introduce Catalog-related Syntax

[ https://issues.apache.org/jira/browse/FLINK-35663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17861052#comment-17861052 ] Rui Fan commented on FLINK-35663: - Thanks [~ferenc-csaky] for the volunteering, I have assigned to you

[jira] [Assigned] (FLINK-35663) Release Testing: FLIP-436: Introduce Catalog-related Syntax

[ https://issues.apache.org/jira/browse/FLINK-35663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-35663: --- Assignee: Ferenc Csaky > Release Testing: FLIP-436: Introduce Catalog-related Syntax >

[jira] [Commented] (FLINK-34273) git fetch fails

[ https://issues.apache.org/jira/browse/FLINK-34273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17861051#comment-17861051 ] Weijie Guo commented on FLINK-34273:

[jira] [Commented] (FLINK-34405) RightOuterJoinTaskTest#testCancelOuterJoinTaskWhileSort2 fails due to an interruption of the RightOuterJoinDriver#prepare method

[ https://issues.apache.org/jira/browse/FLINK-34405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17861050#comment-17861050 ] Weijie Guo commented on FLINK-34405:

[jira] [Updated] (FLINK-35721) I found out that in the Flink SQL documentation it says that Double type cannot be converted to Boolean type, but in reality, it can.

[ https://issues.apache.org/jira/browse/FLINK-35721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-35721: --- Priority: Minor (was: Blocker) > I found out that in the Flink SQL documentation it says that

[jira] [Resolved] (FLINK-35542) ClassNotFoundException when deserializing CheckpointedOffset

[ https://issues.apache.org/jira/browse/FLINK-35542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-35542. - Resolution: Fixed > ClassNotFoundException when deserializing CheckpointedOffset >

[jira] [Commented] (FLINK-35542) ClassNotFoundException when deserializing CheckpointedOffset

[ https://issues.apache.org/jira/browse/FLINK-35542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17861049#comment-17861049 ] Rui Fan commented on FLINK-35542: - Merged to 3.3.0 via 90d69c7f2b8e4ccde7f1b39376e3bd0c5aaf39b7 >

[jira] [Updated] (FLINK-35732) sql-client.sh fails with ClassNotFoundException depending on its location

[ https://issues.apache.org/jira/browse/FLINK-35732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rob Young updated FLINK-35732: -- Description: To reproduce: 1. create a directory `mkdir my-flink-sql-gateway-project` 2. unpack a

[jira] [Updated] (FLINK-35732) sql-client.sh fails with ClassNotFoundException depending on its location

[ https://issues.apache.org/jira/browse/FLINK-35732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rob Young updated FLINK-35732: -- Description: To reproduce: 1. create a directory `mkdir my-flink-sql-gateway-project` 2. unpack a

[jira] [Updated] (FLINK-35732) sql-client.sh fails with ClassNotFoundException depending on its location

[ https://issues.apache.org/jira/browse/FLINK-35732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rob Young updated FLINK-35732: -- Description: To reproduce: 1. create a directory `mkdir my-flink-sql-gateway-project` 2. unpack a

[jira] [Updated] (FLINK-35732) sql-client.sh fails with ClassNotFoundException depending on its location

[ https://issues.apache.org/jira/browse/FLINK-35732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rob Young updated FLINK-35732: -- Summary: sql-client.sh fails with ClassNotFoundException depending on its location (was:

[jira] [Updated] (FLINK-35732) flink-sql-client.sh fails with ClassNotFoundException depending on its location

[ https://issues.apache.org/jira/browse/FLINK-35732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rob Young updated FLINK-35732: -- Summary: flink-sql-client.sh fails with ClassNotFoundException depending on its location (was:

[jira] [Created] (FLINK-35732) flink-sql-client.sh fails with ClassNotFoundException depending on it's location

Rob Young created FLINK-35732: - Summary: flink-sql-client.sh fails with ClassNotFoundException depending on it's location Key: FLINK-35732 URL: https://issues.apache.org/jira/browse/FLINK-35732 Project:

[jira] [Updated] (FLINK-35606) Release Testing Instructions: Verify FLINK-26050 Too many small sst files in rocksdb state backend when using time window created in ascending order

[ https://issues.apache.org/jira/browse/FLINK-35606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-35606: -- Description: Follow up the test for https://issues.apache.org/jira/browse/FLINK-26050

[jira] [Updated] (FLINK-35606) Release Testing Instructions: Verify FLINK-26050 Too many small sst files in rocksdb state backend when using time window created in ascending order

[ https://issues.apache.org/jira/browse/FLINK-35606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-35606: -- Description: Follow up the test for https://issues.apache.org/jira/browse/FLINK-26050

[jira] [Commented] (FLINK-35606) Release Testing Instructions: Verify FLINK-26050 Too many small sst files in rocksdb state backend when using time window created in ascending order

[ https://issues.apache.org/jira/browse/FLINK-35606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17861034#comment-17861034 ] Roman Khachatryan commented on FLINK-35606: --- Hi [~Weijie Guo] , yes, it would make sense to

[jira] [Comment Edited] (FLINK-35565) Flink KafkaSource Batch Job Gets Into Infinite Loop after Resetting Offset

[ https://issues.apache.org/jira/browse/FLINK-35565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17860998#comment-17860998 ] dongwoo.kim edited comment on FLINK-35565 at 6/30/24 1:52 PM: -- Since the

[jira] [Commented] (FLINK-35565) Flink KafkaSource Batch Job Gets Into Infinite Loop after Resetting Offset

[ https://issues.apache.org/jira/browse/FLINK-35565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17860998#comment-17860998 ] dongwoo.kim commented on FLINK-35565: - Since the stoppingOffset logic relies on the last record's

[jira] [Closed] (FLINK-35702) Support Parquet Nested Read

[ https://issues.apache.org/jira/browse/FLINK-35702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-35702. Resolution: Fixed merged in: 8c899b02ab25a34e4d35c73a8fc0299894110aca > Support Parquet Nested

[jira] [Created] (FLINK-35731) Sink V2 operator is mistakenly assumed always to be parallelism configured

Junrui Li created FLINK-35731: - Summary: Sink V2 operator is mistakenly assumed always to be parallelism configured Key: FLINK-35731 URL: https://issues.apache.org/jira/browse/FLINK-35731 Project: Flink