issues  

Messages by Date

• 2026/07/30 [jira] [Resolved] (FLINK-39964) Checkpoints taken after a CLAIM-mode restore from a native savepoint can be unrestorable Sergey Nuyanzin (Jira)
• 2026/07/30 [jira] [Commented] (FLINK-39964) Checkpoints taken after a CLAIM-mode restore from a native savepoint can be unrestorable Sergey Nuyanzin (Jira)
• 2026/07/30 [jira] [Commented] (FLINK-40254) Document checkpoint behavior after a CLAIM-mode restore from a NATIVE savepoint Sergey Nuyanzin (Jira)
• 2026/07/30 [jira] [Updated] (FLINK-40254) Document checkpoint behavior after a CLAIM-mode restore from a NATIVE savepoint Sergey Nuyanzin (Jira)
• 2026/07/30 Re: [PR] [FLINK-40254][docs] Document checkpoint behavior after a CLAIM-mode restore from a NATIVE savepoint [flink] via GitHub
• 2026/07/30 [jira] [Commented] (FLINK-39964) Checkpoints taken after a CLAIM-mode restore from a native savepoint can be unrestorable Sergey Nuyanzin (Jira)
• 2026/07/30 Re: [PR] [BP-2.3][FLINK-39964][state] Fix unrestorable checkpoint after CLAIM restore from native savepoint [flink] via GitHub
• 2026/07/30 [jira] [Commented] (FLINK-39964) Checkpoints taken after a CLAIM-mode restore from a native savepoint can be unrestorable Sergey Nuyanzin (Jira)
• 2026/07/30 Re: [PR] [BP-2.2][FLINK-39964][state] Fix unrestorable checkpoint after CLAIM restore from native savepoint [flink] via GitHub
• 2026/07/30 Re: [PR] [FLINK-40243] Bump JDBC test dependencies: derby 10.15.2.0→10.17.1.0, postgresql 42.5.6→42.7.13 [flink-kubernetes-operator] via GitHub
• 2026/07/30 [jira] [Commented] (FLINK-40208) Support adding jobConfiguration keys of choice to logging MDC Roman Khachatryan (Jira)
• 2026/07/30 Re: [PR] [BP-2.2][FLINK-40227][core] Use readFully to read Variant value/metadata in VariantSerializer.deserialize [flink] via GitHub
• 2026/07/30 Re: [PR] [BP-2.3][FLINK-40227][core] Use readFully to read Variant value/metadata in VariantSerializer.deserialize [flink] via GitHub
• 2026/07/30 [jira] [Reopened] (FLINK-40208) Support adding jobConfiguration keys of choice to logging MDC Roman Khachatryan (Jira)
• 2026/07/30 [jira] [Closed] (FLINK-40208) Support adding jobConfiguration keys of choice to logging MDC Roman Khachatryan (Jira)
• 2026/07/30 [jira] [Updated] (FLINK-40208) Support adding jobConfiguration keys of choice to logging MDC Roman Khachatryan (Jira)
• 2026/07/30 Re: [PR] [FLINK-40227][core] Use readFully to read Variant value/metadata in VariantSerializer.deserialize [flink] via GitHub
• 2026/07/30 Re: [PR] [FLINK-40208] Add JobMdcRegistry for config-driven MDC enrichment [flink] via GitHub
• 2026/07/30 [jira] [Assigned] (FLINK-40208) Support adding jobConfiguration keys of choice to logging MDC Roman Khachatryan (Jira)
• 2026/07/30 [PR] [BP-2.2][FLINK-40227][core] Use readFully to read Variant value/metadata in VariantSerializer.deserialize [flink] via GitHub
• 2026/07/30 [PR] [BP-2.3][FLINK-40227][core] Use readFully to read Variant value/metadata in VariantSerializer.deserialize [flink] via GitHub
• 2026/07/30 Re: [PR] [FLINK-40227][core] Use readFully to read Variant value/metadata in VariantSerializer.deserialize [flink] via GitHub
• 2026/07/30 [jira] [Assigned] (FLINK-40227) VariantSerializer.deserialize ignores DataInputView#read return value, corrupting Variant state restore Ferenc Csaky (Jira)
• 2026/07/30 Re: [PR] [FLINK-40227][core] Use readFully to read Variant value/metadata in VariantSerializer.deserialize [flink] via GitHub
• 2026/07/30 Re: [PR] [FLINK-39888][Kafka] Allow configuring offset reset strategy independently [flink-connector-kafka] via GitHub
• 2026/07/30 Re: [PR] [FLINK-39888][Kafka] Allow configuring offset reset strategy independently [flink-connector-kafka] via GitHub
• 2026/07/30 Re: [PR] [FLINK-39888][Kafka] Allow configuring offset reset strategy independently [flink-connector-kafka] via GitHub
• 2026/07/30 [jira] [Commented] (FLINK-40255) COMPILE PLAN fails for any plan containing a VARIANT type Ferenc Csaky (Jira)
• 2026/07/30 Re: [PR] [FLINK-40268][table] JSON_TYPE implementation [flink] via GitHub
• 2026/07/30 [jira] [Updated] (FLINK-40268) Add new JSON_TYPE built-in function ASF GitHub Bot (Jira)
• 2026/07/30 [PR] [FLINK-40268][table] JSON_TYPE implementation [flink] via GitHub
• 2026/07/30 Re: [PR] [FLINK-39546][s3] Improve observability in flink-s3-fs-native by exposing operation-level S3 metrics [flink] via GitHub
• 2026/07/30 Re: [PR] [FLINK-40243] Bump JDBC test dependencies: derby 10.15.2.0→10.17.1.0, postgresql 42.5.6→42.7.13 [flink-kubernetes-operator] via GitHub
• 2026/07/30 Re: [PR] [FLINK-37925][table] Define VARIANT cast rules so a cast never alters the stored value [flink] via GitHub
• 2026/07/30 Re: [PR] [FLINK-40249][jdbc] Bump Flink, PostgreSQL JDBC driver, and other dependency versions [flink-connector-jdbc] via GitHub
• 2026/07/30 [jira] [Created] (FLINK-40268) Add new JSON_TYPE built-in function Gustavo de Morais (Jira)
• 2026/07/30 Re: [PR] [FLINK-40220][Connector/JDBC] Update the branch name of JDBC connector docs. [flink] via GitHub
• 2026/07/30 Re: [PR] [test][python] Fix Action deserialize tests on release branch [flink-agents] via GitHub
• 2026/07/30 Re: [PR] [FLINK-39888][Kafka] Allow configuring offset reset strategy independently [flink-connector-kafka] via GitHub
• 2026/07/30 [jira] [Created] (FLINK-40267) CREATE MATERIALIZED TABLE skips persisted-metadata-column validation applied by CREATE OR ALTER Arvid Heise (Jira)
• 2026/07/30 [jira] [Closed] (FLINK-39110) Add CRT Support Gabor Somogyi (Jira)
• 2026/07/30 [jira] [Resolved] (FLINK-39110) Add CRT Support Gabor Somogyi (Jira)
• 2026/07/30 [jira] [Commented] (FLINK-39110) Add CRT Support Gabor Somogyi (Jira)
• 2026/07/30 Re: [PR] [FLINK-39732] Introduce TableDiscoverer SPI for flexible table subscription (with default JdbcTableDiscoverer) [flink-cdc] via GitHub
• 2026/07/30 Re: [PR] [hotfix][tests] Fix flaky NPE in SpeculativeExecutionTest [flink] via GitHub
• 2026/07/30 Re: [PR] [hotfix][tests] Fix flaky NPE in SpeculativeExecutionTest [flink] via GitHub
• 2026/07/30 Re: [PR] [FLINK-31951][format] Reset decoder on Avro deserialization failure [flink] via GitHub
• 2026/07/30 [PR] [test][python] Fix Action deserialize tests on release branch [flink-agents] via GitHub
• 2026/07/30 [PR] [hotfix][tests] Fix flaky NPE in SpeculativeExecutionTest [flink] via GitHub
• 2026/07/30 [jira] [Updated] (FLINK-40164) FlinkSessionJob's lifecycleState stays "UPGRADING" even after it's suspended successfully ASF GitHub Bot (Jira)
• 2026/07/30 [PR] [FLINK-40164] Complete suspending when the cancellation is observed [flink-kubernetes-operator] via GitHub
• 2026/07/30 [jira] [Updated] (FLINK-39373) An error occurred when modifying the default value of a column while executing the StarRocks Pipeline Sink operation Leonard Xu (Jira)
• 2026/07/30 [jira] [Commented] (FLINK-33186) CheckpointAfterAllTasksFinishedITCase.testRestoreAfterSomeTasksFinished fails on AZP Sergey Nuyanzin (Jira)
• 2026/07/30 [jira] [Resolved] (FLINK-33186) CheckpointAfterAllTasksFinishedITCase.testRestoreAfterSomeTasksFinished fails on AZP Sergey Nuyanzin (Jira)
• 2026/07/30 Re: [PR] [FLINK-33186][checkpoint/tests] Fix flakiness in CheckpointAfterAllTasksFinishedITCase.testRestoreAfterSomeTasksFinished [flink] via GitHub
• 2026/07/30 Re: [PR] [hotfix][postgres] generateCreateTableEvent result is skipped [flink-cdc] via GitHub
• 2026/07/30 Re: [PR] [FLINK-39110][s3] Add CRT support in native-s3-fs [flink] via GitHub
• 2026/07/30 Re: [PR] [FLINK-40263][format/avro] Validate enum symbols when serializing CHAR/VARCHAR [flink] via GitHub
• 2026/07/30 Re: [PR] [FLINK-40264][format/avro] Propagate legacyTimestampMapping into nested row converters [flink] via GitHub
• 2026/07/30 [jira] [Updated] (FLINK-40263) Enum symbol validation ASF GitHub Bot (Jira)
• 2026/07/30 [PR] [FLINK-40263][format/avro] Validate enum symbols when serializing CHAR/VARCHAR [flink] via GitHub
• 2026/07/30 [jira] [Updated] (FLINK-40264) nested legacyTimestampMapping ASF GitHub Bot (Jira)
• 2026/07/30 [PR] [FLINK-40264][format/avro] Propagate legacyTimestampMapping into nested row converters [flink] via GitHub
• 2026/07/30 Re: [PR] [hotfix][docs] Make the Generated-by line visible in the PR template [flink] via GitHub
• 2026/07/30 [jira] [Closed] (FLINK-40266) MAX_WATERMARK might not be emitted for finished operators Roman Khachatryan (Jira)
• 2026/07/30 [PR] [hotfix][docs] Make the Generated-by line visible in the PR template [flink] via GitHub
• 2026/07/30 [jira] [Created] (FLINK-40266) MAX_WATERMARK might not be emitted for finished operators Roman Khachatryan (Jira)
• 2026/07/30 Re: [PR] [hotfix][ci] Bump stale action to v11 [flink] via GitHub
• 2026/07/30 [jira] [Updated] (FLINK-40253) [Prometheus] PrometheusPushGatewayReporter fails to read boolean configuration values from YAML file wenhao.yu (Jira)
• 2026/07/30 Re: [PR] [FLINK-39732] Introduce TableDiscoverer SPI for flexible table subscription (with default JdbcTableDiscoverer) [flink-cdc] via GitHub
• 2026/07/30 Re: [PR] [FLINK-39110] Add CRT support in native-s3-fs [flink] via GitHub
• 2026/07/30 Re: [PR] [BP-2.2][FLINK-39964][state] Fix unrestorable checkpoint after CLAIM restore from native savepoint [flink] via GitHub
• 2026/07/30 [jira] [Assigned] (FLINK-40214) JSON_OBJECTAGG produces incorrect keys when key and value use the same column Xuyang Zhong (Jira)
• 2026/07/30 [jira] [Commented] (FLINK-40214) JSON_OBJECTAGG produces incorrect keys when key and value use the same column Xuyang Zhong (Jira)
• 2026/07/30 [jira] [Closed] (FLINK-40214) JSON_OBJECTAGG produces incorrect keys when key and value use the same column Xuyang Zhong (Jira)
• 2026/07/30 [jira] [Updated] (FLINK-40214) JSON_OBJECTAGG produces incorrect keys when key and value use the same column Xuyang Zhong (Jira)
• 2026/07/30 Re: [PR] [FLINK-40214][table] Preserve JSON_OBJECTAGG key when wrapping value [flink] via GitHub
• 2026/07/30 [jira] [Commented] (FLINK-40253) [Prometheus] PrometheusPushGatewayReporter fails to read boolean configuration values from YAML file wenhao.yu (Jira)
• 2026/07/30 Re: [PR] [FLINK-40254][docs] Document checkpoint behavior after a CLAIM-mode restore from a NATIVE savepoint [flink] via GitHub
• 2026/07/30 Re: [PR] [BP-2.3][FLINK-39964][state] Fix unrestorable checkpoint after CLAIM restore from native savepoint [flink] via GitHub
• 2026/07/30 Re: [PR] [FLINK-40214][table] Preserve JSON_OBJECTAGG key when wrapping value [flink] via GitHub
• 2026/07/30 Re: [PR] [FLINK-40214][table] Preserve JSON_OBJECTAGG key when wrapping value [flink] via GitHub
• 2026/07/30 [jira] [Resolved] (FLINK-40147) Improve Native S3 FileSystem docs when using S3-compatible servers that do not support AWS checksum-validation Gabor Somogyi (Jira)
• 2026/07/30 [jira] [Commented] (FLINK-40147) Improve Native S3 FileSystem docs when using S3-compatible servers that do not support AWS checksum-validation Gabor Somogyi (Jira)
• 2026/07/30 [jira] [Closed] (FLINK-40147) Improve Native S3 FileSystem docs when using S3-compatible servers that do not support AWS checksum-validation Gabor Somogyi (Jira)
• 2026/07/30 Re: [PR] [FLINK-40147][s3] Improve Native S3 FileSystem docs when using S3-compatible servers that do not support AWS checksum-validation [flink] via GitHub
• 2026/07/30 [jira] [Assigned] (FLINK-40147) Improve Native S3 FileSystem docs when using S3-compatible servers that do not support AWS checksum-validation Gabor Somogyi (Jira)
• 2026/07/30 Re: [PR] [api][runtime][python] Add minimal Event lineage [flink-agents] via GitHub
• 2026/07/30 [jira] [Assigned] (FLINK-40262) Support matching Avro record fields by name in the Avro RowData converters Gyula Fora (Jira)
• 2026/07/30 [jira] [Assigned] (FLINK-40263) Enum symbol validation Gyula Fora (Jira)
• 2026/07/30 [jira] [Assigned] (FLINK-40264) nested legacyTimestampMapping Gyula Fora (Jira)
• 2026/07/30 Re: [PR] [FLINK-40262][format/avro] Support matching Avro record fields by name [flink] via GitHub
• 2026/07/30 [jira] [Commented] (FLINK-37918) Restore the ability to set an interval for GetRecords calls to Kinesis shards. Mirai Kato (Jira)
• 2026/07/30 [PR] [FLINK-40262][format/avro] Support matching Avro record fields by name [flink] via GitHub
• 2026/07/30 [jira] [Updated] (FLINK-40262) Support matching Avro record fields by name in the Avro RowData converters ASF GitHub Bot (Jira)
• 2026/07/30 [jira] [Closed] (FLINK-40022) Table API client hangs when batch query returns an empty result Timo Walther (Jira)
• 2026/07/30 Re: [PR] [hotfix] Remove unused JUnit 4 dependencies [flink-connector-jdbc] via GitHub
• 2026/07/30 Re: [PR] [hotfix][ci] Update GHA actions because of old NodeJS [flink-connector-jdbc] via GitHub
• 2026/07/30 Re: [PR] [FLINK-40022][table] Fix TableResult.await() hang on empty SELECT result [flink] via GitHub
• 2026/07/30 Re: [PR] [Feature] Parallel Tool Call Execution [flink-agents] via GitHub
• 2026/07/30 [jira] [Updated] (FLINK-40265) BinaryStringData.compareTo uses inconsistent UTF-16 and UTF-8 ordering for SMP characters Shuo Cheng (Jira)
• 2026/07/30 [jira] [Updated] (FLINK-40265) BinaryStringData.compareTo uses inconsistent UTF-16 and UTF-8 ordering for SMP characters Shuo Cheng (Jira)
• 2026/07/30 [jira] [Updated] (FLINK-40265) BinaryStringData.compareTo uses inconsistent UTF-16 and UTF-8 ordering for SMP characters Shuo Cheng (Jira)
• 2026/07/30 [jira] [Created] (FLINK-40265) BinaryStringData.compareTo uses inconsistent UTF-16 and UTF-8 ordering for SMP characters Shuo Cheng (Jira)
• 2026/07/30 Re: [PR] [Feature] Parallel Tool Call Execution [flink-agents] via GitHub
• 2026/07/30 Re: [PR] [FLINK-39274] TM It is impossible to bypass the KDC login process, yet the TOKEN issued by JM has not been actually utilized. [flink] via GitHub
• 2026/07/30 Re: [PR] [FLINK-39283][Formats/avro] Upgrade `org.apache.avro:avro` to 1.12.1 [flink] via GitHub
• 2026/07/30 Re: [PR] [FLINK-39274] TM It is impossible to bypass the KDC login process, yet the TOKEN issued by JM has not been actually utilized. [flink] via GitHub
• 2026/07/30 Re: [PR] [hotfix][ci] Bump stale action to v11 [flink] via GitHub
• 2026/07/30 [PR] [hotfix][ci] Bump stale action to v11 [flink] via GitHub
• 2026/07/29 [PR] [hotfix][ci] Update GHA actions because of old NodeJS [flink-connector-jdbc] via GitHub
• 2026/07/29 [jira] [Created] (FLINK-40264) nested legacyTimestampMapping Pritam Kumar (Jira)
• 2026/07/29 Re: [PR] [FLINK-39891] Add option to cancel orphaned session jobs on submit [flink-kubernetes-operator] via GitHub
• 2026/07/29 Re: [PR] [FLINK-39890] Fix NaN in observed scaling coefficient when baseline rate is zero [flink-kubernetes-operator] via GitHub
• 2026/07/29 [jira] [Created] (FLINK-40263) Enum symbol validation Pritam Kumar (Jira)
• 2026/07/29 [jira] [Created] (FLINK-40262) Support matching Avro record fields by name in the Avro RowData converters Pritam Kumar (Jira)
• 2026/07/29 Re: [PR] [FLINK-40187][python] Introduce DataType class in DataFrame API [flink] via GitHub
• 2026/07/29 [jira] [Updated] (FLINK-40187) Introduce DataType class in DataFrame API ASF GitHub Bot (Jira)
• 2026/07/29 [PR] [FLINK-40187][python] Introduce DataType class in DataFrame API [flink] via GitHub
• 2026/07/29 [jira] [Commented] (FLINK-40253) [Prometheus] PrometheusPushGatewayReporter fails to read boolean configuration values from YAML file Yao Zhang (Jira)
• 2026/07/29 [jira] [Created] (FLINK-40261) Support Set semantics, pass-through columns and ROW Value State for Python PTF Wang Chengyu (Jira)
• 2026/07/29 [jira] [Created] (FLINK-40260) Support Python PTF definition API and the stateless runtime path Wang Chengyu (Jira)
• 2026/07/29 [jira] [Assigned] (FLINK-40193) Add join_lateral support to DataFrame API Dian Fu (Jira)
• 2026/07/29 Re: [PR] [api][runtime][python] Add Agent Trace recording to Event Log [flink-agents] via GitHub
• 2026/07/29 Re: [PR] [api][runtime][python] Add Agent Trace recording to Event Log [flink-agents] via GitHub
• 2026/07/29 [I] [Bug] Bounded workflows silently drop records in batch mode with multiple keys [flink-agents] via GitHub
• 2026/07/29 [jira] [Updated] (FLINK-40259) MongoDB CDC SampleBucketSplitStrategy calculates negative $sample size when collection count exceeds Integer.MAX_VALUE soyeong choe (Jira)
• 2026/07/29 [jira] [Updated] (FLINK-40259) MongoDB CDC SampleBucketSplitStrategy calculates negative $sample size when collection count exceeds Integer.MAX_VALUE soyeong choe (Jira)
• 2026/07/29 [jira] [Created] (FLINK-40258) MongoDB CDC SampleBucketSplitStrategy calculates negative $sample size when collection count exceeds Integer.MAX_VALUE soyeong choe (Jira)
• 2026/07/29 [jira] [Created] (FLINK-40257) MongoDB CDC SampleBucketSplitStrategy calculates negative $sample size when collection count exceeds Integer.MAX_VALUE soyeong choe (Jira)
• 2026/07/29 [jira] [Created] (FLINK-40259) MongoDB CDC SampleBucketSplitStrategy calculates negative $sample size when collection count exceeds Integer.MAX_VALUE soyeong choe (Jira)
• 2026/07/29 [jira] [Resolved] (FLINK-40255) COMPILE PLAN fails for any plan containing a VARIANT type Sergey Nuyanzin (Jira)
• 2026/07/29 [jira] [Commented] (FLINK-40255) COMPILE PLAN fails for any plan containing a VARIANT type Sergey Nuyanzin (Jira)
• 2026/07/29 Re: [PR] [FLINK-40255][table-planner] Fix compiled plan serde for VARIANT type [flink] via GitHub
• 2026/07/29 Re: [PR] [FLINK-40256][docs] Include sub-package config options in the configuration reference [flink] via GitHub
• 2026/07/29 [jira] [Updated] (FLINK-40256) Docs: config options in sub-packages are silently missing from the configuration reference ASF GitHub Bot (Jira)
• 2026/07/29 [PR] [FLINK-40256][docs] Include sub-package config options in the configuration reference [flink] via GitHub
• 2026/07/29 Re: [PR] [FLINK-39009] Support PostgreSQL unnest insert in dynamic table. [flink-connector-jdbc] via GitHub
• 2026/07/29 [jira] [Created] (FLINK-40256) Docs: config options in sub-packages are silently missing from the configuration reference Purushottam Sinha (Jira)
• 2026/07/29 Re: [PR] [Feature] Parallel Tool Call Execution [flink-agents] via GitHub
• 2026/07/29 Re: [PR] [FLINK-40255][table-planner] Fix compiled plan serde for VARIANT type [flink] via GitHub
• 2026/07/29 [PR] [api][plan][runtime] Introduce AGENT resource type and sub-agent invocation API [flink-agents] via GitHub
• 2026/07/29 [jira] [Updated] (FLINK-37686) ForSt consecutive failed checkpoint due to check deleted file status when enableFileDeletions Zakelly Lan (Jira)
• 2026/07/29 [jira] [Commented] (FLINK-37686) ForSt consecutive failed checkpoint due to check deleted file status when enableFileDeletions Zakelly Lan (Jira)
• 2026/07/29 [jira] [Resolved] (FLINK-37686) ForSt consecutive failed checkpoint due to check deleted file status when enableFileDeletions Zakelly Lan (Jira)
• 2026/07/29 Re: [PR] FLINK-37686 - Do not fail on NOT_OWNED deleted files [flink] via GitHub
• 2026/07/29 [jira] [Commented] (FLINK-40232) NullPointerException in OutputConversionOperator.processElement when rowtime attribute is null Iman Rastkhadiv (Jira)
• 2026/07/29 [jira] [Updated] (FLINK-40243) Bump JDBC test dependencies: derby 10.15.2.0→10.17.1.0, postgresql 42.5.6→42.7.13 Siddharth R (Jira)
• 2026/07/29 Re: [PR] [FLINK-38466] Bump derby from 10.15.2.0 to 10.17.1.0 [flink-kubernetes-operator] via GitHub
• 2026/07/29 Re: [PR] [Feature] Parallel Tool Call Execution [flink-agents] via GitHub
• 2026/07/29 Re: [PR] [FLINK-38466] Bump derby from 10.15.2.0 to 10.17.1.0 [flink-kubernetes-operator] via GitHub
• 2026/07/29 Re: [PR] [FLINK-40243] Bump postgresql jdbc driver from 42.5.6 to 42.7.13 [flink-kubernetes-operator] via GitHub
• 2026/07/29 Re: [PR] [FLINK-40233][table] Correctly share the parsed JSON across `JSON_VALUE`/`JSON_QUERY` calls when the owning call is skipped because of `NULL` or not taken branch [flink] via GitHub
• 2026/07/29 Re: [PR] [FLINK-40233][table] Correctly share the parsed JSON across `JSON_VALUE`/`JSON_QUERY` calls when the owning call is skipped because of `NULL` or not taken branch [flink] via GitHub
• 2026/07/29 Re: [PR] [FLINK-40233][table] Correctly share the parsed JSON across `JSON_VALUE`/`JSON_QUERY` calls when the owning call is skipped because of `NULL` or not taken branch [flink] via GitHub
• 2026/07/29 Re: [PR] [FLINK-40208] Add JobMdcRegistry for config-driven MDC enrichment [flink] via GitHub
• 2026/07/29 Re: [PR] [FLINK-40208] Add JobMdcRegistry for config-driven MDC enrichment [flink] via GitHub
• 2026/07/29 Re: [PR] [FLINK-40255][table-planner] Fix compiled plan serde for VARIANT type [flink] via GitHub
• 2026/07/29 [PR] [FLINK-40255][table-planner] Fix compiled plan serde for VARIANT type [flink] via GitHub
• 2026/07/29 [jira] [Updated] (FLINK-40255) COMPILE PLAN fails for any plan containing a VARIANT type ASF GitHub Bot (Jira)
• 2026/07/29 Re: [I] curation_of_issuecomponent_Maven:org.apache.flink:flink-shaded-guava [flink-shaded] via GitHub
• 2026/07/29 [I] curation_of_issuecomponent_Maven:org.apache.flink:flink-shaded-guava [flink-shaded] via GitHub
• 2026/07/29 [jira] [Updated] (FLINK-40195) Flink kubernetes operator certificate secret name should not collide with other operators Jira
• 2026/07/29 [jira] [Updated] (FLINK-40195) Flink kubernetes operator certificate secret name should not collide with other operators Jira
• 2026/07/29 Re: [PR] [FLINK-40195] helm: use static webhook certificate Secret name [flink-kubernetes-operator] via GitHub
• 2026/07/29 Re: [PR] [FLINK-40195] helm: use static webhook certificate Secret name [flink-kubernetes-operator] via GitHub
• 2026/07/29 [jira] [Commented] (FLINK-39964) Checkpoints taken after a CLAIM-mode restore from a native savepoint can be unrestorable Aleksandr Savonin (Jira)
• 2026/07/29 Re: [PR] [BP-2.2][FLINK-39964][state] Fix unrestorable checkpoint after CLAIM restore from native savepoint [flink] via GitHub
• 2026/07/29 Re: [D] Community Sync - 2026 [flink-agents] via GitHub
• 2026/07/29 [jira] [Created] (FLINK-40255) COMPILE PLAN fails for any plan containing a VARIANT type Ramin Gharib (Jira)
• 2026/07/29 Re: [D] Community Sync - 2026 [flink-agents] via GitHub
• 2026/07/29 [jira] [Updated] (FLINK-40234) Busy subtask thread may cause splits to be marked as idle erroneously and cause dropped records Keith Lee (Jira)
• 2026/07/29 Re: [PR] [FLINK-39904][python] Add PyFlink GEOGRAPHY support [flink] via GitHub
• 2026/07/29 [PR] [BP-2.2][FLINK-39964][state] Fix unrestorable checkpoint after CLAIM restore from native savepoint [flink] via GitHub
• 2026/07/29 [jira] [Updated] (FLINK-40234) Busy subtask thread may cause splits to be marked as idle erroneously and cause dropped records Roman Khachatryan (Jira)
• 2026/07/29 [jira] [Updated] (FLINK-40234) Busy subtask thread may cause splits to be marked as idle erroneously and cause dropped records Roman Khachatryan (Jira)
• 2026/07/29 [jira] [Assigned] (FLINK-40234) Busy subtask thread may cause splits to be marked as idle erroneously and cause dropped records Roman Khachatryan (Jira)
• 2026/07/29 [jira] [Comment Edited] (FLINK-40010) RescaleTimelineITCase.testRescaleTerminatedByNoResourcesOrNoParallelismsChange is flaky: requirements-update can miss the in-progress rescale Matthias Pohl (Jira)
• 2026/07/29 [jira] [Updated] (FLINK-40010) RescaleTimelineITCase.testRescaleTerminatedByNoResourcesOrNoParallelismsChange is flaky: requirements-update can miss the in-progress rescale Matthias Pohl (Jira)
• 2026/07/29 [jira] [Updated] (FLINK-40009) RescaleTimelineITCase.waitUntilConditionWithTimeout never enforces its timeout on a ForkJoinPool worker Matthias Pohl (Jira)
• 2026/07/29 [jira] [Comment Edited] (FLINK-40067) RescaleTimelineITCase.testRescaleTerminatedByJobFinished fails due to race between cooldown-driven rescale termination and job finish Matthias Pohl (Jira)
• 2026/07/29 [jira] [Comment Edited] (FLINK-40009) RescaleTimelineITCase.waitUntilConditionWithTimeout never enforces its timeout on a ForkJoinPool worker Matthias Pohl (Jira)
• 2026/07/29 [jira] [Updated] (FLINK-40195) Flink kubernetes operator certificate secret name should be configurable ASF GitHub Bot (Jira)
• 2026/07/29 [jira] [Updated] (FLINK-40067) RescaleTimelineITCase.testRescaleTerminatedByJobFinished fails due to race between cooldown-driven rescale termination and job finish Matthias Pohl (Jira)
• 2026/07/29 Re: [PR] [FLINK-40195] helm: make webhook certificate secret name configurable [flink-kubernetes-operator] via GitHub
• 2026/07/29 [jira] [Assigned] (FLINK-40076) RescaleTimelineITCase.testRecordNonTerminatedRescaleMergingWithNewRecoverableFailureTriggerCause fails intermittently: snapshot taken before recoverable failover is merged into in-progress rescale Matthias Pohl (Jira)
• 2026/07/29 [jira] [Resolved] (FLINK-40076) RescaleTimelineITCase.testRecordNonTerminatedRescaleMergingWithNewRecoverableFailureTriggerCause fails intermittently: snapshot taken before recoverable failover is merged into in-progress rescale Matthias Pohl (Jira)
• 2026/07/29 Re: [PR] [BP-2.3][FLINK-40009][FLINK-40010][FLINK-40067][FLINK-40076][tests] Stabilize RescaleTimelineITCase [flink] via GitHub
• 2026/07/29 [jira] [Commented] (FLINK-39964) Checkpoints taken after a CLAIM-mode restore from a native savepoint can be unrestorable Aleksandr Savonin (Jira)
• 2026/07/29 [jira] [Resolved] (FLINK-39571) Improve Flink Kubernetes Operator documentation coverage Dennis-Mircea Ciupitu (Jira)
• 2026/07/29 Re: [PR] [BP-2.3][FLINK-39964][state] Fix unrestorable checkpoint after CLAIM restore from native savepoint [flink] via GitHub
• 2026/07/29 [PR] [BP-2.3][FLINK-39964][state] Fix unrestorable checkpoint after CLAIM restore from native savepoint [flink] via GitHub
• 2026/07/29 Re: [PR] [FLINK-39571][docs] Improve Flink Kubernetes Operator documentation coverage [flink-kubernetes-operator] via GitHub
• 2026/07/29 Re: [PR] [api][plan][python] Add Python CEL Action condition filtering [flink-agents] via GitHub
• 2026/07/29 Re: [D] Community Sync - 2026 [flink-agents] via GitHub
• 2026/07/29 [PR] [api][plan][python] Add Python CEL Action condition filtering [flink-agents] via GitHub
• 2026/07/29 Re: [PR] [FLINK-40254][docs] Document checkpoint behavior after a CLAIM-mode restore from a NATIVE savepoint [flink] via GitHub
• 2026/07/29 Re: [PR] [FLINK-39964][state] Fix unrestorable checkpoint after CLAIM restore from native savepoint [flink] via GitHub
• 2026/07/29 [jira] [Updated] (FLINK-40254) Document checkpoint behavior after a CLAIM-mode restore from a NATIVE savepoint ASF GitHub Bot (Jira)
• 2026/07/29 [PR] [FLINK-40254][docs] Document checkpoint behavior after a CLAIM-mode restore from a NATIVE savepoint [flink] via GitHub

• Later messages