[jira] [Updated] (FLINK-38387) Disable spotless for java 25

[ https://issues.apache.org/jira/browse/FLINK-38387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38387: --- Labels: pull-request-available (was: ) > Disable spotless for java

[jira] [Updated] (FLINK-38387) Disable spotless for java 25

[ https://issues.apache.org/jira/browse/FLINK-38387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin updated FLINK-38387: Description: Currently attempt to build with jdk25 with enabled spotless fails as

[jira] [Updated] (FLINK-37984) Move Cassandra Sink to Sink V2

[ https://issues.apache.org/jira/browse/FLINK-37984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-37984: --- Labels: pull-request-available (was: ) > Move Cassandra Sink to Sink

[jira] [Updated] (FLINK-38468) Performance drops when the coalesce parameter includes functions

[ https://issues.apache.org/jira/browse/FLINK-38468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jie Cheng updated FLINK-38468: -- Attachment: (was: 112.svg) > Performance drops when the coalesce parameter includes functi

[jira] [Updated] (FLINK-38468) Performance drops when the coalesce parameter includes functions

[ https://issues.apache.org/jira/browse/FLINK-38468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jie Cheng updated FLINK-38468: -- Attachment: 118.svg > Performance drops when the coalesce parameter includes functi

[jira] [Comment Edited] (FLINK-38370) CommitterOperator does not checkpoint all pending committables

[ https://issues.apache.org/jira/browse/FLINK-38370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18021425#comment-18021425 ] Maximilian Michels edited comment on FLINK-38370 at 9/22/25 7:5

[jira] [Commented] (FLINK-16686) [State TTL] Make user class loader available in native RocksDB compaction thread

[ https://issues.apache.org/jira/browse/FLINK-16686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18024401#comment-18024401 ] Jun Qin commented on FLINK-16686: - This is finally solved. Thanks [~zakelly] for g

[jira] [Commented] (FLINK-38463) Support TTL in SinkUpsertMaterializerV2

[ https://issues.apache.org/jira/browse/FLINK-38463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18024398#comment-18024398 ] Hemanth Savasere commented on FLINK-38463: -- Hi [~roman] Can you please as

[jira] [Commented] (FLINK-16686) [State TTL] Make user class loader available in native RocksDB compaction thread

[ https://issues.apache.org/jira/browse/FLINK-16686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18024392#comment-18024392 ] Zakelly Lan commented on FLINK-16686: - Merge into: * ma

[jira] [Resolved] (FLINK-16686) [State TTL] Make user class loader available in native RocksDB compaction thread

[ https://issues.apache.org/jira/browse/FLINK-16686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan resolved FLINK-16686. - Fix Version/s: 2.0.1 2.2.0 2.1.1 1.20.4

[jira] [Closed] (FLINK-36467) Bump google-java-format and spotless

[ https://issues.apache.org/jira/browse/FLINK-36467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mate Czagany closed FLINK-36467. Resolution: Fixed > Bump google-java-format and spotl

[jira] [Closed] (FLINK-38258) Enable model param for PTF

[ https://issues.apache.org/jira/browse/FLINK-38258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-38258. Fix Version/s: 2.2.0 Resolution: Fixed Fixed in master

[jira] [Commented] (FLINK-34112) JavaCodeSplitter OOM

[ https://issues.apache.org/jira/browse/FLINK-34112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18023735#comment-18023735 ] Chunhui Yang commented on FLINK-34112: -- I'm also encountering this bu

[jira] [Created] (FLINK-38467) Caused by: java.lang.ClassCastException

terrence created FLINK-38467: Summary: Caused by: java.lang.ClassCastException Key: FLINK-38467 URL: https://issues.apache.org/jira/browse/FLINK-38467 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-38461) Introduce SinkUpsertMaterializerV2

[ https://issues.apache.org/jira/browse/FLINK-38461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38461: --- Labels: pull-request-available (was: ) > Introduce SinkUpsertMaterialize

[jira] [Resolved] (FLINK-38433) Avoid delete ForSt's directory when there happened to be an existing one

[ https://issues.apache.org/jira/browse/FLINK-38433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan resolved FLINK-38433. - Fix Version/s: 2.2.0 Resolution: Fixed > Avoid delete ForSt's directory wh

[jira] [Updated] (FLINK-38469) Bump apache-beam for PyFlink to >= 2.66 to address CVE-2024-52338 for pyarrow

[ https://issues.apache.org/jira/browse/FLINK-38469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wren updated FLINK-38469: - Description: There is no NVD assessment of the CVE yet but the CISA-ADP rating for [NVD - CVE-2024-52338|https

[jira] [Updated] (FLINK-38468) Performance drops when the coalesce parameter includes functions

[ https://issues.apache.org/jira/browse/FLINK-38468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38468: --- Labels: pull-request-available (was: ) > Performance drops when the coalesce parame

[jira] [Commented] (FLINK-38272) The BatchJobRecoveryTest failed of azure cron adaptive scheduler pipeline

[ https://issues.apache.org/jira/browse/FLINK-38272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18023462#comment-18023462 ] Lei Yang commented on FLINK-38272: -- The issue occurred because the JM fail

[jira] [Closed] (FLINK-38462) Introduce state backend type identifier

[ https://issues.apache.org/jira/browse/FLINK-38462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan closed FLINK-38462. - Resolution: Fixed Merged into master as d567a9dee4d54f0401058e7c07081cf05adbd2c1

[jira] [Closed] (FLINK-38461) Introduce SinkUpsertMaterializerV2

[ https://issues.apache.org/jira/browse/FLINK-38461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan closed FLINK-38461. - Resolution: Fixed Merged into master as d567a9dee4d54f0401058e7c07081cf05adbd2c1

[jira] [Reopened] (FLINK-38461) Introduce SinkUpsertMaterializerV2

[ https://issues.apache.org/jira/browse/FLINK-38461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan reopened FLINK-38461: --- > Introduce SinkUpsertMaterialize

[jira] (FLINK-38461) Introduce SinkUpsertMaterializerV2

[ https://issues.apache.org/jira/browse/FLINK-38461 ] Roman Khachatryan deleted comment on FLINK-38461: --- was (Author: roman_khachatryan): Merged into master as d567a9dee4d54f0401058e7c07081cf05adbd2c1 > Introduce SinkUpsertMaterialize

[jira] [Created] (FLINK-38459) SinkUpsertMaterializer V2 (FLIP-544)

Roman Khachatryan created FLINK-38459: - Summary: SinkUpsertMaterializer V2 (FLIP-544) Key: FLINK-38459 URL: https://issues.apache.org/jira/browse/FLINK-38459 Project: Flink Issue Type

[jira] [Resolved] (FLINK-38470) Make CreateMaterializedTableOperation return ResolvedCatalogMaterializedTable

[ https://issues.apache.org/jira/browse/FLINK-38470?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin resolved FLINK-38470. - Fix Version/s: 2.2.0 Resolution: Fixed Merged as

[jira] [Assigned] (FLINK-38470) Make CreateMaterializedTableOperation return ResolvedCatalogMaterializedTable

[ https://issues.apache.org/jira/browse/FLINK-38470?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin reassigned FLINK-38470: --- Assignee: Ramin Gharib > Make CreateMaterializedTableOperation ret

[jira] [Commented] (FLINK-38415) IndexOutOfBoundsException occasionally occurs after rocksdb.use-ingest-db-restore-mode is enabled

[ https://issues.apache.org/jira/browse/FLINK-38415?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18024263#comment-18024263 ] Rui Fan commented on FLINK-38415: - Merged to master(2.2)

[jira] [Updated] (FLINK-38471) flink-end-to-end-tests-common-kafka depends implicitely on kafka-sql-connector

[ https://issues.apache.org/jira/browse/FLINK-38471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38471: --- Labels: pull-request-available (was: ) > flink-end-to-end-tests-common-kafka depe

[jira] [Closed] (FLINK-31500) Move SqlAlterTableSchema conversion logic to AlterTableSchemaConverter

[ https://issues.apache.org/jira/browse/FLINK-31500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin closed FLINK-31500. --- Resolution: Fixed Closing as it was done as part of FLINK-38458 > Move SqlAlterTableSch

[jira] [Assigned] (FLINK-38471) flink-end-to-end-tests-common-kafka depends implicitely on kafka-sql-connector

[ https://issues.apache.org/jira/browse/FLINK-38471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul reassigned FLINK-38471: --- Assignee: Fabian Paul > flink-end-to-end-tests-common-kafka depends implicitely on ka

[jira] [Created] (FLINK-38471) flink-end-to-end-tests-common-kafka depends implicitely on kafka-sql-connector

Fabian Paul created FLINK-38471: --- Summary: flink-end-to-end-tests-common-kafka depends implicitely on kafka-sql-connector Key: FLINK-38471 URL: https://issues.apache.org/jira/browse/FLINK-38471 Project

[jira] [Updated] (FLINK-38254) Hide sensitive information in the exception message when performing table validation

[ https://issues.apache.org/jira/browse/FLINK-38254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi updated FLINK-38254: -- Fix Version/s: (was: 2.1.1) > Hide sensitive information in the exception message w

[jira] [Updated] (FLINK-38324) Job fails to restore keyed state backend when using Forst state backend on S3: FileNotFoundException

[ https://issues.apache.org/jira/browse/FLINK-38324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi updated FLINK-38324: -- Fix Version/s: (was: 2.0.1) (was: 2.2.0

[jira] [Updated] (FLINK-38195) Some markdown syntax errors in tableApi page

[ https://issues.apache.org/jira/browse/FLINK-38195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi updated FLINK-38195: -- Fix Version/s: (was: 2.1.1) > Some markdown syntax errors in tableApi p

[jira] [Updated] (FLINK-38219) Manipulate state in MultiJoin with fixed row kind

[ https://issues.apache.org/jira/browse/FLINK-38219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi updated FLINK-38219: -- Fix Version/s: 2.1.1 (was: 2.1.0) > Manipulate state in MultiJoin w

[jira] [Updated] (FLINK-38220) Adjust JoinToMultiJoinRule to support different types of source

[ https://issues.apache.org/jira/browse/FLINK-38220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi updated FLINK-38220: -- Fix Version/s: 2.1.1 (was: 2.1.0) > Adjust JoinToMultiJoinRule

[jira] [Updated] (FLINK-38020) NonTimeRangeUnboundedPrecedingFunction failing with NPE

[ https://issues.apache.org/jira/browse/FLINK-38020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi updated FLINK-38020: -- Fix Version/s: 2.1.1 > NonTimeRangeUnboundedPrecedingFunction failing with

[jira] [Updated] (FLINK-38193) Upgrade org.apache.commons:commons-lang3 from 3.12.0 to 3.18.0 to mitigate CVE-2025-48924

[ https://issues.apache.org/jira/browse/FLINK-38193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi updated FLINK-38193: -- Fix Version/s: 2.1.1 > Upgrade org.apache.commons:commons-lang3 from 3.12.0 to 3.18.0

[jira] [Updated] (FLINK-38370) CommitterOperator does not checkpoint all pending committables

[ https://issues.apache.org/jira/browse/FLINK-38370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi updated FLINK-38370: -- Fix Version/s: 2.1.1 > CommitterOperator does not checkpoint all pending committab

[jira] [Updated] (FLINK-38400) STDDEV/VAR function with FILTER condition may cause wrong result

[ https://issues.apache.org/jira/browse/FLINK-38400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi updated FLINK-38400: -- Fix Version/s: (was: 2.1.1) > STDDEV/VAR function with FILTER condition may cause wr

[jira] [Updated] (FLINK-38399) As long as the join key includes one of the indexes from the source, the join can be converted into a delta join

[ https://issues.apache.org/jira/browse/FLINK-38399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi updated FLINK-38399: -- Fix Version/s: (was: 2.1.1) > As long as the join key includes one of the indexes f

[jira] [Commented] (FLINK-38400) STDDEV/VAR function with FILTER condition may cause wrong result

[ https://issues.apache.org/jira/browse/FLINK-38400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18024230#comment-18024230 ] Gabor Somogyi commented on FLINK-38400: --- [{{a1ec502}}|https://github.com/ap

[jira] [Updated] (FLINK-38326) Kubernetes support oAuthToken authentication

[ https://issues.apache.org/jira/browse/FLINK-38326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi updated FLINK-38326: -- Fix Version/s: (was: 2.1.1) (was: 1.20.4) > Kubernetes supp

[jira] [Updated] (FLINK-38326) Kubernetes support oAuthToken authentication

[ https://issues.apache.org/jira/browse/FLINK-38326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi updated FLINK-38326: -- Affects Version/s: 1.20.3 2.1.0 > Kubernetes support oAuthTo

[jira] [Resolved] (FLINK-38442) ProfilingServiceTest.testRollingDeletion is unstable

[ https://issues.apache.org/jira/browse/FLINK-38442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin resolved FLINK-38442. - Fix Version/s: 2.2.0 Resolution: Fixed Merged as

[jira] [Updated] (FLINK-38394) Upgrade Flink CDC to Flink 2

[ https://issues.apache.org/jira/browse/FLINK-38394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi updated FLINK-38394: -- Fix Version/s: (was: 2.1.1) > Upgrade Flink CDC to Flin

[jira] [Updated] (FLINK-38470) Make CreateMaterializedTableOperation return ResolvedCatalogMaterializedTable

[ https://issues.apache.org/jira/browse/FLINK-38470?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38470: --- Labels: pull-request-available (was: ) > Make CreateMaterializedTableOperation ret

[jira] [Created] (FLINK-38470) Make CreateMaterializedTableOperation return ResolvedCatalogMaterializedTable

Ramin Gharib created FLINK-38470: Summary: Make CreateMaterializedTableOperation return ResolvedCatalogMaterializedTable Key: FLINK-38470 URL: https://issues.apache.org/jira/browse/FLINK-38470

[jira] [Updated] (FLINK-38469) Bump apache-beam for PyFlink to >= 2.66 to address CVE-2024-52338 for pyarrow

[ https://issues.apache.org/jira/browse/FLINK-38469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wren updated FLINK-38469: - Component/s: API / Python > Bump apache-beam for PyFlink to >= 2.66 to address CVE-2024-52338 for p

[jira] [Updated] (FLINK-38468) Performance drops when the coalesce parameter includes functions

[ https://issues.apache.org/jira/browse/FLINK-38468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jie Cheng updated FLINK-38468: -- Attachment: janino2477367459010568088.java > Performance drops when the coalesce parameter inclu

[jira] [Updated] (FLINK-38468) Performance drops when the coalesce parameter includes functions

[ https://issues.apache.org/jira/browse/FLINK-38468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jie Cheng updated FLINK-38468: -- Description: I have two flink tasks, using 1.12 and 1.18 respectively. flinksql contains the

[jira] [Updated] (FLINK-38468) Performance drops when the coalesce parameter includes functions

[ https://issues.apache.org/jira/browse/FLINK-38468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jie Cheng updated FLINK-38468: -- Attachment: (was: janino2477367459010568088.java) > Performance drops when the coalesce parame

[jira] [Updated] (FLINK-38468) Performance drops when the coalesce parameter includes functions

[ https://issues.apache.org/jira/browse/FLINK-38468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jie Cheng updated FLINK-38468: -- Description: I have two flink tasks, using 1.12 and 1.18 respectively. flinksql contains the

[jira] [Updated] (FLINK-38468) Performance drops when the coalesce parameter includes functions

[ https://issues.apache.org/jira/browse/FLINK-38468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jie Cheng updated FLINK-38468: -- Description: I have two flink tasks, using 1.12 and 1.18 respectively. flinksql contains the

[jira] [Updated] (FLINK-38468) Performance drops when the coalesce parameter includes functions

[ https://issues.apache.org/jira/browse/FLINK-38468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jie Cheng updated FLINK-38468: -- Description: I have two flink tasks, using 1.12 and 1.18 respectively. flinksql contains the

[jira] [Updated] (FLINK-38468) Performance drops when the coalesce parameter includes functions

[ https://issues.apache.org/jira/browse/FLINK-38468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jie Cheng updated FLINK-38468: -- Description: I have two flink tasks, using 1.12 and 1.18 respectively. flinksql contains the

[jira] [Commented] (FLINK-38441) ExecutionGraphCoLocationRestartTest failed in test_ci core

[ https://issues.apache.org/jira/browse/FLINK-38441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18024031#comment-18024031 ] Ruan Hang commented on FLINK-38441: --- Thanks, [~mateczagany] . I will assign thi

[jira] [Commented] (FLINK-38272) The BatchJobRecoveryTest failed of azure cron adaptive scheduler pipeline

[ https://issues.apache.org/jira/browse/FLINK-38272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18024027#comment-18024027 ] Ruan Hang commented on FLINK-38272: --- https://dev.azure.com/apache-flink/apache-f

[jira] [Commented] (FLINK-38403) UnalignedCheckpointITCase failed in test_cron_hadoop313 tests

[ https://issues.apache.org/jira/browse/FLINK-38403?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18024025#comment-18024025 ] Ruan Hang commented on FLINK-38403: --- https://dev.azure.com/apache-flink/apache-f

[jira] [Commented] (FLINK-38439) SqlGatewayServiceITCase failed in test_cron_azure table

[ https://issues.apache.org/jira/browse/FLINK-38439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18023967#comment-18023967 ] Mate Czagany commented on FLINK-38439: -- I could not find any recent commits

[jira] [Created] (FLINK-38466) Bump derby version to 10.17.1.0

Siddharth R created FLINK-38466: --- Summary: Bump derby version to 10.17.1.0 Key: FLINK-38466 URL: https://issues.apache.org/jira/browse/FLINK-38466 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-38463) Support TTL in SinkUpsertMaterializerV2

Roman Khachatryan created FLINK-38463: - Summary: Support TTL in SinkUpsertMaterializerV2 Key: FLINK-38463 URL: https://issues.apache.org/jira/browse/FLINK-38463 Project: Flink Issue Type

[jira] [Commented] (FLINK-38458) Extract SchemaConverter and ReferenceManager to make them reusable

[ https://issues.apache.org/jira/browse/FLINK-38458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18023830#comment-18023830 ] Sergey Nuyanzin commented on FLINK-38458: - Merge

[jira] [Comment Edited] (FLINK-38453) KafkaEnumerator doesn't restore offsets of owned split

[ https://issues.apache.org/jira/browse/FLINK-38453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18023822#comment-18023822 ] Arvid Heise edited comment on FLINK-38453 at 9/30/25 1:5

[jira] [Assigned] (FLINK-38258) Enable model param for PTF

[ https://issues.apache.org/jira/browse/FLINK-38258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-38258: Assignee: Hao Li > Enable model param for

[jira] [Updated] (FLINK-38258) Enable model arguments for PTFs

[ https://issues.apache.org/jira/browse/FLINK-38258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-38258: - Summary: Enable model arguments for PTFs (was: Enable model param for PTF) > Enable mo

[jira] [Updated] (FLINK-38454) Inconsistent idle behavior between StatusWatermarkValve and CombinedWatermarkStatus

[ https://issues.apache.org/jira/browse/FLINK-38454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38454: --- Labels: pull-request-available (was: ) > Inconsistent idle behavior betw

[jira] [Commented] (FLINK-38453) KafkaEnumerator doesn't restore offsets of owned split

[ https://issues.apache.org/jira/browse/FLINK-38453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18023736#comment-18023736 ] Hongshun Wang commented on FLINK-38453: --- Hi, [~arvid] , i also want to solve

[jira] [Resolved] (FLINK-38452) MongoDB CDC connector could not read from collections named with dots

[ https://issues.apache.org/jira/browse/FLINK-38452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanquan Lv resolved FLINK-38452. Fix Version/s: cdc-3.6.0 Resolution: Fixed Fixed in master via

[jira] [Updated] (FLINK-26820) Improve Cassandra connector by adding missing features and refactoring to latest standards

[ https://issues.apache.org/jira/browse/FLINK-26820?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26820: --- Labels: pull-request-available (was: ) > Improve Cassandra connector by adding miss

[jira] [Updated] (FLINK-38454) Inconsistent idle behavior between StatusWatermarkValve and CombinedWatermarkStatus

[ https://issues.apache.org/jira/browse/FLINK-38454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-38454: - Affects Version/s: 2.1.0 > Inconsistent idle behavior between StatusWatermarkValve

[jira] [Updated] (FLINK-38451) KafkaCommitter logs ERRORs unnecessarily during cancellation

[ https://issues.apache.org/jira/browse/FLINK-38451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38451: --- Labels: pull-request-available (was: ) > KafkaCommitter logs ERRORs unnecessarily dur

[jira] [Resolved] (FLINK-31499) Move SqlCreateTable conversion logic to SqlCreateTableConverter

[ https://issues.apache.org/jira/browse/FLINK-31499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin resolved FLINK-31499. - Fix Version/s: 2.2.0 Resolution: Fixed Merged as

[jira] [Commented] (FLINK-38268) Incorrect serialization of VARIANT type FLOAT

[ https://issues.apache.org/jira/browse/FLINK-38268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18023506#comment-18023506 ] Jinkun Liu commented on FLINK-38268: Hello [~twalthr] , I have completed

[jira] [Resolved] (FLINK-38445) Create test plans to validate upsert keys

[ https://issues.apache.org/jira/browse/FLINK-38445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz resolved FLINK-38445. -- Resolution: Fixed Implemented in 4c6defbe5296c2edede7190344d510849eb3ba83 > Cre

[jira] [Commented] (FLINK-38369) RestClientTest failed in test_cron_hadoop313 core

[ https://issues.apache.org/jira/browse/FLINK-38369?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18023474#comment-18023474 ] Mate Czagany commented on FLINK-38369: -- Hi [~ruanhang1993] - I've cre

[jira] [Updated] (FLINK-38448) Fix doc CI rsync logic

[ https://issues.apache.org/jira/browse/FLINK-38448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ferenc Csaky updated FLINK-38448: - Description: At the moment the doc CI GH workflow uses the "burnett01/rsync-deploy

[jira] [Commented] (FLINK-38406) DefaultSchedulerCheckpointCoordinatorTest failed in test_ci core

[ https://issues.apache.org/jira/browse/FLINK-38406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18023433#comment-18023433 ] Mate Czagany commented on FLINK-38406: -- Hi [~ruanhang1993] I have created a PR

[jira] [Updated] (FLINK-38406) DefaultSchedulerCheckpointCoordinatorTest failed in test_ci core

[ https://issues.apache.org/jira/browse/FLINK-38406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38406: --- Labels: pull-request-available (was: ) > DefaultSchedulerCheckpointCoordinatorTest fai

[jira] [Commented] (FLINK-38441) ExecutionGraphCoLocationRestartTest failed in test_ci core

[ https://issues.apache.org/jira/browse/FLINK-38441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18023430#comment-18023430 ] Mate Czagany commented on FLINK-38441: -- Hi [~ruanhang1993] - can you please as

[jira] [Updated] (FLINK-38441) ExecutionGraphCoLocationRestartTest failed in test_ci core

[ https://issues.apache.org/jira/browse/FLINK-38441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38441: --- Labels: pull-request-available (was: ) > ExecutionGraphCoLocationRestartTest failed

[jira] [Commented] (FLINK-38271) PostgresSQL pipeline supports table schema evolution.

[ https://issues.apache.org/jira/browse/FLINK-38271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18023400#comment-18023400 ] ouyangwulin commented on FLINK-38271: - I hope. > PostgresSQL pipeline s

[jira] [Assigned] (FLINK-31499) Move SqlCreateTable conversion logic to SqlCreateTableConverter

[ https://issues.apache.org/jira/browse/FLINK-31499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin reassigned FLINK-31499: --- Assignee: Sergey Nuyanzin (was: xuzhiwen) > Move SqlCreateTable conversion lo

[jira] [Comment Edited] (FLINK-34015) Setting `execution.savepoint.ignore-unclaimed-state` does not take effect when passing this parameter by dynamic properties

[ https://issues.apache.org/jira/browse/FLINK-34015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18023401#comment-18023401 ] Renxiang Zhou edited comment on FLINK-34015 at 9/28/25 12:5

[jira] [Commented] (FLINK-34015) Setting `execution.savepoint.ignore-unclaimed-state` does not take effect when passing this parameter by dynamic properties

[ https://issues.apache.org/jira/browse/FLINK-34015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18023401#comment-18023401 ] Renxiang Zhou commented on FLINK-34015: --- [~zakelly] Seems this issue has

[jira] [Commented] (FLINK-38271) PostgresSQL pipeline supports table schema evolution.

[ https://issues.apache.org/jira/browse/FLINK-38271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18023389#comment-18023389 ] Artur commented on FLINK-38271: --- [~ouyangwuli]  Hello! Thank you; I will wait for

[jira] [Created] (FLINK-38450) flink-cdc sink to iceberg table record duplication

ChaoFang created FLINK-38450: Summary: flink-cdc sink to iceberg table record duplication Key: FLINK-38450 URL: https://issues.apache.org/jira/browse/FLINK-38450 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-38272) The BatchJobRecoveryTest failed of azure cron adaptive scheduler pipeline

[ https://issues.apache.org/jira/browse/FLINK-38272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38272: --- Labels: pull-request-available (was: ) > The BatchJobRecoveryTest failed of azure c

[jira] [Commented] (FLINK-38344) The local files of the HistoryServer may risk never being deleted.

[ https://issues.apache.org/jira/browse/FLINK-38344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18023373#comment-18023373 ] Wei Zhong commented on FLINK-38344: --- Merged to: - master

[jira] [Resolved] (FLINK-38440) flink-cdc sink iceberg write SMALLINT/TINYINT data wrong

[ https://issues.apache.org/jira/browse/FLINK-38440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanquan Lv resolved FLINK-38440. Fix Version/s: cdc-3.6.0 Assignee: ChaoFang Resolution: Fixed Fixed in master via

[jira] [Resolved] (FLINK-38344) The local files of the HistoryServer may risk never being deleted.

[ https://issues.apache.org/jira/browse/FLINK-38344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong resolved FLINK-38344. --- Resolution: Fixed > The local files of the HistoryServer may risk never being dele

[jira] [Closed] (FLINK-38344) The local files of the HistoryServer may risk never being deleted.

[ https://issues.apache.org/jira/browse/FLINK-38344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong closed FLINK-38344. - > The local files of the HistoryServer may risk never being dele

[jira] [Assigned] (FLINK-38061) Caused by: java.util.ConcurrentModificationException When the MySql Chunk Split stage triggers a checkpoint

[ https://issues.apache.org/jira/browse/FLINK-38061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanquan Lv reassigned FLINK-38061: -- Assignee: Yanquan Lv > Caused by: java.util.ConcurrentModificationException When the My

[jira] [Comment Edited] (FLINK-38061) Caused by: java.util.ConcurrentModificationException When the MySql Chunk Split stage triggers a checkpoint

[ https://issues.apache.org/jira/browse/FLINK-38061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18023371#comment-18023371 ] Yanquan Lv edited comment on FLINK-38061 at 9/28/25 2:1

[jira] [Commented] (FLINK-38061) Caused by: java.util.ConcurrentModificationException When the MySql Chunk Split stage triggers a checkpoint

[ https://issues.apache.org/jira/browse/FLINK-38061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18023371#comment-18023371 ] Yanquan Lv commented on FLINK-38061: I would like to fix it. > Ca

[jira] [Updated] (FLINK-38449) Makes error message for fractional values for MemorySize explicit

[ https://issues.apache.org/jira/browse/FLINK-38449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38449: --- Labels: pull-request-available (was: ) > Makes error message for fractional values

[jira] [Created] (FLINK-38449) Makes error message for fractional values for MemorySize explicit

Navin Viswanath created FLINK-38449: --- Summary: Makes error message for fractional values for MemorySize explicit Key: FLINK-38449 URL: https://issues.apache.org/jira/browse/FLINK-38449 Project

[jira] [Created] (FLINK-38448) Fix doc CI rsync logic

Ferenc Csaky created FLINK-38448: Summary: Fix doc CI rsync logic Key: FLINK-38448 URL: https://issues.apache.org/jira/browse/FLINK-38448 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-38448) Fix doc CI rsync logic

[ https://issues.apache.org/jira/browse/FLINK-38448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38448: --- Labels: pull-request-available (was: ) > Fix doc CI rsync lo

[jira] [Updated] (FLINK-38447) Add table sink support for Elasticsearch 8 connector

[ https://issues.apache.org/jira/browse/FLINK-38447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lwn updated FLINK-38447: Labels: pull-request-available (was: pull_request_available) > Add table sink support for Elasticsearc

  1   2   3   4   5   6   7   8   9   10   >