issues
Thread
Date
Earlier messages
Later messages
Messages by Date
2026/08/18
[jira] [Created] (FLINK-40436) Add UDAF support to DataFrame API
Liu Liu (Jira)
2026/08/18
[jira] [Created] (FLINK-40435) Add explode support to DataFrame API
Liu Liu (Jira)
2026/08/18
Re: [PR] [FLINK-40428][table] Drop Calcite's `LogicalSnapshot` [flink]
via GitHub
2026/08/18
[jira] [Created] (FLINK-40434) Add flat_map support to DataFrame API
Liu Liu (Jira)
2026/08/18
[jira] [Created] (FLINK-40433) Add map and map_batches support to DataFrame API
Liu Liu (Jira)
2026/08/18
[jira] [Created] (FLINK-40432) Parallel snapshot/CDC split by long handle space is skewed for AUTO_INCREMENT PKs and can OOM
lifulong (Jira)
2026/08/18
[jira] [Created] (FLINK-40431) Add UDF support to PyFlink DataFrame API
Liu Liu (Jira)
2026/08/18
[jira] [Updated] (FLINK-40428) Remove Calcite's LogicalSnapshot
ASF GitHub Bot (Jira)
2026/08/18
[jira] [Created] (FLINK-40430) Add configuration support to DataFrame API
Liu Liu (Jira)
2026/08/18
[PR] [FLINK-40428][table] Drop Calcite's `LogicalSnapshot` [flink]
via GitHub
2026/08/18
[jira] [Created] (FLINK-40429) Add StatementSet support for multi-sink DataFrame writes
Liu Liu (Jira)
2026/08/18
[jira] [Created] (FLINK-40428) Remove Calcite's LogicalSnapshot
Sergey Nuyanzin (Jira)
2026/08/18
[jira] [Created] (FLINK-40427) Add catalog management and catalog table I/O to DataFrame API
Liu Liu (Jira)
2026/08/18
[jira] [Created] (FLINK-40425) Add OVER window aggregation support to DataFrame API
Liu Liu (Jira)
2026/08/18
[jira] [Created] (FLINK-40426) Add Parquet and JSON filesystem I/O APIs to DataFrame API
Liu Liu (Jira)
2026/08/18
[jira] [Created] (FLINK-40424) Add windowing TVF support to DataFrame API
Liu Liu (Jira)
2026/08/18
[jira] [Created] (FLINK-40423) Add Top-N support to DataFrame API
Liu Liu (Jira)
2026/08/18
[jira] [Created] (FLINK-40422) Add slicing APIs to DataFrame API
Liu Liu (Jira)
2026/08/18
[jira] [Updated] (FLINK-40421) Add sorting support in DataFrame API
Liu Liu (Jira)
2026/08/18
[jira] [Created] (FLINK-40420) Add set operations to DataFrame API
Liu Liu (Jira)
2026/08/18
[jira] [Created] (FLINK-40421) Support sorting in DataFrame API
Liu Liu (Jira)
2026/08/18
[jira] [Created] (FLINK-40419) Add regular join support to DataFrame API
Liu Liu (Jira)
2026/08/18
[jira] [Created] (FLINK-40418) Support attribute-based column access on DataFrame
Liu Liu (Jira)
2026/08/18
[jira] [Created] (FLINK-40417) Add remaining basic functionality to DataFrame API
Liu Liu (Jira)
2026/08/18
Re: [PR] [FLINK-39546][s3] Improve observability in flink-s3-fs-native by exposing operation-level S3 metrics [flink]
via GitHub
2026/08/18
Re: [PR] [FLINK-40415][python] Fix Python 3.9 dependency conflict of grpcio-tools [flink]
via GitHub
2026/08/18
[jira] [Updated] (FLINK-40415) PyFlink tests failed on Python 3.9
ASF GitHub Bot (Jira)
2026/08/18
[PR] [FLINK-40415][python] Fix Python 3.9 dependency conflict of grpcio-tools [flink]
via GitHub
2026/08/18
Re: [PR] [FLINK-40397][mysql] Add currentBinlogPositionLag metric for MySQL binlog reader [flink-cdc]
via GitHub
2026/08/18
Re: [PR] [FLINK-40397][mysql] Add currentBinlogPositionLag metric for MySQL binlog reader [flink-cdc]
via GitHub
2026/08/18
[jira] [Resolved] (FLINK-40409) Introduce inline Python UDF definition in YAML pipeline
Yanquan Lv (Jira)
2026/08/18
Re: [PR] [FLINK-40409][runtime] CDC YAML supports inline Python UDF definition [flink-cdc]
via GitHub
2026/08/18
[jira] [Updated] (FLINK-40409) Introduce inline Python UDF definition in YAML pipeline
ASF GitHub Bot (Jira)
2026/08/18
Re: [PR] [FLINK-40409][runtime] CDC YAML supports inline Python UDF definition [flink-cdc]
via GitHub
2026/08/18
[jira] [Created] (FLINK-40416) Add built-in text AI functions to Pipeline transforms
Mao Jiayi (Jira)
2026/08/18
[jira] [Created] (FLINK-40415) PyFlink tests failed on Python 3.9
Dian Fu (Jira)
2026/08/18
Re: [PR] Bump io.opentelemetry:opentelemetry-api from 1.57.0 to 1.62.0 in /flink-python [flink]
via GitHub
2026/08/18
[jira] [Closed] (FLINK-40335) Hybrid shuffle index files can be corrupted by a ByteBuffer shared across result partitions
Ferenc Csaky (Jira)
2026/08/18
Re: [PR] [BP-1.20][FLINK-40335][runtime] Fix Hybrid Shuffle index corruption caused by shared ByteBuffer [flink]
via GitHub
2026/08/18
Re: [PR] [BP-2.2][FLINK-40335][runtime] Fix Hybrid Shuffle index corruption caused by shared ByteBuffer [flink]
via GitHub
2026/08/18
Re: [PR] [BP-2.3][FLINK-40335][runtime] Fix Hybrid Shuffle index corruption caused by shared ByteBuffer [flink]
via GitHub
2026/08/18
Re: [PR] [FLINK-40335][runtime] Fix Hybrid Shuffle index corruption caused by shared ByteBuffer [flink]
via GitHub
2026/08/18
Re: [PR] [FLINK-40017] Introduce Seaweedfs in native-s3-fs [flink]
via GitHub
2026/08/18
Re: [PR] [BP-2.2][FLINK-40335][runtime] Fix Hybrid Shuffle index corruption caused by shared ByteBuffer [flink]
via GitHub
2026/08/18
Re: [PR] [FLINK-40017] Introduce Seaweedfs in native-s3-fs [flink]
via GitHub
2026/08/18
Re: [PR] [FLINK-40017] Introduce Seaweedfs in native-s3-fs [flink]
via GitHub
2026/08/18
Re: [PR] [FLINK-40017] Introduce Seaweedfs in native-s3-fs [flink]
via GitHub
2026/08/18
Re: [PR] [FLINK-40410][table-planner] Exclude VARIANT from constant folding [flink]
via GitHub
2026/08/18
Re: [PR] [FLINK-40410][table-planner] Exclude VARIANT from constant folding [flink]
via GitHub
2026/08/18
Re: [PR] [FLINK-40017] Introduce Seaweedfs in native-s3-fs [flink]
via GitHub
2026/08/18
Re: [PR] [FLINK-40001][table] Upgrade Calcite version to 1.42.0 [flink]
via GitHub
2026/08/18
Re: [PR] [FLINK-40017] Introduce Seaweedfs in native-s3-fs [flink]
via GitHub
2026/08/18
Re: [PR] [FLINK-40017] Introduce Seaweedfs in native-s3-fs [flink]
via GitHub
2026/08/18
Re: [PR] [FLINK-40017] Introduce Seaweedfs in native-s3-fs [flink]
via GitHub
2026/08/18
Re: [PR] [FLINK-40017] Introduce Seaweedfs in native-s3-fs [flink]
via GitHub
2026/08/18
Re: [PR] [FLINK-40017] Introduce Seaweedfs in native-s3-fs [flink]
via GitHub
2026/08/18
Re: [PR] [FLINK-40017] Introduce Seaweedfs in native-s3-fs [flink]
via GitHub
2026/08/18
Re: [PR] [FLINK-40017] Introduce Seaweedfs in native-s3-fs [flink]
via GitHub
2026/08/18
Re: [PR] [FLINK-40017] Introduce Seaweedfs in native-s3-fs [flink]
via GitHub
2026/08/18
Re: [PR] [FLINK-40017] Introduce Seaweedfs in native-s3-fs [flink]
via GitHub
2026/08/18
Re: [PR] [FLINK-40017] Introduce Seaweedfs in native-s3-fs [flink]
via GitHub
2026/08/18
[jira] [Updated] (FLINK-40414) Autoscaler state ConfigMap is treated as trusted input
ASF GitHub Bot (Jira)
2026/08/18
[PR] [FLINK-40414] Autoscaler state ConfigMap is treated as trusted input [flink-kubernetes-operator]
via GitHub
2026/08/18
[jira] [Created] (FLINK-40414) Autoscaler state ConfigMap is treated as trusted input
Dennis-Mircea Ciupitu (Jira)
2026/08/18
[jira] [Updated] (FLINK-40413) Autoscaling example classes leak into the operator javadoc site
ASF GitHub Bot (Jira)
2026/08/18
[PR] [FLINK-40413] Autoscaling example classes leak into the operator javadoc site [flink-kubernetes-operator]
via GitHub
2026/08/18
[jira] [Created] (FLINK-40413) Autoscaling example classes leak into the operator javadoc site
Dennis-Mircea Ciupitu (Jira)
2026/08/18
Re: [PR] [FLINK-40410][table-planner] Exclude VARIANT from constant folding [flink]
via GitHub
2026/08/18
[jira] [Updated] (FLINK-40410) ClassCastException when constant-folding a VARIANT expression before another constant expression
ASF GitHub Bot (Jira)
2026/08/18
[PR] [FLINK-40410][table-planner] Exclude VARIANT from constant folding [flink]
via GitHub
2026/08/18
Re: [PR] [FLINK-36434][Connectors/Kafka] Create the KafkaConsumer lazily on the split fetcher thread [flink-connector-kafka]
via GitHub
2026/08/18
Re: [PR] [FLINK-40344][table] Support selecting computed grouping expressions [flink]
via GitHub
2026/08/18
[jira] [Commented] (FLINK-40344) Computed grouping expressions cannot be selected in Table API aggregations
Bettle (Jira)
2026/08/18
Re: [PR] [FLINK-40408] Fix NOTICE files to match dependencies [flink-kubernetes-operator]
via GitHub
2026/08/18
Re: [PR] [BP-1.20][FLINK-40335][runtime] Fix Hybrid Shuffle index corruption caused by shared ByteBuffer [flink]
via GitHub
2026/08/18
Re: [PR] [FLINK-40017] Introduce Seaweedfs in native-s3-fs [flink]
via GitHub
2026/08/18
Re: [PR] [FLINK-40017] Introduce Seaweedfs in native-s3-fs [flink]
via GitHub
2026/08/18
[jira] [Resolved] (FLINK-40360) Fix DECIMAL precision truncation when arithmetic result precision exceeds 19 digits
Yanquan Lv (Jira)
2026/08/18
Re: [PR] [FLINK-40360][runtime] Fix DECIMAL precision truncation when arithmetic result precision exceeds 19 digits [flink-cdc]
via GitHub
2026/08/18
Re: [I] [api][plan][runtime] Support triggering action by Event field values [flink-agents]
via GitHub
2026/08/18
Re: [PR] [docs] Document Action trigger conditions [flink-agents]
via GitHub
2026/08/18
Re: [PR] [FLINK-40408] Fix NOTICE files to match dependencies [flink-kubernetes-operator]
via GitHub
2026/08/18
Re: [PR] [FLINK-40400] Harden job artifact fetching in kubernetes operator [flink-kubernetes-operator]
via GitHub
2026/08/18
[jira] [Closed] (FLINK-40387) NativeS3 - configured retry/throttle backoff is ignored due to AWS SDK retry circuit breaker enabled by default - failing checkpoints under S3 503 throttling
Gabor Somogyi (Jira)
2026/08/18
[jira] [Resolved] (FLINK-40387) NativeS3 - configured retry/throttle backoff is ignored due to AWS SDK retry circuit breaker enabled by default - failing checkpoints under S3 503 throttling
Gabor Somogyi (Jira)
2026/08/18
[jira] [Commented] (FLINK-40387) NativeS3 - configured retry/throttle backoff is ignored due to AWS SDK retry circuit breaker enabled by default - failing checkpoints under S3 503 throttling
Gabor Somogyi (Jira)
2026/08/18
Re: [PR] [FLINK-40387][s3] Add option to disable S3 SDK retry circuit breaker [flink]
via GitHub
2026/08/18
Re: [PR] [FLINK-40356][table] Add new MapFromEntries function [flink]
via GitHub
2026/08/18
Re: [PR] [Feature] Parallel Tool Call Execution [flink-agents]
via GitHub
2026/08/18
Re: [PR] [FLINK-40400] Harden job artifact fetching in kubernetes operator [flink-kubernetes-operator]
via GitHub
2026/08/18
[jira] [Updated] (FLINK-31161) upgrade MojoHaus Versions Maven Plugin to 2.14.2
Martijn Visser (Jira)
2026/08/18
Re: [PR] [FLINK-39904][table] Add GEOGRAPHY logical type support [flink]
via GitHub
2026/08/18
Re: [PR] [FLINK-39904][table] Add GEOGRAPHY logical type support [flink]
via GitHub
2026/08/18
Re: [PR] [FLINK-39570] Update dependencies to latest versions [flink-shaded]
via GitHub
2026/08/18
[jira] [Updated] (FLINK-40412) Autoscaler: unfiltered configOverrides merge lets tenants set arbitrary Flink config
Purushottam Sinha (Jira)
2026/08/18
[jira] [Created] (FLINK-40412) Autoscaler: unfiltered configOverrides merge lets tenants set arbitrary Flink config
Purushottam Sinha (Jira)
2026/08/18
[jira] [Closed] (FLINK-40300) PyFlink Table API lit fails for some literal types
Dian Fu (Jira)
2026/08/18
Re: [PR] [FLINK-40300][python] Fix literal expression in Python Table API [flink]
via GitHub
2026/08/18
Re: [PR] [FLINK-40335][runtime] Fix Hybrid Shuffle index corruption caused by shared ByteBuffer [flink]
via GitHub
2026/08/18
Re: [PR] [BP-2.3][FLINK-40335][runtime] Fix Hybrid Shuffle index corruption caused by shared ByteBuffer [flink]
via GitHub
2026/08/18
Re: [PR] [BP-2.2][FLINK-40335][runtime] Fix Hybrid Shuffle index corruption caused by shared ByteBuffer [flink]
via GitHub
2026/08/18
[PR] [FLINK-40335][runtime] Fix Hybrid Shuffle index corruption caused by shared ByteBuffer [flink]
via GitHub
2026/08/18
[PR] [FLINK-40335][runtime] Fix Hybrid Shuffle index corruption caused by shared ByteBuffer [flink]
via GitHub
2026/08/18
[PR] [FLINK-40335][runtime] Fix Hybrid Shuffle index corruption caused by shared ByteBuffer [flink]
via GitHub
2026/08/18
[jira] [Assigned] (FLINK-40411) Introduce an OpenAI-compatible model client for Flink CDC Pipeline
Xiqian Yu (Jira)
2026/08/18
[jira] [Resolved] (FLINK-40411) Introduce an OpenAI-compatible model client for Flink CDC Pipeline
Xiqian Yu (Jira)
2026/08/18
Re: [PR] [FLINK-40411][runtime] Introduce OpenAI-compatible model client [flink-cdc]
via GitHub
2026/08/18
[jira] [Assigned] (FLINK-40410) ClassCastException when constant-folding a VARIANT expression before another constant expression
Arvid Heise (Jira)
2026/08/18
Re: [PR] [runtime] Introduce OpenAI-compatible model client [flink-cdc]
via GitHub
2026/08/18
[jira] [Created] (FLINK-40411) Introduce an OpenAI-compatible model client for Flink CDC Pipeline
Mao Jiayi (Jira)
2026/08/18
Re: [PR] [FLINK-40344][table] Support selecting computed grouping expressions [flink]
via GitHub
2026/08/18
[jira] [Updated] (FLINK-40400) Harden job artifact fetching in kubernetes operator
ASF GitHub Bot (Jira)
2026/08/18
Re: [PR] [FLINK-40400] Harden job artifact fetching in kubernetes operator [flink-kubernetes-operator]
via GitHub
2026/08/18
[jira] [Updated] (FLINK-40335) Hybrid shuffle index files can be corrupted by a ByteBuffer shared across result partitions
Ferenc Csaky (Jira)
2026/08/18
[jira] [Updated] (FLINK-40335) Hybrid shuffle index files can be corrupted by a ByteBuffer shared across result partitions
Ferenc Csaky (Jira)
2026/08/18
Re: [PR] [FLINK-40335][runtime] Fix Hybrid Shuffle index corruption caused by shared ByteBuffer [flink]
via GitHub
2026/08/18
[jira] [Created] (FLINK-40410) ClassCastException when constant-folding a VARIANT expression before another constant expression
Moritz Manner (Jira)
2026/08/18
[jira] [Updated] (FLINK-40410) ClassCastException when constant-folding a VARIANT expression before another constant expression
Moritz Manner (Jira)
2026/08/18
Re: [PR] [runtime] Introduce OpenAI-compatible model client [flink-cdc]
via GitHub
2026/08/18
Re: [PR] [FLINK-40356][table] Add new MapFromEntries function [flink]
via GitHub
2026/08/18
Re: [PR] [FLINK-39546][s3] Improve observability in flink-s3-fs-native by exposing operation-level S3 metrics [flink]
via GitHub
2026/08/18
Re: [PR] [FLINK-40401] Protect against large autoscaler config maps [flink-kubernetes-operator]
via GitHub
2026/08/18
[jira] [Updated] (FLINK-40405) [FLINK-autoscaler] Add reason tags to `autoscaler.balanced` counter to distinguish genuinely balanced from blocked scaling
Kaustubh Butte (Jira)
2026/08/18
[jira] [Updated] (FLINK-40407) [FLINK-autoscaler] Add reason tags to `autoscaler.scalings` counter to explain why scaling was triggered
Kaustubh Butte (Jira)
2026/08/18
[jira] [Updated] (FLINK-40407) [FLINK-autoscaler] Add reason tags to `autoscaler.scalings` counter to explain why scaling was triggered
Kaustubh Butte (Jira)
2026/08/18
Re: [PR] [FLINK-40344][table] Support selecting computed grouping expressions [flink]
via GitHub
2026/08/18
Re: [PR] [FLINK-40401] Protect against large autoscaler config maps [flink-kubernetes-operator]
via GitHub
2026/08/18
[jira] [Assigned] (FLINK-40335) Hybrid shuffle index files can be corrupted by a ByteBuffer shared across result partitions
Ferenc Csaky (Jira)
2026/08/18
[jira] [Updated] (FLINK-40335) Hybrid shuffle index files can be corrupted by a ByteBuffer shared across result partitions
Ferenc Csaky (Jira)
2026/08/18
[jira] [Updated] (FLINK-40335) Hybrid shuffle index files can be corrupted by a ByteBuffer shared across result partitions
Ferenc Csaky (Jira)
2026/08/18
[jira] [Updated] (FLINK-40408) Fix NOTICE files to match dependencies for Flink Kubernetes Operator
ASF GitHub Bot (Jira)
2026/08/18
[PR] [FLINK-40408] Fix NOTICE files to match dependencies [flink-kubernetes-operator]
via GitHub
2026/08/18
Re: [PR] [FLINK-39904][table] Add GEOGRAPHY logical type support [flink]
via GitHub
2026/08/18
Re: [PR] [FLINK-40401] Protect against large autoscaler config maps [flink-kubernetes-operator]
via GitHub
2026/08/18
[jira] [Created] (FLINK-40409) Introduce inline Python UDF definition in YAML pipeline
Xiqian Yu (Jira)
2026/08/18
[jira] [Commented] (FLINK-40407) [FLINK-autoscaler] Add reason tags to `autoscaler.scalings` counter to explain why scaling was triggered
Kaustubh Butte (Jira)
2026/08/18
[jira] [Created] (FLINK-40408) Fix NOTICE files to match dependencies for Flink Kubernetes Operator
Mate Czagany (Jira)
2026/08/18
[jira] [Created] (FLINK-40407) [FLINK-autoscaler] Add reason tags to `autoscaler.scalings` counter to explain why scaling was triggered
Kaustubh Butte (Jira)
2026/08/18
Re: [PR] [FLINK-40277][connector-http] Add HTTP sink response classification and retries [flink-connector-http]
via GitHub
2026/08/18
Re: [PR] [runtime] CDC YAML supports inline Python UDF definition [flink-cdc]
via GitHub
2026/08/18
Re: [PR] [FLINK-40387][s3] Add option to disable S3 SDK retry circuit breaker [flink]
via GitHub
2026/08/18
Re: [PR] [FLINK-40360][runtime] Fix DECIMAL precision truncation when arithmetic result precision exceeds 19 digits [flink-cdc]
via GitHub
2026/08/18
Re: [PR] [FLINK-40387][s3] Add option to disable S3 SDK retry circuit breaker [flink]
via GitHub
2026/08/18
Re: [PR] [runtime] CDC YAML supports inline Python UDF definition [flink-cdc]
via GitHub
2026/08/18
Re: [PR] [FLINK-40344][table] Support selecting computed grouping expressions [flink]
via GitHub
2026/08/18
Re: [PR] [runtime] CDC YAML supports inline Python UDF definition [flink-cdc]
via GitHub
2026/08/18
[PR] [oracle] Support specific-offset startup mode with SCN for Oracle pipeline source [flink-cdc]
via GitHub
2026/08/18
[PR] [FLINK-40344][table] Support selecting computed grouping expressions [flink]
via GitHub
2026/08/18
[jira] [Updated] (FLINK-40344) Computed grouping expressions cannot be selected in Table API aggregations
ASF GitHub Bot (Jira)
2026/08/18
Re: [PR] [FLINK-40315][connect/mariadb] Add MariaDB CDC DataStream source [flink-cdc]
via GitHub
2026/08/18
Re: [PR] [FLINK-40397][mysql] Add currentBinlogPositionLag metric for MySQL binlog reader [flink-cdc]
via GitHub
2026/08/18
Re: [PR] [connect/tidb] Split key ranges by TiKV region via FLIP-27 enumerator [flink-cdc]
via GitHub
2026/08/18
Re: [PR] [runtime] Introduce OpenAI-compatible model client [flink-cdc]
via GitHub
2026/08/17
Re: [PR] [FLINK-40327][state/forst] Close ReadOptions in ForStGeneralMultiGetOperation to fix native memory leak [flink]
via GitHub
2026/08/17
Re: [PR] [FLINK-40401] Protect against large autoscaler config maps [flink-kubernetes-operator]
via GitHub
2026/08/17
[jira] [Closed] (FLINK-40190) Add data creation and conversion APIs to PyFlink DataFrame
Dian Fu (Jira)
2026/08/17
[jira] [Commented] (FLINK-40400) Harden job artifact fetching in kubernetes operator
Purushottam Sinha (Jira)
2026/08/17
Re: [PR] [FLINK-40190][python] Add PyFlink DataFrame creation and conversion APIs [flink]
via GitHub
2026/08/17
[jira] [Created] (FLINK-40406) CI: Maven build has no retry on transient Central failures, causing spurious PR failures
Purushottam Sinha (Jira)
2026/08/17
Re: [PR] [FLINK-36736][table] Fix target columns for row-level updates [flink]
via GitHub
2026/08/17
Re: [PR] [FLINK-36735][table] Include updated columns when sink declares partial required columns for row-level update [flink]
via GitHub
2026/08/17
Re: [PR] [FLINK-40360][runtime] Fix DECIMAL precision truncation when arithmetic result precision exceeds 19 digits [flink-cdc]
via GitHub
2026/08/17
Re: [PR] [FLINK-40401] Protect against large autoscaler config maps [flink-kubernetes-operator]
via GitHub
2026/08/17
Re: [PR] [FLINK-36581][cli] Allow passing Flink configuration by yaml job file [flink-cdc]
via GitHub
2026/08/17
Re: [I] [Bug] Durable replay of newObject() memory updates corrupts short-term memory or crash-loops recovery [flink-agents]
via GitHub
2026/08/17
[PR] [api][runtime] Replay newObject memory updates as object creations during durable recovery [flink-agents]
via GitHub
2026/08/17
[I] [Bug] Durable replay of newObject() memory updates corrupts short-term memory or crash-loops recovery [flink-agents]
via GitHub
2026/08/17
Re: [PR] [docs] Improve the documentation index page and build instructions [flink-agents]
via GitHub
2026/08/17
Re: [I] [Bug] An output schema pydantic cannot render raises instead of taking the prompt fallback [flink-agents]
via GitHub
2026/08/17
Re: [PR] [FLINK-40387][s3] Add option to disable S3 SDK retry circuit breaker [flink]
via GitHub
2026/08/17
Re: [PR] [runtime] Introduce OpenAI-compatible model client [flink-cdc]
via GitHub
2026/08/17
Re: [PR] [runtime] Introduce OpenAI-compatible model client [flink-cdc]
via GitHub
2026/08/17
Re: [PR] [FLINK-36434][Connectors/Kafka] Create the KafkaConsumer lazily on the split fetcher thread [flink-connector-kafka]
via GitHub
2026/08/17
Re: [I] [Bug] Recovered Durable ActionState for keys owned by other subtasks is never pruned [flink-agents]
via GitHub
2026/08/17
Re: [PR] [runtime] CDC YAML supports inline Python UDF definition [flink-cdc]
via GitHub
2026/08/17
[jira] [Updated] (FLINK-39888) [Kafka] Allow configuring offset reset strategy independently of startup offsets
Bowen Li (Jira)
2026/08/17
[jira] [Updated] (FLINK-39888) [Kafka] Allow configuring offset reset strategy independently of startup offsets
Bowen Li (Jira)
2026/08/17
[jira] [Commented] (FLINK-39888) [Kafka] Allow configuring offset reset strategy independently of startup offsets
Bowen Li (Jira)
2026/08/17
[jira] [Resolved] (FLINK-39888) [Kafka] Allow configuring offset reset strategy independently of startup offsets
Bowen Li (Jira)
2026/08/17
Re: [PR] [FLINK-39888][Kafka] Allow configuring offset reset strategy independently [flink-connector-kafka]
via GitHub
2026/08/17
Re: [PR] [FLINK-39888][Kafka] Allow configuring offset reset strategy independently [flink-connector-kafka]
via GitHub
2026/08/17
Re: [PR] [FLINK-39888][Kafka] Allow configuring offset reset strategy independently [flink-connector-kafka]
via GitHub
2026/08/17
[PR] [runtime][python] Use descriptive thread names for the async executors [flink-agents]
via GitHub
2026/08/17
[PR] [plan] Map long/float and other numeric tool parameters to proper JSON Schema types [flink-agents]
via GitHub
2026/08/17
[PR] [integration][ollama] Tolerate tool schemas without a 'required' key [flink-agents]
via GitHub
2026/08/17
Re: [PR] [FLINK-40190][python] Add PyFlink DataFrame creation and conversion APIs [flink]
via GitHub
2026/08/17
[PR] [python] Fix jar URI construction in execution_environment.py [flink-agents]
via GitHub
2026/08/17
Re: [PR] [FLINK-39888][Kafka] Allow configuring offset reset strategy independently [flink-connector-kafka]
via GitHub
2026/08/17
Re: [PR] [FLINK-39888][Kafka] Allow configuring offset reset strategy independently [flink-connector-kafka]
via GitHub
2026/08/17
Re: [PR] [FLINK-39888][Kafka] Allow configuring offset reset strategy independently [flink-connector-kafka]
via GitHub
2026/08/17
Re: [PR] [api][runtime][java][python] Require HTTPS and add digest pinning for URL skill sources [flink-agents]
via GitHub
2026/08/17
Re: [PR] [api][runtime][java][python] Require HTTPS and add digest pinning for URL skill sources [flink-agents]
via GitHub
2026/08/17
Re: [PR] [api][runtime][java][python] Require HTTPS and add digest pinning for URL skill sources [flink-agents]
via GitHub
2026/08/17
Re: [PR] [api][runtime][java][python] Require HTTPS and add digest pinning for URL skill sources [flink-agents]
via GitHub
2026/08/17
Re: [PR] [api][runtime][java][python] Require HTTPS and add digest pinning for URL skill sources [flink-agents]
via GitHub
2026/08/17
Re: [PR] [api][runtime][java][python] Require HTTPS and add digest pinning for URL skill sources [flink-agents]
via GitHub
2026/08/17
[jira] [Commented] (FLINK-40387) NativeS3 - configured retry/throttle backoff is ignored due to AWS SDK retry circuit breaker enabled by default - failing checkpoints under S3 503 throttling
Michael (Jira)
2026/08/17
[jira] [Closed] (FLINK-28260) flink-runtime-web fails to execute "npm ci" on Apple Silicon (arm64) without rosetta
Martijn Visser (Jira)
2026/08/17
Re: [PR] [FLINK-40401] Protect against large autoscaler config maps [flink-kubernetes-operator]
via GitHub
2026/08/17
Re: [PR] Flink Kubernetes Operator 1.16.0 [flink-web]
via GitHub
Earlier messages
Later messages