issues
Thread
Date
Earlier messages
Messages by Date
2026/04/26
Re: [PR] [hotfix][test] Use unique sink name in `CascadedDeltaJoinITCase` [flink]
via GitHub
2026/04/26
Re: [PR] [hotfix][test] Use unique sink name in `CascadedDeltaJoinITCase` [flink]
via GitHub
2026/04/26
Re: [PR] [FLINK-33903][ci] Reenable tests in GHA [flink]
via GitHub
2026/04/26
Re: [PR] [hotfix][test] Use unique sink name in `CascadedDeltaJoinITCase` [flink]
via GitHub
2026/04/26
[PR] [FLINK-33903][ci] Reenable tests in GHA [flink]
via GitHub
2026/04/26
Re: [PR] [FLINK-39225][model] Add retry with default value fallback for triton inference failures [flink]
via GitHub
2026/04/25
[jira] [Commented] (FLINK-39502) Performance regression in remoteSortPartition and compressedFilePartition
Hao Li (Jira)
2026/04/25
[jira] [Updated] (FLINK-39546) Improve observability in flink-s3-fs-native by exposing operation-level S3 metrics
Samrat Deb (Jira)
2026/04/25
[jira] [Updated] (FLINK-39546) Improve observability in flink-s3-fs-native by exposing operation-level S3 metrics
Samrat Deb (Jira)
2026/04/25
[jira] [Updated] (FLINK-39546) Improve observability in flink-s3-fs-native by exposing operation-level S3 metrics
Samrat Deb (Jira)
2026/04/25
[jira] [Updated] (FLINK-39546) Improve observability in flink-s3-fs-native by exposing operation-level S3 metrics
Samrat Deb (Jira)
2026/04/25
[jira] [Updated] (FLINK-39546) Improve observability in flink-s3-fs-native by exposing operation-level S3 metrics
Samrat Deb (Jira)
2026/04/25
[jira] [Created] (FLINK-39546) Improve observability in flink-s3-fs-native by exposing operation-level S3 metrics
Samrat Deb (Jira)
2026/04/25
[jira] [Created] (FLINK-39544) Improve observability in flink-s3-fs-native by exposing operation-level S3 metrics
Samrat Deb (Jira)
2026/04/25
[jira] [Created] (FLINK-39545) Improve observability in flink-s3-fs-native by exposing operation-level S3 metrics
Samrat Deb (Jira)
2026/04/25
[jira] [Created] (FLINK-39543) Improve observability in flink-s3-fs-native by exposing operation-level S3 metrics
Samrat Deb (Jira)
2026/04/25
[jira] [Commented] (FLINK-39425) [flink-metrics-otel] OpenTelemetryEventReporter ignores service.name and service.version config
Paras Negi (Jira)
2026/04/25
Re: [PR] [FLINK-39542] Upgrade avro to 1.11.5 that patches CVE-2025-33042 [flink]
via GitHub
2026/04/25
[jira] [Updated] (FLINK-39542) Upgrade to avro 1.11.5
ASF GitHub Bot (Jira)
2026/04/25
[PR] [FLINK-39542] Upgrade avro to 1.11.5 that patches CVE-2025-33042 [flink]
via GitHub
2026/04/25
[jira] [Updated] (FLINK-39542) Upgrade to avro 1.11.5
Samrat Deb (Jira)
2026/04/25
[jira] [Created] (FLINK-39542) Upgrade to avro 1.11.5
Samrat Deb (Jira)
2026/04/25
Re: [PR] (demo for Jira issue) [FLINK-TODO] Test table-planner loading [flink]
via GitHub
2026/04/25
Re: [PR] [FLINK-39009] Support PostgreSQL unnest insert in dynamic table. [flink-connector-jdbc]
via GitHub
2026/04/25
[jira] [Comment Edited] (FLINK-38617) Kafka consumer do not commit offset when stop-with-savepoint
Hang JI (Jira)
2026/04/25
[jira] [Comment Edited] (FLINK-38617) Kafka consumer do not commit offset when stop-with-savepoint
Hang JI (Jira)
2026/04/25
[jira] [Comment Edited] (FLINK-38617) Kafka consumer do not commit offset when stop-with-savepoint
Hang JI (Jira)
2026/04/25
[jira] [Comment Edited] (FLINK-38617) Kafka consumer do not commit offset when stop-with-savepoint
Hang JI (Jira)
2026/04/25
[jira] [Commented] (FLINK-38617) Kafka consumer do not commit offset when stop-with-savepoint
Hang JI (Jira)
2026/04/25
Re: [PR] [FLINK-39225][model] Add retry with default value fallback for triton inference failures [flink]
via GitHub
2026/04/25
Re: [PR] [FLINK-39092][SQL] Enhance EXPLAIN plan to display watermark specification [flink]
via GitHub
2026/04/25
Re: [PR] [FLINK-39225][model] Add retry with default value fallback for triton inference failures [flink]
via GitHub
2026/04/25
Re: [PR] [FLINK-39225][model] Add retry with default value fallback for triton inference failures [flink]
via GitHub
2026/04/25
[jira] [Updated] (FLINK-38857) Introduce a Triton inference module for batch-oriented AI inference
Yuepeng Pan (Jira)
2026/04/25
Re: [PR] [FLINK-38857][model] Add sequence ID auto-increment support for Triton inference [flink]
via GitHub
2026/04/25
[PR] [Feature][Java] Add java event listeners config [flink-agents]
via GitHub
2026/04/25
Re: [PR] [BP-2.2][FLINK-33903][ci] Reenable tests in GHA [flink]
via GitHub
2026/04/25
Re: [PR] [FLINK-39281] Flink Connector redis stream Source [flink-connector-redis-streams]
via GitHub
2026/04/25
[PR] [BP-2.2][FLINK-33903][ci] Reenable tests in GHA [flink]
via GitHub
2026/04/25
Re: [PR] [BP-2.1][FLINK-33903][ci] Reenable tests in GHA [flink]
via GitHub
2026/04/25
[PR] [BP-2.1][FLINK-33903][ci] Reenable tests in GHA [flink]
via GitHub
2026/04/25
Re: [PR] [BP-2.0][FLINK-33903][ci] Reenable tests in GHA [flink]
via GitHub
2026/04/25
[PR] [BP-2.0][FLINK-33903][ci] Reenable tests in GHA [flink]
via GitHub
2026/04/25
Re: [PR] [FLINK-38857][model] Add sequence ID auto-increment support for Triton inference [flink]
via GitHub
2026/04/25
Re: [PR] [hotfix][test] Use unique sink name in `CascadedDeltaJoinITCase` [flink]
via GitHub
2026/04/25
Re: [PR] [FLINK-39225][model] Add retry with default value fallback for triton inference failures [flink]
via GitHub
2026/04/25
[jira] [Assigned] (FLINK-39225) Add retry with default value fallback for triton inference failures
Dian Fu (Jira)
2026/04/25
[I] [Feature][Java] Add `EventListener` config [flink-agents]
via GitHub
2026/04/25
Re: [PR] [hotfix][tests] Replace deprecated Thread#stop [flink]
via GitHub
2026/04/25
Re: [PR] [hotfix][tests] Replace deprecated Thread#stop [flink]
via GitHub
2026/04/25
Re: [PR] [FLINK-35180][python] Fix embedded (thread-mode) type converters [flink]
via GitHub
2026/04/25
Re: [PR] [FLINK-35180][python] Fix embedded (thread-mode) type converters [flink]
via GitHub
2026/04/24
Re: [PR] [FLINK-35180][python] Fix embedded (thread-mode) type converters [flink]
via GitHub
2026/04/24
Re: [PR] [FLINK-37544] Replace Timer with single thread scheduled executor for BlobServer [flink]
via GitHub
2026/04/24
Re: [PR] [FLINK-37544] Replace Timer with single thread scheduled executor for BlobServer [flink]
via GitHub
2026/04/24
[jira] [Commented] (FLINK-38857) Introduce a Triton inference module for batch-oriented AI inference
Dian Fu (Jira)
2026/04/24
Re: [PR] [FLINK-38857][models] Add health check and circuit breaker for Triton inference [flink]
via GitHub
2026/04/24
[jira] [Commented] (FLINK-39465) Release Testing Instructions: FLIP-555: Flink Native S3 FileSystem
Samrat Deb (Jira)
2026/04/24
[PR] [Feature][Java] Move MCP resource discovery to runtime [flink-agents]
via GitHub
2026/04/24
Re: [PR] [FLINK-39422] [REST][docs] Fix OpenAPI spec for `SlotSharingGroupId`, `MetricCollectionResponseBody`, and `SerializedThrowable` custom serializers [flink]
via GitHub
2026/04/24
Re: [PR] [FLINK-39422] [REST][docs] Fix OpenAPI spec for `SlotSharingGroupId`, `MetricCollectionResponseBody`, and `SerializedThrowable` custom serializers [flink]
via GitHub
2026/04/24
Re: [PR] [FLINK-39422] [REST][docs] Fix OpenAPI spec for `SlotSharingGroupId`, `MetricCollectionResponseBody`, and `SerializedThrowable` custom serializers [flink]
via GitHub
2026/04/24
Re: [PR] (demo for Jira issue) [FLINK-TODO] Test table-planner loading [flink]
via GitHub
2026/04/24
[PR] (demo for Jira issue) [FLINK-TODO] Test table-planner loading [flink]
via GitHub
2026/04/24
Re: [PR] [FLINK-37766] FlinkSessionJob deletion blocked by finalizer [flink-kubernetes-operator]
via GitHub
2026/04/24
[PR] [FLINK-39541] Improve operator metrics documentation and bundle addit… [flink-kubernetes-operator]
via GitHub
2026/04/24
[jira] [Updated] (FLINK-39541) Improve operator metrics documentation and bundle additional metric reporters
Dennis-Mircea Ciupitu (Jira)
2026/04/24
[jira] [Updated] (FLINK-39541) Improve operator metrics documentation and bundle additional metric reporters
Dennis-Mircea Ciupitu (Jira)
2026/04/24
[jira] [Created] (FLINK-39541) Improve operator metrics documentation and bundle additional metric reporters
Dennis-Mircea Ciupitu (Jira)
2026/04/24
Re: [PR] [hotfix][test] Use unique sink name in `CascadedDeltaJoinITCase` [flink]
via GitHub
2026/04/24
Re: [PR] [hotfix][test] Use unique sink name in `CascadedDeltaJoinITCase` [flink]
via GitHub
2026/04/24
[PR] [hotfix][test] Use unique sink name in `CascadedDeltaJoinITCase` [flink]
via GitHub
2026/04/24
Re: [PR] [FLINK-39533][s3] Use abort() instead of drain on close/seek when remaining bytes exceed threshold in NativeS3InputStream [flink]
via GitHub
2026/04/24
Re: [PR] [FLINK-39533][s3] Use abort() instead of drain on close/seek when remaining bytes exceed threshold in NativeS3InputStream [flink]
via GitHub
2026/04/24
Re: [PR] [FLINK-39533][s3] Use abort() instead of drain on close/seek when remaining bytes exceed threshold in NativeS3InputStream [flink]
via GitHub
2026/04/24
Re: [PR] [FLINK-39533][s3] Use abort() instead of drain on close/seek when remaining bytes exceed threshold in NativeS3InputStream [flink]
via GitHub
2026/04/24
Re: [PR] [FLINK-39533][s3] Use abort() instead of drain on close/seek when remaining bytes exceed threshold in NativeS3InputStream [flink]
via GitHub
2026/04/24
Re: [PR] [FLINK-39533][s3] Use abort() instead of drain on close/seek when remaining bytes exceed threshold in NativeS3InputStream [flink]
via GitHub
2026/04/24
Re: [PR] [FLINK-39490][web] Improve feedback when cluster is unreachable [flink]
via GitHub
2026/04/24
Re: [PR] [FLINK-39512][api] extend plugin with open and close life cycle [flink]
via GitHub
2026/04/24
Re: [PR] [FLINK-39540][Connectors/Kinesis] Removed resubscription for EFO subscriptions when they are completed [flink-connector-aws]
via GitHub
2026/04/24
Re: [PR] [hotfix][tests] Replace deprecated Thread#stop [flink]
via GitHub
2026/04/24
[PR] [hotfix][tests] Replace deprecated Thread#stop [flink]
via GitHub
2026/04/24
[jira] [Resolved] (FLINK-31070) Update jline to 3.29.0
Sergey Nuyanzin (Jira)
2026/04/24
[jira] [Commented] (FLINK-31070) Update jline to 3.29.0
Sergey Nuyanzin (Jira)
2026/04/24
[jira] [Assigned] (FLINK-31070) Update jline to 3.29.0
Sergey Nuyanzin (Jira)
2026/04/24
Re: [PR] [FLINK-31070][table] Bump jline to 3.29.0 [flink]
via GitHub
2026/04/24
Re: [PR] [FLINK-31070][table] Bump jline to 3.29.0 [flink]
via GitHub
2026/04/24
Re: [PR] [FLINK-37834] Flink JDBC support ClickHouse Dialect [flink-connector-jdbc]
via GitHub
2026/04/24
Re: [PR] [FLINK-37834] Flink JDBC support ClickHouse Dialect [flink-connector-jdbc]
via GitHub
2026/04/24
Re: [PR] [FLINK-39540][Connectors/Kinesis] Removed resubscription for EFO subscriptions when they are completed [flink-connector-aws]
via GitHub
2026/04/24
Re: [PR] [FLINK-39539][table] Document changelog processing in AGENTS.md [flink]
via GitHub
2026/04/24
[jira] [Updated] (FLINK-39539) Extend planner's Agents.md with more detailed information for our internal table module CDC processing
ASF GitHub Bot (Jira)
2026/04/24
[jira] [Updated] (FLINK-39540) Kinesis Connector - Removed resubscription for EFO subscriptions when they are completed
Ryan Pelaez (Jira)
2026/04/24
[PR] [FLINK-39539][table] Document changelog processing in AGENTS.md [flink]
via GitHub
2026/04/24
[jira] [Assigned] (FLINK-39539) Extend planner's Agents.md with more detailed information for our internal table module CDC processing
Gustavo de Morais (Jira)
2026/04/24
Re: [PR] [FLINK-39540][Connectors/Kinesis] Removed resubscription for EFO subscriptions when they are completed [flink-connector-aws]
via GitHub
2026/04/24
[jira] [Updated] (FLINK-39540) Kinesis Connector - EFO Issue when resharding - IllegalArgumentException
ASF GitHub Bot (Jira)
2026/04/24
Re: [PR] [FLINK-39540][Connectors/Kinesis] Removed resubscription for EFO subscriptions when they are completed [flink-connector-aws]
via GitHub
2026/04/24
Re: [PR] [FLINK-39506] Build with Flink version 2 [flink-connector-http]
via GitHub
2026/04/24
[jira] [Comment Edited] (FLINK-39535) Improve Unit Test & coverage
Gabor Somogyi (Jira)
2026/04/24
[jira] [Commented] (FLINK-39535) Improve Unit Test & coverage
Gabor Somogyi (Jira)
2026/04/24
[jira] [Resolved] (FLINK-39514) Dynamic Kafka source readers do not release splits after removal
Bowen Li (Jira)
2026/04/24
[jira] [Commented] (FLINK-39514) Dynamic Kafka source readers do not release splits after removal
Bowen Li (Jira)
2026/04/24
[jira] [Updated] (FLINK-39514) Dynamic Kafka source readers do not release splits after removal
Bowen Li (Jira)
2026/04/24
[jira] [Commented] (FLINK-39514) Dynamic Kafka source readers do not release splits after removal
Bowen Li (Jira)
2026/04/24
[jira] [Updated] (FLINK-39514) Dynamic Kafka source readers do not release splits after removal
Bowen Li (Jira)
2026/04/24
[jira] [Updated] (FLINK-39514) Dynamic Kafka source readers do not release splits after removal
Bowen Li (Jira)
2026/04/24
[jira] [Assigned] (FLINK-39514) Dynamic Kafka source readers do not release splits after removal
Bowen Li (Jira)
2026/04/24
Re: [PR] [FLINK-39514] Release dynamic Kafka split outputs on metadata shrink [flink-connector-kafka]
via GitHub
2026/04/24
[jira] [Updated] (FLINK-39540) Kinesis Connector - EFO Issue when resharding - IllegalArgumentException
Ryan Pelaez (Jira)
2026/04/24
[jira] [Updated] (FLINK-39540) Kinesis Connector - EFO Issue when resharding - IllegalArgumentException
Ryan Pelaez (Jira)
2026/04/24
[jira] [Created] (FLINK-39540) Kinesis Connector - EFO Issue when resharding - IllegalArgumentException
Ryan Pelaez (Jira)
2026/04/24
Re: [PR] [FLINK-TBD][Connectors/Kinesis] Removed resubscription for EFO subscriptions when they are completed [flink-connector-aws]
via GitHub
2026/04/24
[jira] [Created] (FLINK-39539) Extend planner's Agents.md with more detailed information for our internal table module CDC processing
Gustavo de Morais (Jira)
2026/04/24
[jira] [Resolved] (FLINK-39293) SqlParserException if I select from a view that uses MATCH_RECOGNIZE
Sergey Nuyanzin (Jira)
2026/04/24
[jira] [Assigned] (FLINK-39293) SqlParserException if I select from a view that uses MATCH_RECOGNIZE
Sergey Nuyanzin (Jira)
2026/04/24
[jira] [Commented] (FLINK-39293) SqlParserException if I select from a view that uses MATCH_RECOGNIZE
Sergey Nuyanzin (Jira)
2026/04/24
[jira] [Commented] (FLINK-39293) SqlParserException if I select from a view that uses MATCH_RECOGNIZE
Sergey Nuyanzin (Jira)
2026/04/24
Re: [PR] [BP-2.2][FLINK-39293][table] `MATCH_RECOGNIZE` fails with `SqlParserException` in views [flink]
via GitHub
2026/04/24
Re: [PR] [BP-2.2][FLINK-39293][table] `MATCH_RECOGNIZE` fails with `SqlParserException` in views [flink]
via GitHub
2026/04/24
[jira] [Comment Edited] (FLINK-39131) Multi-Input Processors
Salva (Jira)
2026/04/24
[jira] [Commented] (FLINK-39293) SqlParserException if I select from a view that uses MATCH_RECOGNIZE
Sergey Nuyanzin (Jira)
2026/04/24
Re: [PR] [BP-2.3][FLINK-39293][table] `MATCH_RECOGNIZE` fails with `SqlParserException` in views [flink]
via GitHub
2026/04/24
[jira] [Commented] (FLINK-39293) SqlParserException if I select from a view that uses MATCH_RECOGNIZE
Sergey Nuyanzin (Jira)
2026/04/24
Re: [PR] [FLINK-39293][table] `MATCH_RECOGNIZE` fails with `SqlParserException` in views [flink]
via GitHub
2026/04/24
Re: [PR] [FLINK-39293][table] `MATCH_RECOGNIZE` fails with `SqlParserException` in views [flink]
via GitHub
2026/04/24
Re: [PR] [BP-2.2][FLINK-39293][table] `MATCH_RECOGNIZE` fails with `SqlParserException` in views [flink]
via GitHub
2026/04/24
Re: [PR] [FLINK-31070][table] Bump jline to 3.29.0 [flink]
via GitHub
2026/04/24
Re: [PR] [FLINK-31070][table] Bump jline to 3.29.0 [flink]
via GitHub
2026/04/24
Re: [PR] [FLINK-31070][table] Bump jline to 3.29.0 [flink]
via GitHub
2026/04/24
Re: [PR] [FLINK-33903][ci] Reenable tests in GHA [flink]
via GitHub
2026/04/24
Re: [PR] [FLINK-39533][s3] Use abort() instead of drain on close/seek when remaining bytes exceed threshold in NativeS3InputStream [flink]
via GitHub
2026/04/24
Re: [PR] [FLINK-39513][checkpointing] Parameterize allowNonRestoredState in restoreInitialCheckpointIfPresent [flink]
via GitHub
2026/04/24
[jira] [Updated] (FLINK-33903) Reenable tests that edit file permissions
ASF GitHub Bot (Jira)
2026/04/24
[PR] [FLINK-33903][ci] Reenable tests in GHA [flink]
via GitHub
2026/04/24
Re: [PR] [FLINK-39533][s3] Use abort() instead of drain on close/seek when remaining bytes exceed threshold in NativeS3InputStream [flink]
via GitHub
2026/04/24
Re: [PR] [FLINK-39533][s3] Use abort() instead of drain on close/seek when remaining bytes exceed threshold in NativeS3InputStream [flink]
via GitHub
2026/04/24
Re: [PR] [FLINK-39533][s3] Use abort() instead of drain on close/seek when remaining bytes exceed threshold in NativeS3InputStream [flink]
via GitHub
2026/04/24
Re: [PR] [FLINK-39533][s3] Use abort() instead of drain on close/seek when remaining bytes exceed threshold in NativeS3InputStream [flink]
via GitHub
2026/04/24
Re: [PR] Cross Language Unified Event [flink-agents]
via GitHub
2026/04/24
[jira] [Commented] (FLINK-39131) Multi-Input Processors
Salva (Jira)
2026/04/24
[jira] [Closed] (FLINK-39421) Metadata filter push-down for table sources
Timo Walther (Jira)
2026/04/24
Re: [PR] [FLINK-39533][s3] Use abort() instead of drain on close/seek when remaining bytes exceed threshold in NativeS3InputStream [flink]
via GitHub
2026/04/24
Re: [PR] [FLINK-39421] Metadata filter push-down for table sources [flink]
via GitHub
2026/04/24
Re: [PR] [FLINK-39533][s3] Use abort() instead of drain on close/seek when remaining bytes exceed threshold in NativeS3InputStream [flink]
via GitHub
2026/04/24
Re: [PR] Cross Language Unified Event [flink-agents]
via GitHub
2026/04/24
Re: [PR] [FLINK-39533][s3] Use abort() instead of drain on close/seek when remaining bytes exceed threshold in NativeS3InputStream [flink]
via GitHub
2026/04/24
Re: [PR] [FLINK-39533][s3] Use abort() instead of drain on close/seek when remaining bytes exceed threshold in NativeS3InputStream [flink]
via GitHub
2026/04/24
Re: [PR] [FLINK-39533][s3] Use abort() instead of drain on close/seek when remaining bytes exceed threshold in NativeS3InputStream [flink]
via GitHub
2026/04/24
Re: [PR] Apply conditional SET_SEMANTIC_TABLE trait to FROM_CHANGELOG [flink]
via GitHub
2026/04/24
[PR] Apply conditional SET_SEMANTIC_TABLE trait to FROM_CHANGELOG [flink]
via GitHub
2026/04/24
Re: [PR] [FLINK-39533][s3] Use abort() instead of drain on close/seek when remaining bytes exceed threshold in NativeS3InputStream [flink]
via GitHub
2026/04/24
Re: [PR] [FLINK-32609] Support Projection Pushdown [flink-connector-kafka]
via GitHub
2026/04/24
Re: [PR] [FLINK-39533][s3] Use abort() instead of drain on close/seek when remaining bytes exceed threshold in NativeS3InputStream [flink]
via GitHub
2026/04/24
Re: [PR] [FLINK-39533][s3] Use abort() instead of drain on close/seek when remaining bytes exceed threshold in NativeS3InputStream [flink]
via GitHub
2026/04/24
Re: [PR] [FLINK-39533][s3] Use abort() instead of drain on close/seek when remaining bytes exceed threshold in NativeS3InputStream [flink]
via GitHub
2026/04/24
Re: [PR] [FLINK-39533][s3] Use abort() instead of drain on close/seek when remaining bytes exceed threshold in NativeS3InputStream [flink]
via GitHub
2026/04/24
Re: [PR] [FLINK-39533][s3] Use abort() instead of drain on close/seek when remaining bytes exceed threshold in NativeS3InputStream [flink]
via GitHub
2026/04/24
Re: [PR] [FLINK-36753][runtime]Adaptive Scheduler actively triggers a Checkpoint after all resources are ready [flink]
via GitHub
2026/04/24
Re: [PR] [hotfix][flink-connector-base] Fix duplicated dependency & plugin [flink]
via GitHub
2026/04/24
[jira] [Updated] (FLINK-39538) FROM_CHANGELOG: Flat stream with op codes → upsert stream
Ramin Gharib (Jira)
2026/04/24
[jira] [Updated] (FLINK-39538) FROM_CHANGELOG: Flat stream with op codes → upsert stream
Ramin Gharib (Jira)
2026/04/24
[jira] [Created] (FLINK-39538) Apply conditional SET_SEMANTIC_TABLE trait to FROM_CHANGELOG
Ramin Gharib (Jira)
2026/04/24
[jira] [Created] (FLINK-39537) Apply conditional SET_SEMANTIC_TABLE trait to FROM_CHANGELOG
Ramin Gharib (Jira)
2026/04/24
[jira] [Updated] (FLINK-39533) Use abort() instead of drain on close/seek when remaining bytes exceed threshold in NativeS3InputStream
Gabor Somogyi (Jira)
2026/04/24
[jira] [Assigned] (FLINK-39533) Use abort() instead of drain on close/seek when remaining bytes exceed threshold in NativeS3InputStream
Gabor Somogyi (Jira)
2026/04/24
Re: [PR] [hotfix][flink-tests] Fix duplicated dependency & plugin [flink]
via GitHub
2026/04/24
[PR] [hotfix][flink-connector-base] Fix duplicated dependency & plugin [flink]
via GitHub
2026/04/24
[PR] [hotfix][flink-tests] Fix duplicated dependency & plugin [flink]
via GitHub
2026/04/24
Re: [PR] [FLINK-39516][web dashboard] Address npm security advisories in flink-runtime-web web-dashboard [flink]
via GitHub
2026/04/24
Re: [PR] [FLINK-39513][checkpointing] Parameterize allowNonRestoredState in restoreInitialCheckpointIfPresent [flink]
via GitHub
2026/04/24
Re: [PR] [FLINK-39481][tests] Fix flaky WindowDistinctAggregateITCase#testCumulateWindow_GroupingSets [flink]
via GitHub
2026/04/24
Re: [PR] [FLINK-39533][s3] Use abort() instead of drain on close/seek when remaining bytes exceed threshold in NativeS3InputStream [flink]
via GitHub
2026/04/24
[jira] [Commented] (FLINK-39218) Introduce Flink-Kafka Transactions Management Tool
Aleksandr Savonin (Jira)
2026/04/24
[jira] [Commented] (FLINK-39293) SqlParserException if I select from a view that uses MATCH_RECOGNIZE
Sergey Nuyanzin (Jira)
2026/04/24
Re: [PR] [FLINK-38418][python] Support pickling Instants when collecting TIMESTAMP_LTZ types in PyFlink [flink]
via GitHub
2026/04/24
Re: [PR] [FLINK-31070][table] Bump jline to 3.29.0 [flink]
via GitHub
2026/04/24
[PR] [FLINK-31070][table] Bump jline to 3.29.0 [flink]
via GitHub
2026/04/24
[jira] [Updated] (FLINK-31070) Update jline to 3.29.0
Sergey Nuyanzin (Jira)
2026/04/24
Re: [PR] [BP-2.3][FLINK-39293][table] `MATCH_RECOGNIZE` fails with `SqlParserException` in views [flink]
via GitHub
2026/04/24
Re: [PR] [BP-2.2][FLINK-39293][table] `MATCH_RECOGNIZE` fails with `SqlParserException` in views [flink]
via GitHub
2026/04/24
[PR] [BP-2.3][FLINK-39293][table] `MATCH_RECOGNIZE` fails with `SqlParserException` in views [flink]
via GitHub
2026/04/24
[PR] [BP-2.2][FLINK-39293][table] `MATCH_RECOGNIZE` fails with `SqlParserException` in views [flink]
via GitHub
2026/04/24
Re: [PR] [FLINK-36753][runtime]Adaptive Scheduler actively triggers a Checkpoint after all resources are ready [flink]
via GitHub
2026/04/24
Re: [PR] [FLINK-39513][checkpointing] Parameterize allowNonRestoredState in restoreInitialCheckpointIfPresent [flink]
via GitHub
2026/04/24
Re: [PR] [FLINK-36753][runtime]Adaptive Scheduler actively triggers a Checkpoint after all resources are ready [flink]
via GitHub
2026/04/24
Re: [PR] [FLINK-39534][python] Bump pemja to 0.5.7 [flink]
via GitHub
2026/04/24
Re: [PR] [FLINK-39506] Build with Flink version 2 [flink-connector-http]
via GitHub
2026/04/24
Re: [PR] [FLINK-39534][python] Bump pemja to 0.5.7 [flink]
via GitHub
2026/04/24
Re: [PR] [FLINK-39534][python] Bump pemja to 0.5.7 [flink]
via GitHub
2026/04/24
Re: [PR] [FLINK-39534][python] Bump pemja to 0.5.7 [flink]
via GitHub
2026/04/24
Re: [PR] [FLINK-39534][python] Bump pemja to 0.5.7 [flink]
via GitHub
2026/04/24
Re: [PR] [feature] Enable EventLog display in WebUI by default [flink-agents]
via GitHub
2026/04/24
[jira] [Updated] (FLINK-39506) Update Flink HTTP connector to be based on Flink 2
ASF GitHub Bot (Jira)
2026/04/24
[PR] [FLINK-39506] Build with Flink version 2 [flink-connector-http]
via GitHub
2026/04/24
Re: [PR] [FLINK-36753][runtime]Adaptive Scheduler actively triggers a Checkpoint after all resources are ready [flink]
via GitHub
2026/04/24
Re: [PR] [FLINK-36753][runtime]Adaptive Scheduler actively triggers a Checkpoint after all resources are ready [flink]
via GitHub
2026/04/24
Re: [PR] [FLINK-39392][table] Support conditional traits for PTFs [flink]
via GitHub
2026/04/24
Re: [PR] [FLINK-39392][table] Support conditional traits for PTFs [flink]
via GitHub
Earlier messages