issues  

Messages by Date

• 2026/10/02 Re: [PR] [FLINK-40882][table] Janino should compile same class only once [flink] via GitHub
• 2026/10/02 Re: [PR] [FLINK-40841][table] Non-equi joins fix: retract the matches that a replaced record loses [flink] via GitHub
• 2026/10/02 Re: [PR] [FLINK-40888][table] Improve MATCH_RECOGNIZE performance: lazily eval… [flink] via GitHub
• 2026/10/02 Re: [PR] [FLINK-33484][Connectors/Kafka] Fix offsets committed to Kafka [flink-connector-kafka] via GitHub
• 2026/10/02 [jira] [Updated] (FLINK-34523) Some jar couldn't be downloaded from google-maven-central Martijn Visser (Jira)
• 2026/10/02 [jira] [Commented] (FLINK-40156) FLIP-600: Independent Checkpoint Based On Pipeline Region Mika Naylor (Jira)
• 2026/10/02 Re: [PR] [FLINK-40841][table] Non-equi joins fix: retract the matches that a replaced record loses [flink] via GitHub
• 2026/10/02 [jira] [Updated] (FLINK-40888) Improve MATCH_RECOGNIZE performance: lazily evaluate DEFINE aggregations and avoid extracting all matched pattern events DongShengHe (Jira)
• 2026/10/02 [jira] [Created] (FLINK-40888) Improve MATCH_RECOGNIZE performance: lazily evaluate DEFINE aggregations and avoid extracting all matched pattern events DongShengHe (Jira)
• 2026/10/02 [PR] Bump ip-address from 10.7.0 to 10.7.3 in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/10/02 Re: [PR] [FLINK-40854][table] Parse UTF-8 bytes directly in PARSE_JSON and TRY_PARSE_JSON [flink] via GitHub
• 2026/10/02 Re: [PR] [FLINK-30975][filesystems] Upgrade to Hadoop to 3.4.3 and support AWS SDK v2 in flink-filesystem [flink] via GitHub
• 2026/10/02 [jira] [Resolved] (FLINK-40855) Shut down AWS SDK v1 STS clients after S3 delegation-token acquisition Gabor Somogyi (Jira)
• 2026/10/02 [jira] [Closed] (FLINK-40855) Shut down AWS SDK v1 STS clients after S3 delegation-token acquisition Gabor Somogyi (Jira)
• 2026/10/02 [jira] [Commented] (FLINK-40855) Shut down AWS SDK v1 STS clients after S3 delegation-token acquisition Gabor Somogyi (Jira)
• 2026/10/02 Re: [PR] [FLINK-40882][table] Janino should compile same class only once [flink] via GitHub
• 2026/10/02 Re: [PR] Bump piscina and @angular/build in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/10/02 Re: [PR] Bump @angular/router from 21.2.22 to 21.2.24 in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/10/02 Re: [PR] Bump ip-address from 10.7.0 to 10.7.3 in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/10/02 [jira] [Updated] (FLINK-39954) SinkV2ITCase over-asserts commit multiplicity under unaligned checkpoints Martijn Visser (Jira)
• 2026/10/02 [jira] [Updated] (FLINK-33082) Azure Pipelines 4 is not responding on AZP Martijn Visser (Jira)
• 2026/10/02 [PR] Bump @angular/router from 21.2.22 to 21.2.24 in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/10/02 [PR] Bump brace-expansion from 1.1.18 to 1.1.21 in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/10/02 [PR] Bump piscina and @angular/build in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/10/02 [jira] [Resolved] (FLINK-40059) StateMachineExample.jar bundles a Kafka connector incompatible with Flink 2.x Robert Metzger (Jira)
• 2026/10/02 Re: [PR] [FLINK-40059][examples] Bump flink-connector-kafka to 5.0.0-2.2 [flink] via GitHub
• 2026/10/02 Re: [PR] [FLINK-40882][table] Janino should compile same class only once [flink] via GitHub
• 2026/10/02 [jira] [Commented] (FLINK-30644) ChangelogCompatibilityITCase.testRestore fails due to CheckpointCoordinator being shutdown Martijn Visser (Jira)
• 2026/10/02 [jira] [Commented] (FLINK-34673) SessionRelatedITCase#testTouchSession failure on GitHub Actions Juanvi Soler (Jira)
• 2026/10/02 Re: [PR] [FLINK-40806][table] Add PARSE_XML and TRY_PARSE_XML functions [flink] via GitHub
• 2026/10/02 [jira] [Updated] (FLINK-39962) Runtime: DeclarativeSlotPoolBridgeTest.testAcceptingOfferedSlotsWithoutResourceManagerConnected flaky Martijn Visser (Jira)
• 2026/10/02 [jira] [Updated] (FLINK-30644) ChangelogCompatibilityITCase.testRestore fails due to CheckpointCoordinator being shutdown Martijn Visser (Jira)
• 2026/10/02 [jira] [Commented] (FLINK-39962) Runtime: DeclarativeSlotPoolBridgeTest.testAcceptingOfferedSlotsWithoutResourceManagerConnected flaky Martijn Visser (Jira)
• 2026/10/02 [jira] [Commented] (FLINK-34523) Some jar couldn't be downloaded from google-maven-central Martijn Visser (Jira)
• 2026/10/02 [jira] [Commented] (FLINK-28440) EventTimeWindowCheckpointingITCase failed with restore Martijn Visser (Jira)
• 2026/10/02 [jira] [Commented] (FLINK-32523) NotifyCheckpointAbortedITCase.testNotifyCheckpointAborted fails with timeout on AZP Martijn Visser (Jira)
• 2026/10/02 [jira] [Updated] (FLINK-40123) heck_logs_for_exceptions false-positives on S3A stream_write_exceptions counter, flaking test_kubernetes_materialized_table.sh Martijn Visser (Jira)
• 2026/10/02 [jira] [Commented] (FLINK-39954) SinkV2ITCase over-asserts commit multiplicity under unaligned checkpoints Martijn Visser (Jira)
• 2026/10/02 [jira] [Commented] (FLINK-33082) Azure Pipelines 4 is not responding on AZP Martijn Visser (Jira)
• 2026/10/02 [jira] [Updated] (FLINK-40655) ExecutionVertexTest.testResetForNewExecutionReleasesPartitions is unstable Martijn Visser (Jira)
• 2026/10/02 [jira] [Commented] (FLINK-40655) ExecutionVertexTest.testResetForNewExecutionReleasesPartitions is unstable Martijn Visser (Jira)
• 2026/10/02 [jira] [Updated] (FLINK-40793) DefaultSchedulerTest is unstable across many test methods Martijn Visser (Jira)
• 2026/10/02 [jira] [Commented] (FLINK-40793) DefaultSchedulerTest is unstable across many test methods Martijn Visser (Jira)
• 2026/10/02 [jira] [Created] (FLINK-40887) TaskFailureITCase.testJobWithoutObjectReuse fails with "Expecting Optional to contain a value but it was empty" Martijn Visser (Jira)
• 2026/10/02 [jira] [Closed] (FLINK-40854) Parse UTF-8 bytes directly in PARSE_JSON and TRY_PARSE_JSON Timo Walther (Jira)
• 2026/10/02 [jira] [Updated] (FLINK-39962) Runtime: DeclarativeSlotPoolBridgeTest.testAcceptingOfferedSlotsWithoutResourceManagerConnected flaky Martijn Visser (Jira)
• 2026/10/02 [jira] [Updated] (FLINK-39962) Runtime: DeclarativeSlotPoolBridgeTest.testAcceptingOfferedSlotsWithoutResourceManagerConnected flaky Martijn Visser (Jira)
• 2026/10/02 [jira] [Created] (FLINK-40886) BlobLibraryCacheManagerTest.testApplicationLevelJarSharing fails with FileAlreadyExistsException on the application directory Martijn Visser (Jira)
• 2026/10/02 [jira] [Commented] (FLINK-34427) FineGrainedSlotManagerTest fails fatally (exit code 239) Martijn Visser (Jira)
• 2026/10/02 Re: [PR] [FLINK-40806][table] Add PARSE_XML and TRY_PARSE_XML functions [flink] via GitHub
• 2026/10/02 Re: [PR] [FLINK-40806][table] Add PARSE_XML and TRY_PARSE_XML functions [flink] via GitHub
• 2026/10/02 Re: [PR] [FLINK-40884][rpc] Escape SSL values in the generated Pekko config [flink] via GitHub
• 2026/10/02 [jira] [Updated] (FLINK-40884) Flink configuration breaks when Keystore or Truststore passwords contain specific characters ASF GitHub Bot (Jira)
• 2026/10/02 Re: [PR] [FLINK-29549]- Flink Glue Catalog integration [flink-connector-aws] via GitHub
• 2026/10/02 [PR] [FLINK-40884][rpc] Escape SSL values in the generated Pekko config [flink] via GitHub
• 2026/10/02 [jira] [Resolved] (FLINK-40876) Code splitter should generate same code after repeated runs Sergey Nuyanzin (Jira)
• 2026/10/02 Re: [PR] [FLINK-40876][table] Code splitter should generate same code after repeated runs [flink] via GitHub
• 2026/10/02 [jira] [Created] (FLINK-40885) Support LATERAL SNAPSHOT join in the Table API Fabian Hueske (Jira)
• 2026/10/02 Re: [PR] [FLINK-24379][Formats] Avro Glue Schema Registry table format [flink-connector-aws] via GitHub
• 2026/10/02 Re: [PR] [FLINK-40876][table] Code splitter should generate same code after repeated runs [flink] via GitHub
• 2026/10/02 [jira] [Commented] (FLINK-40876) Code splitter should generate same code after repeated runs Sergey Nuyanzin (Jira)
• 2026/10/02 Re: [PR] [FLINK-40876][table] Code splitter should generate same code after repeated runs [flink] via GitHub
• 2026/10/01 Re: [PR] [FLINK-40876][table] Code splitter should generate same code after repeated runs [flink] via GitHub
• 2026/10/01 [jira] [Commented] (FLINK-40705) PyFlink pandas UDFs fail on MAP inputs across Arrow batches Dian Fu (Jira)
• 2026/10/01 [jira] [Assigned] (FLINK-40884) Flink configuration breaks when Keystore or Truststore passwords contain specific characters Robert Metzger (Jira)
• 2026/10/01 [jira] [Created] (FLINK-40884) Flink configuration breaks when Keystore or Truststore passwords contain specific characters Robert Metzger (Jira)
• 2026/10/01 Re: [PR] [FLINK-40731][table-common] CONVERT_TZ silently returns a wrong timestamp for a time zone it does not recognize [flink] via GitHub
• 2026/10/01 Re: [PR] [FLINK-40825][table] Support casting primitive types to VARIANT [flink] via GitHub
• 2026/10/01 [jira] [Created] (FLINK-40883) Accumulator corruption in NonTimeRowsUnboundedPrecedingFunction Bonnie Varghese (Jira)
• 2026/10/01 Re: [PR] [FLINK-40444][table-common] Preserve attribute order in OBJECT_UPDATE [flink] via GitHub
• 2026/10/01 [jira] [Resolved] (FLINK-40815) Remove the deprecated configuration keys from the flink-dstl-dfs module. Yuepeng Pan (Jira)
• 2026/10/01 Re: [PR] [FLINK-40815][configuration] Remove the deprecated configuration keys from the flink-dstl-dfs module. [flink] via GitHub
• 2026/10/01 Re: [PR] [FLINK-40815][configuration] Remove the deprecated configuration keys from the flink-dstl-dfs module. [flink] via GitHub
• 2026/10/01 Re: [PR] [FLINK-39478][mysql] Persist checkpointIdToFinish and expose enumerat or metrics [flink-cdc] via GitHub
• 2026/10/01 Re: [PR] [FLINK-33404][python] Add default on_timer to CoProcessFunction [flink] via GitHub
• 2026/10/01 Re: [PR] [FLINK-33484][Connectors/Kafka] Fix offsets committed to Kafka [flink-connector-kafka] via GitHub
• 2026/10/01 Re: [PR] [FLINK-33484][Connectors/Kafka] Fix offsets committed to Kafka [flink-connector-kafka] via GitHub
• 2026/10/01 Re: [PR] [FLINK-33484][Connectors/Kafka] Fix offsets committed to Kafka [flink-connector-kafka] via GitHub
• 2026/10/01 Re: [PR] [FLINK-33484][Connectors/Kafka] Fix offsets committed to Kafka [flink-connector-kafka] via GitHub
• 2026/10/01 Re: [PR] [FLINK-33484][Connectors/Kafka] Fix offsets committed to Kafka [flink-connector-kafka] via GitHub
• 2026/10/01 Re: [PR] [FLINK-33484][Connectors/Kafka] Fix offsets committed to Kafka [flink-connector-kafka] via GitHub
• 2026/10/01 Re: [PR] [FLINK-33484][Connectors/Kafka] Fix offsets committed to Kafka [flink-connector-kafka] via GitHub
• 2026/10/01 Re: [PR] [FLINK-39492][starrocks] Fix microsecond precision loss for TIMESTAMP types in StarRocks sink [flink-cdc] via GitHub
• 2026/10/01 [jira] [Assigned] (FLINK-25029) Hadoop Caller Context Setting In Flink Peter Huang (Jira)
• 2026/10/01 Re: [PR] [FLINK-40844][table] Only EXPR$0 when a PTF's whole output is empty [flink] via GitHub
• 2026/10/01 Re: [PR] [FLINK-40882][table] Janino should compile same class only once [flink] via GitHub
• 2026/10/01 [jira] [Updated] (FLINK-40882) Janino should compile same class only once ASF GitHub Bot (Jira)
• 2026/10/01 [PR] [FLINK-40882][table] Janino should compile same class only once [flink] via GitHub
• 2026/10/01 [jira] [Created] (FLINK-40882) Janino should compile same class only once Sergey Nuyanzin (Jira)
• 2026/10/01 Re: [PR] [BP-2.3][FLINK-40670][tests] Use different keys for different data [flink] via GitHub
• 2026/10/01 Re: [PR] [BP-2.2][FLINK-40670][tests] Use different keys for different data [flink] via GitHub
• 2026/10/01 [jira] [Updated] (FLINK-40670) MultiJoinSemanticTests[four-way-mixed-join-multi-key-types-shuffled] loses a row on release-2.3 Sergey Nuyanzin (Jira)
• 2026/10/01 [jira] [Commented] (FLINK-40670) MultiJoinSemanticTests[four-way-mixed-join-multi-key-types-shuffled] loses a row on release-2.3 Sergey Nuyanzin (Jira)
• 2026/10/01 [PR] [BP-2.2][FLINK-40670][tests] Use different keys for different data [flink] via GitHub
• 2026/10/01 [jira] [Created] (FLINK-40879) Add dynamic ratelimit Flink options Peter Huang (Jira)
• 2026/10/01 [PR] [BP-2.3][FLINK-40670][tests] Use different keys for different data [flink] via GitHub
• 2026/10/01 [jira] [Commented] (FLINK-40847) KafkaDynamicSink#equals/hashCode ignore transactionNamingStrategy Hao Li (Jira)
• 2026/10/01 [jira] [Resolved] (FLINK-40847) KafkaDynamicSink#equals/hashCode ignore transactionNamingStrategy Hao Li (Jira)
• 2026/10/01 [jira] [Created] (FLINK-40881) Update Flink wiki with new configs and user guide Peter Huang (Jira)
• 2026/10/01 [jira] [Created] (FLINK-40880) Support dynamic ratelimit in source coordinator with checkpoint latency control loop Peter Huang (Jira)
• 2026/10/01 [jira] [Created] (FLINK-40878) Add dynamic rate limit interfaces Peter Huang (Jira)
• 2026/10/01 Re: [PR] [FLINK-40847][Connectors/Kafka] Include transaction naming strategy in sink equality [flink-connector-kafka] via GitHub
• 2026/10/01 Re: [PR] [FLINK-40670][tests] Use different keys for different data [flink] via GitHub
• 2026/10/01 [jira] [Created] (FLINK-40877) Support Dynamic Rate Limit in Flink Sources Peter Huang (Jira)
• 2026/10/01 Re: [PR] [FLINK-40876][table] Code splitter should generate same code after repeated runs [flink] via GitHub
• 2026/10/01 [jira] [Updated] (FLINK-40876) Code splitter should generate same code after repeated runs ASF GitHub Bot (Jira)
• 2026/10/01 [PR] [FLINK-40876][table] Code splitter should generate same code after repeated runs [flink] via GitHub
• 2026/10/01 [jira] [Created] (FLINK-40876) Code splitter should generate same code after repeated runs Sergey Nuyanzin (Jira)
• 2026/10/01 [jira] [Updated] (FLINK-40876) Code splitter should generate same code after repeated runs Sergey Nuyanzin (Jira)
• 2026/10/01 [jira] [Updated] (FLINK-40876) Code splitter should generate same code after repeated runs Sergey Nuyanzin (Jira)
• 2026/10/01 Re: [PR] [FLINK-40816][kubernetes/configuration] Remove the deprecated configuration keys from the flink-kubernetes module. [flink] via GitHub
• 2026/10/01 Re: [PR] [FLINK-40847][Connectors/Kafka] Include transaction naming strategy in sink equality [flink-connector-kafka] via GitHub
• 2026/10/01 Re: [PR] [FLINK-40847][Connectors/Kafka] Include transaction naming strategy in sink equality [flink-connector-kafka] via GitHub
• 2026/10/01 [jira] [Resolved] (FLINK-40705) PyFlink pandas UDFs fail on MAP inputs across Arrow batches Martijn Visser (Jira)
• 2026/10/01 Re: [PR] [FLINK-40728][k8s][build] Migrate Flink off end-of-life OkHttp and keep it off the core classpath (FLIP-607) [flink] via GitHub
• 2026/10/01 Re: [PR] [FLINK-40571][table-planner] Fix flaky process-stateful-multi-input-with-timeout PTF test [flink] via GitHub
• 2026/10/01 Re: [PR] [FLINK-40705][python] Fix Java 8 compilation of ArrowReaderWriterTest [flink] via GitHub
• 2026/10/01 Re: [PR] [FLINK-40797][table-planner] Exclude NestedLoopJoin from CBO search space for equi-joins [flink] via GitHub
• 2026/10/01 [jira] [Updated] (FLINK-40571) ProcessTableFunctionSemanticTests[process-stateful-multi-input-with-timeout] is flaky on master ASF GitHub Bot (Jira)
• 2026/10/01 [PR] [FLINK-40571][table-planner] Fix flaky process-stateful-multi-input-with-timeout PTF test [flink] via GitHub
• 2026/10/01 Re: [PR] [FLINK-40847][Connectors/Kafka] Include transaction naming strategy in sink equality [flink-connector-kafka] via GitHub
• 2026/10/01 Re: [PR] [FLINK-40847][Connectors/Kafka] Include transaction naming strategy in sink equality [flink-connector-kafka] via GitHub
• 2026/10/01 Re: [PR] [FLINK-40847][Connectors/Kafka] Include transaction naming strategy in sink equality [flink-connector-kafka] via GitHub
• 2026/10/01 Re: [PR] [FLINK-40847][Connectors/Kafka] Include transaction naming strategy in sink equality [flink-connector-kafka] via GitHub
• 2026/10/01 Re: [PR] [FLINK-40847][Connectors/Kafka] Include transaction naming strategy in sink equality [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 [PR] [runtime][java] Reject memory writes below a value field before mutating state [flink-agents] via GitHub
• 2026/10/01 [I] [Bug][runtime] Memory writes below a value field mutate state before failing [flink-agents] 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 [jira] [Created] (FLINK-40875) Optimization to let streaming joins fill key-only deletes instead of adding a ChangelogNormalize Gustavo de Morais (Jira)
• 2026/10/01 Re: [PR] [FLINK-38023][formats] Fix GenericRecord Avro state migration [flink] via GitHub
• 2026/10/01 Re: [PR] [FLINK-40816][kubernetes/configuration] Remove the deprecated configuration keys from the flink-kubernetes module. [flink] via GitHub
• 2026/10/01 [jira] [Commented] (FLINK-40571) ProcessTableFunctionSemanticTests[process-stateful-multi-input-with-timeout] is flaky on master Purushottam Sinha (Jira)
• 2026/10/01 Re: [PR] [FLINK-40815][configuration] Remove the deprecated configuration keys from the flink-dstl-dfs module. [flink] via GitHub
• 2026/10/01 [jira] [Updated] (FLINK-40816) Remove the deprecated configuration keys from the flink-kubernetes module. ASF GitHub Bot (Jira)
• 2026/10/01 [PR] [FLINK-40816][kubernetes/configuration] Remove the deprecated configuration keys from the flink-kubernetes module. [flink] via GitHub
• 2026/10/01 [jira] [Reopened] (FLINK-40326) GatedRateLimiter admits more events per cycle than configured Martijn Visser (Jira)
• 2026/10/01 Re: [PR] [FLINK-40815][configuration] Remove the deprecated configuration keys from the flink-dstl-dfs module. [flink] via GitHub
• 2026/10/01 Re: [PR] [FLINK-40705][python] Fix Java 8 compilation of ArrowReaderWriterTest [flink] via GitHub
• 2026/10/01 [jira] [Updated] (FLINK-40815) Remove the deprecated configuration keys from the flink-dstl-dfs module. ASF GitHub Bot (Jira)
• 2026/10/01 [PR] [FLINK-40815][configuration] Remove the deprecated configuration keys from the flink-dstl-dfs module. [flink] via GitHub
• 2026/10/01 Re: [PR] [FLINK-40857] Fix StatusRecorder not breaking out of for loop [flink-kubernetes-operator] 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-40806][table] Add PARSE_XML and TRY_PARSE_XML functions [flink] via GitHub
• 2026/10/01 Re: [I] [Tech Debt][API][Action] Improve annotation-based cross-language Action declarations [flink-agents] 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-40841][table] Non-equi joins fix: retract the matches that a replaced record loses [flink] via GitHub
• 2026/10/01 Re: [PR] [FLINK-40504][core] Re-activate the source output on any sign of activity [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-40806][table] Add PARSE_XML and TRY_PARSE_XML functions [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] [Comment Edited] (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-37288] Add Google Cloud Spanner dialect and catalog [flink-connector-jdbc] via GitHub
• 2026/10/01 [jira] [Updated] (FLINK-40789) RescaleTimelineITCase.testRecordRescaleForNewAvailableResource records three rescales instead of two Martijn Visser (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] [FLINK-40841][table] Non-equi joins fix: retract the matches that a replaced record loses [flink] via GitHub
• 2026/10/01 Re: [PR] [FLINK-33484][Connectors/Kafka] Fix offsets committed to Kafka [flink-connector-kafka] via GitHub
• 2026/10/01 Re: [PR] [FLINK-40504][core] Re-activate the source output on any sign of activity [flink] via GitHub
• 2026/10/01 [jira] [Created] (FLINK-40874) Mini-batch streaming join evaluates non-equi conditions on key-only deletes of folded pairs Gustavo de Morais (Jira)
• 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 [jira] [Assigned] (FLINK-40858) Streaming join should evaluate non-equi conditions on key-only deletes Gustavo de Morais (Jira)
• 2026/10/01 [PR] [integration][java][python] Reject media blocks in providers that send text only [flink-agents] via GitHub
• 2026/10/01 [jira] [Updated] (FLINK-40858) Streaming join should evaluate non-equi conditions on key-only deletes Gustavo de Morais (Jira)
• 2026/10/01 [jira] [Comment Edited] (FLINK-40872) AsyncExecutionController is never closed. Leak the state backend through the static AsyncRequestBuffer.DELAYER Yordan Pavlov (Jira)
• 2026/10/01 [jira] [Commented] (FLINK-40670) MultiJoinSemanticTests[four-way-mixed-join-multi-key-types-shuffled] loses a row on release-2.3 Martijn Visser (Jira)
• 2026/10/01 Re: [PR] [FLINK-40844][table] Only EXPR$0 when a PTF's whole output is empty [flink] via GitHub
• 2026/10/01 Re: [PR] [FLINK-40615][Connectors/Kafka] fix: Prevent duplicate partition assignment in KafkaSourceEnumerator [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 [PR] [api][java][python] Refactor ChatMessage and separate model invocation results [flink-agents] via GitHub
• 2026/10/01 [jira] [Comment Edited] (FLINK-40872) AsyncExecutionController is never closed. Leak the state backend through the static AsyncRequestBuffer.DELAYER Yordan Pavlov (Jira)
• 2026/10/01 Re: [PR] [FLINK-40872][runtime] Close AsyncExecutionController when async state operators close [flink] via GitHub
• 2026/10/01 [jira] [Assigned] (FLINK-40571) ProcessTableFunctionSemanticTests[process-stateful-multi-input-with-timeout] is flaky on master Martijn Visser (Jira)
• 2026/10/01 [PR] [FLINK-40872][runtime] Close AsyncExecutionController when async state operators close [flink] via GitHub
• 2026/10/01 [jira] [Updated] (FLINK-40872) AsyncExecutionController is never closed. Leak the state backend through the static AsyncRequestBuffer.DELAYER ASF GitHub Bot (Jira)
• 2026/10/01 [jira] [Comment Edited] (FLINK-40872) AsyncExecutionController is never closed. Leak the state backend through the static AsyncRequestBuffer.DELAYER Yordan Pavlov (Jira)
• 2026/10/01 [jira] [Comment Edited] (FLINK-40872) AsyncExecutionController is never closed. Leak the state backend through the static AsyncRequestBuffer.DELAYER Yordan Pavlov (Jira)
• 2026/10/01 [jira] [Commented] (FLINK-40872) AsyncExecutionController is never closed. Leak the state backend through the static AsyncRequestBuffer.DELAYER Yordan Pavlov (Jira)
• 2026/10/01 [jira] [Resolved] (FLINK-40475) StatusWatermarkValve loses or stalls watermarks when subpartitions realign after idleness Martijn Visser (Jira)
• 2026/10/01 [jira] [Reopened] (FLINK-40705) PyFlink pandas UDFs fail on MAP inputs across Arrow batches Martijn Visser (Jira)
• 2026/10/01 [jira] [Created] (FLINK-40873) Fix overlapping config key prefixes in the operator Gyula Fora (Jira)
• 2026/10/01 [jira] [Commented] (FLINK-40571) ProcessTableFunctionSemanticTests[process-stateful-multi-input-with-timeout] is flaky on master Martijn Visser (Jira)
• 2026/10/01 [jira] [Commented] (FLINK-34427) FineGrainedSlotManagerTest fails fatally (exit code 239) Martijn Visser (Jira)
• 2026/10/01 [jira] [Comment Edited] (FLINK-40789) RescaleTimelineITCase.testRecordRescaleForNewAvailableResource records three rescales instead of two Martijn Visser (Jira)
• 2026/10/01 [jira] [Updated] (FLINK-40789) RescaleTimelineITCase.testRecordRescaleForNewAvailableResource records three rescales instead of two Martijn Visser (Jira)
• 2026/10/01 [jira] [Updated] (FLINK-39330) FileSourceTextLinesITCase.testBoundedTextFileSourceWithJobManagerFailove fails Martijn Visser (Jira)
• 2026/10/01 [PR] [FLINK-40705][python] Fix Java 8 compilation of ArrowReaderWriterTest [flink] via GitHub
• 2026/10/01 [jira] [Commented] (FLINK-40789) RescaleTimelineITCase.testRecordRescaleForNewAvailableResource records three rescales instead of two Martijn Visser (Jira)
• 2026/10/01 [jira] [Commented] (FLINK-28440) EventTimeWindowCheckpointingITCase failed with restore Martijn Visser (Jira)
• 2026/10/01 [jira] [Commented] (FLINK-35335) StateCheckpointedITCase failed fatally with 127 exit code Martijn Visser (Jira)
• 2026/10/01 [jira] [Reopened] (FLINK-38574) Avoid reusing re-uploaded sst files when checkpoint notification is delayed Martijn Visser (Jira)
• 2026/10/01 [jira] [Commented] (FLINK-39330) FileSourceTextLinesITCase.testBoundedTextFileSourceWithJobManagerFailove fails Martijn Visser (Jira)
• 2026/10/01 [jira] [Reopened] (FLINK-38534) Fix flaky LocalRecoveryTest by waiting for tasks to reach RUNNING state Martijn Visser (Jira)
• 2026/10/01 [jira] [Commented] (FLINK-40571) ProcessTableFunctionSemanticTests[process-stateful-multi-input-with-timeout] is flaky on master Martijn Visser (Jira)
• 2026/10/01 [jira] [Updated] (FLINK-36297) SIGSEGV caused CI failure Martijn Visser (Jira)
• 2026/10/01 [jira] [Commented] (FLINK-40663) WindowDistinctAggregateStressITCase.testCumulateWindowRollupUnderBackpressure times out after 600s Martijn Visser (Jira)
• 2026/10/01 [jira] [Commented] (FLINK-36297) SIGSEGV caused CI failure Martijn Visser (Jira)
• 2026/10/01 [jira] [Assigned] (FLINK-40857) Kubernetes Operator always replaces CR status 3 times on reconciliation Gyula Fora (Jira)
• 2026/10/01 [jira] [Closed] (FLINK-40857) Kubernetes Operator always replaces CR status 3 times on reconciliation Gyula Fora (Jira)
• 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

• Earlier messages
• Later messages