issues
Thread
Date
Earlier messages
Later messages
Messages by Date
2026/08/16
[jira] [Updated] (FLINK-40397) Add currentBinlogPositionLag metric for MySQL binlog reader
wangkang (Jira)
2026/08/16
Re: [PR] Bump org.apache.logging.log4j:log4j-api from 2.25.4 to 2.25.5 [flink-connector-kafka]
via GitHub
2026/08/16
[jira] [Created] (FLINK-40398) flink-connector-kafka DynamicKafkaSourceReaderTest.testHandleSourceEventRetainsRemovedClusterOffsetsUntilExpired flakiness
Efrat Levitan (Jira)
2026/08/16
[jira] [Commented] (FLINK-40398) flink-connector-kafka DynamicKafkaSourceReaderTest.testHandleSourceEventRetainsRemovedClusterOffsetsUntilExpired flakiness
Efrat Levitan (Jira)
2026/08/16
[jira] [Updated] (FLINK-40397) Add currentBinlogPositionLag metric for MySQL binlog reader
wangkang (Jira)
2026/08/16
[jira] [Updated] (FLINK-40397) Add currentBinlogPositionLag metric for MySQL binlog reader
wangkang (Jira)
2026/08/16
[jira] [Created] (FLINK-40397) Add currentBinlogPositionLag metric for MySQL binlog reader
wangkang (Jira)
2026/08/16
Re: [PR] [Feature][api][runtime] Support auto resolve memory reference for passing data across actions. [flink-agents]
via GitHub
2026/08/15
Re: [PR] [infra] Derive and validate the Flink versions tools/ut.sh uses [flink-agents]
via GitHub
2026/08/15
Re: [PR] [api][plan][runtime][examples] Add pluggable in-chat model routing (MODEL_ROUTER) [flink-agents]
via GitHub
2026/08/15
Re: [PR] [api][plan][runtime][examples] Add pluggable in-chat model routing (MODEL_ROUTER) [flink-agents]
via GitHub
2026/08/15
Re: [PR] [api][plan][runtime][examples] Add pluggable in-chat model routing (MODEL_ROUTER) [flink-agents]
via GitHub
2026/08/15
Re: [PR] [hotfix][runtime] Close every component when an earlier close fails [flink-agents]
via GitHub
2026/08/15
Re: [D] Planning Flink Agents 0.4 [flink-agents]
via GitHub
2026/08/15
Re: [PR] [FLINK-40390][table] Optimised JSON_LENGTH codegen [flink]
via GitHub
2026/08/15
Re: [PR] [FLINK-39904][table] Add GEOGRAPHY logical type support [flink]
via GitHub
2026/08/15
Re: [PR] [hotfix][docs] Fix temporal table function expression examples [flink]
via GitHub
2026/08/15
Re: [PR] [hotfix][docs] Remove dangling references to removed Hive connector docs [flink]
via GitHub
2026/08/15
Re: [PR] [FLINK-40289][docs] Clarify watermark requirements in Window Top-N examples [flink]
via GitHub
2026/08/15
Re: [PR] [FLINK-40290][metrics] Fix duplicate quantile 1.0 in OpenTelemetry histogram summary [flink]
via GitHub
2026/08/15
Re: [PR] [FLINK-40383][docs] Reorder Glossary entries alphabetically [flink]
via GitHub
2026/08/15
Re: [PR] [FLINK-39904][table] Add GEOGRAPHY logical type support [flink]
via GitHub
2026/08/15
Re: [PR] [api][plan][runtime][examples] Add pluggable in-chat model routing (MODEL_ROUTER) [flink-agents]
via GitHub
2026/08/15
Re: [PR] [api][plan][runtime][examples] Add pluggable in-chat model routing (MODEL_ROUTER) [flink-agents]
via GitHub
2026/08/15
Re: [PR] [hotfix][runtime] Close every component when an earlier close fails [flink-agents]
via GitHub
2026/08/15
Re: [PR] [FLINK-40368][table-planner] Fix deduplication changelog inference [flink]
via GitHub
2026/08/15
Re: [PR] [FLINK-40368][table-planner] Fix deduplication changelog inference [flink]
via GitHub
2026/08/15
[PR] [FLINK-40368][table-planner] Fix deduplication changelog inference [flink]
via GitHub
2026/08/15
Re: [PR] [FLINK-40390][table] Optimised JSON_LENGTH codegen [flink]
via GitHub
2026/08/15
[jira] [Updated] (FLINK-40368) Deduplicate output should only be insert-only when ordered by time attribute
ASF GitHub Bot (Jira)
2026/08/15
Re: [PR] [FLINK-40390][table] Optimised JSON_LENGTH codegen [flink]
via GitHub
2026/08/15
Re: [PR] [FLINK-40175][State Catalog] State Catalog initial catalog functionality and keyed state support [flink]
via GitHub
2026/08/15
Re: [PR] [FLINK-39874][s3] Make temp-file cleanup idempotent in NativeS3RecoverableFsDataOutputStream [flink]
via GitHub
2026/08/14
Re: [PR] [FLINK-39291][API / Type Serialization System] FlinkScalaKryoInstantiator InstantiatorStrategy fix [flink]
via GitHub
2026/08/14
Re: [PR] [FLINK-39291][API / Type Serialization System] FlinkScalaKryoInstantiator InstantiatorStrategy fix [flink]
via GitHub
2026/08/14
Re: [PR] [docs] Document Action trigger conditions [flink-agents]
via GitHub
2026/08/14
Re: [PR] [FLINK-40196][python] Add missing-value handling to DataFrame API [flink]
via GitHub
2026/08/14
[jira] [Updated] (FLINK-40196) Add missing-value handling to DataFrame API
ASF GitHub Bot (Jira)
2026/08/14
[PR] [FLINK-40196][python] Add missing-value handling to DataFrame API [flink]
via GitHub
2026/08/14
Re: [PR] [FLINK-39874][s3] Make temp-file cleanup idempotent in NativeS3RecoverableFsDataOutputStream [flink]
via GitHub
2026/08/14
Re: [PR] [FLINK-40390][table] Optimised JSON_LENGTH codegen [flink]
via GitHub
2026/08/14
[jira] [Commented] (FLINK-40391) PTF table argument with a non-default conversion class might fail
Sergey Nuyanzin (Jira)
2026/08/14
[jira] [Updated] (FLINK-40391) PTF table argument with a non-default conversion class might fail
Sergey Nuyanzin (Jira)
2026/08/14
Re: [PR] [BP-2.3][FLINK-40391][table] PTF with non default convertion-class of table arg might fail [flink]
via GitHub
2026/08/14
[jira] [Updated] (FLINK-40390) Validate JSON_LENGTH path prefixes at plan time and reuse the shared JSON codegen
ASF GitHub Bot (Jira)
2026/08/14
[PR] [FLINK-40390][table] Optimised JSON_LENGTH codegen [flink]
via GitHub
2026/08/14
[jira] [Commented] (FLINK-25802) OverWindow in batch mode failed
Sergey Nuyanzin (Jira)
2026/08/14
[jira] [Updated] (FLINK-25802) OverWindow in batch mode failed
Sergey Nuyanzin (Jira)
2026/08/14
[jira] [Commented] (FLINK-30499) Over window codegen error when member code incorrectly used in method body
Sergey Nuyanzin (Jira)
2026/08/14
[jira] [Updated] (FLINK-30499) Over window codegen error when member code incorrectly used in method body
Sergey Nuyanzin (Jira)
2026/08/14
Re: [PR] [FLINK-25802][FLINK-30499][table-planner] Fix TIMESTAMP codegen for RANGE OVER window bounds [flink]
via GitHub
2026/08/14
Re: [PR] [FLINK-25802][FLINK-30499][table-planner] Fix TIMESTAMP codegen for RANGE OVER window bounds [flink]
via GitHub
2026/08/14
Re: [PR] [FLINK-25802][FLINK-30499][table-planner] Fix TIMESTAMP codegen for RANGE OVER window bounds [flink]
via GitHub
2026/08/14
[jira] [Commented] (FLINK-25802) OverWindow in batch mode failed
Sergey Nuyanzin (Jira)
2026/08/14
[jira] [Updated] (FLINK-25802) OverWindow in batch mode failed
Sergey Nuyanzin (Jira)
2026/08/14
[jira] [Updated] (FLINK-30499) Over window codegen error when member code incorrectly used in method body
Sergey Nuyanzin (Jira)
2026/08/14
[jira] [Commented] (FLINK-30499) Over window codegen error when member code incorrectly used in method body
Sergey Nuyanzin (Jira)
2026/08/14
Re: [PR] [FLINK-25802][FLINK-30499][table-planner] Fix TIMESTAMP codegen for RANGE OVER window bounds [flink]
via GitHub
2026/08/14
Re: [PR] [FLINK-40248][ci] Add nightly snapshot publishing to GHA pipeline [flink]
via GitHub
2026/08/14
Re: [PR] [FLINK-40248][ci] Add nightly snapshot publishing to GHA pipeline [flink]
via GitHub
2026/08/14
Re: [PR] [hotfix][ci] Bump github-script to v9 in action.yml [flink]
via GitHub
2026/08/14
Re: [PR] [FLINK-37908] Resolve EFO-enabled KinesisStreamsSource initialization failure on automated restarts [flink-connector-aws]
via GitHub
2026/08/14
Re: [PR] [BP-2.3][FLINK-40391][table] PTF with non default convertion-class of table arg might fail [flink]
via GitHub
2026/08/14
[PR] [BP-2.3][FLINK-40391][table] PTF with non default convertion-class of table arg might fail [flink]
via GitHub
2026/08/14
Re: [PR] [FLINK-37666] CWE-378: Creation of Temporary File With Insecure Permissions in Temporary File Creation [flink]
via GitHub
2026/08/14
Re: [PR] [FLINK-39946][runtime] Unaligned checkpoint restore can mis-map union input channel state after reordering UIDed sources [flink]
via GitHub
2026/08/14
Re: [PR] [FLINK-40017] Introduce Seaweedfs in native-s3-fs [flink]
via GitHub
2026/08/14
[jira] [Commented] (FLINK-40391) PTF table argument with a non-default conversion class might fail
Sergey Nuyanzin (Jira)
2026/08/14
[jira] [Resolved] (FLINK-40391) PTF table argument with a non-default conversion class might fail
Sergey Nuyanzin (Jira)
2026/08/14
Re: [PR] [FLINK-40391][table] PTF with non default convertion-class of table arg might fail [flink]
via GitHub
2026/08/14
Re: [PR] [FLINK-40108] Adding snapshot capability with split enumerator [flink-connector-jdbc]
via GitHub
2026/08/14
[jira] [Commented] (FLINK-39137) Add configurable delay between non-empty GetRecords calls in Kinesis source
Jing Hung (Jira)
2026/08/14
Re: [PR] [FLINK-40108] Adding snapshot capability with split enumerator [flink-connector-jdbc]
via GitHub
2026/08/14
Re: [PR] [DRAFT][FLIP-597][filesystem] Add common object storage stream interfaces [flink]
via GitHub
2026/08/14
[PR] [FLIP-597][filesystem] Add common object storage stream abstractions [flink]
via GitHub
2026/08/14
Re: [PR] [api][runtime][python] Add Agent Trace recording to Event Log [flink-agents]
via GitHub
2026/08/14
Re: [PR] [FLINK-40108] Adding snapshot capability with split enumerator [flink-connector-jdbc]
via GitHub
2026/08/14
Re: [PR] [FLINK-40108] Adding snapshot capability with split enumerator [flink-connector-jdbc]
via GitHub
2026/08/14
Re: [PR] [integrations][java][python] Apply Anthropic native structured output [flink-agents]
via GitHub
2026/08/14
[jira] [Commented] (FLINK-34477) support capture groups in REGEXP_REPLACE
Gustavo de Morais (Jira)
2026/08/14
Re: [I] [Feature] Use descriptive thread names for Java and Python async executors [flink-agents]
via GitHub
2026/08/14
[jira] [Created] (FLINK-40396) Create SplitReaders on the split fetcher thread instead of the caller thread
Edson Wang (Jira)
2026/08/14
[I] [Bug] Tool parameter schema maps long/float (and all other non-int/double numerics) to "object" [flink-agents]
via GitHub
2026/08/14
[I] [Bug] Ollama tool conversion throws NPE when the tool schema has no "required" key [flink-agents]
via GitHub
2026/08/14
[jira] [Created] (FLINK-40395) Add documentation for extended scan partitioning modes
Chanhae Oh (Jira)
2026/08/14
[jira] [Created] (FLINK-40394) Support extended scan partitioning modes in JdbcDynamicTableSource
Chanhae Oh (Jira)
2026/08/14
[jira] [Created] (FLINK-40393) Add PhysicalIdSplitterEnumerator and PhysicalIdPartitionDialect with PostgreSQL and Oracle implementations
Chanhae Oh (Jira)
2026/08/14
[jira] [Updated] (FLINK-40247) Umbrella: FLIP-602: Extended JDBC Scan Partitioning Options for Efficient Data Ingestion
Chanhae Oh (Jira)
2026/08/14
[jira] [Created] (FLINK-40392) Add AbstractDynamicSplitterEnumerator and BoundaryQuerySplitterEnumerator
Chanhae Oh (Jira)
2026/08/14
Re: [PR] Bump org.apache.logging.log4j:log4j-api from 2.25.4 to 2.25.5 [flink-connector-kudu]
via GitHub
2026/08/14
Re: [PR] [docs] Document Action trigger conditions [flink-agents]
via GitHub
2026/08/14
[jira] [Updated] (FLINK-40391) PTF table argument with a non-default conversion class might fail
ASF GitHub Bot (Jira)
2026/08/14
Re: [PR] [FLINK-39904][table] Add GEOGRAPHY logical type support [flink]
via GitHub
2026/08/14
[jira] [Resolved] (FLINK-40367) Make Kafka consumer poll timeout configurable
Robert Metzger (Jira)
2026/08/14
[jira] [Commented] (FLINK-40367) Make Kafka consumer poll timeout configurable
Robert Metzger (Jira)
2026/08/14
Re: [PR] [FLINK-40391][table] PTF with non default convertion-class of table arg might fail [flink]
via GitHub
2026/08/14
Re: [PR] [FLINK-40367][Connectors/Kafka] Make Kafka consumer poll timeout configurable [flink-connector-kafka]
via GitHub
2026/08/14
Re: [PR] [infra] Derive and validate the Flink versions tools/ut.sh uses [flink-agents]
via GitHub
2026/08/14
Re: [PR] [FLINK-40108] Adding snapshot capability with split enumerator [flink-connector-jdbc]
via GitHub
2026/08/14
Re: [PR] [FLINK-40355][table] Add new MAP_CONTAINS_KEY function [flink]
via GitHub
2026/08/14
[jira] [Closed] (FLINK-40389) Source parallelism is not capped at the partition count
Gyula Fora (Jira)
2026/08/14
Re: [PR] [FLINK-40355][table] Add new MAP_CONTAINS_KEY function [flink]
via GitHub
2026/08/14
Re: [PR] [FLINK-40355][table] Add new MAP_CONTAINS_KEY function [flink]
via GitHub
2026/08/14
Re: [PR] [FLINK-40355][table] Add new MAP_CONTAINS_KEY function [flink]
via GitHub
2026/08/14
Re: [PR] [FLINK-40389] Source parallelism is not capped at the partition count [flink-kubernetes-operator]
via GitHub
2026/08/14
Re: [PR] [FLINK-40391][table] PTF with non default convertion-class of table arg might fail [flink]
via GitHub
2026/08/14
Re: [PR] [FLINK-39904][table] Add GEOGRAPHY logical type support [flink]
via GitHub
2026/08/14
Re: [PR] [FLINK-39904][table] Add GEOGRAPHY logical type support [flink]
via GitHub
2026/08/14
[jira] [Commented] (FLINK-40388) FlinkDeployment deletion can remain stuck when savepoint-on-deletion is enabled and the job is not running
Han You (Jira)
2026/08/14
Re: [PR] [FLINK-40391][table] PTF with non default convertion-class of table arg might fail [flink]
via GitHub
2026/08/14
[PR] [FLINK-40391][table] PTF with non default convertion-class of table arg might fail [flink]
via GitHub
2026/08/14
[jira] [Created] (FLINK-40391) PTF table argument with a non-default conversion class might fail
Sergey Nuyanzin (Jira)
2026/08/14
Re: [PR] [FLINK-40108] Adding snapshot capability with split enumerator [flink-connector-jdbc]
via GitHub
2026/08/14
[PR] [FLINK-40389] Source parallelism is not capped at the partition count [flink-kubernetes-operator]
via GitHub
2026/08/14
[jira] [Created] (FLINK-40390) Validate JSON_LENGTH path prefixes at plan time and reuse the shared JSON codegen
Gustavo de Morais (Jira)
2026/08/14
[jira] [Closed] (FLINK-40268) Add new JSON_TYPE built-in function
Gustavo de Morais (Jira)
2026/08/14
Re: [PR] [FLINK-40268][table] Add new JSON_TYPE function [flink]
via GitHub
2026/08/14
Re: [PR] [hotfix] Add help handling to build script [flink-agents]
via GitHub
2026/08/14
Re: [I] [Tech Debt] De-flake the long-term memory e2e test, which asserts an exact LLM consolidation count [flink-agents]
via GitHub
2026/08/14
Re: [PR] [test][python] Assert long-term memory content instead of an exact LLM item count [flink-agents]
via GitHub
2026/08/14
Re: [PR] [ci] Name the tools script test job after the command it runs [flink-agents]
via GitHub
2026/08/14
[jira] [Updated] (FLINK-40389) Source parallelism is not capped at the partition count
Dennis-Mircea Ciupitu (Jira)
2026/08/14
[jira] [Updated] (FLINK-40389) Source parallelism is not capped at the partition count
ASF GitHub Bot (Jira)
2026/08/14
Re: [I] [Tech Debt] tools/ut.sh documents multi-version test coverage that it does not run by default [flink-agents]
via GitHub
2026/08/14
Re: [PR] [hotfix][tools] Report RAT validation dependencies correctly [flink-agents]
via GitHub
2026/08/14
Re: [PR] [hotfix][tools] Report RAT validation dependencies correctly [flink-agents]
via GitHub
2026/08/14
Re: [PR] [ci][integrations] Enable Elasticsearch vector-store tests [flink-agents]
via GitHub
2026/08/14
Re: [I] [Bug] Elasticsearch queryEmbedding applies filters as a post-filter, returning fewer than k documents [flink-agents]
via GitHub
2026/08/14
Re: [PR] [ci][integrations] Enable Elasticsearch vector-store tests [flink-agents]
via GitHub
2026/08/14
[jira] [Created] (FLINK-40389) Source parallelism is not capped at the partition count
Dennis-Mircea Ciupitu (Jira)
2026/08/14
[jira] [Updated] (FLINK-40388) FlinkDeployment deletion can remain stuck when savepoint-on-deletion is enabled and the job is not running
Avi Sanwal (Jira)
2026/08/14
[jira] [Updated] (FLINK-40388) FlinkDeployment deletion can remain stuck when savepoint-on-deletion is enabled and the job is not running
Avi Sanwal (Jira)
2026/08/14
Re: [PR] [hotfix][docs] Add feature-flag review guidelines to AGENTS.md [flink]
via GitHub
2026/08/14
Re: [PR] [hotfix][docs] Add feature-flag review guidelines to AGENTS.md [flink]
via GitHub
2026/08/14
[jira] [Updated] (FLINK-40384) Periodic FlinkStateSnapshot cleanup causes repeated SavepointError events
liting liu (Jira)
2026/08/14
[jira] [Updated] (FLINK-40384) Periodic FlinkStateSnapshot cleanup causes repeated SavepointError events
liting liu (Jira)
2026/08/14
[jira] [Updated] (FLINK-40384) Periodic FlinkStateSnapshot cleanup causes repeated SavepointError events
liting liu (Jira)
2026/08/14
[jira] [Commented] (FLINK-33484) Flink Kafka Connector Offset Lag Issue with Transactional Data and Read Committed Isolation Level
Robert Metzger (Jira)
2026/08/14
[jira] [Assigned] (FLINK-33484) Flink Kafka Connector Offset Lag Issue with Transactional Data and Read Committed Isolation Level
Robert Metzger (Jira)
2026/08/14
Re: [PR] [FLINK-40372][metrics] Unregister JOSDK resource metrics after cleanup [flink-kubernetes-operator]
via GitHub
2026/08/14
Re: [I] [Bug] Elasticsearch queryEmbedding applies filters as a post-filter, returning fewer than k documents [flink-agents]
via GitHub
2026/08/14
[jira] [Comment Edited] (FLINK-40081) Enable the spilling backend for checkpointing during recovery
Rui Fan (Jira)
2026/08/14
[jira] [Resolved] (FLINK-40081) Enable the spilling backend for checkpointing during recovery
Rui Fan (Jira)
2026/08/14
[jira] [Resolved] (FLINK-40313) Support collection constructors and functions in YAML Transform
Xiqian Yu (Jira)
2026/08/14
Re: [PR] [FLINK-36581][cli] Allow passing Flink configuration by yaml job file [flink-cdc]
via GitHub
2026/08/14
Re: [PR] [FLINK-40313][runtime] Support nested collection functions in Transforms [flink-cdc]
via GitHub
2026/08/14
Re: [PR] [FLINK-36581][cli] Allow passing Flink configuration by yaml job file [flink-cdc]
via GitHub
2026/08/14
[jira] [Assigned] (FLINK-40313) Support collection constructors and functions in YAML Transform
Xiqian Yu (Jira)
2026/08/14
Re: [PR] [FLINK-36581][cli] Allow passing Flink configuration by yaml job file [flink-cdc]
via GitHub
2026/08/14
Re: [PR] [FLINK-36581][cli] Allow passing Flink configuration by yaml job file [flink-cdc]
via GitHub
2026/08/14
[jira] [Updated] (FLINK-40388) FlinkDeployment deletion can remain stuck when savepoint-on-deletion is enabled and the job is not running
Avi Sanwal (Jira)
2026/08/14
Re: [PR] [FLINK-40367][Connectors/Kafka] Make Kafka consumer poll timeout configurable [flink-connector-kafka]
via GitHub
2026/08/14
[jira] [Created] (FLINK-40388) FlinkDeployment deletion can remain stuck when savepoint-on-deletion is enabled and the job is not running
Avi Sanwal (Jira)
2026/08/14
Re: [PR] [FLINK-38023][formats] Fix GenericRecord Avro state migration [flink]
via GitHub
2026/08/14
Re: [PR] [FLINK-38023][formats] Fix GenericRecord Avro state migration [flink]
via GitHub
2026/08/14
Re: [PR] [FLINK-29775][tests][JUnit5 migration] Module: flink-statebackend-rocksdb [flink]
via GitHub
2026/08/14
Re: [PR] [FLINK-29775][tests][JUnit5 migration] Module: flink-statebackend-rocksdb [flink]
via GitHub
2026/08/14
Re: [PR] [FLINK-29775][tests][JUnit5 migration] Module: flink-statebackend-rocksdb [flink]
via GitHub
2026/08/14
[jira] [Resolved] (FLINK-32212) Job restarting indefinitely after an IllegalStateException from BlobLibraryCacheManager
Robert Metzger (Jira)
2026/08/14
[jira] [Commented] (FLINK-40199) Add generic connector source and sink APIs to PyFlink DataFrame
Dian Fu (Jira)
2026/08/14
[jira] [Assigned] (FLINK-40199) Add generic connector source and sink APIs to PyFlink DataFrame
Dian Fu (Jira)
2026/08/14
Re: [PR] [FLINK-32212][runtime] Match library BLOBs by content in BlobLibraryCacheManager [flink]
via GitHub
2026/08/14
Re: [PR] [FLINK-40300][python] Fix literal expression in Python Table API [flink]
via GitHub
2026/08/14
Re: [PR] [FLINK-40367][Connectors/Kafka] Make Kafka consumer poll timeout configurable [flink-connector-kafka]
via GitHub
2026/08/13
Re: [PR] [FLINK-40346][model-triton] Preserve null array elements when deserializing Triton responses [flink]
via GitHub
2026/08/13
Re: [I] [Bug] Elasticsearch queryEmbedding applies filters as a post-filter, returning fewer than k documents [flink-agents]
via GitHub
2026/08/13
Re: [PR] [FLINK-40346][model-triton] Preserve null array elements when deserializing Triton responses [flink]
via GitHub
2026/08/13
[jira] [Closed] (FLINK-40191) Add aggregation support to DataFrame API
Dian Fu (Jira)
2026/08/13
Re: [PR] [FLINK-40191][python] Add aggregation support to PyFlink DataFrame API [flink]
via GitHub
2026/08/13
Re: [I] [Bug] Elasticsearch queryEmbedding applies filters as a post-filter, returning fewer than k documents [flink-agents]
via GitHub
2026/08/13
Re: [PR] [FLINK-40199][python] Add generic DataFrame I/O methods [flink]
via GitHub
2026/08/13
[jira] [Updated] (FLINK-40199) Add generic connector source and sink APIs to PyFlink DataFrame
ASF GitHub Bot (Jira)
2026/08/13
[PR] [FLINK-40199][python] Add generic DataFrame I/O methods [flink]
via GitHub
2026/08/13
[jira] [Commented] (FLINK-40199) Add generic connector source and sink APIs to PyFlink DataFrame
Liu Liu (Jira)
2026/08/13
Re: [PR] [FLINK-40300][python] Fix literal expression in Python Table API [flink]
via GitHub
2026/08/13
Re: [PR] [api][runtime][java][python] Require HTTPS and add digest pinning for URL skill sources [flink-agents]
via GitHub
2026/08/13
Re: [PR] [api][runtime][java][python] Require HTTPS and add digest pinning for URL skill sources [flink-agents]
via GitHub
2026/08/13
Re: [PR] [FLINK-40300][python] Fix literal expression in Python Table API [flink]
via GitHub
2026/08/13
Re: [PR] [FLINK-40300][python] Fix literal expression in Python Table API [flink]
via GitHub
2026/08/13
Re: [PR] [FLINK-40017] Introduce Seaweedfs in native-s3-fs [flink]
via GitHub
2026/08/13
Re: [PR] [FLINK-40346][model-triton] Preserve null array elements when deserializing Triton responses [flink]
via GitHub
2026/08/13
Re: [PR] [FLINK-40298][table] Opt-in name-based state schema evolution for RowData [flink]
via GitHub
2026/08/13
Re: [PR] [FLINK-37666] CWE-378: Creation of Temporary File With Insecure Permissions in Temporary File Creation [flink]
via GitHub
2026/08/13
[jira] [Updated] (FLINK-40298) Opt-in name-based state schema evolution for RowData
ASF GitHub Bot (Jira)
2026/08/13
Re: [PR] [FLINK-39786][s3]closeForCommit() leaks orphan multipart uploads on upload failure [flink]
via GitHub
2026/08/13
[PR] [FLINK-40298][table] Opt-in name-based state schema evolution for RowData [flink]
via GitHub
2026/08/13
Re: [PR] [FLINK-39786][s3]closeForCommit() leaks orphan multipart uploads on upload failure [flink]
via GitHub
2026/08/13
Re: [PR] [FLINK-39786][s3]closeForCommit() leaks orphan multipart uploads on upload failure [flink]
via GitHub
2026/08/13
Re: [PR] [FLINK-39786][s3]closeForCommit() leaks orphan multipart uploads on upload failure [flink]
via GitHub
2026/08/13
Re: [PR] [FLINK-39786][s3]closeForCommit() leaks orphan multipart uploads on upload failure [flink]
via GitHub
2026/08/13
Re: [PR] [integrations][vector-store][java] Apply Elasticsearch KNN filters before selecting neighbors [flink-agents]
via GitHub
2026/08/13
Re: [PR] [FLINK-40296][core] Add object-level migrate hook to TypeSerializerSnapshot [flink]
via GitHub
2026/08/13
Re: [PR] Bump org.apache.logging.log4j:log4j-api from 2.25.3 to 2.25.5 in /e2e-test [flink-agents]
via GitHub
2026/08/13
Re: [PR] Bump org.apache.logging.log4j:log4j-api from 2.25.3 to 2.25.5 in /e2e-test [flink-agents]
via GitHub
2026/08/13
Re: [PR] Bump org.apache.logging.log4j:log4j-api from 2.25.3 to 2.25.5 in /e2e-test [flink-agents]
via GitHub
2026/08/13
Re: [PR] [hotfix][tools] Report RAT validation dependencies correctly [flink-agents]
via GitHub
2026/08/13
[I] [Feature] Use descriptive thread names for Java and Python async executors [flink-agents]
via GitHub
2026/08/13
[PR] [runtime] Introduce OpenAI-compatible model client [flink-cdc]
via GitHub
2026/08/13
Re: [PR] [FLINK-40191][python] Add aggregation support to PyFlink DataFrame API [flink]
via GitHub
2026/08/13
Re: [PR] [api][runtime][python] Add Agent Trace recording to Event Log [flink-agents]
via GitHub
Earlier messages
Later messages