issues  

Messages by Date

• 2026/10/01 [jira] [Created] (FLINK-40872) AsyncExecutionController is never closed. Leak the state backend through the static AsyncRequestBuffer.DELAYER Yordan Pavlov (Jira)
• 2026/10/01 Re: [PR] [FLINK-40830][table] Reuse java's getBytes in StringUtf8Utils [flink] via GitHub
• 2026/10/01 Re: [PR] [FLINK-40834][ci] Keep rolled YARN container logs in CI artifacts [flink] via GitHub
• 2026/10/01 Re: [PR] [FLINK-40825][table] Support casting primitive types to VARIANT [flink] via GitHub
• 2026/10/01 Re: [PR] [FLINK-31006][Connectors/Kafka] Signal no more splits after a restored bounded enumerator finds no partition changes [flink-connector-kafka] via GitHub
• 2026/10/01 Re: [PR] [FLINK-31006][Connectors/Kafka] Signal no more splits after a restored bounded enumerator finds no partition changes [flink-connector-kafka] via GitHub
• 2026/10/01 Re: [PR] [FLINK-40743][jdbc] Fix the Table sink's empty lineage dataset name [flink-connector-jdbc] via GitHub
• 2026/10/01 [jira] [Created] (FLINK-40871) Avoid the UTF-8 round trip when casting strings and decimals to VARIANT Ramin Gharib (Jira)
• 2026/10/01 [jira] [Assigned] (FLINK-40860) Add bin/minicluster.sh to run an application on a MiniCluster Robert Metzger (Jira)
• 2026/10/01 [jira] [Resolved] (FLINK-40834) CI artifacts keep only one of jobmanager.log and jobmanager.log.N for YARN containers Martijn Visser (Jira)
• 2026/10/01 [jira] [Assigned] (FLINK-40859) FLIP-611: Running Flink jobs in MiniCluster using the Kubernetes Operator Robert Metzger (Jira)
• 2026/10/01 Re: [PR] [BP-2.3][FLINK-40504][runtime] Re-activate idle FLIP-27 outputs when they resume [flink] via GitHub
• 2026/10/01 Re: [PR] [BP-2.2][FLINK-40504][runtime] Re-activate idle FLIP-27 outputs when they resume [flink] via GitHub
• 2026/10/01 Re: [PR] [BP-2.2][FLINK-40504][runtime] Re-activate idle FLIP-27 outputs when they resume [flink] via GitHub
• 2026/10/01 Re: [PR] [integration][java][python] Send user images to Ollama [flink-agents] via GitHub
• 2026/10/01 Re: [PR] [FLINK-40825][table] Support casting primitive types to VARIANT [flink] via GitHub
• 2026/10/01 Re: [PR] [FLINK-40825][table] Support casting primitive types to VARIANT [flink] via GitHub
• 2026/10/01 Re: [PR] [FLINK-40825][table] Support casting primitive types to VARIANT [flink] via GitHub
• 2026/10/01 Re: [PR] [FLINK-40670][tests] Use different keys for different data [flink] via GitHub
• 2026/10/01 Re: [PR] [FLINK-40825][table] Support casting primitive types to VARIANT [flink] via GitHub
• 2026/10/01 Re: [PR] [FLINK-40825][table] Support casting primitive types to VARIANT [flink] via GitHub
• 2026/10/01 [jira] [Commented] (FLINK-40326) GatedRateLimiter admits more events per cycle than configured Martijn Visser (Jira)
• 2026/10/01 [jira] [Resolved] (FLINK-40326) GatedRateLimiter admits more events per cycle than configured Martijn Visser (Jira)
• 2026/10/01 Re: [PR] [BP-2.3][FLINK-40326][core] Do not over-grant capacity in GatedRateLimiter [flink] via GitHub
• 2026/10/01 Re: [PR] [FLINK-40855][filesystems] Shut down STS clients after S3 delegation-token acquisition [flink] via GitHub
• 2026/10/01 [jira] [Commented] (FLINK-40780) FORWARD edge silently converted to REBALANCE on parallelism mismatch corrupts changelog (upsert/retract) streams Rui Fan (Jira)
• 2026/10/01 Re: [PR] [FLINK-31006][Connectors/Kafka] Signal no more splits after a restored bounded enumerator finds no partition changes [flink-connector-kafka] via GitHub
• 2026/10/01 [jira] [Commented] (FLINK-40780) FORWARD edge silently converted to REBALANCE on parallelism mismatch corrupts changelog (upsert/retract) streams Roman Khachatryan (Jira)
• 2026/10/01 Re: [PR] [FLINK-40854][table] Parse UTF-8 bytes directly in PARSE_JSON and TRY_PARSE_JSON [flink] via GitHub
• 2026/10/01 Re: [PR] [FLINK-40841][table] Non-equi joins fix: retract the matches that a replaced record loses [flink] via GitHub
• 2026/10/01 Re: [PR] [FLINK-40830][table] Reuse java's getBytes in StringUtf8Utils [flink] via GitHub
• 2026/10/01 Re: [PR] [FLINK-40854][table] Parse UTF-8 bytes directly in PARSE_JSON and TRY_PARSE_JSON [flink] via GitHub
• 2026/10/01 Re: [PR] [BP-2.2][FLINK-40475][runtime] Fix watermark loss and stall in StatusWatermarkValve when subpartitions realign after idleness [flink] via GitHub
• 2026/10/01 Re: [PR] [FLINK-40825][table] Support casting primitive types to VARIANT [flink] via GitHub
• 2026/10/01 Re: [PR] [FLINK-40670][tests] Use different keys for different data [flink] via GitHub
• 2026/10/01 Re: [PR] [FLINK-40825][table] Support casting primitive types to VARIANT [flink] via GitHub
• 2026/10/01 Re: [PR] [FLINK-40825][table] Support casting primitive types to VARIANT [flink] via GitHub
• 2026/10/01 Re: [PR] [FLINK-40825][table] Support casting primitive types to VARIANT [flink] via GitHub
• 2026/10/01 Re: [PR] [FLINK-40528][table] Make codegen tolerant to partial deletes [flink] via GitHub
• 2026/10/01 Re: [PR] [FLINK-40528][table] Make codegen tolerant to partial deletes [flink] via GitHub
• 2026/10/01 Re: [PR] [BP-2.2][FLINK-40326][core] Do not over-grant capacity in GatedRateLimiter [flink] via GitHub
• 2026/10/01 [jira] [Commented] (FLINK-40475) StatusWatermarkValve loses or stalls watermarks when subpartitions realign after idleness Martijn Visser (Jira)
• 2026/10/01 Re: [PR] [FLINK-40825][table] Support casting primitive types to VARIANT [flink] via GitHub
• 2026/10/01 [jira] [Updated] (FLINK-40475) StatusWatermarkValve loses or stalls watermarks when subpartitions realign after idleness Martijn Visser (Jira)
• 2026/10/01 Re: [PR] [BP-2.3][FLINK-40475][runtime] Fix watermark loss and stall in StatusWatermarkValve when subpartitions realign after idleness [flink] via GitHub
• 2026/09/30 Re: [PR] [FLINK-40825][table] Support casting primitive types to VARIANT [flink] via GitHub
• 2026/09/30 Re: [PR] [FLINK-40825][table] Support casting primitive types to VARIANT [flink] via GitHub
• 2026/09/30 Re: [PR] [FLINK-40854][table] Parse UTF-8 bytes directly in PARSE_JSON and TRY_PARSE_JSON [flink] via GitHub
• 2026/09/30 Re: [PR] [api][plan][java][python] Support direct declaration of cross-language actions [flink-agents] via GitHub
• 2026/09/30 Re: [PR] [FLINK-40825][table] Support casting primitive types to VARIANT [flink] via GitHub
• 2026/09/30 Re: [PR] [FLINK-40830][table] Reuse java's getBytes in StringUtf8Utils [flink] via GitHub
• 2026/09/30 Re: [PR] [FLINK-40825][table] Support casting primitive types to VARIANT [flink] via GitHub
• 2026/09/30 Re: [PR] [FLINK-40854][table] Parse UTF-8 bytes directly in PARSE_JSON and TRY_PARSE_JSON [flink] via GitHub
• 2026/09/30 Re: [PR] [FLINK-35726][table] Honor @DataTypeHint on POJO fields in type conve… [flink] via GitHub
• 2026/09/30 Re: [PR] [FLINK-35726][table] Honor @DataTypeHint on POJO fields in type conve… [flink] via GitHub
• 2026/09/30 Re: [PR] [FLINK-40852][table] Return NULL from PARSE_JSON and TRY_PARSE_JSON for NULL allowDuplicateKeys [flink] via GitHub
• 2026/09/30 Re: [PR] [FLINK-40705][python] Reset Arrow map child writers between batches [flink] via GitHub
• 2026/09/30 Re: [PR] [FLINK-40705][python] Reset Arrow map child writers between batches [flink] via GitHub
• 2026/09/30 Re: [PR] [integration][java][python] Send user images to Ollama [flink-agents] via GitHub
• 2026/09/30 Re: [PR] [integration][java][python] Send user images to Ollama [flink-agents] via GitHub
• 2026/09/30 Re: [PR] [integration][java][python] Send user images to Ollama [flink-agents] via GitHub
• 2026/09/30 Re: [PR] [FLINK-33404][python] Add default timer callbacks [flink] via GitHub
• 2026/09/30 Re: [PR] [FLINK-40196][python] Add missing-value handling to DataFrame API [flink] via GitHub
• 2026/09/30 [jira] [Closed] (FLINK-40419) Add regular join support to DataFrame API Dian Fu (Jira)
• 2026/09/30 Re: [PR] [FLINK-40419][python] Add regular join support to DataFrame API [flink] via GitHub
• 2026/09/30 [PR] [api][java][python] Restore built-in event types at the JSON boundary [flink-agents] via GitHub
• 2026/09/30 [PR] [api][runtime][java][python] Simplify agent output materialization with typed toDataStream/toTable [flink-agents] via GitHub
• 2026/09/30 [jira] [Closed] (FLINK-40705) PyFlink pandas UDFs fail on MAP inputs across Arrow batches Dian Fu (Jira)
• 2026/09/30 [jira] [Closed] (FLINK-40427) Add catalog management and catalog table I/O to DataFrame API Dian Fu (Jira)
• 2026/09/30 Re: [PR] [FLINK-40427][python] Add catalog management and catalog table I/O to DataFrame API [flink] via GitHub
• 2026/09/30 [jira] [Created] (FLINK-40869) Document FlinkMiniCluster and add a MiniCluster example Dale Lane (Jira)
• 2026/09/30 [jira] [Created] (FLINK-40868) Report operator metrics for FlinkMiniCluster resources Dale Lane (Jira)
• 2026/09/30 [jira] [Created] (FLINK-40870) End-to-end test coverage for FlinkMiniCluster Dale Lane (Jira)
• 2026/09/30 [jira] [Created] (FLINK-40860) Add bin/minicluster.sh to run an application on a MiniCluster Dale Lane (Jira)
• 2026/09/30 [jira] [Created] (FLINK-40867) Support FlinkStateSnapshot for FlinkMiniCluster jobs Dale Lane (Jira)
• 2026/09/30 [jira] [Created] (FLINK-40862) Generate the MiniCluster pod, Deployment, Service and ConfigMap Dale Lane (Jira)
• 2026/09/30 [PR] [FLINK-40724][build] Add maven wrapper [flink-connector-mongodb] via GitHub
• 2026/09/30 [jira] [Created] (FLINK-40866) Add FlinkMiniClusterController and register the FlinkMiniCluster kind Dale Lane (Jira)
• 2026/09/30 [jira] [Created] (FLINK-40865) Add the FlinkMiniCluster observer Dale Lane (Jira)
• 2026/09/30 [jira] [Created] (FLINK-40864) Add the FlinkMiniCluster Flink service and reconciler Dale Lane (Jira)
• 2026/09/30 [jira] [Created] (FLINK-40863) Derive FlinkMiniCluster memory configuration from spec.resources Dale Lane (Jira)
• 2026/09/30 [jira] [Updated] (FLINK-40862) Generate the FlinkMiniCluster pod, Deployment, Service and ConfigMap Dale Lane (Jira)
• 2026/09/30 [jira] [Created] (FLINK-40861) Add the FlinkMiniCluster custom resource definition and API types Dale Lane (Jira)
• 2026/09/30 Re: [PR] [hotfix] Update Maven version recommendation to 3.9.16 [flink-connector-elasticsearch] via GitHub
• 2026/09/30 [PR] [hotfix] Update Maven version recommendation to 3.9.16 [flink-connector-elasticsearch] via GitHub
• 2026/09/30 [PR] [hotfix] Update Maven version recommendation to 3.9.16 [flink-connector-opensearch] via GitHub
• 2026/09/30 [jira] [Created] (FLINK-40859) FLIP-611: Running Flink jobs in MiniCluster using the Kubernetes Operator Dale Lane (Jira)
• 2026/09/30 [PR] [hotfix] Update Maven version recommendation to 3.9.16 [flink-connector-jdbc] via GitHub
• 2026/09/30 Re: [PR] [FLINK-24908][table-planner] Show the position and the failing line in parse errors [flink] via GitHub
• 2026/09/30 Re: [PR] [FLINK-24379][Formats] Avro Glue Schema Registry table format [flink-connector-aws] via GitHub
• 2026/09/30 Re: [PR] [BP-2.3][FLINK-40475][runtime] Fix watermark loss and stall in StatusWatermarkValve when subpartitions realign after idleness [flink] via GitHub
• 2026/09/30 Re: [PR] [BP-2.2][FLINK-40475][runtime] Fix watermark loss and stall in StatusWatermarkValve when subpartitions realign after idleness [flink] via GitHub
• 2026/09/30 [PR] [BP-2.2][FLINK-40475][runtime] Fix watermark loss and stall in StatusWatermarkValve when subpartitions realign after idleness [flink] via GitHub
• 2026/09/30 [PR] [BP-2.3][FLINK-40475][runtime] Fix watermark loss and stall in StatusWatermarkValve when subpartitions realign after idleness [flink] via GitHub
• 2026/09/30 Re: [PR] [FLINK-40857] Fix StatusRecorder not breaking out of for loop [flink-kubernetes-operator] via GitHub
• 2026/09/30 [jira] [Resolved] (FLINK-40832) VariantBuilder.of(BigDecimal) writes malformed or wrong decimals for negative scale or precision/scale > 38 Sergey Nuyanzin (Jira)
• 2026/09/30 [jira] [Commented] (FLINK-40832) VariantBuilder.of(BigDecimal) writes malformed or wrong decimals for negative scale or precision/scale > 38 Sergey Nuyanzin (Jira)
• 2026/09/30 Re: [PR] [FLINK-40832][core] Validate decimal range in VariantBuilder.of(BigDecimal) [flink] via GitHub
• 2026/09/30 Re: [PR] [FLINK-40655][runtime] Fix flaky partition release test [flink] via GitHub
• 2026/09/30 [jira] [Assigned] (FLINK-40855) Shut down AWS SDK v1 STS clients after S3 delegation-token acquisition Jim Hughes (Jira)
• 2026/09/30 [jira] [Commented] (FLINK-40477) Partial deletes fail sink NOT NULL enforcement sepuri sai krishna (Jira)
• 2026/09/30 Re: [PR] [FLINK-39380][table] Add test snapshotting and restoration to ProcessTableFunctionTestHarness [flink] via GitHub
• 2026/09/30 Re: [PR] [FLINK-40809][FLINK-40831][table] Do no count an updated record as a new match in StreamingJoinOperator [flink] via GitHub
• 2026/09/30 [PR] [FLINK-40806][table] Add PARSE_XML and TRY_PARSE_XML functions [flink] via GitHub
• 2026/09/30 Re: [PR] [FLINK-40602][runtime] JobManager silently omits running jobs whose JobMaster fails or times out on GET /jobs/overview [flink] via GitHub
• 2026/09/30 [PR] [FLINK-40852][table] Return NULL from PARSE_JSON and TRY_PARSE_JSON for NULL allowDuplicateKeys [flink] via GitHub
• 2026/09/30 Re: [PR] [FLINK-40852][table] Return NULL from PARSE_JSON and TRY_PARSE_JSON for NULL allowDuplicateKeys [flink] via GitHub
• 2026/09/30 [jira] [Updated] (FLINK-40602) JobManager silently omits running jobs whose JobMaster fails or times out on GET /jobs/overview Han You (Jira)
• 2026/09/30 Re: [PR] [FLINK-40841][table] Non-equi joins fix: retract the matches that a replaced record loses [flink] via GitHub
• 2026/09/30 Re: [PR] [FLINK-40841][table] Non-equi joins fix: retract the matches that a replaced record loses [flink] via GitHub
• 2026/09/30 [jira] [Created] (FLINK-40858) Streaming join should evaluate non-equi conditions on key-only deletes Gustavo de Morais (Jira)
• 2026/09/30 [jira] [Commented] (FLINK-40793) DefaultSchedulerTest is unstable across many test methods Martijn Visser (Jira)
• 2026/09/30 [jira] [Updated] (FLINK-40852) PARSE_JSON fails with NullPointerException when allowDuplicateKeys is NULL ASF GitHub Bot (Jira)
• 2026/09/30 Re: [PR] [FLINK-40857] Fix StatusRecorder not breaking out of for loop [flink-kubernetes-operator] via GitHub
• 2026/09/30 [jira] [Commented] (FLINK-35335) StateCheckpointedITCase failed fatally with 127 exit code Martijn Visser (Jira)
• 2026/09/30 [jira] [Updated] (FLINK-40793) DefaultSchedulerTest is unstable across many test methods Martijn Visser (Jira)
• 2026/09/30 Re: [PR] [FLINK-40857] Fix StatusRecorder not breaking out of for loop [flink-kubernetes-operator] via GitHub
• 2026/09/30 Re: [PR] [FLINK-24908][table-planner] Include the parser position in SqlParserException messages [flink] via GitHub
• 2026/09/30 [jira] [Updated] (FLINK-35335) StateCheckpointedITCase failed fatally with 127 exit code Martijn Visser (Jira)
• 2026/09/30 Re: [PR] [FLINK-40857] Fix StatusRecorder not breaking out of for loop [flink-kubernetes-operator] via GitHub
• 2026/09/30 Re: [PR] [FLINK-40019][core][runtime] Support per-job delegation tokens [flink] via GitHub
• 2026/09/30 [jira] [Commented] (FLINK-40857) Kubernetes Operator always replaces CR status 3 times on reconciliation Gyula Fora (Jira)
• 2026/09/30 Re: [PR] [FLINK-39380][table] Add test snapshotting and restoration to ProcessTableFunctionTestHarness [flink] via GitHub
• 2026/09/30 [jira] [Updated] (FLINK-40857) Kubernetes Operator always replaces CR status 3 times on reconciliation ASF GitHub Bot (Jira)
• 2026/09/30 [jira] [Updated] (FLINK-39380) Add support for test snapshotting/restoration to ProcessTableFunctionTestHarness ASF GitHub Bot (Jira)
• 2026/09/30 [PR] [FLINK-40857] Fix StatusRecorder not breaking out of for loop [flink-kubernetes-operator] via GitHub
• 2026/09/30 Re: [PR] [FLINK-40557][table] Make operation column optional in `TO_CHANGELOG`… [flink] via GitHub
• 2026/09/30 [jira] [Commented] (FLINK-40627) Partially fetched user artifacts are reused on subsequent starts Dale Lane (Jira)
• 2026/09/30 [jira] [Created] (FLINK-40854) Parse UTF-8 bytes directly in PARSE_JSON and TRY_PARSE_JSON Ramin Gharib (Jira)
• 2026/09/30 Re: [PR] [FLINK-40852][table] Return NULL from PARSE_JSON and TRY_PARSE_JSON for NULL allowDuplicateKeys [flink] via GitHub
• 2026/09/30 [jira] [Commented] (FLINK-40639) Deprecated kubernetes.pod-template-file takes precedence over kubernetes.pod-template-file.default sepuri sai krishna (Jira)
• 2026/09/30 [jira] [Commented] (FLINK-32212) Job restarting indefinitely after an IllegalStateException from BlobLibraryCacheManager Jira
• 2026/09/30 [jira] [Resolved] (FLINK-40682) ArchivedExecutionGraphTest and CachedShuffleDescriptorsTest fail with "BUG: trying to schedule a region which is not in CREATED state" Martijn Visser (Jira)
• 2026/09/30 Re: [PR] [FLINK-29549]- Flink Glue Catalog integration [flink-connector-aws] via GitHub
• 2026/09/30 [jira] [Commented] (FLINK-40793) DefaultSchedulerTest is unstable across many test methods sepuri sai krishna (Jira)
• 2026/09/30 Re: [PR] [FLINK-40852][table] Return NULL from PARSE_JSON and TRY_PARSE_JSON for NULL allowDuplicateKeys [flink] via GitHub
• 2026/09/30 [jira] [Created] (FLINK-40856) Support zip-style multi-column explode in DataFrame API Dian Fu (Jira)
• 2026/09/30 Re: [PR] [FLINK-40463][table] Widen JSON_VALUE and JSON_QUERY RETURNING type support [flink] via GitHub
• 2026/09/30 [jira] [Created] (FLINK-40857) Kubernetes Operator always replaces CR status 3 times on reconciliation Mate Czagany (Jira)
• 2026/09/30 Re: [D] Community Sync - 2026 [flink-agents] via GitHub
• 2026/09/30 [jira] [Closed] (FLINK-40708) Support ValueView in PTFs Timo Walther (Jira)
• 2026/09/30 [jira] [Closed] (FLINK-39436) Allow late data to enter PTF Timo Walther (Jira)
• 2026/09/30 Re: [PR] [FLINK-40832][core] Validate decimal range in VariantBuilder.of(BigDecimal) [flink] via GitHub
• 2026/09/30 Re: [PR] [FLINK-40708][table] Support ValueView in PTFs [flink] via GitHub
• 2026/09/30 Re: [PR] [FLINK-40832][core] Validate decimal range in VariantBuilder.of(BigDecimal) [flink] via GitHub
• 2026/09/30 Re: [PR] [FLINK-40435][python] Add explode support to DataFrame API [flink] via GitHub
• 2026/09/30 Re: [PR] [BP-2.3][FLINK-40682][tests] Fix unstable ArchivedExecutionGraphTest and CachedShuffleDescriptorsTest [flink] via GitHub
• 2026/09/30 [jira] [Closed] (FLINK-39437) Support interruptible timers in PTFs Timo Walther (Jira)
• 2026/09/30 [jira] [Commented] (FLINK-40839) INSERT with a column list fails when an omitted column is of type VARIANT Sergey Nuyanzin (Jira)
• 2026/09/30 Re: [PR] [FLINK-40841][table] Non-equi joins fix: retract the matches that a replaced record loses [flink] via GitHub
• 2026/09/30 [jira] [Assigned] (FLINK-40793) DefaultSchedulerTest is unstable across many test methods Martijn Visser (Jira)
• 2026/09/30 Re: [PR] [FLINK-40832][core] Validate decimal range in VariantBuilder.of(BigDecimal) [flink] via GitHub
• 2026/09/30 [jira] [Resolved] (FLINK-40109) YARNSessionFIFOSecuredITCase misses the keytab login in rolled container logs Martijn Visser (Jira)
• 2026/09/30 Re: [PR] [FLINK-40019][core][runtime] Support per-job delegation tokens [flink] via GitHub
• 2026/09/30 Re: [PR] [FLINK-40839][table] Support VARIANT columns omitted from an INSERT column list [flink] via GitHub
• 2026/09/30 Re: [PR] [FLINK-40854][table] Parse UTF-8 bytes directly in PARSE_JSON and TRY_PARSE_JSON [flink] via GitHub
• 2026/09/30 [jira] [Closed] (FLINK-40435) Add explode support to DataFrame API Dian Fu (Jira)
• 2026/09/30 Re: [PR] [FLINK-40435][python] Add explode support to DataFrame API [flink] via GitHub
• 2026/09/30 [PR] [FLINK-39380][table] Add test snapshotting and restoration to ProcessTableFunctionTestHarness [flink] via GitHub
• 2026/09/30 Re: [PR] [BP-2.2][FLINK-40682][tests] Fix unstable ArchivedExecutionGraphTest and CachedShuffleDescriptorsTest [flink] via GitHub
• 2026/09/30 Re: [PR] [FLINK-40852][table] Return NULL from PARSE_JSON and TRY_PARSE_JSON for NULL allowDuplicateKeys [flink] via GitHub
• 2026/09/30 Re: [PR] [FLINK-40852][table] Return NULL from PARSE_JSON and TRY_PARSE_JSON for NULL allowDuplicateKeys [flink] via GitHub
• 2026/09/30 Re: [PR] [FLINK-40852][table] Return NULL from PARSE_JSON and TRY_PARSE_JSON for NULL allowDuplicateKeys [flink] via GitHub
• 2026/09/30 Re: [PR] [BP-2.3][FLINK-40109][yarn][tests] Include rolled logs in the keytab log check [flink] via GitHub
• 2026/09/30 Re: [PR] [FLINK-40855][filesystems] Shut down STS clients after S3 delegation-token acquisition [flink] via GitHub
• 2026/09/30 [jira] [Updated] (FLINK-40854) Parse UTF-8 bytes directly in PARSE_JSON and TRY_PARSE_JSON ASF GitHub Bot (Jira)
• 2026/09/30 [jira] [Updated] (FLINK-40855) Shut down AWS SDK v1 STS clients after S3 delegation-token acquisition ASF GitHub Bot (Jira)
• 2026/09/30 [PR] [FLINK-40855][filesystems] Shut down STS clients after S3 delegation-token acquisition [flink] via GitHub
• 2026/09/30 Re: [PR] [FLINK-40852][table] Return NULL from PARSE_JSON and TRY_PARSE_JSON for NULL allowDuplicateKeys [flink] via GitHub
• 2026/09/30 Re: [PR] [FLINK-40825][table] Support casting primitive types to VARIANT [flink] via GitHub
• 2026/09/30 [jira] [Created] (FLINK-40855) Shut down AWS SDK v1 STS clients after S3 delegation-token acquisition Aleksandr Savonin (Jira)
• 2026/09/30 [PR] [runtime][python] Keep durable call failures whose exception can't be pickled or rebuilt [flink-agents] via GitHub
• 2026/09/30 Re: [PR] [FLINK-40854][table] Parse UTF-8 bytes directly in PARSE_JSON and TRY_PARSE_JSON [flink] via GitHub
• 2026/09/30 [PR] [FLINK-40854][table] Parse UTF-8 bytes directly in PARSE_JSON and TRY_PARSE_JSON [flink] via GitHub
• 2026/09/30 [jira] [Resolved] (FLINK-40839) INSERT with a column list fails when an omitted column is of type VARIANT Sergey Nuyanzin (Jira)
• 2026/09/30 Re: [PR] [FLINK-29549]- Flink Glue Catalog integration [flink-connector-aws] via GitHub
• 2026/09/30 Re: [PR] [FLINK-40839][table] Support VARIANT columns omitted from an INSERT column list [flink] via GitHub
• 2026/09/30 Re: [PR] [FLINK-40608][python] Extract Dataframe type inference mechanism to shared component, add not null by default [flink] via GitHub
• 2026/09/30 [jira] [Updated] (FLINK-32523) NotifyCheckpointAbortedITCase.testNotifyCheckpointAborted fails with timeout on AZP Martijn Visser (Jira)
• 2026/09/30 Re: [PR] [FLINK-40602][runtime] JobManager silently omits running jobs whose JobMaster fails or times out on GET /jobs/overview [flink] via GitHub
• 2026/09/30 Re: [PR] [FLINK-24379] Add Glue Schema Registry SQL formats: Avro, Protobuf, JSON [flink-connector-aws] via GitHub
• 2026/09/30 [jira] [Created] (FLINK-40853) [postgres] Data loss: LSN commit passes the latest completed checkpoint when the delayed checkpoint has no stream offset kim (Jira)
• 2026/09/30 [PR] [FLINK-40853][postgres] Skip LSN commit for checkpoints without a stream offset [flink-cdc] via GitHub
• 2026/09/30 [jira] [Updated] (FLINK-40853) [postgres] Data loss: LSN commit passes the latest completed checkpoint when the delayed checkpoint has no stream offset ASF GitHub Bot (Jira)
• 2026/09/30 [jira] [Commented] (FLINK-40853) [postgres] Data loss: LSN commit passes the latest completed checkpoint when the delayed checkpoint has no stream offset kim (Jira)
• 2026/09/30 [jira] [Updated] (FLINK-40853) [postgres] Data loss: LSN commit passes the latest completed checkpoint when the delayed checkpoint has no stream offset kim (Jira)
• 2026/09/30 [jira] [Commented] (FLINK-40663) WindowDistinctAggregateStressITCase.testCumulateWindowRollupUnderBackpressure times out after 600s Taranpreet Kaur (Jira)
• 2026/09/30 [PR] [legal] Update NOTICE for bundled dependencies [flink-cdc] via GitHub
• 2026/09/30 [jira] [Created] (FLINK-40852) PARSE_JSON fails with NullPointerException when allowDuplicateKeys is NULL Moritz Manner (Jira)
• 2026/09/30 [jira] [Commented] (FLINK-32523) NotifyCheckpointAbortedITCase.testNotifyCheckpointAborted fails with timeout on AZP Martijn Visser (Jira)
• 2026/09/30 [jira] [Created] (FLINK-40851) HybridShuffleITCase NPE in TieredStorageMemoryManagerImpl.release Martijn Visser (Jira)
• 2026/09/30 [jira] [Updated] (FLINK-35335) StateCheckpointedITCase failed fatally with 127 exit code Martijn Visser (Jira)
• 2026/09/30 [jira] [Commented] (FLINK-34427) FineGrainedSlotManagerTest fails fatally (exit code 239) Martijn Visser (Jira)
• 2026/09/30 Re: [PR] [FLINK-40806][table] Add PARSE_XML and TRY_PARSE_XML functions [flink] via GitHub
• 2026/09/30 [jira] [Updated] (FLINK-40806) Add PARSE_XML() and TRY_PARSE_XML() functions ASF GitHub Bot (Jira)
• 2026/09/30 [jira] [Updated] (FLINK-40850) Fluss sink rejects pre-created primary-key tables with custom bucket keys ASF GitHub Bot (Jira)
• 2026/09/30 [PR] [FLINK-40850][pipeline-connector/fluss] Accept custom bucket keys in pre-created primary-key tables [flink-cdc] via GitHub
• 2026/09/30 [jira] [Created] (FLINK-40850) Fluss sink rejects pre-created primary-key tables with custom bucket keys Xiaobing Fang (Jira)
• 2026/09/29 Re: [PR] [FLINK-39995][json] Add ISO-8601 timestamp format with explicit timezone offset support [flink] via GitHub
• 2026/09/29 Re: [PR] [FLINK-39968] [core] Reduce redundant AtomicBoolean allocation in MemorySegment to improve construction performance [flink] via GitHub

• Earlier messages
• Later messages