Messages by Thread
-
-
Re: [PR] [FLINK-39034][runtime] Preserve timestamps in SortPartitionOperator [flink]
via GitHub
-
[jira] [Commented] (FLINK-40338) ELT() throws ClassCastException when the index argument is not INT
sepuri sai krishna (Jira)
-
[jira] [Created] (FLINK-40338) ELT() throws ClassCastException when the index argument is not INT
sepuri sai krishna (Jira)
-
[PR] [FLINK-37977][table] Support VARIANT in user-defined functions and process table functions [flink]
via GitHub
-
[jira] [Updated] (FLINK-37977) Variant implements Serializable
ASF GitHub Bot (Jira)
-
[PR] [FLINK-40089][table] Implement JSON_LENGTH function [flink]
via GitHub
-
Re: [PR] [FLINK-39524][checkpoint] Fetched channel state: spill files, filtered write, reader [flink]
via GitHub
-
Re: [PR] [FLINK-39524][checkpoint] Fetched channel state: spill files, filtered write, reader [flink]
via GitHub
-
Re: [PR] [FLINK-39524][checkpoint] Fetched channel state: spill files, filtered write, reader [flink]
via GitHub
-
Re: [PR] [FLINK-39524][checkpoint] Fetched channel state: spill files, filtered write, reader [flink]
via GitHub
-
Re: [PR] [FLINK-39524][checkpoint] Fetched channel state: spill files, filtered write, reader [flink]
via GitHub
-
Re: [PR] [FLINK-39524][checkpoint] Fetched channel state: spill files, filtered write, reader [flink]
via GitHub
-
Re: [PR] [FLINK-39524][checkpoint] Fetched channel state: spill files, filtered write, reader [flink]
via GitHub
-
Re: [PR] [FLINK-39524][checkpoint] Fetched channel state: spill files, filtered write, reader [flink]
via GitHub
-
Re: [PR] [FLINK-39524][checkpoint] Fetched channel state: spill files, filtered write, reader [flink]
via GitHub
-
Re: [PR] [FLINK-39524][checkpoint] Fetched channel state: spill files, filtered write, reader [flink]
via GitHub
-
Re: [PR] [FLINK-39524][checkpoint] Fetched channel state: spill files, filtered write, reader [flink]
via GitHub
-
Re: [PR] [FLINK-39524][checkpoint] Fetched channel state: spill files, filtered write, reader [flink]
via GitHub
-
Re: [PR] [FLINK-39524][checkpoint] Fetched channel state: spill files, filtered write, reader [flink]
via GitHub
-
Re: [PR] [FLINK-39524][checkpoint] Fetched channel state: spill files, filtered write, reader [flink]
via GitHub
-
Re: [PR] [FLINK-39524][checkpoint] Fetched channel state: spill files, filtered write, reader [flink]
via GitHub
-
Re: [PR] [FLINK-39524][checkpoint] Fetched channel state: spill files, filtered write, reader [flink]
via GitHub
-
Re: [PR] [FLINK-39524][checkpoint] Fetched channel state: spill files, filtered write, reader [flink]
via GitHub
-
Re: [PR] [FLINK-39524][checkpoint] Fetched channel state: spill files, filtered write, reader [flink]
via GitHub
-
Re: [PR] [FLINK-39524][checkpoint] Fetched channel state: spill files, filtered write, reader [flink]
via GitHub
-
Re: [PR] [FLINK-39524][checkpoint] Fetched channel state: spill files, filtered write, reader [flink]
via GitHub
-
Re: [PR] [FLINK-39524][checkpoint] Fetched channel state: spill files, filtered write, reader [flink]
via GitHub
-
Re: [PR] [FLINK-39524][checkpoint] Fetched channel state: spill files, filtered write, reader [flink]
via GitHub
-
Re: [PR] [FLINK-39524][checkpoint] Fetched channel state: spill files, filtered write, reader [flink]
via GitHub
-
Re: [PR] [FLINK-39524][checkpoint] Fetched channel state: spill files, filtered write, reader [flink]
via GitHub
-
Re: [PR] [FLINK-39524][checkpoint] Fetched channel state: spill files, filtered write, reader [flink]
via GitHub
-
Re: [PR] [FLINK-39524][checkpoint] Fetched channel state: spill files, filtered write, reader [flink]
via GitHub
-
Re: [PR] [FLINK-39524][checkpoint] Fetched channel state: spill files, filtered write, reader [flink]
via GitHub
-
Re: [PR] [FLINK-39524][checkpoint] Fetched channel state: spill files, filtered write, reader [flink]
via GitHub
-
Re: [PR] [FLINK-39524][checkpoint] Fetched channel state: spill files, filtered write, reader [flink]
via GitHub
-
Re: [PR] [FLINK-39524][checkpoint] Fetched channel state: spill files, filtered write, reader [flink]
via GitHub
-
Re: [PR] [FLINK-39524][checkpoint] Fetched channel state: spill files, filtered write, reader [flink]
via GitHub
-
[PR] [DRAFT][ci] Extract license check [flink]
via GitHub
-
[jira] [Closed] (FLINK-40322) PyFlink ArrayType/MultisetType.from_sql_type calls to_sql_type instead
Dian Fu (Jira)
-
[jira] [Created] (FLINK-40337) Preserve operator precedence in generated Janino expressions
Mao Jiayi (Jira)
-
Re: [PR] Yd/fix observed generation suspended [flink-kubernetes-operator]
via GitHub
-
Re: [PR] [FLINK-36876] Add proxy for restClient [flink-kubernetes-operator]
via GitHub
-
[jira] [Updated] (FLINK-40331) [FLINK CDC][fluss] Add an opt-in forward routing mode for fluss sink
ASF GitHub Bot (Jira)
-
[PR] [FLINK-40331][cdc-connect][fluss] Support forward shuffle in fluss sink. [flink-cdc]
via GitHub
-
[jira] [Closed] (FLINK-39881) [FKO] Adopt AI-assisted contribution guidelines for the Kubernetes Operator
Gyula Fora (Jira)
-
Re: [PR] [FLINK-39881] Add AGENTS.md and generative AI tooling disclosure to PR template [flink-kubernetes-operator]
via GitHub
-
[jira] [Created] (FLINK-40336) Avoid full state scans in event-time temporal join on sorted state backends
Mate Czagany (Jira)
-
[jira] [Assigned] (FLINK-40246) flink-kubernetes-operator bundles vulnerable logback-core 1.2.13 (CVE-2024-12798, CVE-2025-11226, CVE-2026-1225)
Gyula Fora (Jira)
-
Re: [D] Community Sync - 2026 [flink-agents]
via GitHub
-
Re: [PR] [FLINK-39481][tests] Fix flaky WindowDistinctAggregateITCase#testCumulateWindow_GroupingSets [flink]
via GitHub
-
[jira] [Resolved] (FLINK-40305) VARIANT string and object key decoding ignores the UTF-8 charset
Sergey Nuyanzin (Jira)
-
[jira] [Commented] (FLINK-40305) VARIANT string and object key decoding ignores the UTF-8 charset
Sergey Nuyanzin (Jira)
-
[jira] [Updated] (FLINK-40307) RestoreTestCompleteness was never executed in CI
Sergey Nuyanzin (Jira)
-
[PR] [FLINK-40335][runtime] Fix Hybrid Shuffle index corruption caused by shared ByteBuffer [flink]
via GitHub
-
[jira] [Created] (FLINK-40335) Hybrid shuffle index files can be corrupted by a ByteBuffer shared across result partitions
Mate Czagany (Jira)
-
[jira] [Updated] (FLINK-40335) Hybrid shuffle index files can be corrupted by a ByteBuffer shared across result partitions
Mate Czagany (Jira)
-
[jira] [Commented] (FLINK-40246) flink-kubernetes-operator bundles vulnerable logback-core 1.2.13 (CVE-2024-12798, CVE-2025-11226, CVE-2026-1225)
Purushottam Sinha (Jira)
-
[jira] [Resolved] (FLINK-18476) PythonEnvUtilsTest#testStartPythonProcess fails
Sergey Nuyanzin (Jira)
-
[PR] [BP-2.3][FLINK-40324][table] Append-only should stay unmaterialized without an ON CONFLICT clause [flink]
via GitHub
-
[PR] Auroflow/fix table api lit [flink]
via GitHub
-
[jira] [Created] (FLINK-40334) Insert-only input should not be materialized under upsert-materialize FORCE
Gustavo de Morais (Jira)
-
[jira] [Created] (FLINK-40333) Move setLastReconciledSpec to after successful transition start for BG deployments
Gyula Fora (Jira)
-
[jira] [Updated] (FLINK-40332) FileCatalogStore is not validating catalog names
ASF GitHub Bot (Jira)
-
[PR] [FLINK-40332][table] Prevent path traversal in FileCatalogStore catalog names [flink]
via GitHub
-
[jira] [Created] (FLINK-40332) FileCatalogStore is not validating catalog names
Gabor Somogyi (Jira)
-
[jira] [Created] (FLINK-40331) [FLINK CDC][fluss] Add an opt-in forward routing mode for fluss sink
Hongshun Wang (Jira)
-
[jira] [Updated] (FLINK-40329) Support Single EKU certificates for server and client TLS authentication
Gyula Komlossi (Jira)
-
[jira] [Resolved] (FLINK-40239) Support additional Flink SQL regular expression functions in YAML Transform
Yanquan Lv (Jira)
-
[PR] [BP-1.20][FLINK-40284][tests] Introduce check to guard test names [flink]
via GitHub
-
Re: [I] [Tech Debt] Surface the ASF generative-AI disclosure in the PR template [flink-agents]
via GitHub
-
[jira] [Closed] (FLINK-40164) FlinkSessionJob's lifecycleState stays "UPGRADING" even after it's suspended successfully
Gyula Fora (Jira)
-
Re: [I] [Feature] Add lineage fields to the event log for per-run trace reconstruction [flink-agents]
via GitHub
-
Re: [PR] [FLINK-36779][table] Fix metric is incorrect and non-changing during the time in Rank [flink]
via GitHub
-
Re: [PR] [FLINK-39426] Add flink-connector-migration bridge module for Sink V2… [flink]
via GitHub
-
[PR] [ci] Guard the coding-agent skill's bundled YAML schema against drift [flink-agents]
via GitHub
-
[I] [Tech Debt] The coding-agent skill's bundled YAML schema can drift from docs/yaml-schema.json unnoticed [flink-agents]
via GitHub
-
[jira] [Updated] (FLINK-18476) PythonEnvUtilsTest#testStartPythonProcess fails
ASF GitHub Bot (Jira)
-
[PR] [FLINK-18476][python] `PythonEnvUtils#testStartPythonProcess` might fail [flink]
via GitHub
-
[jira] [Updated] (FLINK-39356) FlinkStateSnapshot cleanup fails with NPE when status is null, permanently blocking CR and namespace deletion
ASF GitHub Bot (Jira)
-
[PR] [FLINK-39356][snapshot] Fix NPE during FlinkStateSnapshot cleanup when status i… [flink-kubernetes-operator]
via GitHub
-
Re: [PR] [FLINK-40203][runtime] Add an explicit option for Flink SQL-compatible YAML Transform expression semantics [flink-cdc]
via GitHub
-
[jira] [Resolved] (FLINK-40007) Fix Postgres CDC snapshot fetch size conf does not take effect
Xiqian Yu (Jira)
-
[jira] [Resolved] (FLINK-40274) [Flink CDC][cdc-cli] Remove unsupported kubernetes-session from target option help message
Xiqian Yu (Jira)
-
[jira] [Assigned] (FLINK-40274) [Flink CDC][cdc-cli] Remove unsupported kubernetes-session from target option help message
Xiqian Yu (Jira)
-
[jira] [Commented] (FLINK-38264) Connection table api
Yash Anand (Jira)
-
[jira] [Comment Edited] (FLINK-38264) Connection table api
Yash Anand (Jira)
-
Re: [PR] [FLINK-39566][runtime-web] Add checkpoint duration Gantt view [flink]
via GitHub
-
[jira] [Updated] (FLINK-36434) Revise threading model of (KafkaPartition)SplitReader
ASF GitHub Bot (Jira)
-
[PR] [FLINK-36434][Connectors/Kafka] Create the KafkaConsumer lazily on the split fetcher thread [flink-connector-kafka]
via GitHub
-
[jira] [Updated] (FLINK-40330) [Kubernetes HA] Orphaned per-job leader entries accumulate in the cluster ConfigMap after interrupted cleanup or leadership loss
Chaitanya Waikar (Jira)
-
[jira] [Created] (FLINK-40330) [Kubernetes HA] Orphaned per-job leader entries accumulate in the cluster ConfigMap after interrupted cleanup or leadership loss
Chaitanya Waikar (Jira)
-
[jira] [Created] (FLINK-40329) Support Single EKU certificates for server and client TLS authentication
Gyula Komlossi (Jira)
-
[jira] [Comment Edited] (FLINK-40284) A number of tests ending with Tests in class name are skipped from CI/local tests
Sergey Nuyanzin (Jira)
-
[PR] [FLINK-40326][core] Do not over-grant capacity in GatedRateLimiter [flink]
via GitHub
-
[jira] [Updated] (FLINK-40315) Add MariaDB CDC DataStream source
ASF GitHub Bot (Jira)
-
[PR] [FLINK-40315][connect/mariadb] Add MariaDB CDC DataStream source [flink-cdc]
via GitHub
-
[jira] [Assigned] (FLINK-40315) Add MariaDB CDC DataStream source
Leonard Xu (Jira)
-
[jira] [Assigned] (FLINK-40328) Add MariaDB-cdc connector docs
Leonard Xu (Jira)
-
[jira] [Assigned] (FLINK-40316) Add MariaDB CDC SQL connector
Leonard Xu (Jira)
-
[jira] [Assigned] (FLINK-40314) Introduce a MariaDB CDC connector
Leonard Xu (Jira)