issues  

Messages by Date

• 2026/06/05 [jira] [Resolved] (FLINK-39872) Add `wrapInException` into allowed list Sergey Nuyanzin (Jira)
• 2026/06/05 Re: [PR] [FLINK-39872][e2e] Add `wrapInExecutionException` to `common.sh` [flink] via GitHub
• 2026/06/05 Re: [PR] [FLINK-39730][runtime] Honor maxExceptions on ApplicationExceptionsHandler [flink] via GitHub
• 2026/06/05 [jira] [Created] (FLINK-39874) NativeS3RecoverableFsDataOutputStream leaks a temp file when the commit-time part upload fails, and uses non-idempotent deletes Li Guo (Jira)
• 2026/06/05 Re: [PR] [FLINK-39873][streaming] Add null check for `connectedSocket` in `SocketStreamIterator.notifyOfError()` [flink] via GitHub
• 2026/06/05 [jira] [Updated] (FLINK-39873) Add null check for connectedSocket in SocketStreamIterator.notifyOfError() ASF GitHub Bot (Jira)
• 2026/06/05 [PR] [FLINK-39873][streaming] Add null check for connectedSocket in `SocketStreamIterator.notifyOfError()` [flink] via GitHub
• 2026/06/05 [jira] [Commented] (FLINK-39873) Add null check for connectedSocket in SocketStreamIterator.notifyOfError() Jubin Soni (Jira)
• 2026/06/05 [jira] [Created] (FLINK-39873) Add null check for connectedSocket in SocketStreamIterator.notifyOfError() Jubin Soni (Jira)
• 2026/06/05 Re: [PR] FLINK-XXXXX: add GROUP BY <int literal>, GROUP BY ALL, ORDER BY ALL support [flink] via GitHub
• 2026/06/05 [jira] [Commented] (FLINK-30975) Enable AWS SDK V2 Support for Flink's S3 FileSystem Modules Diljeet Singh (Jira)
• 2026/06/05 [jira] [Resolved] (FLINK-39865) Nightly S3 artifact upload consistently fails: travis-ci artifacts uploader is unavailable Martijn Visser (Jira)
• 2026/06/05 Re: [PR] [FLINK-39865][ci] Replace abandoned travis-ci artifacts uploader with AWS CLI for nightly S3 upload [flink] via GitHub
• 2026/06/05 Re: [PR] FLINK-XXXXX: add GROUP BY <int literal>, GROUP BY ALL, ORDER BY ALL support [flink] via GitHub
• 2026/06/05 [PR] DynamicKafkaSource should refresh restored cluster properties from KafkaMetadataService [flink-connector-kafka] via GitHub
• 2026/06/05 Re: [PR] [FLINK-39872][e2e] Add `wrapInExecutionException` to `common.sh` [flink] via GitHub
• 2026/06/05 Re: [PR] [FLINK-39730][runtime] Honor maxExceptions on ApplicationExceptionsHandler [flink] via GitHub
• 2026/06/05 [jira] [Updated] (FLINK-39872) Add `wrapInException` into allowed list ASF GitHub Bot (Jira)
• 2026/06/05 [PR] [FLINK-39872][e2e] Add `wrapInExecutionException` to `common.sh` [flink] via GitHub
• 2026/06/05 Re: [PR] FLINK-XXXXX: add GROUP BY ALL support [flink] via GitHub
• 2026/06/05 [jira] [Commented] (FLINK-38536) FinalizeOnMasterTest failed in test_cron_hadoop313 core Martijn Visser (Jira)
• 2026/06/05 [jira] [Updated] (FLINK-39872) Add `wrapInException` into allowed list Sergey Nuyanzin (Jira)
• 2026/06/05 [jira] [Commented] (FLINK-39846) IPv6HostnamesITCase runs unconditionally and fails on AdaptiveScheduler after JUnit5 migration Martijn Visser (Jira)
• 2026/06/05 [jira] [Updated] (FLINK-39846) IPv6HostnamesITCase runs unconditionally and fails on AdaptiveScheduler after JUnit5 migration Martijn Visser (Jira)
• 2026/06/05 [jira] [Resolved] (FLINK-39846) IPv6HostnamesITCase runs unconditionally and fails on AdaptiveScheduler after JUnit5 migration Martijn Visser (Jira)
• 2026/06/05 Re: [PR] [FLINK-39846][tests] Restore IPv6 guard and config in IPv6HostnamesITCase under AdaptiveScheduler [flink] via GitHub
• 2026/06/05 [jira] [Created] (FLINK-39872) Add `wrapInException` into allowed list Sergey Nuyanzin (Jira)
• 2026/06/05 [jira] [Comment Edited] (FLINK-20746) Support ignore-first-line option for CSV format Vishal Kamlapure (Jira)
• 2026/06/05 Re: [PR] [FLINK-39754][core] Fix int overflow in DataOutputSerializer.resize [flink] via GitHub
• 2026/06/05 Re: [PR] [FLINK-39754][core] Fix int overflow in DataOutputSerializer.resize [flink] via GitHub
• 2026/06/05 Re: [PR] [FLINK-39754][core] Fix int overflow in DataOutputSerializer.resize [flink] via GitHub
• 2026/06/05 [jira] [Commented] (FLINK-20746) Support ignore-first-line option for CSV format Vishal Kamlapure (Jira)
• 2026/06/05 Re: [PR] FLINK-XXXXX: add GROUP BY ALL support [flink] via GitHub
• 2026/06/05 [PR] FLINK-XXXXX: add GROUP BY ALL support [flink] via GitHub
• 2026/06/05 Re: [PR] [FLINK-XXXXX][table] Refactor changelog inference program [flink] via GitHub
• 2026/06/05 Re: [PR] [FLINK-39778][s3] Recoverable writer silently loses the in-flight tail on resume [flink] via GitHub
• 2026/06/05 Re: [PR] [FLINK-39778][s3] Recoverable writer silently loses the in-flight tail on resume [flink] via GitHub
• 2026/06/05 Re: [PR] [FLINK-39778][s3] Recoverable writer silently loses the in-flight tail on resume [flink] via GitHub
• 2026/06/05 Re: [PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink] via GitHub
• 2026/06/05 [jira] [Closed] (FLINK-39858) RestClient.close() can leave in-flight request futures uncompleted, hanging the caller Martijn Visser (Jira)
• 2026/06/05 Re: [PR] [FLINK-39858][rest] Fail orphaned in-flight request futures on RestClient close [flink] via GitHub
• 2026/06/05 [jira] [Updated] (FLINK-39781) Add operator for LATERAL SNAPSHOT Join ASF GitHub Bot (Jira)
• 2026/06/05 Re: [PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink] via GitHub
• 2026/06/05 [PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink] via GitHub
• 2026/06/05 Re: [PR] [FLINK-39837] Retain removed dynamic Kafka cluster offsets [flink-connector-kafka] via GitHub
• 2026/06/05 Re: [PR] [FLINK-39837] Retain removed dynamic Kafka cluster offsets [flink-connector-kafka] via GitHub
• 2026/06/05 [jira] [Commented] (FLINK-39837) Make dynamic Kafka source resilient for Kafka topology instability Xin Gao (Jira)
• 2026/06/05 Re: [PR] [FLINK-39778][s3] Recoverable writer silently loses the in-flight tail on resume [flink] via GitHub
• 2026/06/05 Re: [PR] [FLINK-39837] Retain removed dynamic Kafka cluster offsets [flink-connector-kafka] via GitHub
• 2026/06/05 [jira] [Closed] (FLINK-39823) SystemTypeInference infers incorrect partition key Timo Walther (Jira)
• 2026/06/05 Re: [PR] [FLINK-39823][table] Fix incorrect type inference for typed PTF table args [flink] via GitHub
• 2026/06/05 [jira] [Resolved] (FLINK-39799) Preserve user-typed query text for materialized table and view definitions Sergey Nuyanzin (Jira)
• 2026/06/05 [jira] [Commented] (FLINK-39799) Preserve user-typed query text for materialized table and view definitions Sergey Nuyanzin (Jira)
• 2026/06/05 Re: [PR] [FLINK-39799][table] Preserve user-typed query text for materialized table and view definitions [flink] via GitHub
• 2026/06/05 [jira] [Commented] (FLINK-39857) Upgrade Pekko to 1.6.0 Sergey Nuyanzin (Jira)
• 2026/06/05 [jira] [Resolved] (FLINK-39857) Upgrade Pekko to 1.6.0 Sergey Nuyanzin (Jira)
• 2026/06/05 [jira] [Commented] (FLINK-39421) Metadata filter push-down for table sources Sergey Nuyanzin (Jira)
• 2026/06/05 Re: [PR] [FLINK-39857] Upgrade Pekko to 1.6.0 [flink] via GitHub
• 2026/06/05 Re: [PR] [FLINK-39421][table] Fix metadata filter contract and add coverage [flink] via GitHub
• 2026/06/05 [jira] [Assigned] (FLINK-39679) Implicit type conversion fails in code gen Timo Walther (Jira)
• 2026/06/05 Re: [PR] [hotfix][tests] Pin MinIO test image by digest [flink] via GitHub
• 2026/06/05 Re: [PR] [hotfix][tests] Pin MinIO test image by digest [flink] via GitHub
• 2026/06/05 Re: [PR] Rebuild website [flink-web] via GitHub
• 2026/06/05 [jira] [Created] (FLINK-39871) MinioTestContainerTest fails on JDK 8 CI agents in a non-UTC timezone because testcontainers cannot parse the +08:00 Network.created timestamp Martijn Visser (Jira)
• 2026/06/05 [jira] [Assigned] (FLINK-39704) JobMasterServiceLeadershipRunner drops globally-terminal result when leadership is lost mid-completion Matthias Pohl (Jira)
• 2026/06/05 Re: [PR] [FLINK-36753][runtime]Adaptive Scheduler actively triggers a Checkpoint after all resources are ready [flink] via GitHub
• 2026/06/05 Re: [PR] [FLINK-36753][runtime]Adaptive Scheduler actively triggers a Checkpoint after all resources are ready [flink] via GitHub
• 2026/06/05 Re: [PR] [FLINK-39792] Add multi-headers metadata key to Kafka connector [flink-connector-kafka] via GitHub
• 2026/06/05 [PR] Rebuild website [flink-web] via GitHub
• 2026/06/05 [jira] [Closed] (FLINK-39761) Missing 'Connection: close' header on '304 Not Modified' responses causes proxy connection pool poisoning Ferenc Csaky (Jira)
• 2026/06/05 Re: [PR] [BP-2.3][FLINK-39761][runtime] Set 'Connection: close' header when sending '304 Not Modified' responses [flink] via GitHub
• 2026/06/05 Re: [PR] [BP-1.20][FLINK-39761][runtime] Set 'Connection: close' header when sending '304 Not Modified' responses [flink] via GitHub
• 2026/06/05 Re: [PR] [BP-2.2][FLINK-39761][runtime] Set 'Connection: close' header when sending '304 Not Modified' responses [flink] via GitHub
• 2026/06/05 Re: [PR] [BP-2.1][FLINK-39761][runtime] Set 'Connection: close' header when sending '304 Not Modified' responses [flink] via GitHub
• 2026/06/05 Re: [PR] [BP-2.0][FLINK-39761][runtime] Set 'Connection: close' header when sending '304 Not Modified' responses [flink] via GitHub
• 2026/06/05 Re: [PR] [FLINK-39761][runtime] Set 'Connection: close' header when sending '304 Not Modified' responses [flink] via GitHub
• 2026/06/05 Re: [PR] [FLINK-39853][test] Upgrade Testcontainers to 2.0.5 and remove JUnit 4 dependency [flink-kubernetes-operator] via GitHub
• 2026/06/05 Re: [PR] [FLINK-39823][table] Fix incorrect type inference for typed PTF table args [flink] via GitHub
• 2026/06/05 Re: [PR] [FLINK-39846][tests] Restore IPv6 guard and config in IPv6HostnamesITCase under AdaptiveScheduler [flink] via GitHub
• 2026/06/05 Re: [PR] [FLINK-38469][python] Bump Apache Beam to 2.72 [flink] via GitHub
• 2026/06/05 Re: [PR] [FLINK-39858][rest] Fail orphaned in-flight request futures on RestClient close [flink] via GitHub
• 2026/06/05 Re: [PR] [hotfix] Fix some typos for connector-base, protobuf, runtime, table-planner and tests modules. [flink] via GitHub
• 2026/06/05 Re: [PR] [FLINK-39846][tests] Restore IPv6 guard and config in IPv6HostnamesITCase under AdaptiveScheduler [flink] via GitHub
• 2026/06/05 [PR] [hotfix] Fix some typos for connector-base, protobuf, runtime, table-planner and tests modules. [flink] via GitHub
• 2026/06/05 [jira] [Created] (FLINK-39870) Validate literal regex delimiters at planning time for STR_TO_MAP Ramin Gharib (Jira)
• 2026/06/05 [jira] [Created] (FLINK-39869) Validate literal charset at planning time for ENCODE and drop the runtime warning Ramin Gharib (Jira)
• 2026/06/05 [jira] [Created] (FLINK-39868) Remove per-row logging from PARSE_URL and SUBSTRING runtime Ramin Gharib (Jira)
• 2026/06/05 [jira] [Assigned] (FLINK-39868) Remove per-row logging from PARSE_URL and SUBSTRING runtime Ramin Gharib (Jira)
• 2026/06/05 [jira] [Created] (FLINK-39867) Harden built-in scalar function runtime: remove hot-path logging and validate constant args Ramin Gharib (Jira)
• 2026/06/05 [jira] [Assigned] (FLINK-39867) Harden built-in scalar function runtime: remove hot-path logging and validate constant args Ramin Gharib (Jira)
• 2026/06/05 [jira] [Resolved] (FLINK-39758) Fix DECIMAL OOB in SchemaMergingUtils Yanquan Lv (Jira)
• 2026/06/05 [jira] [Assigned] (FLINK-39758) Fix DECIMAL OOB in SchemaMergingUtils Leonard Xu (Jira)
• 2026/06/05 [jira] [Created] (FLINK-39866) Remove dead KEYVALUE code from SqlFunctionUtils and StringCallGen Ramin Gharib (Jira)
• 2026/06/05 Re: [PR] [FLINK-39865][ci] Replace abandoned travis-ci artifacts uploader with AWS CLI for nightly S3 upload [flink] via GitHub
• 2026/06/05 Re: [PR] [FLINK-39823][table] Fix incorrect type inference for typed PTF table args [flink] via GitHub
• 2026/06/05 [jira] [Updated] (FLINK-39865) Nightly S3 artifact upload consistently fails: travis-ci artifacts uploader is unavailable ASF GitHub Bot (Jira)
• 2026/06/05 [PR] [FLINK-39865][ci] Replace abandoned travis-ci artifacts uploader with AWS CLI for nightly S3 upload [flink] via GitHub
• 2026/06/05 [jira] [Created] (FLINK-39865) Nightly S3 artifact upload consistently fails: travis-ci artifacts uploader is unavailable Martijn Visser (Jira)
• 2026/06/05 [jira] [Commented] (FLINK-35661) MiniBatchGroupAggFunction can silently drop records under certain conditions Rui Fan (Jira)
• 2026/06/05 [jira] [Created] (FLINK-39864) ArchUnit ITCase rule flags non-cluster unit tests in flink-core Purushottam Sinha (Jira)
• 2026/06/05 [jira] [Updated] (FLINK-39861) Reduce ArchUnit violations: ITCase MiniCluster rule in flink-filesystems modules Purushottam Sinha (Jira)
• 2026/06/05 [jira] [Updated] (FLINK-39862) Reduce ArchUnit violations: ITCase MiniCluster rule in flink-formats modules Purushottam Sinha (Jira)
• 2026/06/05 [jira] [Created] (FLINK-39863) Reduce ArchUnit violations: ITCase MiniCluster rule in flink-connector-files Purushottam Sinha (Jira)
• 2026/06/05 Re: [PR] [FLINK-39847][table] Support in-place conversion of a table to a materialized table [flink] via GitHub
• 2026/06/05 [jira] [Closed] (FLINK-38853) Umbrella: FLIP-352: Enhance the standardization of the REST API JSON schema Yuepeng Pan (Jira)
• 2026/06/05 [jira] [Created] (FLINK-39862) Reduce ArchUnit violations: ITCase MiniCluster rule in flink-formats modules Purushottam Sinha (Jira)
• 2026/06/05 Re: [PR] [FLINK-39847][table] Support in-place conversion of a table to a materialized table [flink] via GitHub
• 2026/06/05 [jira] [Created] (FLINK-39861) Reduce ArchUnit violations: ITCase MiniCluster rule in flink-filesystems modules Purushottam Sinha (Jira)
• 2026/06/05 [jira] [Updated] (FLINK-39860) Reduce ArchUnit violations: production code must not call @VisibleForTesting methods Purushottam Sinha (Jira)
• 2026/06/05 Re: [PR] Timers [flink] via GitHub
• 2026/06/05 [jira] [Commented] (FLINK-39481) ⁠[tests] Fix flaky WindowDistinctAggregateITCase#testCumulateWindow_GroupingSets⁠ Martijn Visser (Jira)
• 2026/06/05 [jira] [Resolved] (FLINK-39652) Improve documentation for regexp functions Fabian Hueske (Jira)
• 2026/06/05 Re: [PR] [FLINK-39652][docs] Improve documentation for regexp functions [flink] via GitHub
• 2026/06/05 Re: [PR] [FLINK-39652][docs] Improve documentation for regexp functions [flink] via GitHub
• 2026/06/05 [jira] [Resolved] (FLINK-39650) REGEXP_REPLACE does not validate literal regex patterns at plan time and logs errors on the hot path Fabian Hueske (Jira)
• 2026/06/05 [jira] [Resolved] (FLINK-39821) Make return type of REGEX_REPLACE nullable Fabian Hueske (Jira)
• 2026/06/05 [PR] Timers [flink] via GitHub
• 2026/06/05 [jira] [Commented] (FLINK-39761) Missing 'Connection: close' header on '304 Not Modified' responses causes proxy connection pool poisoning Yunfeng Zhou (Jira)
• 2026/06/05 [jira] [Updated] (FLINK-39652) Improve documentation for regexp functions ASF GitHub Bot (Jira)
• 2026/06/05 [PR] [FLINK-39652][docs] Improve documentation for regexp functions [flink] via GitHub
• 2026/06/05 [jira] [Assigned] (FLINK-39652) Improve documentation for regexp functions Ramin Gharib (Jira)
• 2026/06/05 [jira] [Updated] (FLINK-39306) Align the busy-time TRUE_PROCESSING_RATE numerator estimator with the busy-time aggregator Dennis-Mircea Ciupitu (Jira)
• 2026/06/05 [jira] [Updated] (FLINK-39306) Non-source vertices do not use per-second rate metrics, producing inaccurate scaling decisions Dennis-Mircea Ciupitu (Jira)
• 2026/06/05 [jira] [Updated] (FLINK-39306) Non-source vertices do not use per-second rate metrics, producing inaccurate scaling decisions Dennis-Mircea Ciupitu (Jira)
• 2026/06/05 Re: [I] [Release] Manual verification mcp section of user documentation [flink-agents] via GitHub
• 2026/06/05 Re: [I] [Release] Manual verification skills section of user documentation [flink-agents] via GitHub
• 2026/06/05 Re: [I] [Release] Manual verification tool use section of user documentation [flink-agents] via GitHub
• 2026/06/05 Re: [PR] [FLINK-36753][runtime]Adaptive Scheduler actively triggers a Checkpoint after all resources are ready [flink] via GitHub
• 2026/06/05 [PR] [metric] Add key-value metric group for model and action dimensions (#760) [flink-agents] via GitHub
• 2026/06/05 [PR] [bugfix][examples] Point quickstart FileSource at product_review.txt instead of the resources dir [flink-agents] via GitHub
• 2026/06/05 Re: [PR] [FLINK-39860][runtime] Reduce ArchUnit violations: production code must not call @VisibleForTesting methods [flink] via GitHub
• 2026/06/05 [jira] [Updated] (FLINK-39860) Reduce ArchUnit violations: production code must not call @VisibleForTesting methods ASF GitHub Bot (Jira)
• 2026/06/05 [PR] [FLINK-39860][runtime] Reduce ArchUnit violations: production code must not call @VisibleForTesting methods [flink] via GitHub
• 2026/06/05 Re: [I] [Release] Manual verification yaml section of user documentation [flink-agents] via GitHub
• 2026/06/05 Re: [I] [Release] Manual verification yaml section of user documentation [flink-agents] via GitHub
• 2026/06/05 Re: [I] [Release] Manual verification integrate with flink section of user documentation [flink-agents] via GitHub
• 2026/06/05 Re: [I] [Release] Manual verification integrate with flink section of user documentation [flink-agents] via GitHub
• 2026/06/05 Re: [I] [Release] Manual verification react section of user documentation [flink-agents] via GitHub
• 2026/06/05 Re: [I] [Release] Manual verification react section of user documentation [flink-agents] via GitHub
• 2026/06/05 [I] [Tech Debt] Prompt SafeFormatter brace handling is undocumented and inconsistent with Python f-string convention [flink-agents] via GitHub
• 2026/06/05 [jira] [Created] (FLINK-39860) Reduce ArchUnit violations: production code must not call @VisibleForTesting methods Purushottam Sinha (Jira)
• 2026/06/05 Re: [PR] [FLINK-39799][table] Preserve user-typed query text for materialized table and view definitions [flink] via GitHub
• 2026/06/05 [I] [Tech Debt] Quickstart process_chat_response silently drops output on JSON parse failure [flink-agents] via GitHub
• 2026/06/05 [I] [Tech Debt] Polish yaml doc: inter-resource references, complete alias table, schema re-export, Java-loader symmetry [flink-agents] via GitHub
• 2026/06/05 [I] [Tech Debt] Polish react_agent doc: imports, runnable-example link, tool prerequisite, prompt and output-schema clarifications [flink-agents] via GitHub
• 2026/06/05 [I] [Tech Debt] Polish integrate_with_flink doc: self-contained snippets and language-scoped notes [flink-agents] via GitHub
• 2026/06/05 Re: [PR] [FLINK-39823][table] Fix incorrect type inference for typed PTF table args [flink] via GitHub
• 2026/06/05 Re: [PR] [FLINK-39799][table] Preserve user-typed query text for materialized table and view definitions [flink] via GitHub
• 2026/06/05 [jira] [Updated] (FLINK-39823) SystemTypeInference infers incorrect partition key ASF GitHub Bot (Jira)
• 2026/06/05 [PR] [FLINK-39823][table] Fix incorrect type inference for typed PTF table args [flink] via GitHub
• 2026/06/05 Re: [PR] [FLINK-39847][table] Support in-place conversion of a table to a materialized table [flink] via GitHub
• 2026/06/05 Re: [PR] [FLINK-39847][table] Support in-place conversion of a table to a materialized table [flink] via GitHub
• 2026/06/05 Re: [PR] [FLINK-39847][table] Support in-place conversion of a table to a materialized table [flink] via GitHub
• 2026/06/05 [I] [Bugfix] workflow_single_agent_example.py fails — FileSource reads SKILL.md as ProductReview JSON [flink-agents] via GitHub
• 2026/06/05 [I] [Bug] Documented "split topology from infra" YAML pattern fails to load [flink-agents] via GitHub
• 2026/06/05 [I] [Bug] YAML loader silently accepts parameter_types on Python tools [flink-agents] via GitHub
• 2026/06/05 Re: [PR] [api][java][python] Introduce EventType constants and unify Action trigger entry [flink-agents] via GitHub
• 2026/06/05 Re: [PR] [api][java][python] Introduce EventType constants and unify Action trigger entry [flink-agents] via GitHub
• 2026/06/05 [I] [Bug] Java DataStream snippet in integrate_with_flink doc fails to compile [flink-agents] via GitHub
• 2026/06/05 [I] [Bug] Java toTable signature description in integrate_with_flink doc is wrong [flink-agents] via GitHub
• 2026/06/05 Re: [PR] [FLINK-39026][runtime] Remove misleading TODO about getPartitionedState overhead [flink] via GitHub
• 2026/06/05 Re: [PR] [hotfix] [docs] Rework 'Name and Description' section of operators overview to improve grammar and clarity [flink] via GitHub
• 2026/06/05 Re: [PR] [FLINK-38566] Support CEP DSL [flink] via GitHub
• 2026/06/05 Re: [I] [Bug] Java MCPServer ignores the "timeout" ResourceDescriptor argument, always uses 30s default [flink-agents] via GitHub
• 2026/06/05 Re: [PR] [FLINK-39026][runtime] Remove misleading TODO about getPartitionedState overhead [flink] via GitHub
• 2026/06/05 Re: [PR] [hotfix] [docs] Rework 'Name and Description' section of operators overview to improve grammar and clarity [flink] via GitHub
• 2026/06/05 Re: [PR] [FLINK-38566] Support CEP DSL [flink] via GitHub
• 2026/06/05 Re: [PR] Fix the conversion to relational algebra issue in Batch Mode [flink] via GitHub
• 2026/06/05 Re: [PR] Fix the conversion to relational algebra issue in Batch Mode [flink] via GitHub
• 2026/06/05 Re: [PR] [FLINK-38584][metrics] Support checkpoint path as Prometheus info-style metric [flink] via GitHub
• 2026/06/05 Re: [PR] [FLINK-38444][table] Join unique keys should not contain null values [flink] via GitHub
• 2026/06/05 Re: [PR] [FLINK-38584][metrics] Support checkpoint path as Prometheus info-style metric [flink] via GitHub
• 2026/06/05 Re: [PR] [FLINK-38057][runtime] Fix the error value between getting and using idleStartTime in source reader metric group [flink] via GitHub
• 2026/06/05 Re: [PR] [FLINK-37730][rest] Add client method for getting JM exception history [flink] via GitHub
• 2026/06/05 Re: [PR] [FLINK-37730][rest] Add client method for getting JM exception history [flink] via GitHub
• 2026/06/05 Re: [PR] [hotfix] Tracks the number of pending manual compactions. [flink] via GitHub
• 2026/06/05 Re: [PR] [FLINK-36808][table-planner] Fix LookupJoin bug when used with filterable table source [flink] via GitHub
• 2026/06/05 Re: [PR] [hotfix] Tracks the number of pending manual compactions. [flink] via GitHub
• 2026/06/05 Re: [PR] [FLINK-38444][table] Join unique keys should not contain null values [flink] via GitHub
• 2026/06/05 Re: [PR] [hotfix] Adds Override annotation [flink] via GitHub
• 2026/06/05 Re: [PR] [hotfix] Adds Override annotation [flink] via GitHub
• 2026/06/05 Re: [PR] [FLINK-38057][runtime] Fix the error value between getting and using idleStartTime in source reader metric group [flink] via GitHub
• 2026/06/05 Re: [PR] [hotfix]Adds Override annotation [flink] via GitHub
• 2026/06/05 Re: [PR] [hotfix]Adds Override annotation [flink] via GitHub
• 2026/06/05 Re: [PR] [FLINK-37771] Simplify getPartitionedState of AbstractKeyedStateBackend [flink] via GitHub
• 2026/06/05 Re: [PR] [FLINK-37771] Simplify getPartitionedState of AbstractKeyedStateBackend [flink] via GitHub
• 2026/06/05 Re: [PR] [FLINK-37746] Added serialVersionUID in MapTypeInfo class [flink] via GitHub
• 2026/06/05 Re: [PR] [FLINK-37608][fs-connector] File sink supports to close buckets in parallel when snapshot [flink] via GitHub
• 2026/06/05 Re: [PR] [hotfix] Avoid invalid thread for state reader [flink] via GitHub
• 2026/06/05 Re: [PR] [FLINK-37521][table] Implement Proc/RowTimeIntervalJoin with async state [flink] via GitHub
• 2026/06/05 Re: [PR] [FLINK-37746] Added serialVersionUID in MapTypeInfo class [flink] via GitHub
• 2026/06/05 Re: [PR] [FLINK-37655][runtime] Convert WindowStagger into an interface [flink] via GitHub
• 2026/06/05 Re: [PR] [FLINK-36808][table-planner] Fix LookupJoin bug when used with filterable table source [flink] via GitHub
• 2026/06/05 Re: [PR] [FLINK-37716] Simplify YarnClusterDescriptor by removing parameter JobGraph [flink] via GitHub
• 2026/06/05 Re: [PR] [FLINK-37716] Simplify YarnClusterDescriptor by removing parameter JobGraph [flink] via GitHub
• 2026/06/05 Re: [PR] [FLINK-37608][fs-connector] File sink supports to close buckets in parallel when snapshot [flink] via GitHub
• 2026/06/05 Re: [PR] [FLINK-37661] Remove Kryo serializer reference data from version 1.x [flink] via GitHub
• 2026/06/05 Re: [PR] [hotfix] Avoid invalid thread for state reader [flink] via GitHub
• 2026/06/05 Re: [PR] [FLINK-37637] Avoid dead lock for Configuration's addAll [flink] via GitHub
• 2026/06/05 Re: [PR] [hotfix] Remove the redundant config for execution target [flink] via GitHub

• Earlier messages
• Later messages