issues
Thread
Date
Earlier messages
Later messages
Messages by Date
2026/02/12
Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink]
via GitHub
2026/02/12
Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink]
via GitHub
2026/02/12
Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink]
via GitHub
2026/02/12
Re: [PR] [FLINK-38939][runtime] Pause sources until the 1st checkpoint to prioritize processing recovered records [flink]
via GitHub
2026/02/12
Re: [PR] [FLINK-38939][runtime] Pause sources until the 1st checkpoint to prioritize processing recovered records [flink]
via GitHub
2026/02/12
Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink]
via GitHub
2026/02/12
Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink]
via GitHub
2026/02/12
Re: [PR] [hotfix] Fix onnxruntime build failure on macOS x86_64 [flink-agents]
via GitHub
2026/02/12
[jira] [Closed] (FLINK-38928) Implement an operator for handling DO ERROR/NOTHING
Dawid Wysakowicz (Jira)
2026/02/12
Re: [PR] [FLINK-38928] Implement an operator for handling DO ERROR/NOTHING [flink]
via GitHub
2026/02/12
Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink]
via GitHub
2026/02/12
Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink]
via GitHub
2026/02/12
Re: [PR] [FLINK-39050][Table SQL/Planner] Support configurable handling strategy for null rowtime field in watermark generation [flink]
via GitHub
2026/02/12
[jira] [Created] (FLINK-39075) fn_execution test collection fails in test_flink_fn_execution_pb2.py
Samrat Deb (Jira)
2026/02/12
Re: [PR] [FLINK-39050][Table SQL/Planner] Support configurable handling strategy for null rowtime field in watermark generation [flink]
via GitHub
2026/02/12
Re: [PR] [FLINK-39050][Table SQL/Planner] Support configurable handling strategy for null rowtime field in watermark generation [flink]
via GitHub
2026/02/12
Re: [PR] [FLINK-39050][Table SQL/Planner] Support configurable handling strategy for null rowtime field in watermark generation [flink]
via GitHub
2026/02/12
Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink]
via GitHub
2026/02/12
Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink]
via GitHub
2026/02/12
Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink]
via GitHub
2026/02/12
Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink]
via GitHub
2026/02/12
[jira] [Updated] (FLINK-39062) Support applying watermark on logical relations in SQL
featzhang (Jira)
2026/02/12
Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink]
via GitHub
2026/02/12
Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink]
via GitHub
2026/02/12
Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink]
via GitHub
2026/02/12
Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink]
via GitHub
2026/02/11
[jira] [Updated] (FLINK-39062) Support applying watermark on logical relations in SQL
featzhang (Jira)
2026/02/11
Re: [PR] [FLINK-27661][Runtime / Metrics] PrometheusPushGatewayReporter support pushgateway http authentication [flink]
via GitHub
2026/02/11
Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink]
via GitHub
2026/02/11
[jira] [Updated] (FLINK-8093) flink job fail because of kafka producer create fail of "javax.management.InstanceAlreadyExistsException"
ASF GitHub Bot (Jira)
2026/02/11
[PR] [FLINK-8093][connectors/kafka] Add client.id.prefix support to KafkaSink [flink-connector-kafka]
via GitHub
2026/02/11
Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink]
via GitHub
2026/02/11
Re: [PR] [FLINK-38988][Table SQL/API] Support INET_ATON and INET_NTOA functions for IP address conversion [flink]
via GitHub
2026/02/11
Re: [PR] [FLINK-38988][Table SQL/API] Support INET_ATON and INET_NTOA functions for IP address conversion [flink]
via GitHub
2026/02/11
[jira] [Closed] (FLINK-18379) Introduce asynchronous UDF/UDTF
Natea Eshetu Beshada (Jira)
2026/02/11
[jira] [Commented] (FLINK-18379) Introduce asynchronous UDF/UDTF
Natea Eshetu Beshada (Jira)
2026/02/11
[jira] [Assigned] (FLINK-8093) flink job fail because of kafka producer create fail of "javax.management.InstanceAlreadyExistsException"
Natea Eshetu Beshada (Jira)
2026/02/11
[jira] [Updated] (FLINK-39062) Support logical-level watermark definition via SQL function
featzhang (Jira)
2026/02/11
[jira] [Updated] (FLINK-39062) Support logical-level watermark definition via SQL function
featzhang (Jira)
2026/02/11
Re: [PR] [FLINK-39064][Table SQL / API] Add built-in REGEXP_SPLIT function to split string by regular expression pattern [flink]
via GitHub
2026/02/11
[jira] [Updated] (FLINK-39062) Support logical-level watermark definition via SQL function
featzhang (Jira)
2026/02/11
[jira] [Closed] (FLINK-15867) LAST_VALUE and FIRST_VALUE aggregate function does not support time-related types
Natea Eshetu Beshada (Jira)
2026/02/11
[jira] [Commented] (FLINK-15867) LAST_VALUE and FIRST_VALUE aggregate function does not support time-related types
Natea Eshetu Beshada (Jira)
2026/02/11
[jira] [Closed] (FLINK-38969) Extend current JSON_STRING to convert a Variant to a Json string.
Gyula Fora (Jira)
2026/02/11
Re: [PR] [FLINK-38969][SQL] Extend json_string to convert variant type [flink]
via GitHub
2026/02/11
Re: [PR] [FLINK-38515][flink-avro-confluent-registry] Implement OAuth2 mechanism that supports token inheritance for the Schema Registry authentication [flink]
via GitHub
2026/02/11
Re: [PR] [FLINK-38515][flink-avro-confluent-registry] Implement OAuth2 mechanism that supports token inheritance for the Schema Registry authentication [flink]
via GitHub
2026/02/11
Re: [PR] [FLINK-26051][table] Fix ROW_NUMBER with CASE WHEN and WHERE clause causing window ordering exception [flink]
via GitHub
2026/02/11
[jira] [Updated] (FLINK-39074) Add built-in AI model inference capability to PyFlink with automatic lifecycle management
featzhang (Jira)
2026/02/11
[jira] [Updated] (FLINK-26051) one sql has row_number =1 and the subsequent SQL has "case when" and "where" statement result Exception : The window can only be ordered in ASCENDING mode
ASF GitHub Bot (Jira)
2026/02/11
[PR] [FLINK-26051][table] Fix ROW_NUMBER with CASE WHEN and WHERE clause causing window ordering exception [flink]
via GitHub
2026/02/11
[jira] [Assigned] (FLINK-39071) Select fields rather than * to read snapshot data in case of schema changes.
Leonard Xu (Jira)
2026/02/11
[jira] [Created] (FLINK-39074) Add built-in AI model inference capability to PyFlink with automatic lifecycle management
featzhang (Jira)
2026/02/11
Re: [PR] [FLINK-24544][formats] Fix Avro enum deserialization failure with Confluent Schema Registry [flink]
via GitHub
2026/02/11
[jira] [Assigned] (FLINK-24544) Failure when using Kafka connector in Table API with Avro and Confluent schema registry
Natea Eshetu Beshada (Jira)
2026/02/11
Re: [D] Planning Flink Agents 0.3 [flink-agents]
via GitHub
2026/02/11
[PR] [FLINK-24544][formats] Fix Avro enum deserialization failure with Confluent Schema Registry [flink]
via GitHub
2026/02/11
Re: [D] Planning Flink Agents 0.3 [flink-agents]
via GitHub
2026/02/11
[jira] [Updated] (FLINK-24544) Failure when using Kafka connector in Table API with Avro and Confluent schema registry
ASF GitHub Bot (Jira)
2026/02/11
Re: [PR] [FLINK-38892][runtime/rest] Introduce the scheduler and type information of the target job in the JobDetails(Info).java [flink]
via GitHub
2026/02/11
Re: [PR] [FLINK-XXXXX][PyFlink] Add AI inference lifecycle management with infer() API [flink]
via GitHub
2026/02/11
Re: [PR] [FLINK-38892][runtime/rest] Introduce the scheduler and type information of the target job in the JobDetails(Info).java [flink]
via GitHub
2026/02/11
Re: [PR] [FLINK-38988][Table SQL/API] Support INET_ATON and INET_NTOA functions for IP address conversion [flink]
via GitHub
2026/02/11
[PR] [FLINK-XXXXX][PyFlink] Add AI inference lifecycle management with infer() API [flink]
via GitHub
2026/02/11
Re: [PR] [FLINK-38897][Runtime/REST] Introduce the /jobs/:jobid/rescales/config endpoint in the REST API [flink]
via GitHub
2026/02/11
Re: [D] Planning Flink Agents 0.3 [flink-agents]
via GitHub
2026/02/11
[jira] [Updated] (FLINK-39071) Select fields rather than * to read snapshot data in case of schema changes.
Hongshun Wang (Jira)
2026/02/11
Re: [PR] [minor][hotfix] Update configOption name from `sink.job.id.prefix` to `job.id.prefix` [flink-cdc]
via GitHub
2026/02/11
Re: [PR] [FLINK-38897][Runtime/REST] Introduce the /jobs/:jobid/rescales/config endpoint in the REST API [flink]
via GitHub
2026/02/11
Re: [PR] [hotfix][infra][BP-1.20] Add .metals and .bloop into .gitignore (#27480) [flink]
via GitHub
2026/02/11
Re: [PR] [hotfix][infra][BP-1.20] Add .metals and .bloop into .gitignore (#27480) [flink]
via GitHub
2026/02/11
Re: [PR] [hotfix][infra][BP-2.2] Add .metals and .bloop into .gitignore (#27480) [flink]
via GitHub
2026/02/11
Re: [PR] [hotfix][infra][BP-2.2] Add .metals and .bloop into .gitignore (#27480) [flink]
via GitHub
2026/02/11
Re: [PR] [FLINK-38249] Add support for skipping specific Debezium operations in MySQL CDC source. [flink-cdc]
via GitHub
2026/02/11
Re: [PR] [FLINK-37677][cdc-common][cdc-runtime] Handle Exclusion of `create.table` Events in Flink CDC Schema Evolution [flink-cdc]
via GitHub
2026/02/11
Re: [PR] [FLINK-37677][cdc-common][cdc-runtime] Handle Exclusion of `create.table` Events in Flink CDC Schema Evolution [flink-cdc]
via GitHub
2026/02/11
Re: [PR] [FLINK-38249] Add support for skipping specific Debezium operations in MySQL CDC source. [flink-cdc]
via GitHub
2026/02/11
Re: [PR] [FLINK-35661][table] Fix MiniBatchGroupAggFunction silently dropping records (backport 2.1) [flink]
via GitHub
2026/02/11
Re: [PR] [FLINK-35661][table] Fix MiniBatchGroupAggFunction silently dropping records (backport 2.2) [flink]
via GitHub
2026/02/11
Re: [PR] [FLINK-32609] Support Projection Pushdown [flink-connector-kafka]
via GitHub
2026/02/11
Re: [PR] [FLINK-37504] Handle TLS Certificate Renewal [flink]
via GitHub
2026/02/11
Re: [PR] [FLINK-38986][runtime][test] Update further tests with modern cipher suite [flink]
via GitHub
2026/02/11
[jira] [Commented] (FLINK-38624) Flink 2.1 Job Failure: Type Mismatch Exception in StreamPhysicalOverAggregateRule (TIMESTAMP(3) vs TIMESTAMP(3) ROWTIME)
EMERSON WANG (Jira)
2026/02/11
[jira] [Updated] (FLINK-38624) Flink 2.1 Job Failure: Type Mismatch Exception in StreamPhysicalOverAggregateRule (TIMESTAMP(3) vs TIMESTAMP(3) ROWTIME)
EMERSON WANG (Jira)
2026/02/11
[jira] [Updated] (FLINK-38624) Flink 2.1 Job Failure: Type Mismatch Exception in StreamPhysicalOverAggregateRule (TIMESTAMP(3) vs TIMESTAMP(3) ROWTIME)
EMERSON WANG (Jira)
2026/02/11
[jira] [Updated] (FLINK-38624) Flink 2.1 Job Failure: Type Mismatch Exception in StreamPhysicalOverAggregateRule (TIMESTAMP(3) vs TIMESTAMP(3) ROWTIME)
EMERSON WANG (Jira)
2026/02/11
[jira] [Commented] (FLINK-39012) Support global enumerator/dispatcher for dynamic Kafka source
Bowen Li (Jira)
2026/02/11
[jira] [Resolved] (FLINK-39012) Support global enumerator/dispatcher for dynamic Kafka source
Bowen Li (Jira)
2026/02/11
Re: [PR] [FLINK-39012]Add global kafka enumerator support [flink-connector-kafka]
via GitHub
2026/02/11
Re: [PR] [FLINK-39012]Add global kafka enumerator support [flink-connector-kafka]
via GitHub
2026/02/11
[jira] [Updated] (FLINK-39040) allow additional json to be specified for the body request
Ferenc Csaky (Jira)
2026/02/11
[jira] [Closed] (FLINK-39040) allow additional json to be specified for the body request
Ferenc Csaky (Jira)
2026/02/11
[jira] [Assigned] (FLINK-39040) allow additional json to be specified for the body request
Ferenc Csaky (Jira)
2026/02/11
Re: [PR] FLINK-39040 Additional body json for GenericJsonAndUrlQueryCreator [flink-connector-http]
via GitHub
2026/02/11
Re: [D] Planning Flink Agents 0.3 [flink-agents]
via GitHub
2026/02/11
Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink]
via GitHub
2026/02/11
Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink]
via GitHub
2026/02/11
Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink]
via GitHub
2026/02/11
Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink]
via GitHub
2026/02/11
Re: [D] Community Sync - 2026 [flink-agents]
via GitHub
2026/02/11
Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink]
via GitHub
2026/02/11
Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink]
via GitHub
2026/02/11
Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink]
via GitHub
2026/02/11
Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink]
via GitHub
2026/02/11
Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink]
via GitHub
2026/02/11
Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink]
via GitHub
2026/02/11
Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink]
via GitHub
2026/02/11
Re: [PR] [FLINK-39022][security] Set security.ssl.algorithms default value to modern cipher suite [flink]
via GitHub
2026/02/11
[jira] [Commented] (FLINK-38986) SSL connection failures in BlobClientSslTest / NettyClientServerSslTest with latest JDK versions
Gabor Somogyi (Jira)
2026/02/11
[PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink]
via GitHub
2026/02/11
[jira] [Updated] (FLINK-37399) Watermark alignment can prevent backlogged jobs from using all available resources
ASF GitHub Bot (Jira)
2026/02/11
Re: [D] Planning Flink Agents 0.3 [flink-agents]
via GitHub
2026/02/11
[jira] [Commented] (FLINK-38986) SSL connection failures in BlobClientSslTest / NettyClientServerSslTest with latest JDK versions
Yaroslav (Jira)
2026/02/11
Re: [PR] [hotfix][infra][BP-120] Add .metals and .bloop into .gitignore (#27480) [flink]
via GitHub
2026/02/11
[PR] [hotfix][infra][BP-120] Add .metals and .bloop into .gitignore (#27480) [flink]
via GitHub
2026/02/11
[jira] [Assigned] (FLINK-39073) Idle source splits are picked by watermark alignment
Rui Fan (Jira)
2026/02/11
Re: [PR] [hotfix][infra][BP-2.2] Add .metals and .bloop into .gitignore (#27480) [flink]
via GitHub
2026/02/11
Re: [PR] [FLINK-37504] Handle TLS Certificate Renewal [flink]
via GitHub
2026/02/11
[PR] [hotfix][infra][BP-2.2] Add .metals and .bloop into .gitignore (#27480) [flink]
via GitHub
2026/02/11
Re: [PR] [FLINK-39015][table] Fix key extractor for multi join. Change GenericRowData to BinaryRowData [flink]
via GitHub
2026/02/11
Re: [PR] [hotfix] Wait for leader election to prevent OUT_OF_ORDER issues [flink-connector-kafka]
via GitHub
2026/02/11
[jira] [Created] (FLINK-39073) Idle source splits are picked by watermark alignment
Efrat Levitan (Jira)
2026/02/11
Re: [PR] [FLINK-30975] Upgrade hadoop to 3.4.X [flink]
via GitHub
2026/02/11
Re: [PR] [FLINK-39067][docs] Move Python documentation from Hugo to PyDocs [flink]
via GitHub
2026/02/11
[jira] [Updated] (FLINK-39067) Move Python docs to PyDocs
ASF GitHub Bot (Jira)
2026/02/11
[PR] [FLINK-39067][docs] Move Python documentation from Hugo to PyDocs [flink]
via GitHub
2026/02/11
Re: [PR] [FLINK-38953] Cleanup configurations for SSL hostname verification [flink]
via GitHub
2026/02/11
[jira] [Commented] (FLINK-24544) Failure when using Kafka connector in Table API with Avro and Confluent schema registry
Natea Eshetu Beshada (Jira)
2026/02/11
Re: [PR] [FLINK-30068][runtime] Add configurable commit failure strategy for S… [flink]
via GitHub
2026/02/11
Re: [PR] [FLINK-23886][runtime] Fix null column family handle in RocksDBFullRestoreOperation [flink]
via GitHub
2026/02/11
[jira] [Assigned] (FLINK-23886) An exception is thrown out when recover job timers from checkpoint file
Natea Eshetu Beshada (Jira)
2026/02/11
[jira] [Assigned] (FLINK-30068) Allow users to configure what to do with errors while committing transactions during recovery in KafkaSink
Natea Eshetu Beshada (Jira)
2026/02/11
[jira] [Updated] (FLINK-30068) Allow users to configure what to do with errors while committing transactions during recovery in KafkaSink
ASF GitHub Bot (Jira)
2026/02/11
[PR] [pipeline] Use GHA workflow triggers to run labeler workflow [flink-cdc]
via GitHub
2026/02/11
[PR] [FLINK-30068][runtime] Add configurable commit failure strategy for S… [flink]
via GitHub
2026/02/11
[jira] [Updated] (FLINK-23886) An exception is thrown out when recover job timers from checkpoint file
ASF GitHub Bot (Jira)
2026/02/11
[PR] [FLINK-23886][runtime] Fix null column family handle in RocksDBFullRe… [flink]
via GitHub
2026/02/11
[jira] [Updated] (FLINK-39072) Handle InvalidPidMappingException as known failure in KafkaCommitter
Natea Eshetu Beshada (Jira)
2026/02/11
Re: [PR] Handle InvalidPidMappingException as known failure in KafkaCommitter [flink-connector-kafka]
via GitHub
2026/02/11
[PR] Handle InvalidPidMappingException as known failure in KafkaCommitter [flink-connector-kafka]
via GitHub
2026/02/11
[jira] [Assigned] (FLINK-39072) Handle InvalidPidMappingException as known failure in KafkaCommitter
Natea Eshetu Beshada (Jira)
2026/02/11
[jira] [Updated] (FLINK-39072) Handle InvalidPidMappingException as known failure in KafkaCommitter
Natea Eshetu Beshada (Jira)
2026/02/11
[jira] [Created] (FLINK-39072) Handle InvalidPidMappingException as known failure in KafkaCommitter
Natea Eshetu Beshada (Jira)
2026/02/11
Re: [PR] [FLINK-39042][webui] Make watermark timestamps timezone-aware and configurable [flink]
via GitHub
2026/02/11
Re: [PR] [FLINK-39063][pipeline-connector][Fluss] Fix some spelling mistakes in pipeline fluss connector [flink-cdc]
via GitHub
2026/02/11
Re: [PR] [FLINK-39042][webui] Make watermark timestamps timezone-aware and configurable [flink]
via GitHub
2026/02/11
Re: [PR] [FLINK-39042][webui] Make watermark timestamps timezone-aware and configurable [flink]
via GitHub
2026/02/11
Re: [PR] Flink community blog February 2026 [flink-web]
via GitHub
2026/02/11
Re: [PR] [FLINK-38340][runtime] Introduce the rescale timeline related abstraction for performing rescale operations [flink]
via GitHub
2026/02/11
Re: [PR] Flink community blog February 2026 [flink-web]
via GitHub
2026/02/11
Re: [PR] Flink community blog February 2026 [flink-web]
via GitHub
2026/02/11
Re: [PR] Flink community blog February 2026 [flink-web]
via GitHub
2026/02/11
Re: [PR] Flink community blog February 2026 [flink-web]
via GitHub
2026/02/11
Re: [PR] [FLINK-39069][SQL Client] Support saving and exporting SQL execution history [flink]
via GitHub
2026/02/11
Re: [PR] Flink community blog February 2026 [flink-web]
via GitHub
2026/02/11
Re: [PR] Flink community blog February 2026 [flink-web]
via GitHub
2026/02/11
[PR] Select fileds rathert * to read snapshot data in case schema changes. [flink-cdc]
via GitHub
2026/02/11
[jira] [Updated] (FLINK-39069) [SQL Client] Support saving and exporting SQL execution history
ASF GitHub Bot (Jira)
2026/02/11
[PR] [FLINK-39069][SQL Client] Support saving and exporting SQL execution history [flink]
via GitHub
2026/02/11
Re: [I] [Bug] Failed to connect to remote mcp server [flink-agents]
via GitHub
2026/02/11
Re: [PR] support mcp without list_prompts interface [flink-agents]
via GitHub
2026/02/11
Re: [PR] support mcp without list_prompts interface [flink-agents]
via GitHub
2026/02/11
[jira] [Created] (FLINK-39071) Select fileds rathert * to read snapshot data incase schema changes.
Hongshun Wang (Jira)
2026/02/11
Re: [PR] Add Flink Connector Parent 2.0.0 [flink-web]
via GitHub
2026/02/11
[jira] [Created] (FLINK-39070) Update Kafka parent connector
David Radley (Jira)
2026/02/11
Re: [PR] Flink community blog February 2026 [flink-web]
via GitHub
2026/02/11
Re: [PR] FLINK-39040 Additional body json for GenericJsonAndUrlQueryCreator [flink-connector-http]
via GitHub
2026/02/11
[jira] [Created] (FLINK-39069) [SQL Client] Support saving and exporting SQL execution history
featzhang (Jira)
2026/02/11
[jira] [Created] (FLINK-39068) [SQL Client] Support saving and exporting SQL execution history
featzhang (Jira)
2026/02/11
Re: [PR] [minor][hotfix] Update configOption name from `sink.job.id.prefix` to `job.id.prefix` [flink-cdc]
via GitHub
2026/02/11
Re: [PR] [minor][hotfix] Update configOption name from `sink.job.id.prefix` to `job.id.prefix` [flink-cdc]
via GitHub
2026/02/11
Re: [PR] [hotfix] add .worktrees to .gitignore [flink]
via GitHub
2026/02/11
Re: [PR] [FLINK-36429] [runtime-web] Enhancing Flink History Server File Storage and Retrieval with RocksDB [flink]
via GitHub
2026/02/11
Re: [PR] [minor][hotfix] Update configOption name from `sink.job.id.prefix` to `job.id.prefix` [flink-cdc]
via GitHub
2026/02/11
[PR] [hotfix] add .worktrees to .gitignore [flink]
via GitHub
2026/02/11
[PR] [minor][hotfix] Update configOption name from `sink.job.id.prefix` to `job.id.prefix` [flink-cdc]
via GitHub
2026/02/11
Re: [PR] [FLINK-39053][format/avro] Support VARCHAR to ENUM conversion in avro-confluent format [flink]
via GitHub
2026/02/11
[jira] [Resolved] (FLINK-36796) oracle cdc supports pipeline configuration connector
Yanquan Lv (Jira)
2026/02/11
[PR] [FLINK-36429] [runtime-web] Enhancing Flink History Server File Storage and Retrieval with RocksDB [flink]
via GitHub
2026/02/11
[jira] [Closed] (FLINK-38823) Error running wide table task
peiyu (Jira)
2026/02/11
[jira] [Resolved] (FLINK-38512) Postgres YAML CDC support database name with middlescore
Yanquan Lv (Jira)
2026/02/11
[jira] [Resolved] (FLINK-39047) Translate the Chinese documentation related to Transform
Yanquan Lv (Jira)
2026/02/11
[jira] [Resolved] (FLINK-38514) Postgres YAML CDC support UUID_ARRAY
Yanquan Lv (Jira)
2026/02/11
Re: [PR] [FLINK-35661][table] Fix MiniBatchGroupAggFunction silently dropping records (backport 2.0) [flink]
via GitHub
2026/02/11
Re: [PR] [FLINK-39056][pipeline-connector][iceberg] Duplicate Data Issue in Iceberg Sink During Two-Phase Commit [flink-cdc]
via GitHub
2026/02/11
[jira] [Resolved] (FLINK-39010) YAML Pipeline supports item subscription of variant types
Yanquan Lv (Jira)
2026/02/11
Re: [PR] [FLINK-38592] [POC] Native Flink S3 FileSystem [flink]
via GitHub
2026/02/11
Re: [PR] [FLINK-38953] Cleanup configurations for SSL hostname verification [flink]
via GitHub
2026/02/11
Re: [PR] [FLINK-38953] Cleanup configurations for SSL hostname verification [flink]
via GitHub
2026/02/11
Re: [PR] [FLINK-35661][table] Fix MiniBatchGroupAggFunction silently dropping records (backport 2.1) [flink]
via GitHub
2026/02/11
Re: [PR] [FLINK-35661][table] Fix MiniBatchGroupAggFunction silently dropping records (backport 2.1) [flink]
via GitHub
2026/02/11
[jira] [Commented] (FLINK-29671) Kubernetes e2e test fails during test initialization
Natea Eshetu Beshada (Jira)
2026/02/11
[jira] [Commented] (FLINK-35661) MiniBatchGroupAggFunction can silently drop records under certain conditions
Natea Eshetu Beshada (Jira)
2026/02/11
Re: [PR] [FLINK-35661][table] Fix MiniBatchGroupAggFunction silently dropping records (backport 2.2) [flink]
via GitHub
2026/02/11
Re: [PR] [FLINK-35661][table] Fix MiniBatchGroupAggFunction silently dropping records (backport 2.2) [flink]
via GitHub
2026/02/11
[jira] [Commented] (FLINK-35284) Streaming File Sink end-to-end test times out
Natea Eshetu Beshada (Jira)
2026/02/11
Re: [PR] [FLINK-38857][model] Add retry with default value fallback for triton inference failures [flink]
via GitHub
2026/02/11
Re: [PR] [FLINK-38857][model] Add retry with default value fallback for triton inference failures [flink]
via GitHub
2026/02/11
Re: [PR] [FLINK-38897][Runtime/REST] Introduce the /jobs/:jobid/rescales/config endpoint in the REST API [flink]
via GitHub
2026/02/11
[jira] [Updated] (FLINK-39066) Fix fluss's metric histogram always return null
Thorne (Jira)
Earlier messages
Later messages