issues
Thread
Date
Earlier messages
Later messages
Messages by Date
2026/03/01
Re: [PR] [FLINK-38971][table] Migrate ExpandWindowTableFunctionTransposeRule t… [flink]
via GitHub
2026/03/01
[jira] [Updated] (FLINK-39181) Reduce Verbose DEBUG Logging in CI
Martijn Visser (Jira)
2026/03/01
[jira] [Created] (FLINK-39181) Reduce Verbose DEBUG Logging in CI
Martijn Visser (Jira)
2026/03/01
Re: [D] [Feature] Enhance the quickstart experience [flink-agents]
via GitHub
2026/03/01
Re: [D] [Feature] Enhance the quickstart experience [flink-agents]
via GitHub
2026/03/01
Re: [PR] [FLINK-39176][runtime] Introduce NodeHealthManager abstraction [flink]
via GitHub
2026/03/01
Re: [PR] [FLINK-39176][runtime] Integrate NodeHealthManager with Slot Filtering [flink]
via GitHub
2026/03/01
Re: [PR] Bump @angular/core from 20.1.3 to 20.3.17 in /flink-runtime-web/web-dashboard [flink]
via GitHub
2026/03/01
Re: [PR] Bump com.fasterxml.jackson.core:jackson-core from 2.15.2 to 2.18.6 in /flink-models/flink-model-triton [flink]
via GitHub
2026/03/01
[PR] Bump @angular/core from 20.1.3 to 20.3.17 in /flink-runtime-web/web-dashboard [flink]
via GitHub
2026/03/01
[PR] Bump com.fasterxml.jackson.core:jackson-core from 2.15.2 to 2.18.6 in /flink-models/flink-model-triton [flink]
via GitHub
2026/03/01
[jira] [Resolved] (FLINK-39180) RestClientTest.testRestClientClosedHandling fails with wrong assertion
Martijn Visser (Jira)
2026/03/01
Re: [PR] [FLINK-39180][tests] Fix flaky RestClientTest.testRestClientClosedHandling [flink]
via GitHub
2026/02/28
Re: [PR] [FLINK-39124][test] Migrate remaining flink-tests to JUnit 5 [flink]
via GitHub
2026/02/28
Re: [PR] [FLINK-39124][test] Migrate remaining flink-tests to JUnit 5 [flink]
via GitHub
2026/02/28
Re: [PR] [FLINK-39124][test] Migrate remaining flink-tests to JUnit 5 [flink]
via GitHub
2026/02/28
Re: [PR] [FLINK-39124][test] Migrate remaining flink-tests to JUnit 5 [flink]
via GitHub
2026/02/28
Re: [PR] [FLINK-39176][WebUI] Add Node Health status page to Job Manager UI [flink]
via GitHub
2026/02/28
[PR] [FLINK-39176][WebUI] Add Node Health status page to Job Manager UI [flink]
via GitHub
2026/02/28
Re: [PR] [FLINK-39176][Runtime] Add expiration cleanup scheduler for NodeHealthManager [flink]
via GitHub
2026/02/28
[PR] [FLINK-39176][Runtime] Add expiration cleanup scheduler for NodeHealthManager [flink]
via GitHub
2026/02/28
Re: [I] [Feature] [integration] [Java] Chroma vector store for Java [flink-agents]
via GitHub
2026/02/28
Re: [I] [Feature] Batched Summarization for Long-Term Memory [flink-agents]
via GitHub
2026/02/28
Re: [I] [Feature] [runtime] Support batched summarization for long-term memory. [flink-agents]
via GitHub
2026/02/28
Re: [PR] [infra] Support python 3.12. [flink-agents]
via GitHub
2026/02/28
Re: [PR] [FLINK-39176][runtime] Add configuration support for management blocklist [flink]
via GitHub
2026/02/28
[PR] [FLINK-39176][runtime] Add configuration support for management blocklist [flink]
via GitHub
2026/02/28
[PR] Add OpenAI Responses API integration [Java] [flink-agents]
via GitHub
2026/02/28
Re: [PR] [FLINK-33634] Add Conditions to Flink CRD's Status field [flink-kubernetes-operator]
via GitHub
2026/02/28
Re: [PR] [FLINK-39180][tests] Fix flaky RestClientTest.testRestClientClosedHandling [flink]
via GitHub
2026/02/28
Re: [PR] [hotfix] Install yamale to allow CI Kubenetes linting to work [flink-kubernetes-operator]
via GitHub
2026/02/28
[jira] [Commented] (FLINK-38223) ExecutionGraphRestartTest and ExecutionGraphCoLocationRestartTest are flaky on master
Martijn Visser (Jira)
2026/02/28
Re: [PR] [FLINK-39180][tests] Fix flaky RestClientTest.testRestClientClosedHandling [flink]
via GitHub
2026/02/28
[jira] [Updated] (FLINK-39180) RestClientTest.testRestClientClosedHandling fails with wrong assertion
ASF GitHub Bot (Jira)
2026/02/28
[PR] [FLINK-39180][tests] Fix flaky RestClientTest.testRestClientClosedHandling [flink]
via GitHub
2026/02/28
[jira] [Commented] (FLINK-39180) RestClientTest.testRestClientClosedHandling fails with wrong assertion
Martijn Visser (Jira)
2026/02/28
[jira] [Updated] (FLINK-39180) RestClientTest.testRestClientClosedHandling fails with wrong assertion
Martijn Visser (Jira)
2026/02/28
[jira] [Created] (FLINK-39180) RestClientTest.testRestClientClosedHandling fails with wrong assertion
Martijn Visser (Jira)
2026/02/28
Re: [PR] [FLINK-3154][runtime] Upgrade from Kryo v2 + Chill 0.7.6 to Kryo v5 w… [flink]
via GitHub
2026/02/28
Re: [D] [Feature] Enhance the quickstart experience [flink-agents]
via GitHub
2026/02/28
Re: [D] [Feature] Enhance the quickstart experience [flink-agents]
via GitHub
2026/02/28
[jira] [Resolved] (FLINK-34644) RestServerEndpointITCase.testShouldWaitForHandlersWhenClosing failed with ConnectionClosedException
Martijn Visser (Jira)
2026/02/28
Re: [D] [Feature] Enhance the quickstart experience [flink-agents]
via GitHub
2026/02/28
[D] [Feature] Enhance the quickstart experience [flink-agents]
via GitHub
2026/02/28
[PR] [chore][test] Fix flaky postgres pipeline test case [flink-cdc]
via GitHub
2026/02/28
[jira] [Updated] (FLINK-34644) RestServerEndpointITCase.testShouldWaitForHandlersWhenClosing failed with ConnectionClosedException
Martijn Visser (Jira)
2026/02/28
[jira] [Commented] (FLINK-34644) RestServerEndpointITCase.testShouldWaitForHandlersWhenClosing failed with ConnectionClosedException
Martijn Visser (Jira)
2026/02/28
[jira] [Assigned] (FLINK-34644) RestServerEndpointITCase.testShouldWaitForHandlersWhenClosing failed with ConnectionClosedException
Martijn Visser (Jira)
2026/02/28
[jira] [Updated] (FLINK-34644) RestServerEndpointITCase.testShouldWaitForHandlersWhenClosing failed with ConnectionClosedException
ASF GitHub Bot (Jira)
2026/02/28
Re: [PR] [FLINK-34644][runtime] Fix race condition in RestServerEndpoint shutdown [flink]
via GitHub
2026/02/28
Re: [PR] [FLINK-39176][runtime] Add REST API for Node Quarantine [flink]
via GitHub
2026/02/28
[jira] [Updated] (FLINK-39071) Select fields rather than * to read snapshot data in case of schema changes.
ASF GitHub Bot (Jira)
2026/02/28
[PR] [FLINK-39071][oracle-cdc] Fix Oracle pipeline connector wrong field case [flink-cdc]
via GitHub
2026/02/28
[PR] [FLINK-39176][runtime] Add REST API for Node Quarantine [flink]
via GitHub
2026/02/28
Re: [PR] [FLINK-39176][runtime] Integrate NodeHealthManager with Slot Filtering [flink]
via GitHub
2026/02/28
[jira] [Updated] (FLINK-39176) Introduce Node Health Management & Quarantine Framework for ResourceManager
ASF GitHub Bot (Jira)
2026/02/28
[PR] Typo fix [flink-connector-http]
via GitHub
2026/02/28
Re: [PR] [FLINK-38998][table] Fix cascaded event time WindowAggregate does not produce data when offset is specified [flink]
via GitHub
2026/02/28
[PR] [FLINK-39176][runtime] Integrate NodeHealthManager with Slot Filtering [flink]
via GitHub
2026/02/28
Re: [PR] [FLINK-37837][core] Always add create.table to include.schema.changes option [flink-cdc]
via GitHub
2026/02/28
Re: [PR] [FLINK-38897][Runtime/REST] Introduce the /jobs/:jobid/rescales/config endpoint in the REST API [flink]
via GitHub
2026/02/28
Re: [PR] [FLINK-39163][python] Support ML_PREDICT in Python API [flink]
via GitHub
2026/02/28
[jira] [Updated] (FLINK-39163) Support ML_PREDICT in Flink Python API
ASF GitHub Bot (Jira)
2026/02/28
[PR] [FLINK-39163][python] Support ML_PREDICT in Python API [flink]
via GitHub
2026/02/28
[jira] [Commented] (FLINK-39041) Rebuild REST API docs pages to supplement the missing content.
Yuepeng Pan (Jira)
2026/02/28
Re: [PR] [FLINK-39041][docs] Rebuild REST API docs pages to supplement the missing content. [flink]
via GitHub
2026/02/28
Re: [PR] [FLINK-39041][docs] Rebuild REST API docs pages to supplement the missing content. [flink]
via GitHub
2026/02/28
Re: [PR] [FLINK-37485][starrocks] Add support for TIME type [flink-cdc]
via GitHub
2026/02/28
Re: [PR] [FLINK-38897][Runtime/REST] Introduce the /jobs/:jobid/rescales/config endpoint in the REST API [flink]
via GitHub
2026/02/28
Re: [PR] [FLINK-38974][runtime] Handle jobs in running applications during HA recovery [flink]
via GitHub
2026/02/28
Re: [PR] [FLINK-39020][pipeline][doris] Fix the bug When synchronizing MySQL to Doris, data of type java.time.LocalTime is serialized or deserialized, but by default, Jackson does not support the handling of Java 8 time types (such as LocalTime, LocalDateTime, etc.) [flink-cdc]
via GitHub
2026/02/28
[PR] [infra] Support python 3.12. [flink-agents]
via GitHub
2026/02/28
[I] [Feature] Support python 3.12 [flink-agents]
via GitHub
2026/02/28
[jira] [Updated] (FLINK-39179) Add REPLACE INTO filtering in handleQueryEvent to fix pt-table-checksum DML parsing failure
ASF GitHub Bot (Jira)
2026/02/28
[PR] [FLINK-39179][mysql] Add REPLACE INTO filtering in handleQueryEvent to fix pt-table-checksum DML parsing [flink-cdc]
via GitHub
2026/02/28
[jira] [Created] (FLINK-39179) Add REPLACE INTO filtering in handleQueryEvent to fix pt-table-checksum DML parsing failure
MengHui Yu (Jira)
2026/02/28
Re: [PR] [FLINK-38990][Runtime/Checkpointing] Support configurable initial delay for first checkpoint trigger [flink]
via GitHub
2026/02/28
Re: [PR] [FLINK-38830][runtime] Handle duplicate AddColumnEvent gracefully to prevent pipeline crashes [flink-cdc]
via GitHub
2026/02/28
[jira] [Updated] (FLINK-38974) Handle jobs in running applications during HA recovery
ASF GitHub Bot (Jira)
2026/02/28
Re: [PR] [FLINK-38974][runtime] Handle jobs in running applications during HA recovery [flink]
via GitHub
2026/02/27
Re: [PR] [FLINK-38990][Runtime/Checkpointing] Support configurable initial delay for first checkpoint trigger [flink]
via GitHub
2026/02/27
[jira] [Updated] (FLINK-39178) Support cascaded delta join
Xuyang Zhong (Jira)
2026/02/27
Re: [PR] [FLINK-39016][Runtime/REST] Add configurable TTL for ExecutionGraph cache independent of web refresh interval [flink]
via GitHub
2026/02/27
Re: [PR] [FLINK-39021][Deployment/Kubernetes] Support native PersistentVolumeClaim (PVC) mounting for Kubernetes deployments [flink]
via GitHub
2026/02/27
Re: [PR] [FLINK-39051][Table SQL/Planner] Support APPROX_COUNT_DISTINCT aggregate function in streaming mode with Window TVF [flink]
via GitHub
2026/02/27
Re: [PR] [FLINK-39050][Table SQL/Planner] Support configurable handling strategy for null rowtime field in watermark generation [flink]
via GitHub
2026/02/27
Re: [PR] [FLINK-38988][Table SQL/API] Support INET_ATON and INET_NTOA functions for IP address conversion [flink]
via GitHub
2026/02/27
Re: [PR] [plan] Extract ResourceCache and PythonResourceBridge from AgentPlan [flink-agents]
via GitHub
2026/02/27
Re: [PR] [FLINK-38988][Table SQL/API] Support INET_ATON and INET_NTOA functions for IP address conversion [flink]
via GitHub
2026/02/27
[jira] [Closed] (FLINK-38977) Expose exceptions for applications
Zhu Zhu (Jira)
2026/02/27
Re: [PR] [FLINK-38977][runtime] Expose exceptions for applications [flink]
via GitHub
2026/02/27
[jira] [Updated] (FLINK-39131) Multi-Input Processors
Salva (Jira)
2026/02/27
Re: [PR] [FLINK-38828][cdc-runtime] Add state persistence to PostTransformOperator for projection schema evolution [flink-cdc]
via GitHub
2026/02/27
[jira] [Updated] (FLINK-39175) Allow calc that contains non-deterministic func to consume duplicate changes
ASF GitHub Bot (Jira)
2026/02/27
Re: [PR] [FLINK-39175][table-planner] Allow calc that contains non-deterministic func to consume duplicate changes [flink]
via GitHub
2026/02/27
[jira] [Updated] (FLINK-39175) Allow calc that contains non-deterministic func to consume duplicate changes
Xuyang Zhong (Jira)
2026/02/27
[jira] [Updated] (FLINK-39175) Allow calc that contains non-deterministic func to consume duplicate changes
Xuyang Zhong (Jira)
2026/02/27
[jira] [Updated] (FLINK-39178) Support cascaded delta join
Xuyang Zhong (Jira)
2026/02/27
[jira] [Updated] (FLINK-39174) Support lookup join after delta join
Xuyang Zhong (Jira)
2026/02/27
[jira] [Updated] (FLINK-39175) Allow calc that contains non-deterministic func to consume duplicate changes
Xuyang Zhong (Jira)
2026/02/27
[jira] [Updated] (FLINK-39175) Allow calc that contains non-deterministic func to consume duplicate changes
Xuyang Zhong (Jira)
2026/02/27
[jira] [Updated] (FLINK-39174) Support lookup join after delta join
ASF GitHub Bot (Jira)
2026/02/27
Re: [PR] [FLINK-39174][table-planner] Support lookup join after delta join [flink]
via GitHub
2026/02/27
[jira] [Created] (FLINK-39178) Support cascaded delta join
Xuyang Zhong (Jira)
2026/02/27
Re: [I] [Feature] Support OpenAI latest Response API [flink-agents]
via GitHub
2026/02/27
Re: [PR] Bump minimatch in /flink-runtime-web/web-dashboard [flink]
via GitHub
2026/02/27
[PR] Bump minimatch in /flink-runtime-web/web-dashboard [flink]
via GitHub
2026/02/27
[jira] [Closed] (FLINK-39164) Flaky test HistoryServerTest.testRemoveApplicationArchivesBeyondHistorySizeLimit
Zhu Zhu (Jira)
2026/02/27
Re: [PR] [FLINK-38236][mongodb] Add metadata support for full document in MongoDB CDC connector [flink-cdc]
via GitHub
2026/02/27
[jira] [Updated] (FLINK-39164) Flaky test HistoryServerTest.testRemoveApplicationArchivesBeyondHistorySizeLimit
ASF GitHub Bot (Jira)
2026/02/27
Re: [PR] [FLINK-39164][history] Fix HistoryServerTest by adding delay to avoid identical archive timestamps [flink]
via GitHub
2026/02/27
Re: [PR] [FLINK-37837][core] Always add create.table to include.schema.changes option [flink-cdc]
via GitHub
2026/02/27
Re: [PR] [FLINK-39149][mysql-cdc] Implement LATEST mode GTID merging to prevent replaying pre-checkpoint transactions with non-contiguous ranges [flink-cdc]
via GitHub
2026/02/27
Re: [PR] Add Node.js CI workflow for testing [flink-web]
via GitHub
2026/02/27
Re: [D] [Feature] Per-Event-Type Configurable Log Levels for Event Log [flink-agents]
via GitHub
2026/02/27
Re: [D] [Feature] Per-Event-Type Configurable Log Levels for Event Log [flink-agents]
via GitHub
2026/02/27
Re: [D] [Feature] Per-Event-Type Configurable Log Levels for Event Log [flink-agents]
via GitHub
2026/02/27
Re: [D] [Feature] Per-Event-Type Configurable Log Levels for Event Log [flink-agents]
via GitHub
2026/02/27
Re: [D] [Feature] Per-Event-Type Configurable Log Levels for Event Log [flink-agents]
via GitHub
2026/02/27
Re: [D] [Feature] Per-Event-Type Configurable Log Levels for Event Log [flink-agents]
via GitHub
2026/02/27
Re: [D] [Feature] Per-Event-Type Configurable Log Levels for Event Log [flink-agents]
via GitHub
2026/02/27
Re: [D] [Feature] Per-Event-Type Configurable Log Levels for Event Log [flink-agents]
via GitHub
2026/02/27
Re: [D] [Feature] Per-Event-Type Configurable Log Levels for Event Log [flink-agents]
via GitHub
2026/02/27
Re: [D] [Feature] Per-Event-Type Configurable Log Levels for Event Log [flink-agents]
via GitHub
2026/02/27
Re: [D] [Feature] Per-Event-Type Configurable Log Levels for Event Log [flink-agents]
via GitHub
2026/02/27
Re: [D] [Feature] Per-Event-Type Configurable Log Levels for Event Log [flink-agents]
via GitHub
2026/02/27
Re: [PR] [FLINK-38342][runtime] Support record rescale information. [flink]
via GitHub
2026/02/27
Re: [D] [Feature] Per-Event-Type Configurable Log Levels for Event Log [flink-agents]
via GitHub
2026/02/27
[jira] [Commented] (FLINK-39169) [mysql-connector] Use reader instances to run snapshots
Luca Occhipinti (Jira)
2026/02/27
[jira] [Commented] (FLINK-39169) [mysql-connector] Use reader instances to run snapshots
Thorne (Jira)
2026/02/27
[jira] [Commented] (FLINK-39169) [mysql-connector] Use reader instances to run snapshots
Luca Occhipinti (Jira)
2026/02/27
[jira] [Updated] (FLINK-39131) Multi-Input Processors
Salva (Jira)
2026/02/27
[jira] [Updated] (FLINK-39131) Multi-Input Processors
Salva (Jira)
2026/02/27
[jira] [Updated] (FLINK-39131) Multi-Input Processors
Salva (Jira)
2026/02/27
[jira] [Commented] (FLINK-39168) improve mysql’s snapshot-split-Cache split.splitId() result in a local variable to avoid calling the method twice per iteration:
Yanquan Lv (Jira)
2026/02/27
[jira] [Assigned] (FLINK-39168) improve mysql’s snapshot-split-Cache split.splitId() result in a local variable to avoid calling the method twice per iteration:
Yanquan Lv (Jira)
2026/02/27
[jira] [Updated] (FLINK-39168) improve mysql’s snapshot-split-Cache split.splitId() result in a local variable to avoid calling the method twice per iteration:
Yanquan Lv (Jira)
2026/02/27
[jira] [Resolved] (FLINK-39071) Select fields rather than * to read snapshot data in case of schema changes.
Yanquan Lv (Jira)
2026/02/27
[jira] [Commented] (FLINK-39168) improve mysql’s snapshot-split-Cache split.splitId() result in a local variable to avoid calling the method twice per iteration:
Thorne (Jira)
2026/02/27
[jira] [Resolved] (FLINK-39168) improve mysql’s snapshot-split-Cache split.splitId() result in a local variable to avoid calling the method twice per iteration:
Thorne (Jira)
2026/02/27
[jira] [Comment Edited] (FLINK-39169) [mysql-connector] Use reader instances to run snapshots
Thorne (Jira)
2026/02/27
[jira] [Commented] (FLINK-39169) [mysql-connector] Use reader instances to run snapshots
Thorne (Jira)
2026/02/27
[jira] [Closed] (FLINK-39177) Add Flink 2.2 to operator e2es and bump example flink versions
Gyula Fora (Jira)
2026/02/27
[jira] [Created] (FLINK-39177) Add Flink 2.2 to operator e2es and bump example flink versions
Gyula Fora (Jira)
2026/02/27
[jira] [Commented] (FLINK-38892) Introduce the scheduler and type information of the target job in the JobDetails(Info).java
Wei Zhong (Jira)
2026/02/27
[jira] [Resolved] (FLINK-38892) Introduce the scheduler and type information of the target job in the JobDetails(Info).java
Wei Zhong (Jira)
2026/02/27
[jira] [Updated] (FLINK-39175) Allow calc that contains non-deterministic func to consume duplicate changes
Xuyang Zhong (Jira)
2026/02/27
[jira] [Updated] (FLINK-39175) Allow calc that contains non-deterministic to consume duplicate changes
Xuyang Zhong (Jira)
2026/02/27
[jira] [Created] (FLINK-39176) Introduce Node Health Management & Quarantine Framework for ResourceManager
featzhang (Jira)
2026/02/27
[jira] [Closed] (FLINK-39167) Initialize source output before emitting final watermark
Roman Khachatryan (Jira)
2026/02/27
[jira] [Updated] (FLINK-38613) UnalignedCheckpointRescaleWithMixedExchangesITCase.testRescaleFromUnalignedCheckpoint failed in test_cron_jdk11 tests
Roman Khachatryan (Jira)
2026/02/27
[jira] [Updated] (FLINK-38613) UnalignedCheckpointRescaleWithMixedExchangesITCase.testRescaleFromUnalignedCheckpoint failed in test_cron_jdk11 tests
Roman Khachatryan (Jira)
2026/02/27
[jira] [Closed] (FLINK-38613) UnalignedCheckpointRescaleWithMixedExchangesITCase.testRescaleFromUnalignedCheckpoint failed in test_cron_jdk11 tests
Roman Khachatryan (Jira)
2026/02/27
[jira] [Closed] (FLINK-39134) UnalignedCheckpointFailureHandlingITCase.testCheckpointSuccessAfterFailure is flaky
Roman Khachatryan (Jira)
2026/02/27
[jira] [Comment Edited] (FLINK-39166) Add bucket level config parity
Gabor Somogyi (Jira)
2026/02/27
[jira] [Commented] (FLINK-39166) Add bucket level config parity
Gabor Somogyi (Jira)
2026/02/27
[jira] [Resolved] (FLINK-39158) Minor polish for RestAPIStabilityTestUtils to reduce redundant lines
Yuepeng Pan (Jira)
2026/02/27
[jira] [Created] (FLINK-39175) Support calc that contains non-deterministic after delta join
Xuyang Zhong (Jira)
2026/02/27
[jira] [Assigned] (FLINK-39175) Support calc that contains non-deterministic after delta join
Xuyang Zhong (Jira)
2026/02/27
[jira] [Created] (FLINK-39174) Support lookup join after delta join
Xuyang Zhong (Jira)
2026/02/27
[jira] [Commented] (FLINK-39150) Join operator crashes jobs when using custom types or custom type serializers
Piotr Przybylski (Jira)
2026/02/26
[jira] [Comment Edited] (FLINK-39150) Join operator crashes jobs when using custom types or custom type serializers
Lei Yang (Jira)
2026/02/26
[jira] [Comment Edited] (FLINK-39150) Join operator crashes jobs when using custom types or custom type serializers
Lei Yang (Jira)
2026/02/26
[jira] [Closed] (FLINK-39022) Update default cipher suite value in SecurityOptions
Gabor Somogyi (Jira)
2026/02/26
[jira] [Resolved] (FLINK-39022) Update default cipher suite value in SecurityOptions
Gabor Somogyi (Jira)
2026/02/26
[jira] [Commented] (FLINK-39022) Update default cipher suite value in SecurityOptions
Gabor Somogyi (Jira)
2026/02/26
[jira] [Commented] (FLINK-39150) Join operator crashes jobs when using custom types or custom type serializers
Lei Yang (Jira)
2026/02/26
[jira] [Created] (FLINK-39173) Support application-level blob storage
Yi Zhang (Jira)
2026/02/26
[jira] [Updated] (FLINK-38585) Pyflink's thread mode may not work when using shipped venv.zip archive as virtual env
Dian Fu (Jira)
2026/02/26
[jira] [Comment Edited] (FLINK-38585) Pyflink's thread mode may not work when using shipped venv.zip archive as virtual env
Dian Fu (Jira)
2026/02/26
[jira] [Closed] (FLINK-38585) Pyflink's thread mode may not work when using shipped venv.zip archive as virtual env
Dian Fu (Jira)
2026/02/26
[jira] [Commented] (FLINK-34644) RestServerEndpointITCase.testShouldWaitForHandlersWhenClosing failed with ConnectionClosedException
Martijn Visser (Jira)
2026/02/26
[jira] [Commented] (FLINK-34644) RestServerEndpointITCase.testShouldWaitForHandlersWhenClosing failed with ConnectionClosedException
Martijn Visser (Jira)
2026/02/26
[jira] [Commented] (FLINK-39145) UnalignedCheckpointITCase.execute fails
Martijn Visser (Jira)
2026/02/26
[jira] [Commented] (FLINK-38534) LocalRecoveryTest failed in test_cron_azure core
Martijn Visser (Jira)
2026/02/26
[jira] [Updated] (FLINK-38534) LocalRecoveryTest failed in test_cron_azure core
Martijn Visser (Jira)
2026/02/26
[jira] [Updated] (FLINK-39172) Flink Bash Scripts don't support the new yaml 1.2 syntax when reading from config.yaml
Ryan van Huuksloot (Jira)
2026/02/26
[jira] [Created] (FLINK-39172) Flink Bash Scripts don't support the new yaml 1.2 syntax when reading from config.yaml
Ryan van Huuksloot (Jira)
2026/02/26
[jira] [Updated] (FLINK-39171) Oracle pipeline transform fails with quoted uppercase projection columns
tianfy (Jira)
2026/02/26
[jira] [Updated] (FLINK-39171) Oracle pipeline transform fails with quoted uppercase projection columns
tianfy (Jira)
2026/02/26
[jira] [Updated] (FLINK-39171) Oracle pipeline transform fails with quoted uppercase projection columns
tianfy (Jira)
2026/02/26
[jira] [Created] (FLINK-39171) Oracle pipeline transform fails with quoted uppercase projection columns
tianfy (Jira)
2026/02/26
[jira] [Updated] (FLINK-38974) Handle jobs in running applications during HA recovery
Yi Zhang (Jira)
2026/02/26
[jira] [Updated] (FLINK-38974) Handle jobs during HA recovery
Yi Zhang (Jira)
2026/02/26
[jira] [Commented] (FLINK-39107) OpenTelemetryEventReporterITCase fails with ContainerLaunch Container startup failed for image
Martijn Visser (Jira)
2026/02/26
[jira] [Commented] (FLINK-39132) 'kubernetes Materialized Table test' failed because it could not not stop job
Martijn Visser (Jira)
2026/02/26
[jira] [Commented] (FLINK-38613) UnalignedCheckpointRescaleWithMixedExchangesITCase.testRescaleFromUnalignedCheckpoint failed in test_cron_jdk11 tests
Martijn Visser (Jira)
2026/02/26
[jira] [Commented] (FLINK-39145) UnalignedCheckpointITCase.execute fails
Martijn Visser (Jira)
2026/02/26
[jira] [Commented] (FLINK-34644) RestServerEndpointITCase.testShouldWaitForHandlersWhenClosing failed with ConnectionClosedException
Martijn Visser (Jira)
2026/02/26
[jira] [Updated] (FLINK-39134) UnalignedCheckpointFailureHandlingITCase.testCheckpointSuccessAfterFailure is flaky
Roman Khachatryan (Jira)
2026/02/26
[jira] [Updated] (FLINK-39134) UnalignedCheckpointFailureHandlingITCase.testCheckpointSuccessAfterFailure is flaky
Roman Khachatryan (Jira)
2026/02/26
[jira] [Updated] (FLINK-39134) UnalignedCheckpointFailureHandlingITCase.testCheckpointSuccessAfterFailure is flaky
Roman Khachatryan (Jira)
2026/02/26
[jira] [Commented] (FLINK-39126) Support exporting metrics through grpc in batches
Aleksandr Iushmanov (Jira)
2026/02/26
[jira] [Updated] (FLINK-39167) Initialize source output before emitting final watermark
Roman Khachatryan (Jira)
2026/02/26
[jira] [Updated] (FLINK-39167) Initialize source output before emitting final watermark
Roman Khachatryan (Jira)
2026/02/26
[jira] [Created] (FLINK-39170) [Table/SQL] Add async batch lookup join optimization for temporal table joins
featzhang (Jira)
2026/02/26
[jira] [Closed] (FLINK-39155) Add a check watermarks are defined in source for ERROR/NOTHING
Dawid Wysakowicz (Jira)
2026/02/26
[jira] [Commented] (FLINK-39136) GS file system fails to retry on certain 503's due to old GCS lib dependency
Jon Chase (Jira)
2026/02/26
[jira] [Comment Edited] (FLINK-39135) Backport GSBlobStorageImpl precondition check to 1.20.4
Jon Chase (Jira)
2026/02/26
[jira] [Commented] (FLINK-38225) GSBlobStorageImpl needs to add precondition check to make 503 retryable
Jon Chase (Jira)
Earlier messages
Later messages