issues@flink.apache.org, 2026-02

You are viewing a plain text version of this content. The canonical link for it is here.

- Re: [PR] [hotfix] Fix the problems using Kafka as action state store [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2026/02/01 01:56:35 UTC, 2 replies.
- Re: [PR] fix: issuer secret name [flink-kubernetes-operator] - posted by "mlboy (via GitHub)" <gi...@apache.org> on 2026/02/01 03:53:10 UTC, 0 replies.
- [PR] [FLINK-37485][starrocks] Add support for TIME type [flink-cdc] - posted by "Hisoka-X (via GitHub)" <gi...@apache.org> on 2026/02/01 07:25:39 UTC, 5 replies.
- [jira] [Updated] (FLINK-37485) StarRocks Pipeline connector supports TIME type mapping - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/01 07:26:00 UTC, 0 replies.
- [PR] [FLINK-38520][postgres] Postgres YAML CDC support array with null element [flink-cdc] - posted by "Hisoka-X (via GitHub)" <gi...@apache.org> on 2026/02/01 08:19:53 UTC, 1 replies.
- [jira] [Updated] (FLINK-38520) Postgres YAML CDC support array with null element - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/01 08:20:00 UTC, 0 replies.
- Re: [PR] [FLINK-38969][Sql] Extend json_string to convert variant type [flink] - posted by "gaborgsomogyi (via GitHub)" <gi...@apache.org> on 2026/02/01 11:29:39 UTC, 0 replies.
- Re: [PR] [FLINK-38946][flink-metrics] Allow AWS PrivateLink/GCP Cloud Private Service Connect for Datadog integration [flink] - posted by "stoiev (via GitHub)" <gi...@apache.org> on 2026/02/01 11:35:46 UTC, 0 replies.
- [PR] [hotfix] Update binary release script for multi flink version [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2026/02/01 13:29:37 UTC, 3 replies.
- Re: [PR] [FLINK-38848] [table] Supports to pass the required privilege when catalog manager gets the table [flink] - posted by "jerqi (via GitHub)" <gi...@apache.org> on 2026/02/01 14:01:26 UTC, 4 replies.
- Re: [PR] [FLINK-38969][SQL] Extend json_string to convert variant type [flink] - posted by "gaborgsomogyi (via GitHub)" <gi...@apache.org> on 2026/02/01 14:01:31 UTC, 10 replies.
- [jira] [Commented] (FLINK-38995) Update the current Status of Disaggregated State & ForSt - posted by "Yuan Mei (Jira)" <ji...@apache.org> on 2026/02/01 14:11:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38995) Update the current Status of Disaggregated State & ForSt - posted by "Yuan Mei (Jira)" <ji...@apache.org> on 2026/02/01 14:12:00 UTC, 0 replies.
- Re: [D] Flink Agents Release Process [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2026/02/01 14:55:52 UTC, 1 replies.
- Re: [PR] [FLINK-37924][table]Introduce Built-in Function to Access field or element in the Variant [flink] - posted by "yunfengzhou-hub (via GitHub)" <gi...@apache.org> on 2026/02/02 01:37:30 UTC, 0 replies.
- Re: [PR] [FLINK-38981][table] Migrate BatchPhysicalSortMergeJoinRule to java [flink] - posted by "liuyongvs (via GitHub)" <gi...@apache.org> on 2026/02/02 01:59:29 UTC, 0 replies.
- Re: [PR] [FLINK-38980][table] Migrate RemoveRedundantLocalSortAggRule to java [flink] - posted by "liuyongvs (via GitHub)" <gi...@apache.org> on 2026/02/02 01:59:57 UTC, 0 replies.
- [jira] [Created] (FLINK-39004) [JUnit5 Migration] Migrate the remaining classes related to junit4 of flink-table module to junit5 - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/02/02 03:02:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39004) [JUnit5 Migration] Migrate the remaining test classes related to junit4 of flink-table module to junit5 - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/02/02 03:02:00 UTC, 2 replies.
- [jira] [Assigned] (FLINK-39004) [JUnit5 Migration] Migrate the remaining test classes related to junit4 of flink-table module to junit5 - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/02/02 03:03:00 UTC, 0 replies.
- [PR] [FLINK-39004][flink-table] JUnit5 Migration: Migrate the remaining test classes related to junit4 of flink-table module to junit5 [flink] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2026/02/02 03:06:05 UTC, 5 replies.
- Re: [PR] [FLINK-38906] Pass transform parser in context and polish built-in functions [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2026/02/02 03:31:37 UTC, 0 replies.
- Re: [PR] [FLINK-38577] Added BlueGreen active deployment ingress [flink-kubernetes-operator] - posted by "drossos (via GitHub)" <gi...@apache.org> on 2026/02/02 03:44:44 UTC, 1 replies.
- [PR] [hotfix][doc] Add faq for Ollama server [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2026/02/02 06:06:10 UTC, 0 replies.
- [jira] [Created] (FLINK-39005) AVRO Format Improvement - posted by "xiaolong3817 (Jira)" <ji...@apache.org> on 2026/02/02 06:23:00 UTC, 0 replies.
- [PR] [FLINK-38916][table-planner] MultiJoin produces incorrect results for OR join conditions when parallelism is greater than 1 [flink] - posted by "SteveStevenpoor (via GitHub)" <gi...@apache.org> on 2026/02/02 06:26:44 UTC, 12 replies.
- [jira] [Updated] (FLINK-38916) MultiJoin produces incorrect results for OR join conditions when parallelism is greater than 1 - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/02 06:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39006) Flink Document correction - posted by "lajith (Jira)" <ji...@apache.org> on 2026/02/02 07:08:00 UTC, 0 replies.
- Re: [PR] [hotfix][doc] Add Ollama server 0.9.0+ version requirement [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2026/02/02 07:29:53 UTC, 1 replies.
- [jira] [Closed] (FLINK-38577) FlinkBlueGreenDeployment Kubernetes Networking Update / Ingress not Stable - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2026/02/02 07:30:00 UTC, 0 replies.
- [PR] [FLINK-38514][postgres] Add support for UUID array type in PostgreSQL CDC connector [flink-cdc] - posted by "Hisoka-X (via GitHub)" <gi...@apache.org> on 2026/02/02 07:35:26 UTC, 2 replies.
- [jira] [Updated] (FLINK-38514) Postgres YAML CDC support UUID_ARRAY - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/02 07:36:00 UTC, 0 replies.
- [PR] [FLINK-39005][format] Users can choose to use the fast reader feature. [flink] - posted by "low-bee (via GitHub)" <gi...@apache.org> on 2026/02/02 08:08:16 UTC, 15 replies.
- Re: [PR] Announce Flink Agents 0.2.0 [flink-web] - posted by "istavrak (via GitHub)" <gi...@apache.org> on 2026/02/02 08:08:57 UTC, 6 replies.
- [jira] [Updated] (FLINK-39005) AVRO Format Improvement - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/02 08:09:00 UTC, 1 replies.
- [jira] [Created] (FLINK-39007) Run RAT license check automatically - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2026/02/02 08:19:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39007) Run RAT license check in connectors automatically - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2026/02/02 08:20:00 UTC, 1 replies.
- [PR] [FLINK-39007] Run RAT plugin in downstream projects automatically [flink-connector-shared-utils] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2026/02/02 08:41:12 UTC, 4 replies.
- Re: [PR] [FLINK-38888][transform] YAML Pipeline supports item subscription of array and map [flink-cdc] - posted by "Hisoka-X (via GitHub)" <gi...@apache.org> on 2026/02/02 09:01:18 UTC, 0 replies.
- Re: [PR] [FLINK-38912] Upgrade Netty to 4.2.6.Final [flink] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2026/02/02 09:04:58 UTC, 3 replies.
- [jira] [Updated] (FLINK-38911) mysql-cdc-connector datastream support scan.binlog.newly-added-table.enable - posted by "Thorne (Jira)" <ji...@apache.org> on 2026/02/02 09:05:00 UTC, 0 replies.
- [PR] [minor][doc] Fix stable version redirection after 0.2.0 released [flink-agents] - posted by "leonardBang (via GitHub)" <gi...@apache.org> on 2026/02/02 09:12:14 UTC, 3 replies.
- Re: [PR] [FLINK-38888][transform] YAML Pipeline supports item subscription of array, map and row [flink-cdc] - posted by "yuxiqian (via GitHub)" <gi...@apache.org> on 2026/02/02 09:38:46 UTC, 6 replies.
- Re: [PR] Make flink download caching conditional on a cache miss [flink-connector-shared-utils] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2026/02/02 09:41:44 UTC, 1 replies.
- [jira] [Closed] (FLINK-39007) Run RAT license check in connectors automatically - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2026/02/02 09:50:00 UTC, 0 replies.
- Re: [PR] [hotfix] Make cutting patch version in stage_jars.sh platform-agnostic [flink-connector-shared-utils] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2026/02/02 09:51:32 UTC, 1 replies.
- Re: [PR] [hotfix] Intermittent unit test failures we have hit in ExecutionGraph tests [flink] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2026/02/02 10:34:25 UTC, 0 replies.
- [jira] [Commented] (FLINK-38986) SSL connection failures in BlobClientSslTest / NettyClientServerSslTest with latest JDK versions - posted by "Imre Balassa (Jira)" <ji...@apache.org> on 2026/02/02 10:37:00 UTC, 5 replies.
- [jira] [Created] (FLINK-39008) Support record types natively in DataTypeExtractor - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2026/02/02 10:49:00 UTC, 0 replies.
- Re: [PR] [FLINK-38986][runtime][test] Update SSL tests with modern cipher suites [flink] - posted by "gaborgsomogyi (via GitHub)" <gi...@apache.org> on 2026/02/02 10:59:12 UTC, 2 replies.
- [jira] [Updated] (FLINK-38986) SSL connection failures in BlobClientSslTest / NettyClientServerSslTest with latest JDK versions - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2026/02/02 11:04:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38986) SSL connection failures in BlobClientSslTest / NettyClientServerSslTest with latest JDK versions - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2026/02/02 11:05:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38986) SSL connection failures in BlobClientSslTest / NettyClientServerSslTest with latest JDK versions - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2026/02/02 11:05:00 UTC, 0 replies.
- [PR] [FLINK-39008][table-common] Support record types natively in DataTypeExtractor [flink] - posted by "twalthr (via GitHub)" <gi...@apache.org> on 2026/02/02 11:07:51 UTC, 7 replies.
- [jira] [Updated] (FLINK-39008) Support record types natively in DataTypeExtractor - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/02 11:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39009) flink postgres unnest insert way - posted by "Gaurav Miglani (Jira)" <ji...@apache.org> on 2026/02/02 11:35:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38629) Add document for FLIP-544: SinkUpsertMaterializer V2 - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2026/02/02 11:48:00 UTC, 0 replies.
- [PR] [FLINK-38998][table] Fix cascaded event time WindowAggregate does not produce data when offset is specified [flink] - posted by "sa-kononov (via GitHub)" <gi...@apache.org> on 2026/02/02 13:27:38 UTC, 5 replies.
- [jira] [Updated] (FLINK-38998) Cascaded event time Window Aggregate does not produce data when offset is specified - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/02 13:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39010) YAML Pipeline supports item subscription of variant types - posted by "Jia Fan (Jira)" <ji...@apache.org> on 2026/02/02 13:35:00 UTC, 0 replies.
- [PR] [chore][improve] Improve flaky test case FlussSinkITCase [flink-cdc] - posted by "Hisoka-X (via GitHub)" <gi...@apache.org> on 2026/02/02 14:32:40 UTC, 1 replies.
- [PR] [FLINK-38928] Implement an operator for handling DO ERROR/NOTHING [flink] - posted by "dawidwys (via GitHub)" <gi...@apache.org> on 2026/02/02 14:44:37 UTC, 16 replies.
- [jira] [Updated] (FLINK-38928) Implement an operator for handling DO ERROR/NOTHING - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/02 14:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39011) Cast does not support UnresolvedDataType - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2026/02/02 15:31:00 UTC, 0 replies.
- Re: [PR] [FLINK-38592] [POC] Native Flink S3 FileSystem [flink] - posted by "Samrat002 (via GitHub)" <gi...@apache.org> on 2026/02/02 17:31:32 UTC, 48 replies.
- [jira] [Created] (FLINK-39012) Support global enumerator/dispatcher for dynamic Kafka source - posted by "Xin Gao (Jira)" <ji...@apache.org> on 2026/02/02 17:51:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-39012) Support global enumerator/dispatcher for dynamic Kafka source - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2026/02/02 19:17:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39012) Support global enumerator/dispatcher for dynamic Kafka source - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2026/02/02 19:30:00 UTC, 3 replies.
- [jira] [Commented] (FLINK-39012) Support global enumerator/dispatcher for dynamic Kafka source - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2026/02/02 19:31:00 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-39012) Support global enumerator/dispatcher for dynamic Kafka source - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2026/02/02 19:32:00 UTC, 0 replies.
- Re: [PR] [FLINK-32609] Support Projection Pushdown [flink-connector-kafka] - posted by "fqshopify (via GitHub)" <gi...@apache.org> on 2026/02/02 19:56:19 UTC, 16 replies.
- Re: [PR] [FLINK-38263][table] add secret store related interfaces [flink] - posted by "lihaosky (via GitHub)" <gi...@apache.org> on 2026/02/02 20:22:01 UTC, 3 replies.
- [jira] [Created] (FLINK-39013) add E2E test for DynamicKafkaTableSource - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2026/02/02 22:23:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-39013) add E2E test for DynamicKafkaTableSource - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2026/02/02 22:24:00 UTC, 0 replies.
- [PR] [FLINK-39013] add E2E test for DynamicKafkaTableSource [flink-connector-kafka] - posted by "bowenli86 (via GitHub)" <gi...@apache.org> on 2026/02/02 22:26:03 UTC, 1 replies.
- [jira] [Updated] (FLINK-39013) add E2E test for DynamicKafkaTableSource - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/02 22:27:00 UTC, 0 replies.
- [PR] [FLINK-38986][runtime][test] Update further tests with modern cipher suite [flink] - posted by "balassai (via GitHub)" <gi...@apache.org> on 2026/02/02 22:30:11 UTC, 18 replies.
- [PR] FIX: clear reconcilliation status when suspension occurs [flink-kubernetes-operator] - posted by "hemmatio (via GitHub)" <gi...@apache.org> on 2026/02/02 23:03:56 UTC, 1 replies.
- [PR] [FLINK-38261] add catalog connection resource [flink] - posted by "lihaosky (via GitHub)" <gi...@apache.org> on 2026/02/03 00:28:33 UTC, 1 replies.
- [jira] [Updated] (FLINK-38261) Connection catalog object and manager changes - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/03 00:29:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-39010) YAML Pipeline supports item subscription of variant types - posted by "Xiqian Yu (Jira)" <ji...@apache.org> on 2026/02/03 01:00:24 UTC, 0 replies.
- [jira] [Assigned] (FLINK-35661) MiniBatchGroupAggFunction can silently drop records under certain conditions - posted by "Natea Eshetu Beshada (Jira)" <ji...@apache.org> on 2026/02/03 01:05:00 UTC, 0 replies.
- Re: [PR] [FLINK-38846][mysql] Optimize LinkedList processing in handleChange method to reduce complexity [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2026/02/03 01:54:31 UTC, 2 replies.
- [jira] [Resolved] (FLINK-38906) Polish YAML transform built-in functions - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2026/02/03 02:17:00 UTC, 0 replies.
- [PR] [FLINK-35661][table] Fix MiniBatchGroupAggFunction silently dropping records [flink] - posted by "nateab (via GitHub)" <gi...@apache.org> on 2026/02/03 02:17:17 UTC, 12 replies.
- [jira] [Updated] (FLINK-35661) MiniBatchGroupAggFunction can silently drop records under certain conditions - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/03 02:18:00 UTC, 3 replies.
- [jira] [Resolved] (FLINK-38520) Postgres YAML CDC support array with null element - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2026/02/03 02:21:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38965) Postgres cdc source encounted "java.lang.IllegalStateException: Duplicate key Optional" - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2026/02/03 02:22:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38906) Polish YAML transform built-in functions - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2026/02/03 02:23:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38985) [Doc] Add document for VARIANT type and related functions - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2026/02/03 02:25:00 UTC, 0 replies.
- Re: [PR] [FLINK-37288] Add Google Cloud Spanner dialect and catalog [flink-connector-jdbc] - posted by "laughingman7743 (via GitHub)" <gi...@apache.org> on 2026/02/03 02:48:58 UTC, 0 replies.
- Re: [PR] [FLINK-38468][flink-table-planner] When the coalesce parameter contains a function, convert it to case when [flink] - posted by "ChengJie1053 (via GitHub)" <gi...@apache.org> on 2026/02/03 03:04:19 UTC, 0 replies.
- Re: [PR] [FLINK-38941][python] Add Python building blocks for async Python scalar function [flink] - posted by "bgeng777 (via GitHub)" <gi...@apache.org> on 2026/02/03 03:11:00 UTC, 2 replies.
- Re: [PR] [FLINK-36165][source-connector/mysql] Support capturing snapshot data with conditions [flink-cdc] - posted by "ThorneANN (via GitHub)" <gi...@apache.org> on 2026/02/03 03:13:43 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38846) Binlog client use LinkedList to store binlog content - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2026/02/03 03:15:00 UTC, 0 replies.
- Re: [PR] [hotfix] Fix Debezium schema generation for complex types (ARRAY, MAP, ROW) [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2026/02/03 03:29:01 UTC, 0 replies.
- [jira] [Assigned] (FLINK-29855) UDF randomly processed input data twice - posted by "Natea Eshetu Beshada (Jira)" <ji...@apache.org> on 2026/02/03 03:45:00 UTC, 0 replies.
- Re: [D] Flink-Agents Memory Design [flink-agents] - posted by "coderplay (via GitHub)" <gi...@apache.org> on 2026/02/03 03:46:41 UTC, 0 replies.
- Re: [D] Resource Cross-Language Support for Flink Agents [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2026/02/03 03:48:00 UTC, 0 replies.
- Re: [D] Improve Python Async Execution API [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2026/02/03 03:48:37 UTC, 0 replies.
- Re: [D] Support Fine-Grain Durable Execution [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2026/02/03 03:48:46 UTC, 0 replies.
- Re: [D] Flink Multi-Version Support [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2026/02/03 03:49:15 UTC, 0 replies.
- Re: [D] Support Java Async Execution [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2026/02/03 03:49:21 UTC, 0 replies.
- Re: [D] Flink Agents Support Multi-JDK Versions [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2026/02/03 03:49:32 UTC, 0 replies.
- [PR] [FLINK-29855][table-planner] Fix non-deterministic UDF evaluated mult… [flink] - posted by "nateab (via GitHub)" <gi...@apache.org> on 2026/02/03 03:51:36 UTC, 5 replies.
- [jira] [Updated] (FLINK-29855) UDF randomly processed input data twice - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/03 03:52:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-39009) flink postgres unnest insert way - posted by "Gaurav Miglani (Jira)" <ji...@apache.org> on 2026/02/03 04:10:00 UTC, 1 replies.
- [jira] [Created] (FLINK-39014) Fix the conversion to relational algebra issue in Batch Mode - posted by "Archit Goyal (Jira)" <ji...@apache.org> on 2026/02/03 04:57:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39014) Fix the conversion to relational algebra issue in Batch Mode - posted by "Archit Goyal (Jira)" <ji...@apache.org> on 2026/02/03 04:58:00 UTC, 2 replies.
- [jira] [Assigned] (FLINK-38822) Extend URL_DECODE with a recursive parameter for multi-level decoding - posted by "Natea Eshetu Beshada (Jira)" <ji...@apache.org> on 2026/02/03 05:05:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38751) RowTimeRangeBoundedPrecedingFunction incorrectly cleans lastTriggeringTsState, may not discard expired data - posted by "Natea Eshetu Beshada (Jira)" <ji...@apache.org> on 2026/02/03 05:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39015) Fix ro - posted by "Dmitriy Linevich (Jira)" <ji...@apache.org> on 2026/02/03 05:28:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39015) Fix MultiJoin rowadata behaviour for HeapStateBackend - posted by "Dmitriy Linevich (Jira)" <ji...@apache.org> on 2026/02/03 05:29:00 UTC, 4 replies.
- Re: [PR] [FLINK-38869] InitializationContext for KafkaSubscriber [flink-connector-kafka] - posted by "leonardBang (via GitHub)" <gi...@apache.org> on 2026/02/03 05:42:46 UTC, 4 replies.
- [PR] Fix the conversion to relational algebra issue in Batch Mode [flink] - posted by "argoyal2212 (via GitHub)" <gi...@apache.org> on 2026/02/03 06:13:39 UTC, 3 replies.
- Re: [PR] [FLINK-38857][Model] Introduce a Triton inference module under flink-models [flink] - posted by "dianfu (via GitHub)" <gi...@apache.org> on 2026/02/03 06:33:49 UTC, 8 replies.
- [jira] [Created] (FLINK-39016) Add configurable TTL for ExecutionGraph cache independent of web refresh interval - posted by "Liu (Jira)" <ji...@apache.org> on 2026/02/03 07:14:00 UTC, 0 replies.
- [PR] [FLINK-39015][table] Fix key extractor for multi join. Change GenericRowData to BinaryRowData [flink] - posted by "ldadima (via GitHub)" <gi...@apache.org> on 2026/02/03 07:39:50 UTC, 46 replies.
- Re: [PR] [FLINK-38089] Avoid pushing down non-deterministic filter in FILTER_RULES [flink] - posted by "nateab (via GitHub)" <gi...@apache.org> on 2026/02/03 07:55:03 UTC, 0 replies.
- [PR] [FLINK-39016][Runtime/REST] Add configurable TTL for ExecutionGraph cache independent of web refresh interval [flink] - posted by "Myracle (via GitHub)" <gi...@apache.org> on 2026/02/03 08:05:55 UTC, 4 replies.
- [jira] [Updated] (FLINK-39016) Add configurable TTL for ExecutionGraph cache independent of web refresh interval - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/03 08:06:00 UTC, 0 replies.
- Re: [PR] [FLINK-36796][pipeline-connector][oracle]add oracle pipeline connector. [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2026/02/03 08:08:10 UTC, 8 replies.
- [jira] [Closed] (FLINK-35476) The IF built-in function returns an exception when returning a string - posted by "Natea Eshetu Beshada (Jira)" <ji...@apache.org> on 2026/02/03 08:11:00 UTC, 0 replies.
- Re: [PR] [FLINK-25538] Migrate tests from JUnit 4 to JUnit 5 [flink-connector-kafka] - posted by "fapaul (via GitHub)" <gi...@apache.org> on 2026/02/03 08:15:15 UTC, 6 replies.
- [PR] [HOTFIX] Fix tests flakeyness [flink-connector-kafka] - posted by "Efrat19 (via GitHub)" <gi...@apache.org> on 2026/02/03 08:24:07 UTC, 0 replies.
- [jira] [Created] (FLINK-39017) Flink WebUI Job graph node click interaction fails in Chrome 144+ (PointerEvents suppression) - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2026/02/03 08:38:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39017) Flink WebUI Job graph node click interaction fails in Chrome 144+ (PointerEvents suppression) - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2026/02/03 08:44:00 UTC, 4 replies.
- [PR] [FLINK-38539][table] Fix integer overflow in AbstractBytesMultiMap wh… [flink] - posted by "nateab (via GitHub)" <gi...@apache.org> on 2026/02/03 08:54:19 UTC, 3 replies.
- [jira] [Updated] (FLINK-38539) IndexOutOfBoundsException in AbstractSliceSyncStateWindowAggProcessor / AbstractBytesMultiMap with memory state backend - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/03 08:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39018) Support checkpoint for LocalInputChannel - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2026/02/03 08:55:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-39019) [Iceberg] Support deletion vectors for format-version 3 tables - posted by "suhwan (Jira)" <ji...@apache.org> on 2026/02/03 08:57:00 UTC, 2 replies.
- [jira] [Created] (FLINK-39019) [Iceberg] Support deletion vectors for format-version 3 tables - posted by "suhwan (Jira)" <ji...@apache.org> on 2026/02/03 08:57:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38912) Upgrade Flink to use Netty 4.2.6.Final - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2026/02/03 08:58:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39019) [Iceberg] Support deletion vectors for format-version 3 tables - posted by "suhwan (Jira)" <ji...@apache.org> on 2026/02/03 08:58:00 UTC, 2 replies.
- Re: [PR] [hotfix][docs] Pull request to update documentation for Flink 2.0 support. [flink-kubernetes-operator] - posted by "gyfora (via GitHub)" <gi...@apache.org> on 2026/02/03 08:58:42 UTC, 0 replies.
- [jira] [Closed] (FLINK-38912) Upgrade Flink to use Netty 4.2.6.Final - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2026/02/03 08:59:00 UTC, 0 replies.
- Re: [PR] Debugging the Blue/Green e2e tests [flink-kubernetes-operator] - posted by "gyfora (via GitHub)" <gi...@apache.org> on 2026/02/03 08:59:08 UTC, 0 replies.
- Re: [PR] [FLINK-38943][runtime] Support Adaptive Partition Selection for RescalePartitioner and RebalancePartitioner [flink] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2026/02/03 09:01:07 UTC, 6 replies.
- [jira] [Created] (FLINK-39020) When synchronizing MySQL to Doris, data of type java.time.LocalTime is serialized or deserialized, but by default, Jackson does not support the handling of Java 8 time types (such as LocalTime, LocalDateTime, etc.) - posted by "林健昌 (Jira)" <ji...@apache.org> on 2026/02/03 09:04:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37411) Introduce the rollback mechanism for Autoscaler - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2026/02/03 09:07:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38421) BlueGreen Deployment Documentation - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2026/02/03 09:07:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-37411) Introduce the rollback mechanism for Autoscaler - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2026/02/03 09:07:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38395) Enable/fix the Flink Operator e2e tests for Blue/Green Deployments - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2026/02/03 09:09:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39018) Support checkpoint for LocalInputChannel - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2026/02/03 09:13:00 UTC, 0 replies.
- [PR] [FLINK-39020][pipeline][doris] Fix the bug When synchronizing MySQL to Doris, data of type java.time.LocalTime is serialized or deserialized, but by default, Jackson does not support the handling of Java 8 time types (such as LocalTime, LocalDateTime, etc.) [flink-cdc] - posted by "linjianchang (via GitHub)" <gi...@apache.org> on 2026/02/03 09:18:23 UTC, 2 replies.
- [jira] [Updated] (FLINK-39020) When synchronizing MySQL to Doris, data of type java.time.LocalTime is serialized or deserialized, but by default, Jackson does not support the handling of Java 8 time types (such as LocalTime, LocalDateTime, etc.) - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/03 09:19:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-38987) Add RRSA (RAM Roles for Service Accounts) support for Flink OSS FileSystem - posted by "Maximilian Michels (Jira)" <ji...@apache.org> on 2026/02/03 09:21:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-29855) UDF randomly processed input data twice - posted by "Natea Eshetu Beshada (Jira)" <ji...@apache.org> on 2026/02/03 09:26:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-29855) UDF randomly processed input data twice - posted by "Natea Eshetu Beshada (Jira)" <ji...@apache.org> on 2026/02/03 09:26:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38543) Change the overall UC restore process, JM and task initialization - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2026/02/03 09:28:00 UTC, 2 replies.
- [jira] [Assigned] (FLINK-39019) [Iceberg] Support deletion vectors for format-version 3 tables - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2026/02/03 09:31:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38871) PyFlink Planner incorrectly propagates constants into downstream UDF inputs when filtering on materialized ROW fields - posted by "Natea Eshetu Beshada (Jira)" <ji...@apache.org> on 2026/02/03 09:49:00 UTC, 1 replies.
- Re: [PR] [FLINK-37586][udf] Add support for options in user-defined functions and update related documentation [flink-cdc] - posted by "Hisoka-X (via GitHub)" <gi...@apache.org> on 2026/02/03 09:58:17 UTC, 0 replies.
- [PR] Kubernetes Operator 1.14.0 [flink-web] - posted by "gyfora (via GitHub)" <gi...@apache.org> on 2026/02/03 10:05:55 UTC, 1 replies.
- Re: [PR] [hotfix] Fix kafka connection flakeyness in tests [flink-connector-kafka] - posted by "Savonitar (via GitHub)" <gi...@apache.org> on 2026/02/03 10:10:08 UTC, 1 replies.
- [jira] [Closed] (FLINK-39008) Support record types natively in DataTypeExtractor - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2026/02/03 10:31:00 UTC, 0 replies.
- Re: [PR] [FLINK-38992] Expire associated state together for non-time over windows [flink] - posted by "fhueske (via GitHub)" <gi...@apache.org> on 2026/02/03 10:38:34 UTC, 0 replies.
- [PR] [FLINK-35637][table-planner] Fix ScalarFunctionCallGen for complex ar… [flink] - posted by "nateab (via GitHub)" <gi...@apache.org> on 2026/02/03 10:43:12 UTC, 3 replies.
- [jira] [Updated] (FLINK-35637) ScalarFunctionCallGen does not handle complex argument type properly - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/03 10:44:00 UTC, 0 replies.
- [PR] Update log4j to 2.25.3 [flink] - posted by "eschcam (via GitHub)" <gi...@apache.org> on 2026/02/03 11:24:50 UTC, 0 replies.
- [jira] [Created] (FLINK-39021) Support native PersistentVolumeClaim (PVC) mounting for Kubernetes deployments - posted by "Liu (Jira)" <ji...@apache.org> on 2026/02/03 11:29:00 UTC, 0 replies.
- Re: [PR] [Hotfix] Update log4j to 2.25.3 [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2026/02/03 11:29:37 UTC, 3 replies.
- [jira] [Created] (FLINK-39022) Update default cipher suite value in SecurityOptions - posted by "Imre Balassa (Jira)" <ji...@apache.org> on 2026/02/03 12:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39022) Update default cipher suite value in SecurityOptions - posted by "Imre Balassa (Jira)" <ji...@apache.org> on 2026/02/03 12:55:00 UTC, 3 replies.
- Re: [PR] [FLINK-38957][table-planner] Support `ProcessTableFunction` registration via `CompiledPlan` [flink] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2026/02/03 13:19:08 UTC, 7 replies.
- [PR] [DRAFT][hotfix] Wait for leader election to prevent OUT_OF_ORDER issues [flink-connector-kafka] - posted by "Savonitar (via GitHub)" <gi...@apache.org> on 2026/02/03 13:22:54 UTC, 1 replies.
- [jira] [Updated] (FLINK-39022) Update default cipher suite value in SecurityOptions, - posted by "Imre Balassa (Jira)" <ji...@apache.org> on 2026/02/03 13:33:00 UTC, 0 replies.
- [PR] [FLINK-39011][table-api-java] Accept UnresolvedDataType in BaseExpression.cast() [flink] - posted by "twalthr (via GitHub)" <gi...@apache.org> on 2026/02/03 13:45:58 UTC, 2 replies.
- [jira] [Updated] (FLINK-39011) Cast does not support UnresolvedDataType - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/03 13:46:00 UTC, 0 replies.
- Re: [PR] [Hotfix][Flink-CI-Tools] Update Guava to 32.0.1 [flink] - posted by "eschcam (via GitHub)" <gi...@apache.org> on 2026/02/03 14:02:56 UTC, 0 replies.
- [jira] [Assigned] (FLINK-39022) Update default cipher suite value in SecurityOptions - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2026/02/03 14:16:00 UTC, 0 replies.
- [PR] Flink community blog February 2026 [flink-web] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2026/02/03 14:27:00 UTC, 50 replies.
- [PR] [FLINK-38512][postgres] Update database name validation to allow hyphens [flink-cdc] - posted by "Hisoka-X (via GitHub)" <gi...@apache.org> on 2026/02/03 14:44:25 UTC, 1 replies.
- [jira] [Updated] (FLINK-38512) Postgres YAML CDC support database name with middlescore - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/03 14:45:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-20110) Support 'merge' method for first_value and last_value UDAF - posted by "david radley (Jira)" <ji...@apache.org> on 2026/02/03 15:02:00 UTC, 0 replies.
- Re: [PR] Bump org.assertj:assertj-core from 3.25.3 to 3.27.7 [flink-connector-opensearch] - posted by "reta (via GitHub)" <gi...@apache.org> on 2026/02/03 15:02:44 UTC, 2 replies.
- [PR] [FLINK-39022][core] Set security.ssl.algorithms default value to modern cipher suite [flink] - posted by "balassai (via GitHub)" <gi...@apache.org> on 2026/02/03 16:11:41 UTC, 3 replies.
- [PR] [hotfix][test] amend unit test so it works with IBM java [flink] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2026/02/03 16:13:43 UTC, 0 replies.
- [jira] [Commented] (FLINK-21672) End to end tests (streaming) aren't Java vendor neutral (sun.management bean used) - posted by "david radley (Jira)" <ji...@apache.org> on 2026/02/03 16:18:00 UTC, 0 replies.
- Re: [PR] [FLINK-21672][test] amend unit test so it tolerates IBM java [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2026/02/03 16:24:45 UTC, 1 replies.
- [jira] [Updated] (FLINK-21672) End to end tests (streaming) aren't Java vendor neutral (sun.management bean used) - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/03 16:25:00 UTC, 0 replies.
- [PR] [hotfix] Use Thread Context ClassLoader for user class loading [flink-agents] - posted by "klaudworks (via GitHub)" <gi...@apache.org> on 2026/02/03 17:21:10 UTC, 10 replies.
- Re: [PR] [FLINK-38962][connectors/opensearch] Add OpenSearch 3.x support with opensearch-java client [flink-connector-opensearch] - posted by "reta (via GitHub)" <gi...@apache.org> on 2026/02/03 18:06:14 UTC, 25 replies.
- [jira] [Created] (FLINK-39023) Implement Avro To Variant Type converter - posted by "Swapna Marru (Jira)" <ji...@apache.org> on 2026/02/03 18:08:00 UTC, 0 replies.
- Re: [PR] [hotfix] Wait for leader election to prevent OUT_OF_ORDER issues [flink-connector-kafka] - posted by "Savonitar (via GitHub)" <gi...@apache.org> on 2026/02/03 19:01:20 UTC, 1 replies.
- [jira] [Assigned] (FLINK-38539) IndexOutOfBoundsException in AbstractSliceSyncStateWindowAggProcessor / AbstractBytesMultiMap with memory state backend - posted by "Natea Eshetu Beshada (Jira)" <ji...@apache.org> on 2026/02/03 20:40:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-35637) ScalarFunctionCallGen does not handle complex argument type properly - posted by "Natea Eshetu Beshada (Jira)" <ji...@apache.org> on 2026/02/03 20:40:00 UTC, 0 replies.
- Re: [PR] [FLINK-39022][security] Set security.ssl.algorithms default value to modern cipher suite [flink] - posted by "balassai (via GitHub)" <gi...@apache.org> on 2026/02/03 21:44:28 UTC, 38 replies.
- [PR] [FLINK-39009] FEATURE postgres unnest insert way [flink-connector-jdbc] - posted by "gaurav7261 (via GitHub)" <gi...@apache.org> on 2026/02/04 00:51:33 UTC, 2 replies.
- [jira] [Updated] (FLINK-39009) flink postgres unnest insert way - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/04 00:52:00 UTC, 0 replies.
- Re: [PR] [FLINK-38814][Connector/Kinesis] Kinesis Source in EFO - Fix idle consumer on subscription failure [flink-connector-aws] - posted by "elrob (via GitHub)" <gi...@apache.org> on 2026/02/04 01:13:44 UTC, 2 replies.
- [jira] [Closed] (FLINK-38941) Add Python building blocks for Async Python Scalar Function - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2026/02/04 01:48:00 UTC, 0 replies.
- Re: [PR] [FLINK-38699][ui] Sort jobs by default [flink] - posted by "zhuzhurk (via GitHub)" <gi...@apache.org> on 2026/02/04 02:13:42 UTC, 0 replies.
- [jira] [Closed] (FLINK-38699) Order the WebUI's Completed Job List by end time order - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2026/02/04 02:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39024) Support incremental snapshot connector supports predicate pushdown - posted by "Thorne (Jira)" <ji...@apache.org> on 2026/02/04 02:43:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-39024) Support incremental snapshot connector supports predicate pushdown - posted by "Thorne (Jira)" <ji...@apache.org> on 2026/02/04 02:43:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39024) Incremental snapshot connectors supports predicate pushdown - posted by "Thorne (Jira)" <ji...@apache.org> on 2026/02/04 02:44:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39024) Support incremental snapshot connectors supports predicate pushdown - posted by "Thorne (Jira)" <ji...@apache.org> on 2026/02/04 02:44:00 UTC, 0 replies.
- Re: [PR] [FLINK-38770][runtime] Fix parallelism overrides ignored in Application Mode [flink] - posted by "DongyuanPan (via GitHub)" <gi...@apache.org> on 2026/02/04 02:53:21 UTC, 0 replies.
- [jira] [Resolved] (FLINK-39004) [JUnit5 Migration] Migrate the remaining test classes related to junit4 of flink-table module to junit5 - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/02/04 06:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39025) Add HashMap index for InstanceID lookups in ResourceManager - posted by "Natea Eshetu Beshada (Jira)" <ji...@apache.org> on 2026/02/04 06:17:00 UTC, 0 replies.
- [PR] [FLINK-39025] Add InstanceID index to ResourceManager for O(1) lookups [flink] - posted by "nateab (via GitHub)" <gi...@apache.org> on 2026/02/04 06:22:52 UTC, 1 replies.
- [jira] [Updated] (FLINK-39025) Add HashMap index for InstanceID lookups in ResourceManager - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/04 06:23:00 UTC, 0 replies.
- Re: [PR] Bump com.microsoft.sqlserver:mssql-jdbc from 10.2.1.jre8 to 11.1.0.jre8-preview in /flink-connector-jdbc-sqlserver [flink-connector-jdbc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/02/04 06:32:40 UTC, 0 replies.
- [PR] [FLINK-38421] Blue/Green Deployments documentation [flink-kubernetes-operator] - posted by "schongloo (via GitHub)" <gi...@apache.org> on 2026/02/04 06:37:17 UTC, 2 replies.
- Re: [PR] [FLINK-38907][postgres] Debezium publication filtering data lost [flink-cdc] - posted by "loserwang1024 (via GitHub)" <gi...@apache.org> on 2026/02/04 07:11:06 UTC, 1 replies.
- [jira] [Created] (FLINK-39026) Remove misleading TODO about getPartitionedState overhead - posted by "Natea Eshetu Beshada (Jira)" <ji...@apache.org> on 2026/02/04 07:35:00 UTC, 0 replies.
- [I] [Bug] ClassNotFoundException when loading user-defined resource classes from uploaded JARs [flink-agents] - posted by "klaudworks (via GitHub)" <gi...@apache.org> on 2026/02/04 07:39:29 UTC, 1 replies.
- [PR] [FLINK-16316][runtime] Remove misleading TODO about getPartitionedSta… [flink] - posted by "nateab (via GitHub)" <gi...@apache.org> on 2026/02/04 07:46:44 UTC, 0 replies.
- Re: [PR] [FLINK-39026][runtime] Remove misleading TODO about getPartitionedState overhead [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2026/02/04 07:52:22 UTC, 0 replies.
- Re: [PR] [FLINK-38606][Connectors/MongoDB] Support for Flink 2.1.0 API [flink-connector-mongodb] - posted by "neoneo008 (via GitHub)" <gi...@apache.org> on 2026/02/04 07:52:43 UTC, 4 replies.
- [jira] [Updated] (FLINK-39026) Remove misleading TODO about getPartitionedState overhead - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/04 07:53:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39026) Remove misleading TODO about overheads - posted by "Natea Eshetu Beshada (Jira)" <ji...@apache.org> on 2026/02/04 08:03:00 UTC, 0 replies.
- [PR] [FLINK-39027][runtime] Remove misleading TODO about isAvailable() overhead [flink] - posted by "nateab (via GitHub)" <gi...@apache.org> on 2026/02/04 08:07:58 UTC, 1 replies.
- Re: [PR] [Bugfix] Use Thread Context ClassLoader for user class loading [flink-agents] - posted by "klaudworks (via GitHub)" <gi...@apache.org> on 2026/02/04 08:44:48 UTC, 2 replies.
- [jira] [Updated] (FLINK-39015) Fix MultiJoin RowData behaviour for HeapStateBackend - posted by "Dmitriy Linevich (Jira)" <ji...@apache.org> on 2026/02/04 08:58:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-25538) [JUnit5 Migration] Module: flink-connector-kafka - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2026/02/04 09:03:00 UTC, 0 replies.
- [PR] [optimize] Add isWarnEnabled guard for expensive log construction [flink] - posted by "dingqianwen (via GitHub)" <gi...@apache.org> on 2026/02/04 09:09:26 UTC, 1 replies.
- [PR] [FLINK-39021][Deployment/Kubernetes] Support native PersistentVolumeClaim (PVC) mounting for Kubernetes deployments [flink] - posted by "Myracle (via GitHub)" <gi...@apache.org> on 2026/02/04 09:21:03 UTC, 2 replies.
- [jira] [Updated] (FLINK-39021) Support native PersistentVolumeClaim (PVC) mounting for Kubernetes deployments - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/04 09:22:00 UTC, 0 replies.
- Re: [PR] [FLINK-39026][runtime] Remove misleading TODO about isAvailable() overhead [flink] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2026/02/04 09:27:21 UTC, 2 replies.
- [jira] [Created] (FLINK-39027) Support DDL for postgres pipeline connector - posted by "Mingliang Zhu (Jira)" <ji...@apache.org> on 2026/02/04 10:14:00 UTC, 0 replies.
- [PR] [FLINK-39027][pipeline-connector][postgres] Support DDL for postgres pipeline connector [flink-cdc] - posted by "zml1206 (via GitHub)" <gi...@apache.org> on 2026/02/04 10:15:41 UTC, 1 replies.
- [jira] [Updated] (FLINK-39027) Support DDL for postgres pipeline connector - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/04 10:16:00 UTC, 0 replies.
- Re: [PR] [FLINK-37504] Handle TLS Certificate Renewal [flink] - posted by "JTaky (via GitHub)" <gi...@apache.org> on 2026/02/04 11:17:41 UTC, 6 replies.
- [PR] [FLINK-XXXXX][state] Use ByteBuffer API to reduce GC pressure in RocksDB state backend [flink] - posted by "nateab (via GitHub)" <gi...@apache.org> on 2026/02/04 11:18:09 UTC, 0 replies.
- [jira] [Created] (FLINK-39028) Use ByteBuffer API to reduce GC pressure in RocksDB state backend - posted by "Natea Eshetu Beshada (Jira)" <ji...@apache.org> on 2026/02/04 11:20:00 UTC, 0 replies.
- Re: [PR] [FLINK-39028][state] Use ByteBuffer API to reduce GC pressure in RocksDB state backend [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2026/02/04 11:26:13 UTC, 1 replies.
- [jira] [Updated] (FLINK-39028) Use ByteBuffer API to reduce GC pressure in RocksDB state backend - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/04 11:27:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38957) ProcessTableFunction UDFs cannot be loaded via CompiledPlan - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2026/02/04 11:31:00 UTC, 0 replies.
- [D] Planning Flink Agents 0.3 [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2026/02/04 11:36:14 UTC, 22 replies.
- Re: [D] Community Sync - 2026 [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2026/02/04 11:43:55 UTC, 3 replies.
- Re: [PR] [FLINK-38790] Update to Flink 2.2 [flink-connector-kafka] - posted by "gaborgsomogyi (via GitHub)" <gi...@apache.org> on 2026/02/04 13:54:35 UTC, 0 replies.
- [PR] [Hotfix] Update testcontainers to 1.21.4 [flink] - posted by "eschcam (via GitHub)" <gi...@apache.org> on 2026/02/04 14:32:43 UTC, 4 replies.
- [jira] [Closed] (FLINK-38957) ProcessTableFunction UDFs cannot be loaded via CompiledPlan - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2026/02/04 15:04:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38998) Cascaded event time Window Aggregate does not produce data when offset is specified - posted by "Sergey Kononov (Jira)" <ji...@apache.org> on 2026/02/04 15:15:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-39011) Cast does not support UnresolvedDataType - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2026/02/04 15:31:00 UTC, 0 replies.
- [PR] Add Flink Connector Parent 2.0.0 [flink-web] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2026/02/04 16:47:28 UTC, 7 replies.
- [PR] [FLINK-39000] Avoid redundant seeks during operator list state restore [flink] - posted by "infocusmodereal (via GitHub)" <gi...@apache.org> on 2026/02/04 17:25:28 UTC, 1 replies.
- [jira] [Updated] (FLINK-39000) Avoid redundant seeks during operator list state restore - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/04 17:26:00 UTC, 0 replies.
- [PR] Reorder connector releases [flink-web] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2026/02/04 17:47:15 UTC, 2 replies.
- Re: [PR] Update the slack invitation link [flink-web] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2026/02/04 18:15:34 UTC, 1 replies.
- Re: [PR] [FLINK-37772] Add AWS Connectors v5.1.0 [flink-web] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2026/02/04 18:16:21 UTC, 1 replies.
- [jira] [Updated] (FLINK-37772) Release flink-connector-aws v5.1.0 - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2026/02/04 18:17:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37772) Release flink-connector-aws v5.1.0 - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2026/02/04 18:17:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37772) Release flink-connector-aws v5.1.0 - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2026/02/04 18:18:00 UTC, 0 replies.
- Re: [PR] Add HBase 3.0.1 connector [flink-web] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2026/02/04 18:18:07 UTC, 1 replies.
- [jira] [Created] (FLINK-39029) Move catalog store factory builder from TableFactoryUtil to new class - posted by "Hao Li (Jira)" <ji...@apache.org> on 2026/02/04 18:39:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38259) FLIP-529: Connections in Flink SQL and TableAPI - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2026/02/04 19:04:00 UTC, 0 replies.
- [PR] [hotfix] [pyflink] Fix Python Datastream JDBC Java method reference [flink] - posted by "bandersen23 (via GitHub)" <gi...@apache.org> on 2026/02/04 20:54:11 UTC, 2 replies.
- [PR] [FLINK-38987] Add RRSA (RAM Roles for Service Accounts) support for Flink OSS FileSystem [flink] - posted by "zhaoyunjiong (via GitHub)" <gi...@apache.org> on 2026/02/04 20:59:23 UTC, 3 replies.
- [jira] [Updated] (FLINK-38987) Add RRSA (RAM Roles for Service Accounts) support for Flink OSS FileSystem - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/04 21:00:00 UTC, 0 replies.
- [PR] [FLINK-39023][Formats][Avro] add avro to variant datatype converter [flink] - posted by "swapna267 (via GitHub)" <gi...@apache.org> on 2026/02/04 22:31:48 UTC, 1 replies.
- [jira] [Updated] (FLINK-39023) Implement Avro To Variant Type converter - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/04 22:32:00 UTC, 0 replies.
- [PR] [FLINK-39029] move catalog store factory builder to new class [flink] - posted by "lihaosky (via GitHub)" <gi...@apache.org> on 2026/02/05 01:46:04 UTC, 4 replies.
- [jira] [Updated] (FLINK-39029) Move catalog store factory builder from TableFactoryUtil to new class - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/05 01:47:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38956) The Web UI cannot automatically show the latest edge name for AdaptiveScheduler - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/02/05 02:00:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38956) Fix the job-overview Web UI cannot automatically show the latest edge name for AdaptiveScheduler - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/02/05 02:02:00 UTC, 1 replies.
- [PR] [FLINK-38956][runtime-web] Fix the job-overview Web UI cannot automatically show the latest edge name for AdaptiveScheduler [flink] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2026/02/05 02:04:42 UTC, 2 replies.
- [jira] [Created] (FLINK-39030) Support emit-only-on-update mode for CUMULATE window TVF to reduce unnecessary outputs - posted by "Liu (Jira)" <ji...@apache.org> on 2026/02/05 02:27:00 UTC, 0 replies.
- [PR] [ci] Fix master branch documentation build failure [flink-cdc] - posted by "yuxiqian (via GitHub)" <gi...@apache.org> on 2026/02/05 02:39:49 UTC, 1 replies.
- [PR] [FLINK-39010][transform] YAML Pipeline supports item subscription of Variant type [flink-cdc] - posted by "Hisoka-X (via GitHub)" <gi...@apache.org> on 2026/02/05 03:06:53 UTC, 4 replies.
- [jira] [Updated] (FLINK-39010) YAML Pipeline supports item subscription of variant types - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/05 03:07:00 UTC, 0 replies.
- [PR] [FLINK-39030][Table SQL/API] Support emit-only-on-update mode for CUMULATE window TVF to reduce unnecessary outputs [flink] - posted by "Myracle (via GitHub)" <gi...@apache.org> on 2026/02/05 03:11:57 UTC, 1 replies.
- [jira] [Updated] (FLINK-39030) Support emit-only-on-update mode for CUMULATE window TVF to reduce unnecessary outputs - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/05 03:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39031) [PyFlink] support Python 3.13 and 3.14 - posted by "Honglei Jiang (Jira)" <ji...@apache.org> on 2026/02/05 03:32:00 UTC, 0 replies.
- [PR] [FLINK-38751][runtime] Fix incorrect lastTriggeringTsState cleanup in RowTimeRangeBoundedPrecedingFunction [flink] - posted by "zzwqqq (via GitHub)" <gi...@apache.org> on 2026/02/05 03:58:04 UTC, 1 replies.
- [jira] [Updated] (FLINK-38751) RowTimeRangeBoundedPrecedingFunction incorrectly cleans lastTriggeringTsState, may not discard expired data - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/05 03:59:00 UTC, 0 replies.
- [PR] [docs] Add workaround to install flink-agents 0.2.0 [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2026/02/05 04:17:30 UTC, 3 replies.
- [jira] [Created] (FLINK-39032) [webui] Add customizable timestamp formatting for watermarks - posted by "Zuofeng Zhang (Jira)" <ji...@apache.org> on 2026/02/05 05:42:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39032) [webui] Add customizable timestamp formatting for watermarks - posted by "Zuofeng Zhang (Jira)" <ji...@apache.org> on 2026/02/05 05:43:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-39032) [webui] Add customizable timestamp formatting for watermarks - posted by "Zuofeng Zhang (Jira)" <ji...@apache.org> on 2026/02/05 05:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39033) File Connector does not support WebHDFS protocol - posted by "CHANHAE OH (Jira)" <ji...@apache.org> on 2026/02/05 06:01:00 UTC, 0 replies.
- [PR] [infra] Add configurable log level for CI test runs [flink-agents] - posted by "XL-Zhao-23 (via GitHub)" <gi...@apache.org> on 2026/02/05 06:55:38 UTC, 6 replies.
- [PR] Revert [FLINK-38869] InitializationContext for KafkaSubscriber (#208) [flink-connector-kafka] - posted by "Efrat19 (via GitHub)" <gi...@apache.org> on 2026/02/05 09:17:51 UTC, 0 replies.
- [jira] [Created] (FLINK-39034) fullWindowPartition + sortStream + STREAMING causes timestamps to be set to null - posted by "Grzegorz Liter (Jira)" <ji...@apache.org> on 2026/02/05 10:20:00 UTC, 0 replies.
- [PR] [Hotfix] Update lz4-java to 1.10.3 [flink] - posted by "eschcam (via GitHub)" <gi...@apache.org> on 2026/02/05 11:12:14 UTC, 19 replies.
- [jira] [Created] (FLINK-39035) Support Avro fast-read and column pruning in AvroDeserializationSchema via configuration - posted by "xiaolong3817 (Jira)" <ji...@apache.org> on 2026/02/05 11:58:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39035) Support Avro fast-read and column pruning in AvroDeserializationSchema via configuration - posted by "xiaolong3817 (Jira)" <ji...@apache.org> on 2026/02/05 11:59:00 UTC, 1 replies.
- [PR] [FLINK-39035][format][avro] Support Avro fast-read and column pruning… [flink] - posted by "low-bee (via GitHub)" <gi...@apache.org> on 2026/02/05 12:08:32 UTC, 4 replies.
- [PR] [FLINK-38966][build] Update rsync for GHA to latest v8.0.2 (LTS) for main docs [flink] - posted by "MartijnVisser (via GitHub)" <gi...@apache.org> on 2026/02/05 13:19:16 UTC, 2 replies.
- [jira] [Updated] (FLINK-38945) [FLIP-561] Restructure Flink documentation - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/02/05 13:25:00 UTC, 1 replies.
- [PR] [FLINK-37837][core] Always add create.table to include.schema.changes option [flink-cdc] - posted by "Hisoka-X (via GitHub)" <gi...@apache.org> on 2026/02/05 14:18:32 UTC, 4 replies.
- [jira] [Updated] (FLINK-37837) Always Add create.table to include.schema.changes option - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/05 14:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39036) RowDataToAvroConverter ignores logical type when converting timestamps - posted by "Grzegorz Liter (Jira)" <ji...@apache.org> on 2026/02/05 14:36:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-21672) End to end tests (streaming) aren't Java vendor neutral (sun.management bean used) - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/02/05 15:15:00 UTC, 0 replies.
- Re: [PR] Add AWS Connectors 6.0.0 [flink-web] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2026/02/05 15:42:57 UTC, 0 replies.
- [PR] [FLINK-38341][configuration] Introduce the rescale history configuration option. [flink] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2026/02/05 15:54:49 UTC, 3 replies.
- [jira] [Updated] (FLINK-38341) Introduce the rescale history configuration option. - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/05 15:55:00 UTC, 0 replies.
- [PR] [FLINK-38342][runtime] Support record rescale information. [flink] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2026/02/05 16:00:23 UTC, 3 replies.
- [jira] [Updated] (FLINK-38342) Support record rescale information - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/05 16:01:00 UTC, 0 replies.
- [PR] [FLINK-38343][runtime] Support store rescale history with statistics by ExecutionGraphInfoStore. [flink] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2026/02/05 16:04:21 UTC, 2 replies.
- [jira] [Updated] (FLINK-38343) Support store rescale history with statistics by ExecutionGraphInfoStore. - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/05 16:05:00 UTC, 0 replies.
- Re: [PR] [FLINK-38913][table-planner][BP-2.2] ArrayIndexOutOfBoundsException unparsing CAST [flink] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2026/02/05 17:08:48 UTC, 0 replies.
- Re: [PR] [FLINK-38913][table-planner][BP-2.1] ArrayIndexOutOfBoundsException unparsing CAST. [flink] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2026/02/05 17:11:28 UTC, 0 replies.
- [jira] [Resolved] (FLINK-39013) add E2E test for DynamicKafkaTableSource - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2026/02/05 17:49:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-39013) add E2E test for DynamicKafkaTableSource - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2026/02/05 17:49:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38969) Extend current JSON_STRING to convert a Variant to a Json string. - posted by "Swapna Marru (Jira)" <ji...@apache.org> on 2026/02/05 18:06:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38966) Update rsync Github Actions to 8.0.2 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/02/05 18:17:00 UTC, 1 replies.
- [jira] [Resolved] (FLINK-38966) Update rsync Github Actions to 8.0.2 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/02/05 18:17:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38966) Update rsync Github Actions to 8.0.2 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/02/05 18:17:00 UTC, 0 replies.
- [PR] [FLINK-38945][docs][FLIP-561] Restructure Flink documentation [flink] - posted by "MartijnVisser (via GitHub)" <gi...@apache.org> on 2026/02/05 18:29:56 UTC, 11 replies.
- [jira] [Created] (FLINK-39037) support query kafka cluster id as metadata in records of DynamicKafkaTableSource - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2026/02/05 18:44:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39037) support query kafka cluster id as metadata in records of DynamicKafkaTableSource - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2026/02/05 18:50:00 UTC, 2 replies.
- [PR] [FLINK-39037] support query kafka cluster id as metadata in records of DynamicKafkaTableSource [flink-connector-kafka] - posted by "bowenli86 (via GitHub)" <gi...@apache.org> on 2026/02/05 19:43:51 UTC, 2 replies.
- [jira] [Commented] (FLINK-38624) Flink 2.1 Job Failure: Type Mismatch Exception in StreamPhysicalOverAggregateRule (TIMESTAMP(3) vs TIMESTAMP(3) ROWTIME) - posted by "EMERSON WANG (Jira)" <ji...@apache.org> on 2026/02/05 19:45:00 UTC, 5 replies.
- [PR] Bump @modelcontextprotocol/sdk and @angular/cli in /flink-runtime-web/web-dashboard [flink] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/02/05 23:12:02 UTC, 3 replies.
- [PR] [FLINK-39012]Add global kafka enumerator support [flink-connector-kafka] - posted by "lnbest0707 (via GitHub)" <gi...@apache.org> on 2026/02/06 00:11:09 UTC, 7 replies.
- [jira] [Created] (FLINK-39038) GitHub flink-cdc repository actions clean-up - posted by "Xiqian Yu (Jira)" <ji...@apache.org> on 2026/02/06 01:26:00 UTC, 0 replies.
- [PR] [FLINK-39038][infra] Limit GitHub actions max parallelism and workflow triggers [flink-cdc] - posted by "yuxiqian (via GitHub)" <gi...@apache.org> on 2026/02/06 01:33:42 UTC, 6 replies.
- [jira] [Updated] (FLINK-39038) GitHub flink-cdc repository actions clean-up - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/06 01:34:00 UTC, 1 replies.
- [I] [Tech Debt] Reduce size of flink-agents wheel [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2026/02/06 02:39:43 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38888) YAML Pipeline supports item subscription of complex types - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2026/02/06 02:49:00 UTC, 0 replies.
- Re: [PR] [FLINK-37351][runtime] Ensure Writer/Committer Colocation for Non-Pre-Commit Topologies [flink] - posted by "rionmonster (via GitHub)" <gi...@apache.org> on 2026/02/06 04:19:49 UTC, 1 replies.
- Re: [PR] [FLINK-36158][FOLLOWUP] Replace the ZK HA path from jobgraphs to execution-plans [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/02/06 06:33:18 UTC, 1 replies.
- Re: [PR] support mcp without list_prompts interface [flink-agents] - posted by "qingfei1994 (via GitHub)" <gi...@apache.org> on 2026/02/06 07:46:42 UTC, 8 replies.
- [PR] [hotfix] Explicitly limit version for onnxruntime for python 3.10. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2026/02/06 07:54:18 UTC, 2 replies.
- Re: [PR] [FLINK-38959][pipeline-connector][postgres]Added support for schema change in the postgres pipeline connector [flink-cdc] - posted by "JNSimba (via GitHub)" <gi...@apache.org> on 2026/02/06 08:18:17 UTC, 0 replies.
- [jira] [Commented] (FLINK-38241) Dispatcher throws FlinkJobNotFoundException when `requestCheckpointStats` for a FINISHED stream job - posted by "junzhong qin (Jira)" <ji...@apache.org> on 2026/02/06 10:28:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38241) Dispatcher throws FlinkJobNotFoundException when `requestCheckpointStats` for a FINISHED stream job - posted by "junzhong qin (Jira)" <ji...@apache.org> on 2026/02/06 10:30:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39039) Expose JOSDK cacheSyncTimeout as operator config - posted by "junzhong qin (Jira)" <ji...@apache.org> on 2026/02/06 11:00:00 UTC, 3 replies.
- [jira] [Created] (FLINK-39039) Expose JOSDK cacheSyncTimeout as operator config - posted by "junzhong qin (Jira)" <ji...@apache.org> on 2026/02/06 11:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39040) allow additional json to be specified for the body request - posted by "david radley (Jira)" <ji...@apache.org> on 2026/02/06 11:10:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-36887) Add support for Flink 1.20 in Flink Hive connector - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2026/02/06 12:00:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-39041) Rebuild rest api docs pages to supplement the missing content. - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/02/06 12:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39041) Rebuild rest api docs pages to supplement the missing content. - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/02/06 12:27:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39041) Rebuild REST API docs pages to supplement the missing content. - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/02/06 12:28:00 UTC, 2 replies.
- [PR] [FLINK-39041][docs] Rebuild REST API docs pages to supplement the missing content. [flink] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2026/02/06 12:31:29 UTC, 14 replies.
- [jira] [Created] (FLINK-39042) [webui] Make watermark timestamps timezone-aware and configurable - posted by "featzhang (Jira)" <ji...@apache.org> on 2026/02/06 12:34:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38606) Update MongoDB connector to Flink 2.1.0 - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2026/02/06 13:22:00 UTC, 2 replies.
- [jira] [Assigned] (FLINK-38606) Update MongoDB connector to Flink 2.1.0 - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2026/02/06 13:22:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38606) Update MongoDB connector to Flink 2.1.0 - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2026/02/06 13:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39043) UpgradeFailureException from SnapshotObserver blocks reconciliation of spec changes for FINISHED batch jobs - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2026/02/06 14:02:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39043) UpgradeFailureException from SnapshotObserver blocks reconciliation of spec changes for FINISHED batch jobs - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2026/02/06 14:03:00 UTC, 3 replies.
- [PR] Bump JOSDK to 5.3 [flink-kubernetes-operator] - posted by "csviri (via GitHub)" <gi...@apache.org> on 2026/02/06 14:17:17 UTC, 0 replies.
- [PR] FLINK-39039 Additional body json for GenericJsonAndUrlQueryCreator [flink-connector-http] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2026/02/06 14:49:13 UTC, 1 replies.
- [PR] [FLINK-38892][runtime/rest] Introduce the scheduler and type information of the target job in the JobDetails(Info).java [flink] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2026/02/06 15:09:21 UTC, 7 replies.
- [jira] [Updated] (FLINK-38892) Introduce the scheduler and type information of the target job in the /jobs/overview endpoint of the REST API - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/06 15:10:00 UTC, 0 replies.
- Re: [PR] [FLINK-38340][runtime] Introduce the rescale timeline related abstraction for performing rescale operations [flink] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2026/02/06 15:51:20 UTC, 20 replies.
- Re: [PR] [hotfix] Stabilize integration tests [flink-connector-jdbc] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2026/02/06 16:32:29 UTC, 5 replies.
- [PR] [FLINK-21672][test][BP-2.2] Amend unit test so it works with IBM java (#27515) [flink] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2026/02/06 17:09:46 UTC, 2 replies.
- [PR] [FLINK-21672][test] Amend unit test so it works with IBM java (#27515) [flink] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2026/02/06 17:12:23 UTC, 0 replies.
- [PR] [FLINK-21672][test][BP-1.20] Amend unit test so it works with IBM java (#27515) [flink] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2026/02/06 17:15:21 UTC, 2 replies.
- Re: [PR] [FLINK-21672][test][BP-2.1] Amend unit test so it works with IBM java (#27515) [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2026/02/06 17:22:23 UTC, 1 replies.
- [PR] [FLINK-39006] Fix outdated SSL configuration documentation [flink] - posted by "zenobiapanvelwalla (via GitHub)" <gi...@apache.org> on 2026/02/06 21:37:17 UTC, 13 replies.
- [jira] [Updated] (FLINK-39006) Flink Document correction - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/06 21:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39044) Optimize BinaryStringData.copy() to return this for immutable strings - posted by "Natea Eshetu Beshada (Jira)" <ji...@apache.org> on 2026/02/07 00:02:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39044) Optimize BinaryStringData.copy() to return this for immutable strings - posted by "Natea Eshetu Beshada (Jira)" <ji...@apache.org> on 2026/02/07 00:05:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-39044) Optimize BinaryStringData.copy() to return this for immutable strings - posted by "Natea Eshetu Beshada (Jira)" <ji...@apache.org> on 2026/02/07 00:05:00 UTC, 0 replies.
- [PR] [FLINK-39044][table] Optimize BinaryStringData.copy() for compact strings [flink] - posted by "nateab (via GitHub)" <gi...@apache.org> on 2026/02/07 00:07:38 UTC, 7 replies.
- Re: [PR] [pipeline-connector/paimon] Support table specific table.properties configuration [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/02/07 00:08:00 UTC, 1 replies.
- [PR] [FLINK-39044][benchmark] Add StringDataBenchmark for Table API string serialization [flink-benchmarks] - posted by "nateab (via GitHub)" <gi...@apache.org> on 2026/02/07 00:25:00 UTC, 1 replies.
- [jira] [Closed] (FLINK-39044) Optimize BinaryStringData.copy() to return this for immutable strings - posted by "Natea Eshetu Beshada (Jira)" <ji...@apache.org> on 2026/02/07 00:38:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-21672) End to end tests (streaming) aren't Java vendor neutral (sun.management bean used) - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/02/07 00:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39045) [docs] Add automatic fix for Hugo ref syntax errors in connector docs - posted by "featzhang (Jira)" <ji...@apache.org> on 2026/02/07 03:56:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-39045) [docs] Add automatic fix for Hugo ref syntax errors in connector docs - posted by "featzhang (Jira)" <ji...@apache.org> on 2026/02/07 03:56:00 UTC, 1 replies.
- [PR] [FLINK-39045][Docs] Add automatic fix for Hugo ref syntax errors in connector docs [flink] - posted by "featzhang (via GitHub)" <gi...@apache.org> on 2026/02/07 03:58:01 UTC, 6 replies.
- [jira] [Updated] (FLINK-39045) [docs] Add automatic fix for Hugo ref syntax errors in connector docs - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/07 03:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39046) [docs] Incorrect Hugo ref syntax in Kinesis documentation - posted by "featzhang (Jira)" <ji...@apache.org> on 2026/02/07 04:27:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39046) [Docs][Kinesis] Incorrect Hugo ref syntax in Kinesis documentation - posted by "featzhang (Jira)" <ji...@apache.org> on 2026/02/07 04:37:00 UTC, 0 replies.
- Re: [PR] [hotfix] Avoid duplicate loop for configuration [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/02/07 06:27:25 UTC, 1 replies.
- [jira] [Created] (FLINK-39047) Translate the Chinese documentation related to Transform - posted by "Jia Fan (Jira)" <ji...@apache.org> on 2026/02/07 07:23:00 UTC, 0 replies.
- [PR] [FLINK-39047][doc] Translate the Chinese documentation related to Transform [flink-cdc] - posted by "Hisoka-X (via GitHub)" <gi...@apache.org> on 2026/02/07 07:57:59 UTC, 1 replies.
- [jira] [Updated] (FLINK-39047) Translate the Chinese documentation related to Transform - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/07 07:59:00 UTC, 0 replies.
- [PR] [hotfix][runtime] Log unexpected non-terminal task state [flink] - posted by "rkhachatryan (via GitHub)" <gi...@apache.org> on 2026/02/07 12:52:56 UTC, 4 replies.
- [PR] [FLINK-39042][webui] Make watermark timestamps timezone-aware and configurable [flink] - posted by "featzhang (via GitHub)" <gi...@apache.org> on 2026/02/07 17:17:31 UTC, 10 replies.
- [jira] [Updated] (FLINK-39042) [webui] Make watermark timestamps timezone-aware and configurable - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/07 17:18:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38936) FileSystem SQL Connector,The connector metadata file.name, Caused by: java.nio.file.InvalidPathException: Illegal char <:> at index 2 - posted by "Rion Williams (Jira)" <ji...@apache.org> on 2026/02/07 17:23:00 UTC, 1 replies.
- [PR] Flink 38936 [flink] - posted by "rionmonster (via GitHub)" <gi...@apache.org> on 2026/02/07 18:06:51 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-38936) FileSystem SQL Connector,The connector metadata file.name, Caused by: java.nio.file.InvalidPathException: Illegal char <:> at index 2 - posted by "Rion Williams (Jira)" <ji...@apache.org> on 2026/02/07 20:37:00 UTC, 1 replies.
- Re: [PR] [draft] MySqlDatabaseSchema include gh-ost ddl in HistorizedRelationalDatabaseSchema [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/02/08 00:11:05 UTC, 1 replies.
- Re: [PR] FLINK-39040 Additional body json for GenericJsonAndUrlQueryCreator [flink-connector-http] - posted by "qinf (via GitHub)" <gi...@apache.org> on 2026/02/08 04:26:21 UTC, 15 replies.
- [jira] [Updated] (FLINK-39040) allow additional json to be specified for the body request - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/08 04:27:00 UTC, 1 replies.
- Re: [PR] [FLINK-38349][runtime] Address SpillingThread Zero-Division During Channel Merging Operations [flink] - posted by "rionmonster (via GitHub)" <gi...@apache.org> on 2026/02/08 04:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39048) [iceberg] Upgrade iceberg-flink-runtime from 1.19 to 1.20 to align with Flink 1.20.x - posted by "suhwan (Jira)" <ji...@apache.org> on 2026/02/08 06:09:00 UTC, 0 replies.
- [PR] [FLINK-39048][iceberg] Bump iceberg-flink-runtime from 1.19 to 1.20 [flink-cdc] - posted by "suhwan-cheon (via GitHub)" <gi...@apache.org> on 2026/02/08 06:18:42 UTC, 1 replies.
- [jira] [Updated] (FLINK-39048) [iceberg] Upgrade iceberg-flink-runtime from 1.19 to 1.20 to align with Flink 1.20.x - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/08 06:19:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39048) [iceberg] Bump iceberg-flink-runtime from 1.19 to 1.20 - posted by "suhwan (Jira)" <ji...@apache.org> on 2026/02/08 06:20:00 UTC, 0 replies.
- Re: [PR] Bump com.nimbusds:nimbus-jose-jwt from 4.41.1 to 9.37.4 in /flink-end-to-end-tests/flink-end-to-end-tests-sql [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/02/08 06:31:40 UTC, 2 replies.
- Re: [PR] Bump io.netty:netty-codec-http from 4.1.108.Final to 4.1.127.Final-redhat-00001 in /flink-kubernetes [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/02/08 06:31:43 UTC, 0 replies.
- [jira] [Created] (FLINK-39049) Introduce built-in functions `VARIANT_VALUE` and `VARIANT_QUERY` to extract values from a variant - posted by "Jinkun Liu (Jira)" <ji...@apache.org> on 2026/02/08 08:52:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39049) Introduce built-in functions `VARIANT_VALUE` and `VARIANT_QUERY` to extract values from a variant - posted by "Jinkun Liu (Jira)" <ji...@apache.org> on 2026/02/08 08:53:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-39049) Introduce built-in functions `VARIANT_VALUE` and `VARIANT_QUERY` to extract values from a variant - posted by "Jinkun Liu (Jira)" <ji...@apache.org> on 2026/02/08 08:57:00 UTC, 3 replies.
- [I] [Feature] Add retries for remote calls in MCPServer, MCPTool and MCPPrompt [flink-agents] - posted by "yanand0909 (via GitHub)" <gi...@apache.org> on 2026/02/08 11:39:55 UTC, 1 replies.
- Re: [PR] [FLINK-38447] Add table sink support for Elasticsearch 8 connector [flink-connector-elasticsearch] - posted by "lwn3148 (via GitHub)" <gi...@apache.org> on 2026/02/08 18:25:06 UTC, 7 replies.
- Re: [PR] [FLINK-37950][Connectors/MongoDB] Supporting ordered & bypassdocumentValidation behaviour for sink writer. [flink-connector-mongodb] - posted by "neoneo008 (via GitHub)" <gi...@apache.org> on 2026/02/08 20:49:59 UTC, 6 replies.
- Re: [PR] [FLINK-35599] Introduce JDBC pipeline sink connector [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/02/09 00:08:39 UTC, 1 replies.
- Re: [PR] [FLINK-38909] Fix Unable to delete S3 checkpoint due to presence of default file [flink] - posted by "och5351 (via GitHub)" <gi...@apache.org> on 2026/02/09 01:59:26 UTC, 1 replies.
- [jira] [Updated] (FLINK-39033) File Connector does not support WebHDFS protocol - posted by "CHANHAE OH (Jira)" <ji...@apache.org> on 2026/02/09 02:23:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-39046) [Docs][Kinesis] Incorrect Hugo ref syntax in Kinesis documentation - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2026/02/09 06:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39050) Support configurable handling strategy for null rowtime field in watermark generation - posted by "Liu (Jira)" <ji...@apache.org> on 2026/02/09 06:30:00 UTC, 0 replies.
- [PR] [FLINK-39050][Table SQL/Planner] Support configurable handling strategy for null rowtime field in watermark generation [flink] - posted by "Myracle (via GitHub)" <gi...@apache.org> on 2026/02/09 07:06:06 UTC, 10 replies.
- [jira] [Updated] (FLINK-39050) Support configurable handling strategy for null rowtime field in watermark generation - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/09 07:07:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38498) JDBC Connector Data Type Mapping lacks: Mysql Timestamp and Postgres Timestamp_tz - posted by "Zhe Wang (Jira)" <ji...@apache.org> on 2026/02/09 07:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39051) Support APPROX_COUNT_DISTINCT aggregate function in streaming mode with Window TVF - posted by "Liu (Jira)" <ji...@apache.org> on 2026/02/09 08:00:00 UTC, 0 replies.
- [PR] [FLINK-39051][Table SQL/Planner] Support APPROX_COUNT_DISTINCT aggregate function in streaming mode with Window TVF [flink] - posted by "Myracle (via GitHub)" <gi...@apache.org> on 2026/02/09 08:22:27 UTC, 2 replies.
- [jira] [Updated] (FLINK-39051) Support APPROX_COUNT_DISTINCT aggregate function in streaming mode with Window TVF - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/09 08:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39052) ModuleNotFoundError: No module named 'pkg_resources' - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2026/02/09 09:09:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38857) Introduce a Triton inference module under flink-models for batch-oriented AI inference - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2026/02/09 09:14:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38857) Introduce a Triton inference module under flink-models for batch-oriented AI inference - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2026/02/09 09:15:00 UTC, 0 replies.
- [PR] [FLINK-39052][python] Remove usage of pkg_resources [flink] - posted by "dianfu (via GitHub)" <gi...@apache.org> on 2026/02/09 09:26:30 UTC, 5 replies.
- [jira] [Updated] (FLINK-39052) ModuleNotFoundError: No module named 'pkg_resources' - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/09 09:27:00 UTC, 1 replies.
- Re: [PR] [FLINK-38551][table-planner] Extend MultiJoin tests based on current join tests [flink] - posted by "gustavodemorais (via GitHub)" <gi...@apache.org> on 2026/02/09 09:28:17 UTC, 1 replies.
- [PR] [test] Improve pipeline connector test coverage i.e. doris/postgres/fluss [flink-cdc] - posted by "leonardBang (via GitHub)" <gi...@apache.org> on 2026/02/09 11:10:25 UTC, 2 replies.
- [jira] [Closed] (FLINK-39052) ModuleNotFoundError: No module named 'pkg_resources' - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2026/02/09 11:53:00 UTC, 1 replies.
- [jira] [Reopened] (FLINK-39052) ModuleNotFoundError: No module named 'pkg_resources' - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2026/02/09 11:53:00 UTC, 0 replies.
- [PR] [FLINK-38236][mongodb] Add metadata support for full document in MongoDB CDC connector [flink-cdc] - posted by "Hisoka-X (via GitHub)" <gi...@apache.org> on 2026/02/09 12:20:26 UTC, 1 replies.
- [jira] [Updated] (FLINK-38236) MongoDB CDC - Include Full Document as Metadata Field - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/09 12:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39053) AvroTypeException when writing Flink VARCHAR to Avro ENUM in Kafka avro-confluent format - posted by "Dominik Dębowczyk (Jira)" <ji...@apache.org> on 2026/02/09 12:54:00 UTC, 0 replies.
- [PR] [ci][fix] fix label ci run failed [flink-cdc] - posted by "Hisoka-X (via GitHub)" <gi...@apache.org> on 2026/02/09 13:07:40 UTC, 2 replies.
- [PR] [FLINK-39053][format/avro] Support VARCHAR to ENUM conversion in avro-confluent format [flink] - posted by "ddebowczyk92 (via GitHub)" <gi...@apache.org> on 2026/02/09 13:22:03 UTC, 10 replies.
- [jira] [Updated] (FLINK-39053) AvroTypeException when writing Flink VARCHAR to Avro ENUM in Kafka avro-confluent format - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/09 13:23:00 UTC, 0 replies.
- Re: [PR] [FLINK-36595][docs] Explicitly set connector compatibility as string … [flink-connector-rabbitmq] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2026/02/09 13:56:07 UTC, 1 replies.
- [jira] [Commented] (FLINK-39002) Could not resolve ResourceManager because of NPE - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2026/02/09 14:15:00 UTC, 2 replies.
- [jira] [Assigned] (FLINK-35311) FLIP-454: New Apicurio Avro format - posted by "david radley (Jira)" <ji...@apache.org> on 2026/02/09 14:26:00 UTC, 0 replies.
- Re: [PR] Bump org.assertj:assertj-core from 3.23.1 to 3.27.7 [flink-connector-http] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2026/02/09 14:43:53 UTC, 1 replies.
- [PR] [hotfix][mcp] Fix MCPTool Jackson deserialization by ignoring unknown properties [flink-agents] - posted by "avichaym (via GitHub)" <gi...@apache.org> on 2026/02/09 14:54:01 UTC, 8 replies.
- [I] [Feature] Add Amazon Bedrock integration for chat models and embedding models [flink-agents] - posted by "avichaym (via GitHub)" <gi...@apache.org> on 2026/02/09 14:56:08 UTC, 1 replies.
- [I] [Feature] Add Amazon OpenSearch and S3 Vectors vector store integrations [flink-agents] - posted by "avichaym (via GitHub)" <gi...@apache.org> on 2026/02/09 14:58:10 UTC, 1 replies.
- [PR] [FLINK-39022][tests] Enable TLSv1.2 support explicitly [flink] - posted by "rkhachatryan (via GitHub)" <gi...@apache.org> on 2026/02/09 15:21:41 UTC, 1 replies.
- [PR] [hotfix] Fix onnxruntime build failure on macOS x86_64 [flink-agents] - posted by "alnzng (via GitHub)" <gi...@apache.org> on 2026/02/09 18:28:01 UTC, 12 replies.
- [jira] [Created] (FLINK-39054) DynamicKafkaSourceEnumStateSerializer should preserve full per-cluster properties instead of only bootstrap.servers - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2026/02/09 21:11:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-39054) DynamicKafkaSourceEnumStateSerializer should preserve full per-cluster properties instead of only bootstrap.servers - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2026/02/09 21:11:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39054) DynamicKafkaSourceEnumStateSerializer should preserve full per-cluster properties instead of only bootstrap.servers - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2026/02/09 21:46:00 UTC, 1 replies.
- [PR] [Hotfix] Cap setuptools<82 to pull in pkg_resources module [flink-agents] - posted by "alnzng (via GitHub)" <gi...@apache.org> on 2026/02/09 23:04:37 UTC, 0 replies.
- [jira] [Resolved] (FLINK-39048) [iceberg] Bump iceberg-flink-runtime from 1.19 to 1.20 - posted by "suhwan (Jira)" <ji...@apache.org> on 2026/02/09 23:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39055) [iceberg] Support default column values in Iceberg sink connector - posted by "suhwan (Jira)" <ji...@apache.org> on 2026/02/09 23:47:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39055) [Iceberg] Support default column values in Iceberg sink connector - posted by "suhwan (Jira)" <ji...@apache.org> on 2026/02/09 23:48:00 UTC, 2 replies.
- [jira] [Commented] (FLINK-39055) [Iceberg] Support default column values in Iceberg sink connector - posted by "suhwan (Jira)" <ji...@apache.org> on 2026/02/09 23:49:00 UTC, 0 replies.
- Re: [PR] [hotfix] Cap setuptools<82 to pull in pkg_resources module [flink-agents] - posted by "alnzng (via GitHub)" <gi...@apache.org> on 2026/02/10 00:08:13 UTC, 4 replies.
- [PR] Add unified metrics support to AsyncPredictFunction and PredictFunction [flink] - posted by "featzhang (via GitHub)" <gi...@apache.org> on 2026/02/10 02:23:41 UTC, 0 replies.
- Re: [PR] [FLINK-38857][model] Add unified metrics support to AsyncPredictFunction and PredictFunction [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2026/02/10 02:31:41 UTC, 2 replies.
- [PR] [FLINK-39054] DynamicKafkaSourceEnumStateSerializer should preserve full per-cluster properties instead of only bootstrap.servers [flink-connector-kafka] - posted by "bowenli86 (via GitHub)" <gi...@apache.org> on 2026/02/10 02:39:48 UTC, 1 replies.
- [PR] [FLINK-38857][model-triton] Add retry with default value fallback for inference failures [flink] - posted by "featzhang (via GitHub)" <gi...@apache.org> on 2026/02/10 02:50:42 UTC, 1 replies.
- [PR] [FLINK-38857][model] Add sequence ID auto-increment support for Triton inference [flink] - posted by "featzhang (via GitHub)" <gi...@apache.org> on 2026/02/10 03:11:36 UTC, 1 replies.
- [jira] [Resolved] (FLINK-38943) Support Adaptive Partition Selection for RescalePartitioner & RebalancePartitioner - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/02/10 03:21:00 UTC, 0 replies.
- [I] [examples][java] Add Table API example for product review analysis [flink-agents] - posted by "weiqingy (via GitHub)" <gi...@apache.org> on 2026/02/10 03:22:19 UTC, 3 replies.
- [jira] [Resolved] (FLINK-38808) Support partition transforms in Iceberg sink - posted by "ChaoFang (Jira)" <ji...@apache.org> on 2026/02/10 03:27:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38808) Support partition transforms in Iceberg sink - posted by "ChaoFang (Jira)" <ji...@apache.org> on 2026/02/10 03:27:00 UTC, 0 replies.
- [PR] [hotfix][infra] Update github PR labeler settings for release 0.2.0. [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2026/02/10 03:33:59 UTC, 2 replies.
- [jira] [Created] (FLINK-39056) Duplicate Data Issue in Iceberg Sink During Two-Phase Commit - posted by "ChaoFang (Jira)" <ji...@apache.org> on 2026/02/10 03:34:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39056) FLINK-CDC Duplicate Data Issue in Iceberg Sink During Two-Phase Commit - posted by "ChaoFang (Jira)" <ji...@apache.org> on 2026/02/10 03:35:00 UTC, 1 replies.
- [PR] [FLINK-39052][python] Bump version auditwheel to 6.6.0 [flink] - posted by "dianfu (via GitHub)" <gi...@apache.org> on 2026/02/10 03:45:04 UTC, 3 replies.
- Re: [PR] [hotfix][docs] Add 2026 on NOTICE [flink-kubernetes-operator] - posted by "yangjf2019 (via GitHub)" <gi...@apache.org> on 2026/02/10 04:24:22 UTC, 0 replies.
- [I] [Tech Debt] [python] Remove setuptools<82 constraint after apache-flink upgrades to apache-beam>=2.66.0 [flink-agents] - posted by "alnzng (via GitHub)" <gi...@apache.org> on 2026/02/10 04:32:36 UTC, 0 replies.
- [PR] [examples][java] Add Table API example for product review analysis [flink-agents] - posted by "weiqingy (via GitHub)" <gi...@apache.org> on 2026/02/10 04:44:26 UTC, 1 replies.
- Re: [PR] [FLINK-38205][format][pb] Discard unknown fields by default [flink] - posted by "X-czh (via GitHub)" <gi...@apache.org> on 2026/02/10 04:46:46 UTC, 0 replies.
- [PR] [Feature][Java] Added retires to remote calls in MCP server [flink-agents] - posted by "yanand0909 (via GitHub)" <gi...@apache.org> on 2026/02/10 04:52:42 UTC, 5 replies.
- [jira] [Created] (FLINK-39057) [JUnit5 Migration] Migrate assertion lines to assertj for flink-model-triton module - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/02/10 04:54:00 UTC, 0 replies.
- [PR] [FLINK-39057][JUnit5 Migration] Migrate assertion lines to assertj for flink-model-triton module [flink] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2026/02/10 04:59:38 UTC, 3 replies.
- [jira] [Updated] (FLINK-39057) [JUnit5 Migration] Migrate assertion lines to assertj for flink-model-triton module - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/10 05:00:00 UTC, 1 replies.
- [jira] [Created] (FLINK-39058) Use Preconditions#checkArgument to replace raw condition validation in model-triton module - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/02/10 05:08:00 UTC, 0 replies.
- [PR] [FLINK-39058][model-triton] Use Preconditions#checkArgument to replace raw condition validation in model-triton module [flink] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2026/02/10 05:11:04 UTC, 4 replies.
- [jira] [Updated] (FLINK-39058) Use Preconditions#checkArgument to replace raw condition validation in model-triton module - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/10 05:12:00 UTC, 2 replies.
- [jira] [Assigned] (FLINK-37950) MongoDB connector should support ordered option - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2026/02/10 05:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37950) MongoDB connector should support ordered option - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2026/02/10 05:18:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37950) MongoDB connector should support ordered option - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2026/02/10 05:18:00 UTC, 0 replies.
- Re: [PR] [FLINK-32344][connectors/mongodb] Support unbounded streaming read via change stream feature. [flink-connector-mongodb] - posted by "Jiabao-Sun (via GitHub)" <gi...@apache.org> on 2026/02/10 05:30:25 UTC, 1 replies.
- [jira] [Closed] (FLINK-32344) MongoDB connector support unbounded streaming read via ChangeStream feature - posted by "Jiabao Sun (Jira)" <ji...@apache.org> on 2026/02/10 05:32:00 UTC, 0 replies.
- [PR] [FLINK-39056][pipeline-connector][iceberg] Duplicate Data Issue in Iceberg Sink During Two-Phase Commit [flink-cdc] - posted by "fcfangcc (via GitHub)" <gi...@apache.org> on 2026/02/10 06:08:56 UTC, 9 replies.
- [PR] [FLINK-39052][python] Limit setuptools version to < 81.0.0 [flink] - posted by "dianfu (via GitHub)" <gi...@apache.org> on 2026/02/10 06:22:29 UTC, 0 replies.
- Re: [PR] [FLINK-39052][python] Limit setuptools version to < 82.0.0 [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2026/02/10 06:29:49 UTC, 4 replies.
- [jira] [Commented] (FLINK-39052) ModuleNotFoundError: No module named 'pkg_resources' - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2026/02/10 06:31:00 UTC, 2 replies.
- [jira] [Comment Edited] (FLINK-39052) ModuleNotFoundError: No module named 'pkg_resources' - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2026/02/10 06:36:00 UTC, 2 replies.
- Re: [I] [Tech Debt] Improve observability of ci [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2026/02/10 08:59:44 UTC, 0 replies.
- [jira] [Created] (FLINK-39059) Add unified metrics support to AsyncPredictFunction and PredictFunction - posted by "featzhang (Jira)" <ji...@apache.org> on 2026/02/10 09:36:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-39058) Use Preconditions#checkArgument to replace raw condition validation in model-triton module - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/02/10 11:10:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-39057) [JUnit5 Migration] Migrate assertion lines to assertj for flink-model-triton module - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/02/10 11:11:00 UTC, 0 replies.
- [PR] [FLINK-38857][models] Add health check and circuit breaker for Triton inference [flink] - posted by "featzhang (via GitHub)" <gi...@apache.org> on 2026/02/10 11:18:21 UTC, 2 replies.
- Re: [PR] [FLINK-38857][model] Add retry with default value fallback for triton inference failures [flink] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2026/02/10 11:54:26 UTC, 3 replies.
- [PR] [FLINK-38455] Fix ES8 pipeline connector failure when batch contains only SchemaChangeEvents [flink-cdc] - posted by "Hisoka-X (via GitHub)" <gi...@apache.org> on 2026/02/10 12:26:20 UTC, 1 replies.
- [jira] [Updated] (FLINK-38455) MySQL CDC to ES8 pipeline connector cannot work - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/10 12:27:00 UTC, 0 replies.
- [PR] [FLINK-38857][models] Add HTTP connection pool management for Triton inference [flink] - posted by "featzhang (via GitHub)" <gi...@apache.org> on 2026/02/10 12:43:39 UTC, 11 replies.
- Re: [PR] [FLINK-38936][connectors/filesystem] Improve OS-Independent File Path Resolution for FileSystem Connector [flink] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2026/02/10 12:43:57 UTC, 5 replies.
- [jira] [Updated] (FLINK-38936) FileSystem SQL Connector,The connector metadata file.name, Caused by: java.nio.file.InvalidPathException: Illegal char <:> at index 2 - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/10 12:44:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37742) POJO type expected but was: GenericType when resume from savepoint - posted by "Mukul Gupta (Jira)" <ji...@apache.org> on 2026/02/10 12:48:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-39017) Flink WebUI Job graph node click interaction fails in Chrome 144+ (PointerEvents suppression) - posted by "Jacob Jona Fahlenkamp (Jira)" <ji...@apache.org> on 2026/02/10 14:39:00 UTC, 1 replies.
- [PR] [FLINK-39017][web] Fix task click handler in job graph for Chrome 144+ [flink] - posted by "MartijnVisser (via GitHub)" <gi...@apache.org> on 2026/02/10 15:08:36 UTC, 4 replies.
- [jira] [Created] (FLINK-39060) Bump Java depencies to resolve CVEs - posted by "Cameron (Jira)" <ji...@apache.org> on 2026/02/10 15:09:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-35661) MiniBatchGroupAggFunction can silently drop records under certain conditions - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2026/02/10 16:06:00 UTC, 1 replies.
- [PR] [FLINK-XXXXX][table] Support ALTER VIEW SET WATERMARK syntax [flink] - posted by "featzhang (via GitHub)" <gi...@apache.org> on 2026/02/10 16:22:45 UTC, 1 replies.
- [PR] [FLINK-AGENTS-523] Add Amazon Bedrock chat model and embedding model integrations [flink-agents] - posted by "avichaym (via GitHub)" <gi...@apache.org> on 2026/02/10 16:27:16 UTC, 0 replies.
- [PR] [FLINK-AGENTS-523] Add Amazon Bedrock chat model and embedding model integrations [flink-agents] - posted by "avichaym (via GitHub)" <gi...@apache.org> on 2026/02/10 16:30:32 UTC, 6 replies.
- [PR] [FLINK-XXXXX][table] Support WATERMARK clause in CREATE VIEW statement [flink] - posted by "featzhang (via GitHub)" <gi...@apache.org> on 2026/02/10 16:36:16 UTC, 1 replies.
- Re: [PR] [FLINK-AGENTS-524] Add Amazon OpenSearch and S3 Vectors vector store integrations [flink-agents] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/02/10 16:38:21 UTC, 0 replies.
- [jira] [Created] (FLINK-39061) StateMachine example uses State V2 API, breaking canonical savepoint compatibility and version upgrade workflow - posted by "Sebastien Pereira (Jira)" <ji...@apache.org> on 2026/02/10 17:48:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39061) StateMachine example uses State V2 API, breaking canonical savepoint compatibility - posted by "Sebastien Pereira (Jira)" <ji...@apache.org> on 2026/02/10 17:48:00 UTC, 1 replies.
- Re: [PR] [FLINK-39002][tests] Temporarily disable SSL in test_file_sink [flink] - posted by "rkhachatryan (via GitHub)" <gi...@apache.org> on 2026/02/10 18:49:40 UTC, 2 replies.
- [jira] [Updated] (FLINK-39002) Could not resolve ResourceManager because of NPE - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/10 18:50:00 UTC, 0 replies.
- [PR] [FLINK-35661][table] Fix MiniBatchGroupAggFunction silently dropping records (backport 2.2) [flink] - posted by "nateab (via GitHub)" <gi...@apache.org> on 2026/02/10 19:58:05 UTC, 6 replies.
- [PR] [FLINK-35661][table] Fix MiniBatchGroupAggFunction silently dropping records (backport 2.1) [flink] - posted by "nateab (via GitHub)" <gi...@apache.org> on 2026/02/10 19:58:08 UTC, 7 replies.
- [PR] [FLINK-35661][table] Fix MiniBatchGroupAggFunction silently dropping records (backport 2.0) [flink] - posted by "nateab (via GitHub)" <gi...@apache.org> on 2026/02/10 19:58:12 UTC, 4 replies.
- Re: [PR] [Flink-38911][cdc connector mysql] mysql-cdc-connector datastream support scan.binlog.newly-added-table.enabled [flink-cdc] - posted by "ThorneANN (via GitHub)" <gi...@apache.org> on 2026/02/11 01:39:50 UTC, 2 replies.
- [PR] [test] Testing whether there are security issues in CI [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2026/02/11 01:57:06 UTC, 1 replies.
- [jira] [Created] (FLINK-39062) Support Watermark Definition in SQL Views - posted by "featzhang (Jira)" <ji...@apache.org> on 2026/02/11 02:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39063) FIx some spelling mistake in fluss connector - posted by "Thorne (Jira)" <ji...@apache.org> on 2026/02/11 02:16:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39063) FIx some spelling mistake in fluss connector - posted by "Thorne (Jira)" <ji...@apache.org> on 2026/02/11 02:18:00 UTC, 5 replies.
- [jira] [Assigned] (FLINK-39063) FIx some spelling mistake in fluss connector - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2026/02/11 02:42:00 UTC, 0 replies.
- [PR] [FLINK-27661][Runtime / Metrics] PrometheusPushGatewayReporter support pushgateway http authentication [flink] - posted by "Myracle (via GitHub)" <gi...@apache.org> on 2026/02/11 02:43:13 UTC, 7 replies.
- [jira] [Commented] (FLINK-27661) [Metric]Flink-Metrics PrometheusPushGatewayReporter support pushgateway http authentication - posted by "Liu (Jira)" <ji...@apache.org> on 2026/02/11 02:46:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38892) Introduce the scheduler and type information of the target job in the JobDetails(Info).java - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/02/11 02:49:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-39064) Add built-in REGEXP_SPLIT function to split string by regular expression pattern - posted by "Liu (Jira)" <ji...@apache.org> on 2026/02/11 02:57:00 UTC, 1 replies.
- [jira] [Created] (FLINK-39064) Add built-in REGEXP_SPLIT function to split string by regular expression pattern - posted by "Liu (Jira)" <ji...@apache.org> on 2026/02/11 02:57:00 UTC, 0 replies.
- [PR] [FLINK-39064][Table SQL / API] Add built-in REGEXP_SPLIT function to split string by regular expression pattern [flink] - posted by "Myracle (via GitHub)" <gi...@apache.org> on 2026/02/11 03:18:15 UTC, 6 replies.
- [PR] [FLINK-39056][pipeline-connector][Fluss] Fix some spelling mistakes in pipeline fluss connector [flink-cdc] - posted by "ThorneANN (via GitHub)" <gi...@apache.org> on 2026/02/11 03:27:47 UTC, 4 replies.
- [jira] [Created] (FLINK-39065) Support additional CsvParser.Feature options for CSV format deserialization - posted by "Liu (Jira)" <ji...@apache.org> on 2026/02/11 03:33:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39065) Support additional CsvParser.Feature options for CSV format deserialization - posted by "Liu (Jira)" <ji...@apache.org> on 2026/02/11 03:34:00 UTC, 2 replies.
- [jira] [Created] (FLINK-39066) fix fluss conector 's FlussHistogram always return null - posted by "Thorne (Jira)" <ji...@apache.org> on 2026/02/11 03:49:00 UTC, 0 replies.
- [PR] [FLINK-39065][Formats (JSON, Avro, Parquet, ORC, SequenceFile)] Support additional CsvParser.Feature options for CSV format deserialization [flink] - posted by "Myracle (via GitHub)" <gi...@apache.org> on 2026/02/11 03:59:33 UTC, 1 replies.
- [jira] [Updated] (FLINK-38096) AsyncSinkWriter may hang when configured with a custom rate limiting strategy - posted by "Taranpreet Kaur (Jira)" <ji...@apache.org> on 2026/02/11 04:08:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-38096) AsyncSinkWriter may hang when configured with a custom rate limiting strategy - posted by "Taranpreet Kaur (Jira)" <ji...@apache.org> on 2026/02/11 04:10:00 UTC, 0 replies.
- Re: [PR] [FLINK-37645] Improve existsUnboundedSource by avoiding duplicate check transformations [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/02/11 06:39:55 UTC, 1 replies.
- [jira] [Resolved] (FLINK-35661) MiniBatchGroupAggFunction can silently drop records under certain conditions - posted by "Natea Eshetu Beshada (Jira)" <ji...@apache.org> on 2026/02/11 06:41:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9558) Memory leaks during usage of bucketing-sink with disabled checkpointing - posted by "Natea Eshetu Beshada (Jira)" <ji...@apache.org> on 2026/02/11 06:54:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9558) Memory leaks during usage of bucketing-sink with disabled checkpointing - posted by "Natea Eshetu Beshada (Jira)" <ji...@apache.org> on 2026/02/11 06:54:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-9558) Memory leaks during usage of bucketing-sink with disabled checkpointing - posted by "Natea Eshetu Beshada (Jira)" <ji...@apache.org> on 2026/02/11 06:55:00 UTC, 0 replies.
- [PR] [FLINK-32212][runtime] Fix infinite restart loop from BlobLibraryCach… [flink] - posted by "nateab (via GitHub)" <gi...@apache.org> on 2026/02/11 07:17:02 UTC, 1 replies.
- [jira] [Updated] (FLINK-32212) Job restarting indefinitely after an IllegalStateException from BlobLibraryCacheManager - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/11 07:18:00 UTC, 0 replies.
- Re: [PR] [FLINK-38953] Cleanup configurations for SSL hostname verification [flink] - posted by "gaborgsomogyi (via GitHub)" <gi...@apache.org> on 2026/02/11 07:19:56 UTC, 5 replies.
- [jira] [Assigned] (FLINK-32212) Job restarting indefinitely after an IllegalStateException from BlobLibraryCacheManager - posted by "Natea Eshetu Beshada (Jira)" <ji...@apache.org> on 2026/02/11 07:22:00 UTC, 0 replies.
- [D] Agent Skills Investigation [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2026/02/11 07:23:45 UTC, 0 replies.
- [D] Memory Framework Investigation [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2026/02/11 07:25:36 UTC, 0 replies.
- [jira] [Assigned] (FLINK-39017) Flink WebUI Job graph node click interaction fails in Chrome 144+ (PointerEvents suppression) - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/02/11 07:34:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-39017) Flink WebUI Job graph node click interaction fails in Chrome 144+ (PointerEvents suppression) - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/02/11 07:39:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39063) FIx some spelling mistakes in fluss connector - posted by "Thorne (Jira)" <ji...@apache.org> on 2026/02/11 07:44:00 UTC, 1 replies.
- [jira] [Resolved] (FLINK-39038) GitHub flink-cdc repository actions clean-up - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2026/02/11 08:06:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38945) [FLIP-561] Restructure Flink documentation - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/02/11 08:06:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-39064) Add built-in REGEXP_SPLIT function to split string by regular expression pattern - posted by "Natea Eshetu Beshada (Jira)" <ji...@apache.org> on 2026/02/11 08:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39067) Move Python docs to PyDocs - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/02/11 08:08:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38988) Support INET_ATON and INET_NTOA functions for IP address conversion - posted by "Liu (Jira)" <ji...@apache.org> on 2026/02/11 08:15:00 UTC, 0 replies.
- Re: [PR] [FLINK-39063][pipeline-connector][Fluss] Fix some spelling mistakes in pipeline fluss connector [flink-cdc] - posted by "ThorneANN (via GitHub)" <gi...@apache.org> on 2026/02/11 08:26:29 UTC, 1 replies.
- [PR] [FLINK-38897][Runtime/REST] Introduce the /jobs/:jobid/rescales/config endpoint in the REST API [flink] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2026/02/11 08:28:15 UTC, 19 replies.
- [jira] [Updated] (FLINK-38897) Introduce the /jobs/:jobid/rescales/config endpoint in the REST API - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/11 08:29:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-39066) Fix fluss's metric Histogram always return null - posted by "Thorne (Jira)" <ji...@apache.org> on 2026/02/11 08:34:00 UTC, 3 replies.
- [jira] [Updated] (FLINK-39066) Fix fluss's metric histogram always return null - posted by "Thorne (Jira)" <ji...@apache.org> on 2026/02/11 08:35:00 UTC, 3 replies.
- [jira] [Reopened] (FLINK-35661) MiniBatchGroupAggFunction can silently drop records under certain conditions - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2026/02/11 08:35:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-35284) Streaming File Sink end-to-end test times out - posted by "Natea Eshetu Beshada (Jira)" <ji...@apache.org> on 2026/02/11 08:49:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-29671) Kubernetes e2e test fails during test initialization - posted by "Natea Eshetu Beshada (Jira)" <ji...@apache.org> on 2026/02/11 08:59:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-39010) YAML Pipeline supports item subscription of variant types - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2026/02/11 09:18:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38514) Postgres YAML CDC support UUID_ARRAY - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2026/02/11 09:19:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-39047) Translate the Chinese documentation related to Transform - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2026/02/11 09:20:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38512) Postgres YAML CDC support database name with middlescore - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2026/02/11 09:21:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-36796) oracle cdc supports pipeline configuration connector - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2026/02/11 09:22:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38823) Error running wide table task - posted by "peiyu (Jira)" <ji...@apache.org> on 2026/02/11 09:22:00 UTC, 0 replies.
- [PR] [FLINK-36429] [runtime-web] Enhancing Flink History Server File Storage and Retrieval with RocksDB [flink] - posted by "Shawnsuun (via GitHub)" <gi...@apache.org> on 2026/02/11 09:22:39 UTC, 2 replies.
- [PR] [minor][hotfix] Update configOption name from `sink.job.id.prefix` to `job.id.prefix` [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2026/02/11 09:31:08 UTC, 4 replies.
- [PR] [hotfix] add .worktrees to .gitignore [flink] - posted by "nateab (via GitHub)" <gi...@apache.org> on 2026/02/11 09:31:32 UTC, 1 replies.
- [jira] [Created] (FLINK-39068) [SQL Client] Support saving and exporting SQL execution history - posted by "featzhang (Jira)" <ji...@apache.org> on 2026/02/11 09:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39069) [SQL Client] Support saving and exporting SQL execution history - posted by "featzhang (Jira)" <ji...@apache.org> on 2026/02/11 09:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39070) Update Kafka parent connector - posted by "David Radley (Jira)" <ji...@apache.org> on 2026/02/11 09:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39071) Select fileds rathert * to read snapshot data incase schema changes. - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2026/02/11 10:10:00 UTC, 0 replies.
- Re: [I] [Bug] Failed to connect to remote mcp server [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2026/02/11 10:13:15 UTC, 0 replies.
- [PR] [FLINK-39069][SQL Client] Support saving and exporting SQL execution history [flink] - posted by "featzhang (via GitHub)" <gi...@apache.org> on 2026/02/11 10:15:07 UTC, 1 replies.
- [PR] Select fileds rathert * to read snapshot data in case schema changes. [flink-cdc] - posted by "loserwang1024 (via GitHub)" <gi...@apache.org> on 2026/02/11 10:15:52 UTC, 0 replies.
- [jira] [Updated] (FLINK-39069) [SQL Client] Support saving and exporting SQL execution history - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/11 10:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39072) Handle InvalidPidMappingException as known failure in KafkaCommitter - posted by "Natea Eshetu Beshada (Jira)" <ji...@apache.org> on 2026/02/11 11:02:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-39072) Handle InvalidPidMappingException as known failure in KafkaCommitter - posted by "Natea Eshetu Beshada (Jira)" <ji...@apache.org> on 2026/02/11 11:03:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39072) Handle InvalidPidMappingException as known failure in KafkaCommitter - posted by "Natea Eshetu Beshada (Jira)" <ji...@apache.org> on 2026/02/11 11:03:00 UTC, 1 replies.
- [PR] Handle InvalidPidMappingException as known failure in KafkaCommitter [flink-connector-kafka] - posted by "nateab (via GitHub)" <gi...@apache.org> on 2026/02/11 11:03:56 UTC, 1 replies.
- [PR] [FLINK-23886][runtime] Fix null column family handle in RocksDBFullRe… [flink] - posted by "nateab (via GitHub)" <gi...@apache.org> on 2026/02/11 11:28:17 UTC, 0 replies.
- [jira] [Updated] (FLINK-23886) An exception is thrown out when recover job timers from checkpoint file - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/11 11:29:00 UTC, 0 replies.
- [PR] [FLINK-30068][runtime] Add configurable commit failure strategy for S… [flink] - posted by "nateab (via GitHub)" <gi...@apache.org> on 2026/02/11 11:29:09 UTC, 1 replies.
- [PR] [pipeline] Use GHA workflow triggers to run labeler workflow [flink-cdc] - posted by "yuxiqian (via GitHub)" <gi...@apache.org> on 2026/02/11 11:29:10 UTC, 1 replies.
- [jira] [Updated] (FLINK-30068) Allow users to configure what to do with errors while committing transactions during recovery in KafkaSink - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/11 11:30:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-23886) An exception is thrown out when recover job timers from checkpoint file - posted by "Natea Eshetu Beshada (Jira)" <ji...@apache.org> on 2026/02/11 11:32:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-30068) Allow users to configure what to do with errors while committing transactions during recovery in KafkaSink - posted by "Natea Eshetu Beshada (Jira)" <ji...@apache.org> on 2026/02/11 11:33:00 UTC, 0 replies.
- Re: [PR] [FLINK-23886][runtime] Fix null column family handle in RocksDBFullRestoreOperation [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2026/02/11 11:37:15 UTC, 2 replies.
- [jira] [Commented] (FLINK-24544) Failure when using Kafka connector in Table API with Avro and Confluent schema registry - posted by "Natea Eshetu Beshada (Jira)" <ji...@apache.org> on 2026/02/11 11:59:00 UTC, 1 replies.
- [PR] [FLINK-39067][docs] Move Python documentation from Hugo to PyDocs [flink] - posted by "MartijnVisser (via GitHub)" <gi...@apache.org> on 2026/02/11 12:44:45 UTC, 5 replies.
- [jira] [Updated] (FLINK-39067) Move Python docs to PyDocs - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/11 12:45:00 UTC, 0 replies.
- Re: [PR] [FLINK-30975] Upgrade hadoop to 3.4.X [flink] - posted by "ctrlaltdilj (via GitHub)" <gi...@apache.org> on 2026/02/11 13:17:48 UTC, 4 replies.
- [jira] [Created] (FLINK-39073) Idle source splits are picked by watermark alignment - posted by "Efrat Levitan (Jira)" <ji...@apache.org> on 2026/02/11 13:25:00 UTC, 0 replies.
- [PR] [hotfix][infra][BP-2.2] Add .metals and .bloop into .gitignore (#27480) [flink] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2026/02/11 13:58:22 UTC, 3 replies.
- [jira] [Assigned] (FLINK-39073) Idle source splits are picked by watermark alignment - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2026/02/11 14:08:00 UTC, 0 replies.
- [PR] [hotfix][infra][BP-120] Add .metals and .bloop into .gitignore (#27480) [flink] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2026/02/11 14:08:18 UTC, 1 replies.
- [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink] - posted by "pnowojski (via GitHub)" <gi...@apache.org> on 2026/02/11 15:30:39 UTC, 37 replies.
- [jira] [Updated] (FLINK-37399) Watermark alignment can prevent backlogged jobs from using all available resources - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/11 15:31:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-39040) allow additional json to be specified for the body request - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2026/02/11 17:58:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-39040) allow additional json to be specified for the body request - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2026/02/11 17:58:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-39012) Support global enumerator/dispatcher for dynamic Kafka source - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2026/02/11 18:06:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38624) Flink 2.1 Job Failure: Type Mismatch Exception in StreamPhysicalOverAggregateRule (TIMESTAMP(3) vs TIMESTAMP(3) ROWTIME) - posted by "EMERSON WANG (Jira)" <ji...@apache.org> on 2026/02/11 18:34:00 UTC, 5 replies.
- Re: [PR] [FLINK-38249] Add support for skipping specific Debezium operations in MySQL CDC source. [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/02/12 00:06:41 UTC, 1 replies.
- Re: [PR] [FLINK-37677][cdc-common][cdc-runtime] Handle Exclusion of `create.table` Events in Flink CDC Schema Evolution [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/02/12 00:06:44 UTC, 1 replies.
- Re: [PR] [hotfix][infra][BP-1.20] Add .metals and .bloop into .gitignore (#27480) [flink] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2026/02/12 01:38:43 UTC, 1 replies.
- [jira] [Updated] (FLINK-39071) Select fields rather than * to read snapshot data in case of schema changes. - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2026/02/12 02:41:00 UTC, 1 replies.
- [PR] [FLINK-XXXXX][PyFlink] Add AI inference lifecycle management with infer() API [flink] - posted by "featzhang (via GitHub)" <gi...@apache.org> on 2026/02/12 03:55:31 UTC, 1 replies.
- Re: [PR] [FLINK-38988][Table SQL/API] Support INET_ATON and INET_NTOA functions for IP address conversion [flink] - posted by "lincoln-lil (via GitHub)" <gi...@apache.org> on 2026/02/12 03:55:32 UTC, 4 replies.
- [PR] [FLINK-24544][formats] Fix Avro enum deserialization failure with Confluent Schema Registry [flink] - posted by "nateab (via GitHub)" <gi...@apache.org> on 2026/02/12 04:37:17 UTC, 2 replies.
- [jira] [Updated] (FLINK-24544) Failure when using Kafka connector in Table API with Avro and Confluent schema registry - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/12 04:38:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-24544) Failure when using Kafka connector in Table API with Avro and Confluent schema registry - posted by "Natea Eshetu Beshada (Jira)" <ji...@apache.org> on 2026/02/12 04:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39074) Add built-in AI model inference capability to PyFlink with automatic lifecycle management - posted by "featzhang (Jira)" <ji...@apache.org> on 2026/02/12 05:05:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-39071) Select fields rather than * to read snapshot data in case of schema changes. - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2026/02/12 06:02:00 UTC, 0 replies.
- [PR] [FLINK-26051][table] Fix ROW_NUMBER with CASE WHEN and WHERE clause causing window ordering exception [flink] - posted by "nateab (via GitHub)" <gi...@apache.org> on 2026/02/12 06:09:19 UTC, 4 replies.
- [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 - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/12 06:10:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39074) Add built-in AI model inference capability to PyFlink with automatic lifecycle management - posted by "featzhang (Jira)" <ji...@apache.org> on 2026/02/12 06:12:00 UTC, 0 replies.
- Re: [PR] [FLINK-38515][flink-avro-confluent-registry] Implement OAuth2 mechanism that supports token inheritance for the Schema Registry authentication [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/02/12 06:39:25 UTC, 1 replies.
- [jira] [Closed] (FLINK-38969) Extend current JSON_STRING to convert a Variant to a Json string. - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2026/02/12 07:04:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-15867) LAST_VALUE and FIRST_VALUE aggregate function does not support time-related types - posted by "Natea Eshetu Beshada (Jira)" <ji...@apache.org> on 2026/02/12 07:05:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-15867) LAST_VALUE and FIRST_VALUE aggregate function does not support time-related types - posted by "Natea Eshetu Beshada (Jira)" <ji...@apache.org> on 2026/02/12 07:06:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39062) Support logical-level watermark definition via SQL function - posted by "featzhang (Jira)" <ji...@apache.org> on 2026/02/12 07:19:00 UTC, 2 replies.
- [jira] [Assigned] (FLINK-8093) flink job fail because of kafka producer create fail of "javax.management.InstanceAlreadyExistsException" - posted by "Natea Eshetu Beshada (Jira)" <ji...@apache.org> on 2026/02/12 07:27:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-18379) Introduce asynchronous UDF/UDTF - posted by "Natea Eshetu Beshada (Jira)" <ji...@apache.org> on 2026/02/12 07:38:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-18379) Introduce asynchronous UDF/UDTF - posted by "Natea Eshetu Beshada (Jira)" <ji...@apache.org> on 2026/02/12 07:38:00 UTC, 0 replies.
- [PR] [FLINK-8093][connectors/kafka] Add client.id.prefix support to KafkaSink [flink-connector-kafka] - posted by "nateab (via GitHub)" <gi...@apache.org> on 2026/02/12 07:42:13 UTC, 0 replies.
- [jira] [Updated] (FLINK-8093) flink job fail because of kafka producer create fail of "javax.management.InstanceAlreadyExistsException" - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/12 07:43:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39062) Support applying watermark on logical relations in SQL - posted by "featzhang (Jira)" <ji...@apache.org> on 2026/02/12 07:59:00 UTC, 1 replies.
- [jira] [Created] (FLINK-39075) fn_execution test collection fails in test_flink_fn_execution_pb2.py - posted by "Samrat Deb (Jira)" <ji...@apache.org> on 2026/02/12 08:21:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38928) Implement an operator for handling DO ERROR/NOTHING - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2026/02/12 08:32:00 UTC, 1 replies.
- Re: [PR] [FLINK-38939][runtime] Pause sources until the 1st checkpoint to prioritize processing recovered records [flink] - posted by "Efrat19 (via GitHub)" <gi...@apache.org> on 2026/02/12 08:45:06 UTC, 9 replies.
- [PR] [FLINK-XXXXX][Web UI] Display slot sharing group ID in operator nodes [flink] - posted by "featzhang (via GitHub)" <gi...@apache.org> on 2026/02/12 09:25:45 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-35321) CheckpointCommittableManagerImpl re-registers pendingCommittables gauge on every commit operation - posted by "Piotr Rudnicki (Jira)" <ji...@apache.org> on 2026/02/12 09:35:00 UTC, 6 replies.
- [jira] [Commented] (FLINK-35321) CheckpointCommittableManagerImpl re-registers pendingCommittables gauge on every commit operation - posted by "Piotr Rudnicki (Jira)" <ji...@apache.org> on 2026/02/12 09:35:00 UTC, 1 replies.
- [jira] [Created] (FLINK-39076) [web ui] Display slot sharing group in operator nodes in Flink Web UI - posted by "featzhang (Jira)" <ji...@apache.org> on 2026/02/12 09:37:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39076) [web ui] Display slot sharing group in operator nodes in Flink Web UI - posted by "featzhang (Jira)" <ji...@apache.org> on 2026/02/12 09:39:00 UTC, 2 replies.
- [jira] [Created] (FLINK-39077) Calculation of table changes for MT with several non persisted columns might fail - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/02/12 09:48:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39077) Calculation of table changes for MT with several non persisted columns might fail - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/02/12 09:50:00 UTC, 1 replies.
- [PR] [FLINK-39077][table] Calculation of table changes for MT with several non persisted columns might fail [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2026/02/12 09:55:11 UTC, 2 replies.
- [jira] [Created] (FLINK-39078) Disallow ON CONFLICT for non upsert sinks - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2026/02/12 09:59:00 UTC, 0 replies.
- [PR] [FLINK-39078] Disallow ON CONFLICT for non upsert sinks [flink] - posted by "dawidwys (via GitHub)" <gi...@apache.org> on 2026/02/12 10:05:24 UTC, 2 replies.
- [jira] [Updated] (FLINK-39078) Disallow ON CONFLICT for non upsert sinks - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/12 10:06:00 UTC, 0 replies.
- [PR] [FLINK-XXXXX][Web UI] Add Top N Metrics Dashboard for performance diagnostics [flink] - posted by "featzhang (via GitHub)" <gi...@apache.org> on 2026/02/12 10:29:44 UTC, 1 replies.
- [jira] [Assigned] (FLINK-39002) Could not resolve ResourceManager because of NPE - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2026/02/12 10:55:00 UTC, 1 replies.
- Re: [PR] Add Turkish Translation for Apache Flink Website [flink-web] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2026/02/12 10:57:03 UTC, 0 replies.
- [PR] [FLINK-35321] Register commitables metric at snapshotState invocation [flink] - posted by "DeamonDev (via GitHub)" <gi...@apache.org> on 2026/02/12 12:18:16 UTC, 3 replies.
- [jira] [Updated] (FLINK-35321) CheckpointCommittableManagerImpl re-registers pendingCommittables gauge on every commit operation - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/12 12:19:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-39061) StateMachine example uses State V2 API, breaking canonical savepoint compatibility - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2026/02/12 12:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39079) Add Diagnostic Summary Page in Flink Web UI - posted by "featzhang (Jira)" <ji...@apache.org> on 2026/02/12 13:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39080) Missing license undetected by connector CI - posted by "Efrat Levitan (Jira)" <ji...@apache.org> on 2026/02/12 13:37:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39079) Add Diagnostic Summary Page in Flink Web UI - posted by "featzhang (Jira)" <ji...@apache.org> on 2026/02/12 13:40:00 UTC, 3 replies.
- Re: [PR] [FLINK-38999][lineage] License lineage files [flink-connector-kafka] - posted by "Efrat19 (via GitHub)" <gi...@apache.org> on 2026/02/12 14:00:10 UTC, 2 replies.
- [jira] (FLINK-35321) CheckpointCommittableManagerImpl re-registers pendingCommittables gauge on every commit operation - posted by "Piotr Rudnicki (Jira)" <ji...@apache.org> on 2026/02/12 17:12:00 UTC, 0 replies.
- [PR] [FLINK-35321] Add flag for metric registration [flink] - posted by "DeamonDev (via GitHub)" <gi...@apache.org> on 2026/02/12 17:28:01 UTC, 3 replies.
- [jira] [Created] (FLINK-39081) FLIP-559: Add ARTIFACT keyword option in CREATE FUNCTION's USING clause - posted by "Mika Naylor (Jira)" <ji...@apache.org> on 2026/02/12 18:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39082) Add ARTIFACT keyword option in CREATE FUNCTION's USING clause - posted by "Mika Naylor (Jira)" <ji...@apache.org> on 2026/02/12 18:17:00 UTC, 0 replies.
- Re: [PR] [FLINK-35321] Ensure pendingCommitables metric is not re-registered when copying CommitableCollector [flink] - posted by "DeamonDev (via GitHub)" <gi...@apache.org> on 2026/02/12 20:26:16 UTC, 21 replies.
- [PR] [FLINK-38789] Change all unit tests to org.assertj.core.api.Assertions [flink-connector-http] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2026/02/12 21:25:12 UTC, 3 replies.
- [jira] [Updated] (FLINK-38789) Consistently use AssertJ-related assertion APIs to implement assertions in the HTTP connector - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/12 21:26:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-25205) Optimize SinkUpsertMaterializer - posted by "Natea Eshetu Beshada (Jira)" <ji...@apache.org> on 2026/02/12 22:00:00 UTC, 1 replies.
- [jira] [Closed] (FLINK-25205) Optimize SinkUpsertMaterializer - posted by "Natea Eshetu Beshada (Jira)" <ji...@apache.org> on 2026/02/12 22:01:02 UTC, 0 replies.
- [jira] [Assigned] (FLINK-28440) EventTimeWindowCheckpointingITCase failed with restore - posted by "Natea Eshetu Beshada (Jira)" <ji...@apache.org> on 2026/02/12 22:04:00 UTC, 0 replies.
- [PR] [FLINK-28440][changelog] Fix premature discard of state handles during checkpoint restore [flink] - posted by "nateab (via GitHub)" <gi...@apache.org> on 2026/02/12 22:04:56 UTC, 5 replies.
- [jira] [Assigned] (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 - posted by "Natea Eshetu Beshada (Jira)" <ji...@apache.org> on 2026/02/12 22:15:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38755) FLIP-549: Support Application Management - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/02/13 01:46:00 UTC, 1 replies.
- [jira] [Created] (FLINK-39083) Support field-level error tolerance for CSV format deserialization - posted by "Liu (Jira)" <ji...@apache.org> on 2026/02/13 02:10:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-13856) Reduce the delete file api when the checkpoint is completed - posted by "Liu (Jira)" <ji...@apache.org> on 2026/02/13 02:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39084) Variant Field accesor helper methods - posted by "Swapna Marru (Jira)" <ji...@apache.org> on 2026/02/13 03:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39085) Potential task duplication in the same TM slot after JM failover - posted by "Yi Zhang (Jira)" <ji...@apache.org> on 2026/02/13 03:21:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39085) Potential task duplication in the same TM slot after JM failover - posted by "Yi Zhang (Jira)" <ji...@apache.org> on 2026/02/13 03:23:00 UTC, 6 replies.
- [PR] [FLINK-39084][core] variant accessor methods for handling map or array types in converters [flink] - posted by "swapna267 (via GitHub)" <gi...@apache.org> on 2026/02/13 03:38:57 UTC, 3 replies.
- [jira] [Updated] (FLINK-39084) Variant Field accesor helper methods - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/13 03:39:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-38755) FLIP-549: Support Application Management - posted by "Yi Zhang (Jira)" <ji...@apache.org> on 2026/02/13 06:03:00 UTC, 2 replies.
- Re: [PR] [FLINK-38601][mongodb] Catch throwable errors when consuming from unbounded streams [flink-cdc] - posted by "yuxiqian (via GitHub)" <gi...@apache.org> on 2026/02/13 08:13:35 UTC, 0 replies.
- [PR] [ci] Bump TestContainers version to 2.0.3 to fix CI failure [flink-cdc] - posted by "yuxiqian (via GitHub)" <gi...@apache.org> on 2026/02/13 08:46:17 UTC, 0 replies.
- Re: [PR] [ci] Specify Docker API version explicitly as a workaround of testcontainers/testcontainers-java#11212 [flink-cdc] - posted by "rolnico (via GitHub)" <gi...@apache.org> on 2026/02/13 09:36:09 UTC, 2 replies.
- [jira] [Assigned] (FLINK-38603) FLIP-553 [Metrics] Robust OTel gRPC metric exporter - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2026/02/13 09:49:00 UTC, 0 replies.
- [PR] [FLINK-38096] AsyncSinkWriter may hang when configured with a custom … [flink] - posted by "HundalTaran (via GitHub)" <gi...@apache.org> on 2026/02/13 09:54:36 UTC, 3 replies.
- [jira] [Commented] (FLINK-38727) Unstable test cases EventTimeWindowCheckpointingITCase.testPreAggregatedSlidingTimeWindow - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2026/02/13 09:55:00 UTC, 3 replies.
- [jira] [Updated] (FLINK-38727) Unstable test cases EventTimeWindowCheckpointingITCase.testPreAggregatedSlidingTimeWindow - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2026/02/13 09:56:00 UTC, 2 replies.
- [jira] [Closed] (FLINK-38789) Consistently use AssertJ-related assertion APIs to implement assertions in the HTTP connector - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2026/02/13 10:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39086) BlobServer returns unresolvable pod hostname in Kubernetes HA mode, breaking job submission (Regression from 1.20) - posted by "Sebastien Pereira (Jira)" <ji...@apache.org> on 2026/02/13 11:57:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39086) BlobServer returns unresolvable pod hostname in Kubernetes HA mode, breaking job submission (Regression from 1.20) - posted by "Sebastien Pereira (Jira)" <ji...@apache.org> on 2026/02/13 11:58:00 UTC, 1 replies.
- [jira] [Closed] (FLINK-39078) Disallow ON CONFLICT for non upsert sinks - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2026/02/13 12:41:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38928) Implement an operator for handling DO ERROR/NOTHING - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2026/02/13 12:41:00 UTC, 0 replies.
- [jira] [Reopened] (FLINK-38928) Implement an operator for handling DO ERROR/NOTHING - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2026/02/13 12:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39087) Upgrade wiremock in the HTTP connector - posted by "David Radley (Jira)" <ji...@apache.org> on 2026/02/13 13:59:00 UTC, 0 replies.
- [PR] [FLINK-38244][hotfix] Fix the full snapshot phase, the field case is adjusted based on `isTableIdCaseInsensitive`. [flink-cdc] - posted by "sd4324530 (via GitHub)" <gi...@apache.org> on 2026/02/13 14:07:12 UTC, 2 replies.
- [PR] [FLINK-39087] upgrade wiremock [flink-connector-http] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2026/02/13 14:13:15 UTC, 2 replies.
- [jira] [Updated] (FLINK-39087) Upgrade wiremock in the HTTP connector - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/13 14:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39088) Preserve upsert keys for explicit (injective) CAST calls to avoid unnecessary SinkUpsertMaterializer - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2026/02/13 14:26:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39088) Preserve upsert keys for explicit (injective) CAST calls to avoid unnecessary SinkUpsertMaterializer - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2026/02/13 14:27:00 UTC, 5 replies.
- [PR] [FLINK-38928] Implement an operator for handling DO ERROR/NOTHING (#2… [flink] - posted by "dawidwys (via GitHub)" <gi...@apache.org> on 2026/02/13 14:32:20 UTC, 80 replies.
- [PR] [FLINK-39088][table] Add supportsInjectiveCast and isKeyPreservingCast to preserve upsert keys for string casts [flink] - posted by "gustavodemorais (via GitHub)" <gi...@apache.org> on 2026/02/13 14:52:27 UTC, 15 replies.
- [PR] [FLINK-38603] Allow enabling gzip compression for OTel gRPC/HTTP exporters [flink] - posted by "Izeren (via GitHub)" <gi...@apache.org> on 2026/02/13 15:39:35 UTC, 3 replies.
- [jira] [Updated] (FLINK-38603) FLIP-553 [Metrics] Robust OTel gRPC metric exporter - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/13 15:40:00 UTC, 0 replies.
- [PR] [FLINK-39081] Add ARTIFACT keyword option in CREATE FUNCTION's USING clause [flink] - posted by "autophagy (via GitHub)" <gi...@apache.org> on 2026/02/13 15:41:37 UTC, 8 replies.
- [jira] [Updated] (FLINK-39081) FLIP-559: Add ARTIFACT keyword option in CREATE FUNCTION's USING clause - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/13 15:42:00 UTC, 0 replies.
- [PR] [hotfix] Update testcontainers dependency to fix Ubuntu - Docker issue [flink-connector-kafka] - posted by "Savonitar (via GitHub)" <gi...@apache.org> on 2026/02/13 17:00:22 UTC, 0 replies.
- [PR] [FLINK-39087 upgrade wiremock [flink-connector-http] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2026/02/13 17:00:51 UTC, 2 replies.
- [jira] [Commented] (FLINK-39086) BlobServer returns unresolvable pod hostname in Kubernetes HA mode, breaking job submission (Regression from 1.20) - posted by "Sebastien Pereira (Jira)" <ji...@apache.org> on 2026/02/13 17:21:00 UTC, 0 replies.
- [PR] [hotfix] Update testcontainers dependency to fix GitHub Runner - Docker issue [flink] - posted by "Savonitar (via GitHub)" <gi...@apache.org> on 2026/02/13 17:43:39 UTC, 10 replies.
- Re: [PR] [hotfix] Update testcontainers dependency to fix GitHub Runner - Docker issue [flink-connector-kafka] - posted by "1996fanrui (via GitHub)" <gi...@apache.org> on 2026/02/13 18:15:43 UTC, 0 replies.
- [PR] [hotfix] Wait for log partition initialization before producing in tests [flink-connector-kafka] - posted by "Savonitar (via GitHub)" <gi...@apache.org> on 2026/02/13 18:58:16 UTC, 2 replies.
- [PR] [FLINK-29245] Remove unused RetryRule [flink-connector-kafka] - posted by "Savonitar (via GitHub)" <gi...@apache.org> on 2026/02/13 20:04:14 UTC, 3 replies.
- [jira] [Updated] (FLINK-29245) [JUnit 5 Migration] Remove RetryRule - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/13 20:05:00 UTC, 0 replies.
- [PR] Bump org.apache.avro:avro from 1.12.0 to 1.12.1 [flink-connector-kafka] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/02/13 21:14:33 UTC, 0 replies.
- [PR] Bump org.apache.avro:avro from 1.11.4 to 1.11.5 [flink] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/02/13 21:15:16 UTC, 2 replies.
- [PR] Bump org.apache.avro:avro from 1.11.4 to 1.11.5 [flink-connector-aws] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/02/13 21:19:01 UTC, 0 replies.
- [PR] [FLINK-39055] [Iceberg] Support default column values in Iceberg sink connector [flink-cdc] - posted by "suhwan-cheon (via GitHub)" <gi...@apache.org> on 2026/02/13 23:31:11 UTC, 8 replies.
- [jira] [Commented] (FLINK-38972) FLIP-560: Application Capability Enhancement - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/02/14 00:40:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-38755) FLIP-549: Support Application Management - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/02/14 00:41:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38972) FLIP-560: Application Capability Enhancement - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/02/14 00:41:00 UTC, 0 replies.
- [PR] Add release automation scripts (Phase A) [flink] - posted by "nateab (via GitHub)" <gi...@apache.org> on 2026/02/14 01:05:28 UTC, 7 replies.
- [jira] [Updated] (FLINK-38970) AdaptiveBatchSchedulerTest is unstable - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/02/14 02:06:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-37853) FLIP-530: Dynamic job configuration - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/02/14 03:54:00 UTC, 2 replies.
- [jira] [Updated] (FLINK-39089) [SQL] Enhanced projection field alias display - posted by "featzhang (Jira)" <ji...@apache.org> on 2026/02/14 05:41:00 UTC, 1 replies.
- [jira] [Created] (FLINK-39089) [Table] Enhanced projection field alias display - posted by "featzhang (Jira)" <ji...@apache.org> on 2026/02/14 05:41:00 UTC, 0 replies.
- [PR] [FLINK-39089][SQL] Enhanced projection field alias display [flink] - posted by "featzhang (via GitHub)" <gi...@apache.org> on 2026/02/14 05:41:56 UTC, 2 replies.
- [PR] [table-planner] Enhance FlinkLogicalJoin explain output with structured condition display [flink] - posted by "featzhang (via GitHub)" <gi...@apache.org> on 2026/02/14 06:21:02 UTC, 1 replies.
- [jira] [Created] (FLINK-39090) [SQL] Enhanced join condition structured display - posted by "featzhang (Jira)" <ji...@apache.org> on 2026/02/14 06:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39091) [SQL] Enhance structured filter condition display of Explain output - posted by "featzhang (Jira)" <ji...@apache.org> on 2026/02/14 06:45:00 UTC, 0 replies.
- [PR] [table] Enhance EXPLAIN plan to display watermark specification [flink] - posted by "featzhang (via GitHub)" <gi...@apache.org> on 2026/02/14 07:03:26 UTC, 0 replies.
- [jira] [Created] (FLINK-39092) [SQL] Enhance EXPLAIN plan to display watermark specification - posted by "featzhang (Jira)" <ji...@apache.org> on 2026/02/14 07:10:00 UTC, 0 replies.
- Re: [PR] [FLINK-39092][SQL] Enhance EXPLAIN plan to display watermark specification [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2026/02/14 07:10:19 UTC, 1 replies.
- [jira] [Updated] (FLINK-39092) [SQL] Enhance EXPLAIN plan to display watermark specification - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/14 07:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39093) [SQL] Display ChangelogMode in Execution Plan for Streaming Queries - posted by "featzhang (Jira)" <ji...@apache.org> on 2026/02/14 07:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39094) Avoid creating duplicate function instances in code generation - posted by "dylanhz (Jira)" <ji...@apache.org> on 2026/02/14 07:49:00 UTC, 0 replies.
- [PR] [table][planner] Display ChangelogMode in execution plan for streaming queries [flink] - posted by "featzhang (via GitHub)" <gi...@apache.org> on 2026/02/14 07:50:04 UTC, 0 replies.
- [jira] [Created] (FLINK-39095) [SQL] Display ChangelogMode in Execution Plan for Streaming Queries - posted by "featzhang (Jira)" <ji...@apache.org> on 2026/02/14 07:53:00 UTC, 0 replies.
- Re: [PR] [FLINK-39095][table][planner] Display ChangelogMode in execution plan for streaming queries [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2026/02/14 07:55:19 UTC, 1 replies.
- [jira] [Updated] (FLINK-39095) [SQL] Display ChangelogMode in Execution Plan for Streaming Queries - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/14 07:56:00 UTC, 0 replies.
- [PR] [FLINK-39094][table-planner] Avoid creating duplicate function instances in code generation [flink] - posted by "dylanhz (via GitHub)" <gi...@apache.org> on 2026/02/14 08:07:48 UTC, 9 replies.
- [jira] [Updated] (FLINK-39094) Avoid creating duplicate function instances in code generation - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/14 08:08:00 UTC, 0 replies.
- [PR] [table-planner] Enhance EXPLAIN output to display detailed estimated rowcount and cost information [flink] - posted by "featzhang (via GitHub)" <gi...@apache.org> on 2026/02/14 08:14:20 UTC, 0 replies.
- [jira] [Created] (FLINK-39096) [SQL]Enhance EXPLAIN output to display detailed estimated rowcount and cost information - posted by "featzhang (Jira)" <ji...@apache.org> on 2026/02/14 08:21:00 UTC, 0 replies.
- Re: [PR] [FLINK-39096][table-planner] Enhance EXPLAIN output to display detailed estimated rowcount and cost information [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2026/02/14 08:24:59 UTC, 2 replies.
- [jira] [Updated] (FLINK-39096) [SQL]Enhance EXPLAIN output to display detailed estimated rowcount and cost information - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/14 08:26:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-29245) [JUnit 5 Migration] Remove RetryRule - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2026/02/14 09:57:00 UTC, 0 replies.
- [I] [Bug] Java agents fail to connect to MCP servers that do not support prompts [flink-agents] - posted by "avichaym (via GitHub)" <gi...@apache.org> on 2026/02/14 10:57:01 UTC, 0 replies.
- [PR] [FLINK-AGENTS] Fix Java agents failing to connect to MCP servers without prompt support (#538) [flink-agents] - posted by "avichaym (via GitHub)" <gi...@apache.org> on 2026/02/14 11:00:57 UTC, 1 replies.
- [PR] [FLINK-39052][python]Fix fn_execution test collection fails in test_flink [flink] - posted by "Samrat002 (via GitHub)" <gi...@apache.org> on 2026/02/14 17:43:33 UTC, 1 replies.
- [jira] [Resolved] (FLINK-39075) fn_execution test collection fails in test_flink_fn_execution_pb2.py - posted by "Samrat Deb (Jira)" <ji...@apache.org> on 2026/02/14 17:52:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-39089) [SQL] Enhanced projection field alias display - posted by "Rion Williams (Jira)" <ji...@apache.org> on 2026/02/14 21:31:00 UTC, 0 replies.
- [PR] FLINK-38334: Fix MySQL CDC source stuck in INITIAL_ASSIGNING [flink-cdc] - posted by "morozov (via GitHub)" <gi...@apache.org> on 2026/02/15 04:01:24 UTC, 2 replies.
- [jira] [Updated] (FLINK-38334) MySQL CDC source may get stuck in the INITIAL_ASSIGNING state - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/15 04:02:00 UTC, 0 replies.
- [PR] Fix typo in AggregatedMetric string representation [flink-kubernetes-operator] - posted by "littleeleventhwolf (via GitHub)" <gi...@apache.org> on 2026/02/15 07:28:57 UTC, 0 replies.
- [PR] [FLINK-38624][table] Type Mismatch Exception in StreamPhysicalOverAggregateRule [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2026/02/15 11:30:51 UTC, 15 replies.
- [jira] [Commented] (FLINK-39095) [SQL] Display ChangelogMode in Execution Plan for Streaming Queries - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/02/16 08:07:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-39093) [SQL] Display ChangelogMode in Execution Plan for Streaming Queries - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/02/16 08:08:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-39092) [SQL] Enhance EXPLAIN plan to display watermark specification - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/02/16 08:09:00 UTC, 0 replies.
- [PR] [hotfix] Fix CI [flink-connector-hbase] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2026/02/16 09:14:41 UTC, 1 replies.
- [PR] [FLINK-38592] Support configurable choice for plugin based file system loading. [flink] - posted by "Izeren (via GitHub)" <gi...@apache.org> on 2026/02/16 09:52:02 UTC, 19 replies.
- [jira] [Created] (FLINK-39097) [e2e-Test]Run kubernetes SQL application test failure - posted by "Samrat Deb (Jira)" <ji...@apache.org> on 2026/02/16 10:25:00 UTC, 0 replies.
- [PR] [hotfix] Pin Testcontainers to 1.21.4 for Docker API compatibility [flink-connector-hbase] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2026/02/16 12:02:39 UTC, 0 replies.
- [jira] [Created] (FLINK-39098) Fix connector CI failures caused by testcontainers using too old Docker API - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2026/02/16 12:11:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39098) Fix connector CI failures caused by testcontainers using too old Docker API - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2026/02/16 12:12:00 UTC, 4 replies.
- [jira] [Created] (FLINK-39099) Update testcontainers to 1.21.4 - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2026/02/16 12:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39100) DynamoDB source connector fails to renew AWS IAM credentials - posted by "Emre Kartoglu (Jira)" <ji...@apache.org> on 2026/02/16 12:19:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39100) DynamoDB source connector fails to renew AWS IAM credentials - posted by "Emre Kartoglu (Jira)" <ji...@apache.org> on 2026/02/16 12:19:00 UTC, 2 replies.
- [jira] [Updated] (FLINK-39100) DynamoDB CDC source connector fails to renew AWS IAM credentials - posted by "Emre Kartoglu (Jira)" <ji...@apache.org> on 2026/02/16 12:20:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-39100) DynamoDB CDC source connector intermittently fails to renew AWS IAM credentials - posted by "Emre Kartoglu (Jira)" <ji...@apache.org> on 2026/02/16 12:22:00 UTC, 4 replies.
- [jira] [Updated] (FLINK-39099) Update testcontainers to 1.21.4 - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2026/02/16 12:31:00 UTC, 1 replies.
- [PR] [FLINK-39099] Update `testcontainers` version to 1.21.4 [flink] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2026/02/16 12:32:18 UTC, 9 replies.
- [PR] [FLINK-39098] Bump `testcontainers` to 1.21.4 for Docker API compatibility [flink-connector-kudu] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2026/02/16 12:35:07 UTC, 1 replies.
- [PR] [FLINK-39098] Bump `testcontainers` to 1.21.4 for Docker API compatibility [flink-connector-aws] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2026/02/16 12:42:58 UTC, 0 replies.
- Re: [PR] [FLINK-39098] Pin `testcontainers` to 1.21.4 for Docker API compatibility [flink-connector-hbase] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2026/02/16 13:03:44 UTC, 0 replies.
- [jira] [Commented] (FLINK-39098) Fix connector CI failures caused by testcontainers using too old Docker API - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2026/02/16 13:07:00 UTC, 0 replies.
- [PR] [hotfix] Update CI Flink versions and test released versions in scheduled CI [flink-connector-aws] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2026/02/16 13:29:18 UTC, 0 replies.
- Re: [PR] [FLINK-37968] Bump Netty version to v4.1.122.Final [flink-connector-aws] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2026/02/16 13:43:04 UTC, 1 replies.
- Re: [PR] [FLINK-38592] Initial Native Flink S3 FileSystem [flink] - posted by "Izeren (via GitHub)" <gi...@apache.org> on 2026/02/16 13:55:13 UTC, 44 replies.
- Re: [PR] [FLINK-39076][Web UI] Display slot sharing group in operator nodes [flink] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2026/02/16 15:02:47 UTC, 0 replies.
- Re: [PR] [FLINK-39087] Upgrade wiremock [flink-connector-http] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2026/02/16 15:06:54 UTC, 2 replies.
- [jira] [Created] (FLINK-39101) Rationalize the pom file versions and exclusions - posted by "David Radley (Jira)" <ji...@apache.org> on 2026/02/16 15:24:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-39087) Upgrade wiremock in the HTTP connector - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2026/02/16 15:26:00 UTC, 0 replies.
- [PR] [FLINK-39101] rationalize pom files [flink-connector-http] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2026/02/16 16:30:27 UTC, 2 replies.
- [jira] [Updated] (FLINK-39101) Rationalize the pom file versions and exclusions - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/16 16:31:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-39098) Fix connector CI failures caused by testcontainers using too old Docker API - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2026/02/16 16:36:00 UTC, 0 replies.
- [jira] [Commented] (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 - posted by "Natea Eshetu Beshada (Jira)" <ji...@apache.org> on 2026/02/16 20:59:00 UTC, 0 replies.
- Re: [PR] [doc] Add documents for adding dependencies to flink-agents project. [flink-agents] - posted by "JinkunLiu (via GitHub)" <gi...@apache.org> on 2026/02/17 06:26:01 UTC, 2 replies.
- Re: [PR] Bump js-yaml from 4.1.0 to 4.1.1 in /flink-runtime-web/web-dashboard [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/02/17 06:35:44 UTC, 0 replies.
- [I] [Bug] [Example] Missing flink-json dependency causes ValidationException in WorkflowMultipleAgentExample [flink-agents] - posted by "JinkunLiu (via GitHub)" <gi...@apache.org> on 2026/02/17 07:27:03 UTC, 3 replies.
- [jira] [Created] (FLINK-39102) All E2E Kubernetes tests fail on Azure CI - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/02/17 07:52:00 UTC, 0 replies.
- [PR] Blue/Green Deployments for the Flink Kubernetes Operator 1.14.0 [flink-web] - posted by "schongloo (via GitHub)" <gi...@apache.org> on 2026/02/17 08:20:25 UTC, 4 replies.
- [PR] [FLINK-39102][e2e] Upgrade minikube, crictl, and cri-dockerd for tu 24.04 compatibility [flink] - posted by "MartijnVisser (via GitHub)" <gi...@apache.org> on 2026/02/17 08:31:32 UTC, 3 replies.
- [jira] [Updated] (FLINK-39102) All E2E Kubernetes tests fail on Azure CI - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/17 08:32:00 UTC, 0 replies.
- Re: [PR] [FLINK-38592][filesystem] Support configurable choice for plugin based file system loading. [flink] - posted by "rkhachatryan (via GitHub)" <gi...@apache.org> on 2026/02/17 09:53:46 UTC, 1 replies.
- [jira] [Commented] (FLINK-38592) Native Flink S3 FileSystem - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2026/02/17 09:57:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38592) Native Flink S3 FileSystem - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2026/02/17 09:59:00 UTC, 0 replies.
- Re: [PR] [FLINK-39099] Update `testcontainers` dependency to fix GitHub Runner Docker issue [flink] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2026/02/17 10:35:07 UTC, 1 replies.
- [jira] [Assigned] (FLINK-39099) Update testcontainers to 1.21.4 - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2026/02/17 10:43:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-39099) Update testcontainers to 1.21.4 - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2026/02/17 10:44:00 UTC, 0 replies.
- [PR] [FLINK-39099] Update `testcontainers` to fix GitHub runner Docker compatibility issue [flink] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2026/02/17 10:52:51 UTC, 1 replies.
- [PR] [BP-2.1][FLINK-39099] Update `testcontainers` to fix GitHub runner Docker compatibility issue [flink] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2026/02/17 10:53:35 UTC, 2 replies.
- [PR] [BP-2.0][FLINK-39099] Update `testcontainers` to fix GitHub runner Docker compatibility issue [flink] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2026/02/17 10:54:17 UTC, 2 replies.
- [PR] [BP-1.20][FLINK-39099] Update `testcontainers` to fix GitHub runner Docker compatibility issue [flink] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2026/02/17 10:54:51 UTC, 5 replies.
- [PR] [hotfix] fixing test-case failure for flink 2.2 support [flink-connector-mongodb] - posted by "neoneo008 (via GitHub)" <gi...@apache.org> on 2026/02/17 11:16:00 UTC, 4 replies.
- [jira] [Created] (FLINK-39103) BufferManager.recycle fails TM due to RemoteTransportException - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2026/02/17 11:38:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39103) BufferManager.recycle fails TM due to RemoteTransportException - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2026/02/17 11:39:00 UTC, 3 replies.
- [PR] [FLINK-39103][runtime] Tolerate errors when recycling buffer from input channel notification if it had errors already [flink] - posted by "rkhachatryan (via GitHub)" <gi...@apache.org> on 2026/02/17 11:55:40 UTC, 20 replies.
- [jira] [Comment Edited] (FLINK-39086) BlobServer returns unresolvable pod hostname in Kubernetes HA mode, breaking job submission (Regression from 1.20) - posted by "Sebastien Pereira (Jira)" <ji...@apache.org> on 2026/02/17 13:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39104) Allow enabling gzip compression for OTel gRPC/HTTP exporters - posted by "Aleksandr Iushmanov (Jira)" <ji...@apache.org> on 2026/02/17 15:30:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39104) Allow enabling gzip compression for OTel gRPC/HTTP exporters - posted by "Aleksandr Iushmanov (Jira)" <ji...@apache.org> on 2026/02/17 15:42:00 UTC, 1 replies.
- Re: [PR] [FLINK-39101] Rationalize POM file versions and exclusions [flink-connector-http] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2026/02/17 16:25:15 UTC, 0 replies.
- [jira] [Closed] (FLINK-39101) Rationalize the pom file versions and exclusions - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2026/02/17 16:26:00 UTC, 0 replies.
- Re: [PR] [FLINK-39102][e2e] Fix Kubernetes E2E tests broken by Docker 29 runner update [flink] - posted by "MartijnVisser (via GitHub)" <gi...@apache.org> on 2026/02/17 17:41:17 UTC, 1 replies.
- Re: [PR] [FLINK-39104][metrics] Allow enabling gzip compression for OTel gRPC/HTTP exporters [flink] - posted by "Izeren (via GitHub)" <gi...@apache.org> on 2026/02/17 17:43:41 UTC, 1 replies.
- Re: [PR] [BP-2.2][FLINK-39099] Update `testcontainers` to fix GitHub runner Docker compatibility issue [flink] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2026/02/17 17:47:48 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-39099) Update testcontainers to 1.21.4 - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2026/02/17 17:53:00 UTC, 1 replies.
- [PR] [BP 2.2][FLINK-39102][e2e] Fix Kubernetes E2E tests broken by Docker 29 runner update [flink] - posted by "MartijnVisser (via GitHub)" <gi...@apache.org> on 2026/02/17 17:53:42 UTC, 2 replies.
- [PR] [BP 2.0][FLINK-39102][e2e] Fix Kubernetes E2E tests broken by Docker 29 runner update [flink] - posted by "MartijnVisser (via GitHub)" <gi...@apache.org> on 2026/02/17 17:53:59 UTC, 2 replies.
- [PR] [BP 2.1][FLINK-39102][e2e] Fix Kubernetes E2E tests broken by Docker 29 runner update [flink] - posted by "MartijnVisser (via GitHub)" <gi...@apache.org> on 2026/02/17 17:54:07 UTC, 2 replies.
- [PR] [BP 1.20][FLINK-39102][e2e] Fix Kubernetes E2E tests broken by Docker 29 runner update [flink] - posted by "MartijnVisser (via GitHub)" <gi...@apache.org> on 2026/02/17 17:54:27 UTC, 2 replies.
- [PR] [BP 1.19][FLINK-39102][e2e] Fix Kubernetes E2E tests broken by Docker 29 runner update [flink] - posted by "MartijnVisser (via GitHub)" <gi...@apache.org> on 2026/02/17 17:57:03 UTC, 2 replies.
- [jira] [Commented] (FLINK-39054) DynamicKafkaSourceEnumStateSerializer should preserve full per-cluster properties instead of only bootstrap.servers - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2026/02/17 18:32:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-39054) DynamicKafkaSourceEnumStateSerializer should preserve full per-cluster properties instead of only bootstrap.servers - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2026/02/17 18:33:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-39104) Allow enabling gzip compression for OTel gRPC/HTTP exporters - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2026/02/17 19:38:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-39104) Allow enabling gzip compression for OTel gRPC/HTTP exporters - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2026/02/17 19:38:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38102) RestApiMetricsCollectorTest is unstable - posted by "David Radley (Jira)" <ji...@apache.org> on 2026/02/17 21:28:00 UTC, 0 replies.
- [PR] [FLINK-34099] De-stabilize CheckpointIntervalDuringBacklogITCase [flink] - posted by "rkhachatryan (via GitHub)" <gi...@apache.org> on 2026/02/17 22:22:49 UTC, 0 replies.
- [jira] [Updated] (FLINK-34099) CheckpointIntervalDuringBacklogITCase.testNoCheckpointDuringBacklog is unstable on AZP - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/17 22:23:00 UTC, 4 replies.
- Re: [PR] (do not merge) [FLINK-34099][tests] De-stabilize CheckpointIntervalDuringBacklogITCase [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2026/02/17 22:31:43 UTC, 0 replies.
- [jira] [Updated] (FLINK-34099) CheckpointIntervalDuringBacklog is ignored for the first checkpoint (CheckpointIntervalDuringBacklogITCase.testNoCheckpointDuringBacklog is unstable on AZP) - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2026/02/17 22:35:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-34099) CheckpointIntervalDuringBacklog is ignored for the first checkpoint (CheckpointIntervalDuringBacklogITCase.testNoCheckpointDuringBacklog is unstable on AZP) - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2026/02/17 23:31:00 UTC, 0 replies.
- Re: [PR] [FLINK-32514] Support configuring checkpointing interval during process backlog [flink] - posted by "rkhachatryan (via GitHub)" <gi...@apache.org> on 2026/02/17 23:46:12 UTC, 0 replies.
- Re: [PR] [improvement] adding runtime converter array [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/02/18 00:08:39 UTC, 1 replies.
- [PR] [FLINK-38096] AsyncSinkWriter may hang when configured with a custom rate limiting strategy [flink] - posted by "HundalTaran (via GitHub)" <gi...@apache.org> on 2026/02/18 04:06:38 UTC, 5 replies.
- [PR] Bump tar and @angular/cli in /flink-runtime-web/web-dashboard [flink] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/02/18 04:18:31 UTC, 3 replies.
- [I] [Feature] Support per-event-type configurable log levels for event log [flink-agents] - posted by "weiqingy (via GitHub)" <gi...@apache.org> on 2026/02/18 05:52:24 UTC, 3 replies.
- [PR] [FLINK-AGENTS-541][api][runtime] Support per-event-type configurable log levels for event log [flink-agents] - posted by "weiqingy (via GitHub)" <gi...@apache.org> on 2026/02/18 05:58:56 UTC, 0 replies.
- [jira] [Assigned] (FLINK-39102) All E2E Kubernetes tests fail on Azure CI - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/02/18 07:53:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-39102) All E2E Kubernetes tests fail on Azure CI - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/02/18 07:55:00 UTC, 0 replies.
- [PR] [hotfix][docs] Clarify Kryo behavior [flink] - posted by "rmetzger (via GitHub)" <gi...@apache.org> on 2026/02/18 08:02:56 UTC, 1 replies.
- [jira] [Commented] (FLINK-36059) SqlClientITCase failed due to could not create/start container - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/02/18 08:08:00 UTC, 2 replies.
- [jira] [Updated] (FLINK-36059) SqlClientITCase failed due to could not create/start container - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/02/18 08:08:00 UTC, 2 replies.
- [jira] [Assigned] (FLINK-36059) SqlClientITCase failed due to could not create/start container - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/02/18 08:13:00 UTC, 0 replies.
- [PR] [FLINK-36059][tests] Bump cp-kafka and cp-schema-registry from 7.2.2 to 7.2.9 [flink] - posted by "MartijnVisser (via GitHub)" <gi...@apache.org> on 2026/02/18 08:25:18 UTC, 3 replies.
- [jira] [Closed] (FLINK-39097) [e2e-Test]Run kubernetes SQL application test failure - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/02/18 08:45:00 UTC, 0 replies.
- Re: [PR] [FLINK-39045][Docs] Add validation check for Hugo ref syntax in connector docs [flink] - posted by "MartijnVisser (via GitHub)" <gi...@apache.org> on 2026/02/18 08:47:46 UTC, 0 replies.
- [jira] [Created] (FLINK-39105) RestClientTest.testConnectionTimeout fails with different expected exception - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/02/18 08:51:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39105) RestClientTest.testConnectionTimeout fails with different expected exception - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/02/18 08:55:00 UTC, 1 replies.
- [D] [Feature] Dynamic Runtime Loading and Refresh of MCP Tools and Prompts [flink-agents] - posted by "yanand0909 (via GitHub)" <gi...@apache.org> on 2026/02/18 08:59:05 UTC, 2 replies.
- [jira] [Closed] (FLINK-39099) Update testcontainers to 1.21.4 - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2026/02/18 09:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39106) Support ROW and ARRAY data types in DynamoDB Table API / SQL sink - posted by "Dominik Dębowczyk (Jira)" <ji...@apache.org> on 2026/02/18 09:48:00 UTC, 0 replies.
- [PR] [FLINK-39106] Support ROW and ARRAY data types in DynamoDB TAPI / SQL sink [flink-connector-aws] - posted by "ddebowczyk92 (via GitHub)" <gi...@apache.org> on 2026/02/18 10:00:26 UTC, 1 replies.
- [jira] [Updated] (FLINK-39106) Support ROW and ARRAY data types in DynamoDB Table API / SQL sink - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/18 10:01:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-39105) RestClientTest.testConnectionTimeout fails with different expected exception - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/02/18 10:32:00 UTC, 2 replies.
- [jira] [Created] (FLINK-39107) OpenTelemetryEventReporterITCase fails with ContainerLaunch Container startup failed for image - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/02/18 10:42:00 UTC, 0 replies.
- Re: [PR] [FLINK-38595][table] Add tests for multiple features with MJ [flink] - posted by "gustavodemorais (via GitHub)" <gi...@apache.org> on 2026/02/18 10:55:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-36298) NullPointerException in Calcite causes a PyFlink test failure - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/02/18 12:40:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-36059) SqlClientITCase failed due to could not create/start container - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/02/18 12:48:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-35005) SqlClientITCase Failed to build JobManager image - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/02/18 12:48:00 UTC, 0 replies.
- [PR] [backport][FLINK-38421] Blue/Green Deployments documentation [flink-kubernetes-operator] - posted by "gyfora (via GitHub)" <gi...@apache.org> on 2026/02/18 12:56:37 UTC, 1 replies.
- Re: [PR] [FLINK-39088][table] Fix upsert key preservation by introducing injective cast checks for CAST [flink] - posted by "twalthr (via GitHub)" <gi...@apache.org> on 2026/02/18 13:35:03 UTC, 5 replies.
- Re: [PR] [FLINK-34099][tests] Harden and disable CheckpointIntervalDuringBacklogITCase [flink] - posted by "rkhachatryan (via GitHub)" <gi...@apache.org> on 2026/02/18 13:35:19 UTC, 4 replies.
- [PR] [hotfix][example] Add missing flink-json dependency [flink-agents] - posted by "JinkunLiu (via GitHub)" <gi...@apache.org> on 2026/02/18 13:45:52 UTC, 2 replies.
- [jira] [Assigned] (FLINK-39107) OpenTelemetryEventReporterITCase fails with ContainerLaunch Container startup failed for image - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/02/18 14:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39108) CheckpointIntervalDuringBacklogITCase.testNoCheckpointDuringBacklog is unstable on AZP - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2026/02/18 14:27:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-34099) CheckpointIntervalDuringBacklogITCase.testNoCheckpointDuringBacklog is unstable on AZP - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2026/02/18 14:28:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39108) CheckpointIntervalDuringBacklog is ignored for the first checkpoint - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2026/02/18 14:28:00 UTC, 4 replies.
- [jira] [Commented] (FLINK-38506) SideOutputITCase.testWatermarkForwarding failed in test_cron_adaptive_scheduler tests - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2026/02/18 14:42:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38603) FLIP-553 [Metrics] Robust OTel gRPC metric exporter - posted by "David Anderson (Jira)" <ji...@apache.org> on 2026/02/18 15:14:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-38592) Native Flink S3 FileSystem - posted by "Samrat Deb (Jira)" <ji...@apache.org> on 2026/02/18 15:40:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38592) [Phase 1] Native Flink S3 FileSystem - posted by "Samrat Deb (Jira)" <ji...@apache.org> on 2026/02/18 15:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39109) [Phase 2] Native s3 Filesystem - posted by "Samrat Deb (Jira)" <ji...@apache.org> on 2026/02/18 15:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39110) Add CRT Support - posted by "Samrat Deb (Jira)" <ji...@apache.org> on 2026/02/18 15:42:00 UTC, 0 replies.
- [jira] [Reopened] (FLINK-38506) SideOutputITCase.testWatermarkForwarding failed in test_cron_adaptive_scheduler tests - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2026/02/18 15:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39111) Alter NativeS3AccessHelper Interface to NativeS3ObjectOperations - posted by "Samrat Deb (Jira)" <ji...@apache.org> on 2026/02/18 15:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39112) Support MultiPart Upload in NativeS3OutputStream - posted by "Samrat Deb (Jira)" <ji...@apache.org> on 2026/02/18 15:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39113) Add Encryption context support - posted by "Samrat Deb (Jira)" <ji...@apache.org> on 2026/02/18 15:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39114) Add configurable timeout - posted by "Samrat Deb (Jira)" <ji...@apache.org> on 2026/02/18 15:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39115) create URI Handling Utility - posted by "Samrat Deb (Jira)" <ji...@apache.org> on 2026/02/18 15:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39116) Improve batch wait time using threadpool - posted by "Samrat Deb (Jira)" <ji...@apache.org> on 2026/02/18 15:56:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39113) Add Encryption context support - posted by "Samrat Deb (Jira)" <ji...@apache.org> on 2026/02/18 15:58:00 UTC, 0 replies.
- [PR] [FLINK-38506][tests] Fix flaky SideOutputITCase [flink] - posted by "rkhachatryan (via GitHub)" <gi...@apache.org> on 2026/02/18 16:12:42 UTC, 5 replies.
- [jira] [Updated] (FLINK-38506) SideOutputITCase.testWatermarkForwarding failed in test_cron_adaptive_scheduler tests - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/18 16:13:00 UTC, 1 replies.
- [PR] Rebuild website [flink-web] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2026/02/18 17:22:31 UTC, 1 replies.
- [jira] [Commented] (FLINK-38613) UnalignedCheckpointRescaleWithMixedExchangesITCase.testRescaleFromUnalignedCheckpoint failed in test_cron_jdk11 tests - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2026/02/18 18:20:00 UTC, 4 replies.
- [PR] (do not merge) [FLINK-38613][tests] demo [flink] - posted by "rkhachatryan (via GitHub)" <gi...@apache.org> on 2026/02/18 18:25:13 UTC, 2 replies.
- [jira] [Updated] (FLINK-38613) UnalignedCheckpointRescaleWithMixedExchangesITCase.testRescaleFromUnalignedCheckpoint failed in test_cron_jdk11 tests - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/18 18:26:00 UTC, 3 replies.
- [jira] [Comment Edited] (FLINK-38613) UnalignedCheckpointRescaleWithMixedExchangesITCase.testRescaleFromUnalignedCheckpoint failed in test_cron_jdk11 tests - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2026/02/18 18:27:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38845) Add ArchivedApplicationStore to manage terminated applications - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/02/18 19:15:00 UTC, 1 replies.
- Re: [PR] [FLINK-35321] Ensure pendingCommitables metric is not re-registered when copying CommittableCollector [flink] - posted by "rionmonster (via GitHub)" <gi...@apache.org> on 2026/02/18 21:27:37 UTC, 2 replies.
- [jira] [Closed] (FLINK-39067) Move Python docs to PyDocs - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/02/18 21:50:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38506) SideOutputITCase.testWatermarkForwarding failed in test_cron_adaptive_scheduler tests - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2026/02/18 22:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39117) Flaky ChainUnionTest testMigrationAndRestore - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2026/02/18 22:53:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39117) Flaky ChainUnionTest testMigrationAndRestore - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2026/02/18 22:53:00 UTC, 1 replies.
- [jira] [Closed] (FLINK-34099) CheckpointIntervalDuringBacklogITCase.testNoCheckpointDuringBacklog is unstable on AZP - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2026/02/18 22:56:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38533) SqlClientITCase failed for image confluentinc/cp-kafka:7.2.2 startup - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2026/02/18 23:12:00 UTC, 5 replies.
- [jira] [Reopened] (FLINK-38533) SqlClientITCase failed for image confluentinc/cp-kafka:7.2.2 startup - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2026/02/18 23:12:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38939) Pause sources until the 1st checkpoint to prioritize processing recovered records - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2026/02/18 23:16:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38939) Pause sources until the 1st checkpoint to prioritize processing recovered records - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2026/02/18 23:22:00 UTC, 0 replies.
- Re: [PR] [FLINK-38250] The Flink CDC type supports the timeTZ field type. [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/02/19 00:08:45 UTC, 1 replies.
- [jira] [Created] (FLINK-39118) Add Documentation for native s3 fs - posted by "Samrat Deb (Jira)" <ji...@apache.org> on 2026/02/19 03:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39119) Add flink-s3-fs-native as part of flink dist in /opt - posted by "Samrat Deb (Jira)" <ji...@apache.org> on 2026/02/19 03:11:00 UTC, 0 replies.
- [PR] [FLINK-38533] SqlClientITCase failed for image confluentinc/cp-kafka:7.2.2 startup [flink] - posted by "Samrat002 (via GitHub)" <gi...@apache.org> on 2026/02/19 06:30:37 UTC, 5 replies.
- [jira] [Updated] (FLINK-38533) SqlClientITCase failed for image confluentinc/cp-kafka:7.2.2 startup - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/19 06:31:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-38533) SqlClientITCase failed for image confluentinc/cp-kafka:7.2.2 startup - posted by "Samrat Deb (Jira)" <ji...@apache.org> on 2026/02/19 06:53:00 UTC, 1 replies.
- [jira] [Created] (FLINK-39120) Update to Kafka 4.2.0 - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2026/02/19 08:44:00 UTC, 0 replies.
- Re: [PR] [FLINK-38764] Upgrade lz4 to 1.8.1 due to security vulnerability [flink] - posted by "pnowojski (via GitHub)" <gi...@apache.org> on 2026/02/19 09:05:14 UTC, 2 replies.
- [PR] [FLINK-39120] Update Kafka version to 4.2.0 [flink-connector-kafka] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2026/02/19 09:27:07 UTC, 5 replies.
- [jira] [Updated] (FLINK-39120) Update to Kafka 4.2.0 - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/19 09:28:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38613) UnalignedCheckpointRescaleWithMixedExchangesITCase.testRescaleFromUnalignedCheckpoint failed in test_cron_jdk11 tests - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2026/02/19 09:39:00 UTC, 0 replies.
- [PR] [FLINK-39107][metrics] Run otel container from a prebuilt image [flink] - posted by "Efrat19 (via GitHub)" <gi...@apache.org> on 2026/02/19 09:49:52 UTC, 1 replies.
- [jira] [Updated] (FLINK-39107) OpenTelemetryEventReporterITCase fails with ContainerLaunch Container startup failed for image - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/19 09:50:00 UTC, 0 replies.
- Re: [PR] [FLINK-39107][tests] Run otel container from a prebuilt image [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2026/02/19 09:58:31 UTC, 11 replies.
- [jira] [Created] (FLINK-39121) kafka connector CI test timeout due to "/tmp/testcontainers_start.sh: Text file busy" - posted by "Efrat Levitan (Jira)" <ji...@apache.org> on 2026/02/19 10:51:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-39121) kafka connector CI test timeout due to "/tmp/testcontainers_start.sh: Text file busy" - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2026/02/19 10:53:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38924) Redirect users to documentation home page when encountering a 404 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/02/19 12:00:03 UTC, 0 replies.
- [jira] [Commented] (FLINK-38924) Redirect users to documentation home page when encountering a 404 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/02/19 12:01:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38924) Redirect users to documentation home page when encountering a 404 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/02/19 12:01:00 UTC, 0 replies.
- [jira] (FLINK-38924) Redirect users to documentation home page when encountering a 404 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/02/19 12:01:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38914) Redirect users to deeplink when visiting an outdated or master docs page (instead of stable) - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/02/19 12:02:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38914) Redirect users to deeplink when visiting an outdated or master docs page (instead of stable) - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/02/19 12:03:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38955) Add canonical tag to generated Javadoc and PyDocs - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/02/19 12:04:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38955) Add canonical tag to generated Javadoc and PyDocs - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/02/19 12:04:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38955) Add canonical tag to generated Javadoc and PyDocs - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/02/19 12:04:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38925) Update Matomo URL to the right domain - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/02/19 12:07:00 UTC, 1 replies.
- [jira] (FLINK-38925) Update Matomo URL to the right domain - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/02/19 12:07:00 UTC, 3 replies.
- [jira] [Closed] (FLINK-38533) SqlClientITCase failed for image confluentinc/cp-kafka:7.2.2 startup - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/02/19 12:12:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37399) Watermark alignment can prevent backlogged jobs from using all available resources - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2026/02/19 12:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39122) Decimals with incorrect precision lead to null value in PTF - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2026/02/19 13:04:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39123) ValueLiteralExpression.asSerializableString has problems with TIMESTAMP_LTZ(9) - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2026/02/19 13:30:00 UTC, 1 replies.
- [jira] [Created] (FLINK-39123) ValueLiteralExpression.asSerializableString has problems with TIMESTAMP_LTZ(3) - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2026/02/19 13:30:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38953) Cleanup configurations for SSL hostname verification - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2026/02/19 13:42:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38953) Cleanup configurations for SSL hostname verification - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2026/02/19 13:42:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38953) Cleanup configurations for SSL hostname verification - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2026/02/19 13:42:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38953) Cleanup configurations for SSL hostname verification - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2026/02/19 13:42:00 UTC, 0 replies.
- [PR] [HOTFIX] Add .gitmodules for releasing [flink-connector-http] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2026/02/19 13:55:41 UTC, 2 replies.
- [jira] [Updated] (FLINK-38523) Upgrade Pekko to 1.4.0 - posted by "Mate Czagany (Jira)" <ji...@apache.org> on 2026/02/19 14:00:00 UTC, 1 replies.
- [PR] [FLINK-39073][runtime] Defer alignment check for idle splits [flink] - posted by "Efrat19 (via GitHub)" <gi...@apache.org> on 2026/02/19 14:23:19 UTC, 8 replies.
- [jira] [Updated] (FLINK-39073) Idle source splits are picked by watermark alignment - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/19 14:24:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-39088) Preserve upsert keys for explicit (injective) CAST calls to avoid unnecessary SinkUpsertMaterializer - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2026/02/19 14:31:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38523) Upgrade Pekko to 1.4.0 - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2026/02/19 15:42:00 UTC, 0 replies.
- Re: [PR] [FLINK-38523] Upgrade Pekko to 1.4.0 [flink] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2026/02/19 15:42:25 UTC, 0 replies.
- [jira] [Closed] (FLINK-38523) Upgrade Pekko to 1.4.0 - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2026/02/19 15:43:00 UTC, 0 replies.
- Re: [PR] [hotfix] Add `.gitmodules` for releasing [flink-connector-http] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2026/02/19 15:46:55 UTC, 0 replies.
- Re: [PR] [FLINK-38794] Update to Kafka 4.1.1 [flink-connector-kafka] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2026/02/19 15:53:39 UTC, 1 replies.
- [jira] [Closed] (FLINK-39120) Update to Kafka 4.2.0 - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2026/02/19 15:54:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38794) Update Kafka Connector to Kafka 4.1.1 - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2026/02/19 15:55:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38794) Update Kafka Connector to Kafka 4.1.1 - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2026/02/19 15:55:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-39037) support query kafka cluster id as metadata in records of DynamicKafkaTableSource - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2026/02/19 17:04:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-39037) support query kafka cluster id as metadata in records of DynamicKafkaTableSource - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2026/02/19 17:05:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-39029) Move catalog store factory builder from TableFactoryUtil to new class - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2026/02/19 18:40:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-39029) Move catalog store factory builder from TableFactoryUtil to new class - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2026/02/19 18:40:00 UTC, 0 replies.
- [PR] [hotfix][docs] Fix the typo of syntax for ref link [flink-connector-aws] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2026/02/20 06:33:00 UTC, 7 replies.
- Re: [PR] [FLINK-37698] Rename fromSchedulerNg to fromWithinExecutionGraph [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/02/20 06:34:04 UTC, 1 replies.
- Re: [PR] [hotfix] Rename SessionDispatcherFactory to DefaultDispatcherFactory [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/02/20 06:34:08 UTC, 1 replies.
- Re: [PR] [hotfix] [build] Exclude commons-beanutils from Hadoop dependency to remediate CVE-2025-48734 [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/02/20 06:34:12 UTC, 0 replies.
- [jira] [Created] (FLINK-39124) [JUnit5 Migration] Module: flink-tests - posted by "Mate Czagany (Jira)" <ji...@apache.org> on 2026/02/20 06:55:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38945) [FLIP-561] Restructure Flink documentation - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/02/20 08:29:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38925) Update Matomo URL to the right domain - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/02/20 08:29:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38925) Update Matomo URL to the right domain - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/02/20 08:29:00 UTC, 0 replies.
- [PR] FLIP-547: Support checkpoint during recovery [flink] - posted by "1996fanrui (via GitHub)" <gi...@apache.org> on 2026/02/20 09:21:05 UTC, 0 replies.
- Re: [PR] [WIP] FLIP-547: Support checkpoint during recovery [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2026/02/20 09:25:37 UTC, 0 replies.
- [jira] [Commented] (FLINK-39103) BufferManager.recycle fails TM due to RemoteTransportException - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2026/02/20 09:41:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-39103) BufferManager.recycle fails TM due to RemoteTransportException - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2026/02/20 09:42:00 UTC, 0 replies.
- [PR] [hotfix] change parent to 1.1 [flink-connector-http] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2026/02/20 09:59:15 UTC, 2 replies.
- [jira] [Created] (FLINK-39125) Support injective casts from CHAR/VARCHAR to BINARY/VARBINARY for upsert key preservation - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2026/02/20 13:24:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39125) Support injective casts from CHAR/VARCHAR to BINARY/VARBINARY for upsert key preservation - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2026/02/20 13:30:00 UTC, 0 replies.
- [PR] [FLINK-39088][table] Support injective casts from VARCHAR to BINARY [flink] - posted by "gustavodemorais (via GitHub)" <gi...@apache.org> on 2026/02/20 13:31:56 UTC, 4 replies.
- [jira] [Updated] (FLINK-39126) Support exporting metrics through grpc in batches - posted by "Aleksandr Iushmanov (Jira)" <ji...@apache.org> on 2026/02/20 13:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39127) Support exported metrics attributes truncation rules - posted by "Aleksandr Iushmanov (Jira)" <ji...@apache.org> on 2026/02/20 13:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39126) Support exporting metrics through grpc in batches - posted by "Aleksandr Iushmanov (Jira)" <ji...@apache.org> on 2026/02/20 13:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39128) DynamoDB CDC source connector millisBehindLatest metric gets stuck after failover - posted by "Emre Kartoglu (Jira)" <ji...@apache.org> on 2026/02/20 13:59:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39128) DynamoDB CDC source connector millisBehindLatest metric gets stuck after failover - posted by "Emre Kartoglu (Jira)" <ji...@apache.org> on 2026/02/20 14:01:00 UTC, 3 replies.
- [jira] [Closed] (FLINK-39103) BufferManager.recycle fails TM due to RemoteTransportException - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2026/02/20 15:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39129) Support native types in MetricConfig - posted by "Aleksandr Iushmanov (Jira)" <ji...@apache.org> on 2026/02/20 16:04:00 UTC, 0 replies.
- [PR] [FLINK-39105][rest] Fix RestClientTest.testConnectionTimeout to handle environment-dependent exception types [flink] - posted by "MartijnVisser (via GitHub)" <gi...@apache.org> on 2026/02/20 16:11:18 UTC, 2 replies.
- [jira] [Assigned] (FLINK-39105) RestClientTest.testConnectionTimeout fails with different expected exception - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/02/20 16:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39130) Allow native types to be used for MetricConfig - posted by "Aleksandr Iushmanov (Jira)" <ji...@apache.org> on 2026/02/20 16:14:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39130) Allow native types to be used for MetricConfig - posted by "Aleksandr Iushmanov (Jira)" <ji...@apache.org> on 2026/02/20 16:16:00 UTC, 3 replies.
- [PR] [FLINK-39130][metrics] Allow native types in MetricConfig [flink] - posted by "Izeren (via GitHub)" <gi...@apache.org> on 2026/02/20 16:22:20 UTC, 17 replies.
- [jira] [Created] (FLINK-39131) Multi-Input Processors - posted by "Salva (Jira)" <ji...@apache.org> on 2026/02/20 18:31:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39131) Multi-Input Processors - posted by "Salva (Jira)" <ji...@apache.org> on 2026/02/20 18:32:00 UTC, 26 replies.
- [jira] [Resolved] (FLINK-39105) RestClientTest.testConnectionTimeout fails with different expected exception - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/02/20 21:32:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37853) FLIP-530: Dynamic job configuration - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/02/21 02:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39132) 'kubernetes Materialized Table test' failed because it could not not stop job - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/02/21 08:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39133) DispatcherTest.testApplicationStatusChange_ThrowsIfDuplicateTerminalStatus fails on state exception - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/02/21 08:57:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38403) UnalignedCheckpointITCase failed in test_cron_hadoop313 tests - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/02/21 08:58:00 UTC, 1 replies.
- [jira] [Reopened] (FLINK-38403) UnalignedCheckpointITCase failed in test_cron_hadoop313 tests - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/02/21 08:58:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-38403) UnalignedCheckpointITCase failed in test_cron_hadoop313 tests - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/02/21 08:59:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38967) UnalignedCheckpointFailureHandlingITCase fails intermittently - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/02/21 09:02:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-38939) Pause sources until the 1st checkpoint to prioritize processing recovered records - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/02/21 09:32:00 UTC, 0 replies.
- Re: [PR] [FLINK-38807][state] Add state SQL metadata based type inference [flink] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2026/02/21 16:14:18 UTC, 11 replies.
- [jira] [Updated] (FLINK-38403) UnalignedCheckpointITCase failed in test_cron_hadoop313 tests - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2026/02/21 16:47:00 UTC, 0 replies.
- [I] [Tech Debt] Refactor ActionExecutionOperator into focused manager classes [flink-agents] - posted by "weiqingy (via GitHub)" <gi...@apache.org> on 2026/02/21 23:37:21 UTC, 0 replies.
- [PR] [runtime] Refactor ActionExecutionOperator into focused manager classes [flink-agents] - posted by "weiqingy (via GitHub)" <gi...@apache.org> on 2026/02/22 00:41:21 UTC, 0 replies.
- [I] [Tech Debt] Refactor AgentPlan & ResourceCache [flink-agents] - posted by "weiqingy (via GitHub)" <gi...@apache.org> on 2026/02/22 03:32:27 UTC, 0 replies.
- [PR] [plan] Extract ResourceCache and PythonResourceBridge from AgentPlan [flink-agents] - posted by "weiqingy (via GitHub)" <gi...@apache.org> on 2026/02/22 03:39:14 UTC, 2 replies.
- [I] [Feature] Runtime reloading for MCP tools and prompts [flink-agents] - posted by "weiqingy (via GitHub)" <gi...@apache.org> on 2026/02/22 04:00:10 UTC, 3 replies.
- Re: [PR] [FLINK-36753] Adaptive Scheduler actively triggers a Checkpoint [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/02/22 06:30:20 UTC, 1 replies.
- Re: [PR] [FLINK-38525][python] Fix coder doesn't process TIMESTAMP_LTZ correctly [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/02/22 06:30:25 UTC, 1 replies.
- [PR] [FLINK-39073][tests] Retry kafka containers startup [flink-connector-kafka] - posted by "Efrat19 (via GitHub)" <gi...@apache.org> on 2026/02/22 10:18:21 UTC, 0 replies.
- [PR] [FLINK-38971][table] Migrate ExpandWindowTableFunctionTransposeRule t… [flink] - posted by "RVRhub (via GitHub)" <gi...@apache.org> on 2026/02/22 10:54:38 UTC, 3 replies.
- [jira] [Updated] (FLINK-38971) Migrate ExpandWindowTableFunctionTransposeRule - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/22 10:55:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-39107) OpenTelemetryEventReporterITCase fails with ContainerLaunch Container startup failed for image - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/02/22 14:16:00 UTC, 1 replies.
- [jira] [Created] (FLINK-39134) UnalignedCheckpointFailureHandlingITCase.testCheckpointSuccessAfterFailure is flaky - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/02/22 14:17:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-39134) UnalignedCheckpointFailureHandlingITCase.testCheckpointSuccessAfterFailure is flaky - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/02/22 14:18:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-39134) UnalignedCheckpointFailureHandlingITCase.testCheckpointSuccessAfterFailure is flaky - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2026/02/22 15:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39135) Backport GSBlobStorageImpl precondition check to 1.20.4 - posted by "Jon Chase (Jira)" <ji...@apache.org> on 2026/02/22 20:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39136) GS file system fails to retry on certain 503's due to old GCS lib dependency - posted by "Jon Chase (Jira)" <ji...@apache.org> on 2026/02/22 20:13:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39136) GS file system fails to retry on certain 503's due to old GCS lib dependency - posted by "Jon Chase (Jira)" <ji...@apache.org> on 2026/02/22 20:14:00 UTC, 0 replies.
- Re: [PR] [FLINK-38276][cdc-common] PaimonWriter does not invalidate cache when… [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/02/23 00:07:24 UTC, 1 replies.
- [jira] [Updated] (FLINK-39133) DispatcherTest.testApplicationStatusChange_ThrowsIfDuplicateTerminalStatus fails on state exception - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2026/02/23 07:35:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-39133) DispatcherTest.testApplicationStatusChange_ThrowsIfDuplicateTerminalStatus fails on state exception - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2026/02/23 07:43:00 UTC, 2 replies.
- [jira] [Commented] (FLINK-38764) switch lz4-java to at.yawk.lz4 version due to CVE - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2026/02/23 08:01:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38764) switch lz4-java to at.yawk.lz4 version due to CVE - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2026/02/23 08:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39137) Add configurable delay between non-empty GetRecords calls in Kinesis source - posted by "Andreas Bube (Jira)" <ji...@apache.org> on 2026/02/23 08:17:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39137) Add configurable delay between non-empty GetRecords calls in Kinesis source - posted by "Andreas Bube (Jira)" <ji...@apache.org> on 2026/02/23 08:52:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-39088) Preserve upsert keys for explicit (injective) CAST calls to avoid unnecessary SinkUpsertMaterializer - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2026/02/23 09:44:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38624) Flink 2.1 Job Failure: Type Mismatch Exception in StreamPhysicalOverAggregateRule (TIMESTAMP(3) vs TIMESTAMP(3) ROWTIME) - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2026/02/23 09:54:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-39136) GS file system fails to retry on certain 503's due to old GCS lib dependency - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/02/23 10:43:00 UTC, 2 replies.
- [jira] [Created] (FLINK-39138) Update Flink Connector Kafka to Flink Connector Parent POM 2.0 - posted by "Thomas Cooper (Jira)" <ji...@apache.org> on 2026/02/23 11:05:00 UTC, 0 replies.
- [PR] [FLINK-39138] Update to flink connector parent pom version 2.0 [flink-connector-kafka] - posted by "tomncooper (via GitHub)" <gi...@apache.org> on 2026/02/23 11:10:00 UTC, 4 replies.
- [jira] [Updated] (FLINK-39138) Update Flink Connector Kafka to Flink Connector Parent POM 2.0 - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/23 11:11:00 UTC, 0 replies.
- Re: [PR] [FLINK-39121][tests] Retry kafka containers startup [flink-connector-kafka] - posted by "rkhachatryan (via GitHub)" <gi...@apache.org> on 2026/02/23 11:15:31 UTC, 0 replies.
- [jira] [Updated] (FLINK-39121) kafka connector CI test timeout due to "/tmp/testcontainers_start.sh: Text file busy" - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/23 11:16:00 UTC, 1 replies.
- [jira] [Closed] (FLINK-39121) kafka connector CI test timeout due to "/tmp/testcontainers_start.sh: Text file busy" - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2026/02/23 11:19:00 UTC, 0 replies.
- Re: [PR] [hotfix] Fix kafka connection flakiness in tests [flink-connector-kafka] - posted by "Efrat19 (via GitHub)" <gi...@apache.org> on 2026/02/23 11:30:30 UTC, 0 replies.
- [jira] [Resolved] (FLINK-29245) [JUnit 5 Migration] Remove RetryRule - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2026/02/23 11:49:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38999) License lineage files - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2026/02/23 13:27:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38999) License lineage files - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2026/02/23 13:27:00 UTC, 0 replies.
- [PR] Update CI for Flink Connector Parent POM 2.0 compatibility [flink-connector-shared-utils] - posted by "tomncooper (via GitHub)" <gi...@apache.org> on 2026/02/23 14:05:35 UTC, 0 replies.
- Re: [PR] [FLINK-38742][cdc-pipeline/postgres] Fix timestamp with time zone [flink-cdc] - posted by "cloneot (via GitHub)" <gi...@apache.org> on 2026/02/23 14:20:39 UTC, 0 replies.
- [PR] [wip] BYTES -> STRING's non-injectivity for invalid UTF-8 bytes input [flink] - posted by "gustavodemorais (via GitHub)" <gi...@apache.org> on 2026/02/23 14:54:12 UTC, 3 replies.
- [jira] [Created] (FLINK-39139) Update lz4-java to 1.10.3 - posted by "Cameron (Jira)" <ji...@apache.org> on 2026/02/23 15:09:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39139) Update lz4-java to 1.10.3 - posted by "Cameron (Jira)" <ji...@apache.org> on 2026/02/23 15:20:00 UTC, 2 replies.
- [jira] [Created] (FLINK-39140) Enhance Unaligned Checkpoint ITCases to perform checkpointing during recovery - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2026/02/23 15:54:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38624) Flink 2.1 Job Failure: Type Mismatch Exception in StreamPhysicalOverAggregateRule (TIMESTAMP(3) vs TIMESTAMP(3) ROWTIME) - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/02/23 16:09:00 UTC, 0 replies.
- [PR] [FLINK-39123][table] [flink] - posted by "rionmonster (via GitHub)" <gi...@apache.org> on 2026/02/23 17:49:01 UTC, 1 replies.
- [jira] [Commented] (FLINK-39123) ValueLiteralExpression.asSerializableString has problems with TIMESTAMP_LTZ(9) - posted by "Rion Williams (Jira)" <ji...@apache.org> on 2026/02/23 17:59:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-39123) ValueLiteralExpression.asSerializableString has problems with TIMESTAMP_LTZ(9) - posted by "Rion Williams (Jira)" <ji...@apache.org> on 2026/02/23 17:59:00 UTC, 0 replies.
- Re: [PR] [FLINK-39123][table] Updated ValueLiteralExpression Support for Larger Precision TIMESTAMP_LTZ Instances [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2026/02/23 17:59:57 UTC, 2 replies.
- [PR] [FLINK-24379] Add Glue Schema Registry Avro SQL format factory [flink-connector-aws] - posted by "fmorillo7694 (via GitHub)" <gi...@apache.org> on 2026/02/23 18:04:49 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38807) Add state SQL metadata based type inference - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2026/02/23 18:14:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38807) Add state SQL metadata based type inference - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2026/02/23 18:14:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38807) Add state SQL metadata based type inference - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2026/02/23 18:14:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38162) Use of SQL functions with time attributes causes downstream temporal functions to fail - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/02/23 18:44:00 UTC, 0 replies.
- Re: [PR] [BP-2.1][FLINK-38624][table] Type Mismatch Exception in StreamPhysicalOverAggregateRule [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2026/02/23 19:03:21 UTC, 0 replies.
- [PR] [BP-2.0][FLINK-38624][table] Type Mismatch Exception in StreamPhysicalOverAggregateRule [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2026/02/23 19:43:20 UTC, 1 replies.
- [jira] [Created] (FLINK-39141) Support AWS Glue Schema Registry JSON for Table API - posted by "Francisco Morillo (Jira)" <ji...@apache.org> on 2026/02/23 20:17:00 UTC, 0 replies.
- [PR] [BP-2.2][FLINK-38624][table] Type Mismatch Exception in StreamPhysicalOverAggregateRule [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2026/02/23 20:20:55 UTC, 1 replies.
- [jira] [Created] (FLINK-39142) Support AWS Glue Schema Registry Protobuf for Table API - posted by "Francisco Morillo (Jira)" <ji...@apache.org> on 2026/02/23 20:39:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38830) PreTransformOperator needs to avoid crashing with "Field names must be unique" error and handle processing a duplicate AddColumnEvent better - posted by "Vinay Sagar Gonabavi (Jira)" <ji...@apache.org> on 2026/02/23 23:13:00 UTC, 1 replies.
- [PR] [FLINK-38830][runtime] Handle duplicate AddColumnEvent gracefully to prevent pipeline crashes [flink-cdc] - posted by "VinaySagarGonabavi (via GitHub)" <gi...@apache.org> on 2026/02/23 23:14:29 UTC, 1 replies.
- [jira] [Updated] (FLINK-38830) PreTransformOperator needs to avoid crashing with "Field names must be unique" error and handle processing a duplicate AddColumnEvent better - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/23 23:15:00 UTC, 0 replies.
- Re: [PR] [FLINK-38857][Model] Add docs for Triton inference model [flink] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2026/02/24 01:30:56 UTC, 0 replies.
- [PR] [FLINK-38828][cdc-runtime] Add state persistence to PostTransformOperator for projection schema evolution [flink-cdc] - posted by "VinaySagarGonabavi (via GitHub)" <gi...@apache.org> on 2026/02/24 01:38:52 UTC, 1 replies.
- [jira] [Updated] (FLINK-38828) PostTransformOperator needs to detect dynamic projection updates when restarting from checkpoint/savepoint - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/24 01:39:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38828) PostTransformOperator needs to detect dynamic projection updates when restarting from checkpoint/savepoint - posted by "Vinay Sagar Gonabavi (Jira)" <ji...@apache.org> on 2026/02/24 01:40:00 UTC, 1 replies.
- [PR] [FLINK-39066][pipeline-connector][Fluss] fix the metric histogram always return null [flink-cdc] - posted by "ThorneANN (via GitHub)" <gi...@apache.org> on 2026/02/24 03:25:03 UTC, 1 replies.
- [PR] [FLINK-39133][runtime] Fix DispatcherTest to properly handle async op… [flink] - posted by "eemario (via GitHub)" <gi...@apache.org> on 2026/02/24 03:34:58 UTC, 2 replies.
- [jira] [Updated] (FLINK-38973) Job ID assignment and matching based on name - posted by "Yi Zhang (Jira)" <ji...@apache.org> on 2026/02/24 03:46:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38977) Expose exceptions for applications - posted by "Yi Zhang (Jira)" <ji...@apache.org> on 2026/02/24 03:47:00 UTC, 1 replies.
- [PR] Expose exceptions for applications [flink] - posted by "eemario (via GitHub)" <gi...@apache.org> on 2026/02/24 03:53:24 UTC, 0 replies.
- Re: [PR] [FLINK-38977][runtime] Expose exceptions for applications [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2026/02/24 03:59:09 UTC, 2 replies.
- [jira] [Updated] (FLINK-38978) Expose JM config for applications - posted by "Yi Zhang (Jira)" <ji...@apache.org> on 2026/02/24 04:19:00 UTC, 1 replies.
- [PR] [FLINK-38978][runtime] Expose JM config for applications [flink] - posted by "eemario (via GitHub)" <gi...@apache.org> on 2026/02/24 05:54:35 UTC, 2 replies.
- [jira] [Created] (FLINK-39143) fluss‘s connection use connection pool be better - posted by "Thorne (Jira)" <ji...@apache.org> on 2026/02/24 05:55:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-39143) fluss‘s connection use connection pool be better - posted by "Thorne (Jira)" <ji...@apache.org> on 2026/02/24 05:59:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39143) fluss‘s connection use connection pool be better - posted by "Thorne (Jira)" <ji...@apache.org> on 2026/02/24 05:59:00 UTC, 0 replies.
- [jira] (FLINK-39143) fluss‘s connection use connection pool be better - posted by "Thorne (Jira)" <ji...@apache.org> on 2026/02/24 05:59:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39143) It is better to use a connection pool for fluss's connections - posted by "Thorne (Jira)" <ji...@apache.org> on 2026/02/24 06:00:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-38970) AdaptiveBatchSchedulerTest is unstable - posted by "Shekhar Prasad Rajak (Jira)" <ji...@apache.org> on 2026/02/24 06:09:00 UTC, 1 replies.
- Re: [PR] [FLINK-37247][FileSystems][Tests] Implement common Hadoop file system integration tests for GCS. [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/02/24 06:37:11 UTC, 0 replies.
- Re: [PR] [FLINK-37328][FileSystems] Upgrade GCS connector to 2.2.26. [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/02/24 06:37:14 UTC, 0 replies.
- [jira] [Commented] (FLINK-39137) Add configurable delay between non-empty GetRecords calls in Kinesis source - posted by "Andreas Bube (Jira)" <ji...@apache.org> on 2026/02/24 07:17:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39143) It is better to use a transient connection for fluss's connection - posted by "Thorne (Jira)" <ji...@apache.org> on 2026/02/24 07:18:00 UTC, 1 replies.
- [PR] [FLINK-39124] Update flink-tests to JUnit5 [flink] - posted by "mateczagany (via GitHub)" <gi...@apache.org> on 2026/02/24 07:21:29 UTC, 3 replies.
- [jira] [Updated] (FLINK-39124) [JUnit5 Migration] Module: flink-tests - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/24 07:22:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-39084) Variant Field accesor helper methods - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2026/02/24 07:38:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39144) fix IOManager not close - posted by "peiyu (Jira)" <ji...@apache.org> on 2026/02/24 07:43:00 UTC, 1 replies.
- [jira] [Created] (FLINK-39144) fix IOManager not close - posted by "peiyu (Jira)" <ji...@apache.org> on 2026/02/24 07:43:00 UTC, 0 replies.
- [PR] [FLINK-39143][pipeline-connecotr][fluss]Optimize the connection of fluss when use FlussMetaDataApplier [flink-cdc] - posted by "ThorneANN (via GitHub)" <gi...@apache.org> on 2026/02/24 07:49:44 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38727) Unstable test cases EventTimeWindowCheckpointingITCase.testPreAggregatedSlidingTimeWindow - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2026/02/24 07:54:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38970) AdaptiveBatchSchedulerTest is unstable - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2026/02/24 07:55:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38850) Support PostgreSQL uuid type - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/02/24 07:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39145) UnalignedCheckpointITCase.execute fails - Could not acquire the minimum required resources. - posted by "Efrat Levitan (Jira)" <ji...@apache.org> on 2026/02/24 07:56:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38851) Support passing arbitrary database options to JDBC Catalog - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/02/24 07:56:00 UTC, 0 replies.
- [PR] [FLINK-39144][paimon] Fix ioManager close. [flink-cdc] - posted by "sd4324530 (via GitHub)" <gi...@apache.org> on 2026/02/24 07:56:54 UTC, 1 replies.
- [PR] [FLINK-38244][hotfix] Fix the full snapshot phase, the field case is adjusted based on isTableIdCaseInsensitive [flink-cdc] - posted by "sd4324530 (via GitHub)" <gi...@apache.org> on 2026/02/24 08:09:11 UTC, 1 replies.
- Re: [PR] [Feature][Java] Added retries to remote calls in MCP server [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2026/02/24 09:29:18 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38596) The comment of the created MaxCompute table is incorrect - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2026/02/24 09:33:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-39066) Fix fluss's metric histogram always return null - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2026/02/24 09:34:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38601) MongoDB CDC silently stops consuming from unbounded streams when Throwable errors occur and never recovers - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2026/02/24 09:35:00 UTC, 0 replies.
- Re: [PR] [FLINK-39143][pipeline-connecotr][Fluss]Optimize the connection of fluss when use FlussMetaDataApplier [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2026/02/24 09:42:49 UTC, 6 replies.
- [jira] [Updated] (FLINK-39145) UnalignedCheckpointITCase.execute fails - IllegalStateException: Trying to access closed classloader - posted by "Efrat Levitan (Jira)" <ji...@apache.org> on 2026/02/24 09:52:00 UTC, 3 replies.
- [jira] [Updated] (FLINK-39124) [JUnit5 Migration] Migrate the JUnit5 for Module: flink-tests - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/02/24 09:53:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-39124) [JUnit5 Migration] Migrate the JUnit5 for Module: flink-tests - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/02/24 09:53:00 UTC, 0 replies.
- [PR] [hotfix] fixup typos in docs [flink-connector-http] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2026/02/24 10:03:30 UTC, 1 replies.
- [PR] [FLINK-39145][checkpointing] Account for already closed classloader during async operation failure [flink] - posted by "Efrat19 (via GitHub)" <gi...@apache.org> on 2026/02/24 10:06:32 UTC, 2 replies.
- [jira] [Commented] (FLINK-38287) Kafka 4.1.0 Queue Semantics support in Flink Connector Kafka - posted by "Shekhar Prasad Rajak (Jira)" <ji...@apache.org> on 2026/02/24 10:09:00 UTC, 0 replies.
- [PR] [FLINK-38727] Fix flaky test by adding slot request timeout configura… [flink] - posted by "Shekharrajak (via GitHub)" <gi...@apache.org> on 2026/02/24 10:12:24 UTC, 1 replies.
- [PR] [FLINK-38970] Fix flaky AdaptiveBatchSchedulerTest by using synchrono… [flink] - posted by "Shekharrajak (via GitHub)" <gi...@apache.org> on 2026/02/24 11:01:51 UTC, 1 replies.
- [jira] [Created] (FLINK-39146) Update log4j to 2.25.3 - posted by "Cameron (Jira)" <ji...@apache.org> on 2026/02/24 11:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39147) Update Guava to 32.0.1 - posted by "Cameron (Jira)" <ji...@apache.org> on 2026/02/24 11:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39148) Update flink-connector-kafka & flink-sql-connector-kafka to 4.0.1-2.0 - posted by "Cameron (Jira)" <ji...@apache.org> on 2026/02/24 11:35:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-39147) Update Guava to 32.0.1 - posted by "Shekhar Prasad Rajak (Jira)" <ji...@apache.org> on 2026/02/24 11:40:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-39148) Update flink-connector-kafka & flink-sql-connector-kafka to 4.0.1-2.0 - posted by "Shekhar Prasad Rajak (Jira)" <ji...@apache.org> on 2026/02/24 11:41:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-39146) Update log4j to 2.25.3 - posted by "Cameron (Jira)" <ji...@apache.org> on 2026/02/24 11:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39149) `gtid.new.channel.position=LATEST` Incorrectly Replays Pre-Checkpoint Transactions for Old Channels in Multi-Source Replication - posted by "Jia Fan (Jira)" <ji...@apache.org> on 2026/02/24 11:43:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39149) `gtid.new.channel.position=LATEST` Incorrectly Replays Pre-Checkpoint Transactions for Old Channels in Multi-Source Replication - posted by "Jia Fan (Jira)" <ji...@apache.org> on 2026/02/24 11:44:00 UTC, 3 replies.
- [jira] [Commented] (FLINK-39139) Update lz4-java to 1.10.3 - posted by "Cameron (Jira)" <ji...@apache.org> on 2026/02/24 11:44:00 UTC, 0 replies.
- [PR] [hotfix][doc] Use version 0.2.0 rather than 0.2-SNAPSHOT in maven dependency doc. [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2026/02/24 12:43:42 UTC, 2 replies.
- [PR] [hotfix][mcp][python] Check whether mcp server supports prompts via server capabilities [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2026/02/24 12:46:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-39107) OpenTelemetryEventReporterITCase fails with ContainerLaunch Container startup failed for image - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/02/24 12:51:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-39131) Multi-Input Processors - posted by "Salva (Jira)" <ji...@apache.org> on 2026/02/24 13:54:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-39131) Multi-Input Processors - posted by "Salva (Jira)" <ji...@apache.org> on 2026/02/24 13:55:00 UTC, 8 replies.
- [PR] [FLINK-39080][debug] main CI license behavior [flink] - posted by "Efrat19 (via GitHub)" <gi...@apache.org> on 2026/02/24 13:56:57 UTC, 2 replies.
- [jira] [Updated] (FLINK-39080) Missing license undetected by connector CI - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/24 13:58:00 UTC, 0 replies.
- Re: [PR] [FLINK-38242] Improve upgrading documentation for SQL/Table API state compatibility and add Flink 2.x to compatibility table [flink] - posted by "zhimin-z (via GitHub)" <gi...@apache.org> on 2026/02/24 15:21:19 UTC, 0 replies.
- [jira] [Closed] (FLINK-38916) MultiJoin produces incorrect results for OR join conditions when parallelism is greater than 1 - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2026/02/24 16:06:00 UTC, 0 replies.
- Re: [PR] [FLINK-38866][flink-table-planner] Passing timestamp precision from window strategy to window operators to support non-compact BinaryRowData timestamps [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2026/02/24 16:55:26 UTC, 3 replies.
- Re: [PR] [FLINK-38733] Add new SplitterEnumerator on JdbcSource [flink-connector-jdbc] - posted by "eskabetxe (via GitHub)" <gi...@apache.org> on 2026/02/24 19:07:32 UTC, 1 replies.
- [jira] [Created] (FLINK-39150) Join operator crashes jobs when using custom types or custom type serializers - posted by "Piotr Przybylski (Jira)" <ji...@apache.org> on 2026/02/24 22:21:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39150) Join operator crashes jobs when using custom types or custom type serializers - posted by "Piotr Przybylski (Jira)" <ji...@apache.org> on 2026/02/24 22:23:00 UTC, 3 replies.
- [jira] [Created] (FLINK-39151) Hide warning about UnixOperatingSystemMXBean missing on Windows - posted by "Piotr Przybylski (Jira)" <ji...@apache.org> on 2026/02/24 22:46:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39151) Hide warning about UnixOperatingSystemMXBean missing on Windows - posted by "Piotr Przybylski (Jira)" <ji...@apache.org> on 2026/02/24 22:51:00 UTC, 1 replies.
- [PR] [FLINK-39151][metrics] Hide warning about UnixOperatingSystemMXBean missing on Windows [flink] - posted by "piotrp (via GitHub)" <gi...@apache.org> on 2026/02/24 23:00:37 UTC, 2 replies.
- [PR] (demo for Jira issue) [FLINK-39150] Test showing issue with AdaptiveJoin [flink] - posted by "piotrp (via GitHub)" <gi...@apache.org> on 2026/02/24 23:08:54 UTC, 1 replies.
- [jira] [Updated] (FLINK-38893) Introduce the /jobs/:jobid/rescales/overview endpoint in the REST API - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/02/25 02:22:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38894) Introduce the /jobs/:jobid/rescales/history endpoint in the REST API - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/02/25 02:22:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38896) Introduce the /jobs/:jobid/rescales/summary endpoint in the REST API - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/02/25 02:22:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38895) Introduce the /jobs/:jobid/rescales/details/:rescaleuuid endpoint in the REST API - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/02/25 02:22:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-39143) It is better to use a transient connection for fluss's connection - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2026/02/25 02:22:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38455) MySQL CDC to ES8 pipeline connector cannot work - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2026/02/25 02:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39152) The FlussConfig Utils class is not in the correct directory and does not have a private instance - posted by "Thorne (Jira)" <ji...@apache.org> on 2026/02/25 03:11:00 UTC, 0 replies.
- Re: [PR] [FLINK-38247] Handle BIGINT UNSIGNED overflow in PreparedStatement [flink-cdc] - posted by "Copilot (via GitHub)" <gi...@apache.org> on 2026/02/25 03:23:44 UTC, 0 replies.
- [PR] Fix FlussConfig Utils class is not in the correct directory and does … [flink-cdc] - posted by "ThorneANN (via GitHub)" <gi...@apache.org> on 2026/02/25 03:25:36 UTC, 0 replies.
- [PR] [FLINK-39149][mysql-cdc] Implement LATEST mode GTID merging to prevent replaying pre-checkpoint transactions with non-contiguous ranges [flink-cdc] - posted by "Hisoka-X (via GitHub)" <gi...@apache.org> on 2026/02/25 03:44:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-38259) FLIP-529: Connections in Flink SQL and TableAPI - posted by "Shekhar Prasad Rajak (Jira)" <ji...@apache.org> on 2026/02/25 04:45:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38264) Connection table api - posted by "Shekhar Prasad Rajak (Jira)" <ji...@apache.org> on 2026/02/25 04:46:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38262) Convert connection sqlnode to operations - posted by "Shekhar Prasad Rajak (Jira)" <ji...@apache.org> on 2026/02/25 04:46:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-39117) Flaky ChainUnionTest testMigrationAndRestore - posted by "Shekhar Prasad Rajak (Jira)" <ji...@apache.org> on 2026/02/25 04:49:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-39117) Flaky ChainUnionTest testMigrationAndRestore - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2026/02/25 06:35:00 UTC, 0 replies.
- Re: [PR] [FLINK-37932] Add UserAgent in GCS requests [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/02/25 06:39:50 UTC, 1 replies.
- Re: [PR] Bump @angular/common from 20.1.3 to 20.3.14 in /flink-runtime-web/web-dashboard [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/02/25 06:39:54 UTC, 0 replies.
- [PR] [FLINK-39080][debug] test CI license behavior [flink-connector-kafka] - posted by "Efrat19 (via GitHub)" <gi...@apache.org> on 2026/02/25 06:47:53 UTC, 0 replies.
- [D] [Feature] Per-Event-Type Configurable Log Levels for Event Log [flink-agents] - posted by "weiqingy (via GitHub)" <gi...@apache.org> on 2026/02/25 07:15:42 UTC, 14 replies.
- [jira] [Created] (FLINK-39153) Add comprehensive performance metrics for PyFlink - posted by "Liu (Jira)" <ji...@apache.org> on 2026/02/25 07:20:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-39041) Rebuild REST API docs pages to supplement the missing content. - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/02/25 07:35:00 UTC, 0 replies.
- [PR] [FLINK-39117] Fix flaky ChainUnionTest [flink] - posted by "Shekharrajak (via GitHub)" <gi...@apache.org> on 2026/02/25 07:38:46 UTC, 1 replies.
- [PR] [FLINK-39124][test] Migrate CancellingTestBase and StreamFaultToleranceTestBase to JUnit 5 [flink] - posted by "mateczagany (via GitHub)" <gi...@apache.org> on 2026/02/25 07:48:23 UTC, 1 replies.
- [PR] [FLINK-39124][test] Migrate operator restore tests to JUnit 5 [flink] - posted by "mateczagany (via GitHub)" <gi...@apache.org> on 2026/02/25 07:48:41 UTC, 2 replies.
- [PR] [FLINK-39124][test] Migrate checkpointing ITCases to JUnit 5 [flink] - posted by "mateczagany (via GitHub)" <gi...@apache.org> on 2026/02/25 07:48:54 UTC, 1 replies.
- [PR] [FLINK-39124][test] Migrate streaming and runtime ITCases to JUnit 5 [flink] - posted by "mateczagany (via GitHub)" <gi...@apache.org> on 2026/02/25 07:49:08 UTC, 1 replies.
- [PR] [FLINK-39124][test] Migrate remaining flink-tests to JUnit 5 [flink] - posted by "mateczagany (via GitHub)" <gi...@apache.org> on 2026/02/25 07:49:18 UTC, 1 replies.
- [jira] [Closed] (FLINK-39133) DispatcherTest.testApplicationStatusChange_ThrowsIfDuplicateTerminalStatus fails on state exception - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2026/02/25 08:19:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-39133) DispatcherTest.testApplicationStatusChange_ThrowsIfDuplicateTerminalStatus fails on state exception - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2026/02/25 08:19:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38978) Expose JM config for applications - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2026/02/25 08:20:00 UTC, 0 replies.
- Re: [PR] [FLINK-39001][doc][Flink-source]supple NewlyAddTable's doc with mongodb,postgres,oracle connectors [flink-cdc] - posted by "ThorneANN (via GitHub)" <gi...@apache.org> on 2026/02/25 08:53:55 UTC, 3 replies.
- Re: [PR] [FLINK-39106] Support ROW and ARRAY data types in DynamoDB API / SQL sink [flink-connector-aws] - posted by "gguptp (via GitHub)" <gi...@apache.org> on 2026/02/25 08:54:24 UTC, 2 replies.
- [jira] [Created] (FLINK-39154) [Table]Support Async Batch Lookup Join (with Calc) for Temporal Table Join - posted by "featzhang (Jira)" <ji...@apache.org> on 2026/02/25 09:14:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39154) [Table]Support Async Batch Lookup Join (with Calc) for Temporal Table Join - posted by "featzhang (Jira)" <ji...@apache.org> on 2026/02/25 09:14:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39154) [Table/SQL] Support Async Batch Lookup Join (with Calc) for Temporal Table Join - posted by "featzhang (Jira)" <ji...@apache.org> on 2026/02/25 09:16:00 UTC, 0 replies.
- Re: [PR] [FLINK-34864][cdc-connector-mysql] Add the IgnoreNoPrimaryKeyTable parameter to skip tables without primary keys in multi-table synchronization [flink-cdc] - posted by "yzeng1618 (via GitHub)" <gi...@apache.org> on 2026/02/25 09:16:13 UTC, 0 replies.
- [jira] [Updated] (FLINK-39140) Enhance Unaligned Checkpoint ITCases to perform checkpointing during recovery - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2026/02/25 09:19:00 UTC, 2 replies.
- [jira] [Created] (FLINK-39155) Add a check watermarks are defined in source for ERROR/NOTHING - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2026/02/25 09:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39156) Document the changes - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2026/02/25 09:31:00 UTC, 0 replies.
- [PR] [FLINK-38729] Bump Flink version to 2.2.0 [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2026/02/25 09:56:29 UTC, 1 replies.
- [jira] [Updated] (FLINK-38729) Bump Flink version of Flink CDC to 2.1 or 2.2 - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/25 09:57:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38850) Support PostgreSQL uuid type - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/02/25 10:04:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-39001) [doc] Supplement the documentation with newlyaddedtable - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2026/02/25 10:10:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38851) Support passing arbitrary database options to JDBC Catalog - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/02/25 10:31:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-39130) Allow native types to be used for MetricConfig - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2026/02/25 10:43:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-39130) Allow native types to be used for MetricConfig - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2026/02/25 10:44:00 UTC, 0 replies.
- [jira] [Reopened] (FLINK-39130) Allow native types to be used for MetricConfig - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2026/02/25 10:52:00 UTC, 0 replies.
- [PR] [hotfix][tests] Fix HistoryServerTest by adding delay to avoid identi… [flink] - posted by "eemario (via GitHub)" <gi...@apache.org> on 2026/02/25 11:25:30 UTC, 1 replies.
- Re: [PR] [FLINK-39139] Update lz4-java to 1.10.3 [flink] - posted by "1996fanrui (via GitHub)" <gi...@apache.org> on 2026/02/25 12:59:15 UTC, 4 replies.
- [jira] [Resolved] (FLINK-39139) Update lz4-java to 1.10.3 - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2026/02/25 13:04:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-39139) Update lz4-java to 1.10.3 - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2026/02/25 13:17:00 UTC, 1 replies.
- [PR] Dynamodb client refresh [flink-connector-aws] - posted by "mviningas (via GitHub)" <gi...@apache.org> on 2026/02/25 13:31:13 UTC, 4 replies.
- [jira] [Created] (FLINK-39157) ColumnList has no hashCode/equals - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2026/02/25 13:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39158) Minor polish for RestAPIStabilityTestUtils to reduce redundant lines - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/02/25 14:06:00 UTC, 0 replies.
- [PR] [FLINK-39158][runtime/test] Minor polish for RestAPIStabilityTestUtils to reduce redundant lines [flink] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2026/02/25 14:15:13 UTC, 1 replies.
- [jira] [Updated] (FLINK-39158) Minor polish for RestAPIStabilityTestUtils to reduce redundant lines - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/25 14:16:00 UTC, 0 replies.
- [PR] [FLINK-39157][table-common] Add ColumnList.hashCode()/equals() [flink] - posted by "twalthr (via GitHub)" <gi...@apache.org> on 2026/02/25 14:31:47 UTC, 5 replies.
- [jira] [Updated] (FLINK-39157) ColumnList has no hashCode/equals - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/25 14:32:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-39150) Join operator crashes jobs when using custom types or custom type serializers - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2026/02/25 14:37:00 UTC, 5 replies.
- [PR] [FLINK-37951] Enable VariantSerializerUpgradeTest [flink] - posted by "JinkunLiu (via GitHub)" <gi...@apache.org> on 2026/02/25 15:06:30 UTC, 1 replies.
- [jira] [Updated] (FLINK-37951) Enable VariantSerializerUpgradeTest in Flink 2.2 - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/25 15:07:00 UTC, 0 replies.
- Re: [PR] [FLINK-25538][Connectors/Kafka] Migration flink-connector-kafka from Junit4 to Junit5 [flink-connector-kafka] - posted by "Savonitar (via GitHub)" <gi...@apache.org> on 2026/02/25 15:12:14 UTC, 1 replies.
- [PR] Bump io.airlift:aircompressor from 0.27 to 2.0.3 in /flink-runtime [flink] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/02/25 15:35:11 UTC, 1 replies.
- [PR] [FLINK-33634] Add Conditions to Flink CRD's Status field [flink-kubernetes-operator] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2026/02/25 15:53:43 UTC, 5 replies.
- [jira] [Created] (FLINK-39159) Using KeyedProcessFunction in batch mode reads events out of order - posted by "Grzegorz Liter (Jira)" <ji...@apache.org> on 2026/02/25 17:14:00 UTC, 0 replies.
- [PR] FLINK-39098 fixing test-case failure due to build server not supporting docker 1.33 api [flink-connector-mongodb] - posted by "neoneo008 (via GitHub)" <gi...@apache.org> on 2026/02/25 20:01:37 UTC, 0 replies.
- Re: [PR] FLINK-39098 fixing test-case failure [flink-connector-mongodb] - posted by "neoneo008 (via GitHub)" <gi...@apache.org> on 2026/02/25 20:03:32 UTC, 0 replies.
- [jira] [Created] (FLINK-39160) [runtime][rpc][metrics] Expose RPC response frame size and oversized-response rejection metrics - posted by "Arun Lakshman (Jira)" <ji...@apache.org> on 2026/02/25 21:59:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39160) [runtime][rpc][metrics] Expose RPC response frame size and oversized-response rejection metrics - posted by "Arun Lakshman (Jira)" <ji...@apache.org> on 2026/02/25 21:59:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-39160) [Runtime][Rpc][Metrics] Expose RPC response frame size and oversized-response rejection metrics - posted by "Arun Lakshman (Jira)" <ji...@apache.org> on 2026/02/25 22:01:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-39160) [Runtime][Rpc][Metrics] Expose RPC response frame size and oversized-response rejection metrics - posted by "Arun Lakshman (Jira)" <ji...@apache.org> on 2026/02/25 22:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39161) INTERVAL WEEK, QUARTER has wron math - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/02/25 22:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39161) INTERVAL WEEK, QUARTER has wron math - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/02/25 22:36:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39162) The data of the custom partitioner is corrupted when unaligned checkpoint is enabled - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2026/02/25 23:51:00 UTC, 4 replies.
- [jira] [Created] (FLINK-39162) The data of the custom partitioner is corrupted during unaligned checkpoint - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2026/02/25 23:51:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-39136) GS file system fails to retry on certain 503's due to old GCS lib dependency - posted by "Jon Chase (Jira)" <ji...@apache.org> on 2026/02/26 01:55:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38340) Introduce the rescale timeline related abstraction for performing rescale operations - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2026/02/26 02:02:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38340) Introduce the rescale timeline related abstraction for performing rescale operations - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2026/02/26 02:03:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38973) Job ID assignment and matching based on name - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2026/02/26 02:21:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-39145) UnalignedCheckpointITCase.execute fails - IllegalStateException: Trying to access closed classloader - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/02/26 03:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39163) Support ML_PREDICT in Flink Python API - posted by "Biao Geng (Jira)" <ji...@apache.org> on 2026/02/26 03:26:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37951) Enable VariantSerializerUpgradeTest in Flink 2.2 - posted by "Jinkun Liu (Jira)" <ji...@apache.org> on 2026/02/26 04:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39164) Flaky test HistoryServerTest.testRemoveApplicationArchivesBeyondHistorySizeLimit - posted by "Yi Zhang (Jira)" <ji...@apache.org> on 2026/02/26 05:56:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-34415) Move away from Kafka-Zookeeper based tests in favor of Kafka-KRaft - posted by "Taranpreet Kaur (Jira)" <ji...@apache.org> on 2026/02/26 06:44:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-38956) Fix the job-overview Web UI cannot automatically show the latest edge name for AdaptiveScheduler - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/02/26 07:21:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-39150) Join operator crashes jobs when using custom types or custom type serializers - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2026/02/26 07:25:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39161) INTERVAL WEEK, QUARTER has wrong math - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/02/26 08:38:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-39161) INTERVAL WEEK, QUARTER has wrong math - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/02/26 08:39:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-39161) INTERVAL WEEK, QUARTER has wrong math - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/02/26 08:39:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39165) Concurrent FlinkDeployment and FlinkSessionJob upgrades lead to savepoint failure and state loss - posted by "Ihor Mielientiev (Jira)" <ji...@apache.org> on 2026/02/26 09:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39165) Concurrent FlinkDeployment and FlinkSessionJob upgrades lead to savepoint failure and state loss - posted by "Ihor Mielientiev (Jira)" <ji...@apache.org> on 2026/02/26 09:03:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-39130) Allow native types to be used for MetricConfig - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2026/02/26 09:07:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-39159) Using KeyedProcessFunction in batch mode reads events out of order - posted by "Grzegorz Liter (Jira)" <ji...@apache.org> on 2026/02/26 09:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39166) Add bucket level config parity - posted by "Samrat Deb (Jira)" <ji...@apache.org> on 2026/02/26 09:38:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39166) Add bucket level config parity - posted by "Samrat Deb (Jira)" <ji...@apache.org> on 2026/02/26 09:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39167) Initialize source output before emitting final watermark - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2026/02/26 10:20:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38585) Pyflink's thread mode may not work when using shipped venv.zip archive as virtual env - posted by "Biao Geng (Jira)" <ji...@apache.org> on 2026/02/26 11:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39168) improve mysql’s snapshot-split - posted by "Thorne (Jira)" <ji...@apache.org> on 2026/02/26 11:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39169) [mysql-connector] Use reader instances to run snapshots in clustered instances - posted by "Luca Occhipinti (Jira)" <ji...@apache.org> on 2026/02/26 11:11:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39169) [mysql-connector] Use reader instances to run snapshots - posted by "Luca Occhipinti (Jira)" <ji...@apache.org> on 2026/02/26 11:11:00 UTC, 3 replies.
- [jira] [Updated] (FLINK-39168) improve mysql’s snapshot-split - posted by "Thorne (Jira)" <ji...@apache.org> on 2026/02/26 11:18:00 UTC, 2 replies.
- [jira] [Updated] (FLINK-39168) improve mysql’s snapshot-split-Cache split.splitId() result in a local variable to avoid calling the method twice per iteration: - posted by "Thorne (Jira)" <ji...@apache.org> on 2026/02/26 11:22:00 UTC, 4 replies.
- [jira] [Commented] (FLINK-36356) HadoopRecoverableWriterTest.testRecoverWithState due to IOException - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2026/02/26 13:21:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-34415) Move away from Kafka-Zookeeper based tests in favor of Kafka-KRaft - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/02/26 13:56:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38403) UnalignedCheckpointITCase failed in test_cron_hadoop313 tests - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2026/02/26 13:58:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-39145) UnalignedCheckpointITCase.execute fails - IllegalStateException: Trying to access closed classloader - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2026/02/26 13:59:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-39145) UnalignedCheckpointITCase.execute fails - IllegalStateException: Trying to access closed classloader - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2026/02/26 14:00:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39145) UnalignedCheckpointITCase.execute fails - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2026/02/26 14:01:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-39135) Backport GSBlobStorageImpl precondition check to 1.20.4 - posted by "Jon Chase (Jira)" <ji...@apache.org> on 2026/02/26 14:52:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38225) GSBlobStorageImpl needs to add precondition check to make 503 retryable - posted by "Jon Chase (Jira)" <ji...@apache.org> on 2026/02/26 14:54:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-39135) Backport GSBlobStorageImpl precondition check to 1.20.4 - posted by "Jon Chase (Jira)" <ji...@apache.org> on 2026/02/26 14:55:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-39155) Add a check watermarks are defined in source for ERROR/NOTHING - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2026/02/26 15:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39170) [Table/SQL] Add async batch lookup join optimization for temporal table joins - posted by "featzhang (Jira)" <ji...@apache.org> on 2026/02/26 16:27:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39167) Initialize source output before emitting final watermark - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2026/02/26 16:50:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-39126) Support exporting metrics through grpc in batches - posted by "Aleksandr Iushmanov (Jira)" <ji...@apache.org> on 2026/02/26 18:56:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39134) UnalignedCheckpointFailureHandlingITCase.testCheckpointSuccessAfterFailure is flaky - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2026/02/26 23:23:00 UTC, 2 replies.
- [jira] [Commented] (FLINK-34644) RestServerEndpointITCase.testShouldWaitForHandlersWhenClosing failed with ConnectionClosedException - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/02/27 00:22:00 UTC, 3 replies.
- [jira] [Commented] (FLINK-39145) UnalignedCheckpointITCase.execute fails - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/02/27 00:23:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-39132) 'kubernetes Materialized Table test' failed because it could not not stop job - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/02/27 00:25:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38974) Handle jobs during HA recovery - posted by "Yi Zhang (Jira)" <ji...@apache.org> on 2026/02/27 02:07:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38974) Handle jobs in running applications during HA recovery - posted by "Yi Zhang (Jira)" <ji...@apache.org> on 2026/02/27 02:08:00 UTC, 1 replies.
- [jira] [Created] (FLINK-39171) Oracle pipeline transform fails with quoted uppercase projection columns - posted by "tianfy (Jira)" <ji...@apache.org> on 2026/02/27 03:14:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39171) Oracle pipeline transform fails with quoted uppercase projection columns - posted by "tianfy (Jira)" <ji...@apache.org> on 2026/02/27 03:19:00 UTC, 2 replies.
- [jira] [Created] (FLINK-39172) Flink Bash Scripts don't support the new yaml 1.2 syntax when reading from config.yaml - posted by "Ryan van Huuksloot (Jira)" <ji...@apache.org> on 2026/02/27 04:51:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39172) Flink Bash Scripts don't support the new yaml 1.2 syntax when reading from config.yaml - posted by "Ryan van Huuksloot (Jira)" <ji...@apache.org> on 2026/02/27 04:57:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38534) LocalRecoveryTest failed in test_cron_azure core - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/02/27 05:37:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38534) LocalRecoveryTest failed in test_cron_azure core - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/02/27 05:37:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38585) Pyflink's thread mode may not work when using shipped venv.zip archive as virtual env - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2026/02/27 05:48:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-38585) Pyflink's thread mode may not work when using shipped venv.zip archive as virtual env - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2026/02/27 05:55:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38585) Pyflink's thread mode may not work when using shipped venv.zip archive as virtual env - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2026/02/27 05:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39173) Support application-level blob storage - posted by "Yi Zhang (Jira)" <ji...@apache.org> on 2026/02/27 06:15:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-39022) Update default cipher suite value in SecurityOptions - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2026/02/27 06:48:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-39022) Update default cipher suite value in SecurityOptions - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2026/02/27 06:50:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-39022) Update default cipher suite value in SecurityOptions - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2026/02/27 06:50:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-39150) Join operator crashes jobs when using custom types or custom type serializers - posted by "Lei Yang (Jira)" <ji...@apache.org> on 2026/02/27 06:51:00 UTC, 1 replies.
- [jira] [Created] (FLINK-39174) Support lookup join after delta join - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2026/02/27 08:21:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-39175) Support calc that contains non-deterministic after delta join - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2026/02/27 08:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39175) Support calc that contains non-deterministic after delta join - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2026/02/27 08:22:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-39158) Minor polish for RestAPIStabilityTestUtils to reduce redundant lines - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/02/27 08:38:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-39166) Add bucket level config parity - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2026/02/27 09:04:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-39166) Add bucket level config parity - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2026/02/27 09:12:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-39134) UnalignedCheckpointFailureHandlingITCase.testCheckpointSuccessAfterFailure is flaky - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2026/02/27 09:23:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38613) UnalignedCheckpointRescaleWithMixedExchangesITCase.testRescaleFromUnalignedCheckpoint failed in test_cron_jdk11 tests - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2026/02/27 09:24:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-39167) Initialize source output before emitting final watermark - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2026/02/27 09:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39176) Introduce Node Health Management & Quarantine Framework for ResourceManager - posted by "featzhang (Jira)" <ji...@apache.org> on 2026/02/27 09:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39175) Allow calc that contains non-deterministic to consume duplicate changes - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2026/02/27 09:50:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39175) Allow calc that contains non-deterministic func to consume duplicate changes - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2026/02/27 09:51:00 UTC, 5 replies.
- [jira] [Resolved] (FLINK-38892) Introduce the scheduler and type information of the target job in the JobDetails(Info).java - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2026/02/27 09:57:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38892) Introduce the scheduler and type information of the target job in the JobDetails(Info).java - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2026/02/27 09:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39177) Add Flink 2.2 to operator e2es and bump example flink versions - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2026/02/27 10:37:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-39177) Add Flink 2.2 to operator e2es and bump example flink versions - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2026/02/27 11:17:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-39169) [mysql-connector] Use reader instances to run snapshots - posted by "Thorne (Jira)" <ji...@apache.org> on 2026/02/27 11:51:00 UTC, 3 replies.
- [jira] [Comment Edited] (FLINK-39169) [mysql-connector] Use reader instances to run snapshots - posted by "Thorne (Jira)" <ji...@apache.org> on 2026/02/27 11:53:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-39168) improve mysql’s snapshot-split-Cache split.splitId() result in a local variable to avoid calling the method twice per iteration: - posted by "Thorne (Jira)" <ji...@apache.org> on 2026/02/27 11:56:00 UTC, 1 replies.
- [jira] [Resolved] (FLINK-39168) improve mysql’s snapshot-split-Cache split.splitId() result in a local variable to avoid calling the method twice per iteration: - posted by "Thorne (Jira)" <ji...@apache.org> on 2026/02/27 11:57:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-39071) Select fields rather than * to read snapshot data in case of schema changes. - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2026/02/27 11:57:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-39168) improve mysql’s snapshot-split-Cache split.splitId() result in a local variable to avoid calling the method twice per iteration: - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2026/02/27 11:58:00 UTC, 0 replies.
- Re: [PR] Add Node.js CI workflow for testing [flink-web] - posted by "lalohdzhdz07-blip (via GitHub)" <gi...@apache.org> on 2026/02/28 02:18:57 UTC, 0 replies.
- Re: [PR] [FLINK-39164][history] Fix HistoryServerTest by adding delay to avoid identical archive timestamps [flink] - posted by "zhuzhurk (via GitHub)" <gi...@apache.org> on 2026/02/28 02:47:14 UTC, 0 replies.
- [jira] [Updated] (FLINK-39164) Flaky test HistoryServerTest.testRemoveApplicationArchivesBeyondHistorySizeLimit - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/28 02:48:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-39164) Flaky test HistoryServerTest.testRemoveApplicationArchivesBeyondHistorySizeLimit - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2026/02/28 02:49:00 UTC, 0 replies.
- [PR] Bump minimatch in /flink-runtime-web/web-dashboard [flink] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/02/28 02:56:37 UTC, 1 replies.
- Re: [I] [Feature] Support OpenAI latest Response API [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2026/02/28 03:27:07 UTC, 0 replies.
- [jira] [Created] (FLINK-39178) Support cascaded delta join - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2026/02/28 03:54:00 UTC, 0 replies.
- Re: [PR] [FLINK-39174][table-planner] Support lookup join after delta join [flink] - posted by "xuyangzhong (via GitHub)" <gi...@apache.org> on 2026/02/28 03:58:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-39174) Support lookup join after delta join - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/28 03:59:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-39178) Support cascaded delta join - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2026/02/28 04:09:00 UTC, 1 replies.
- Re: [PR] [FLINK-39175][table-planner] Allow calc that contains non-deterministic func to consume duplicate changes [flink] - posted by "xuyangzhong (via GitHub)" <gi...@apache.org> on 2026/02/28 04:21:44 UTC, 0 replies.
- [jira] [Closed] (FLINK-38977) Expose exceptions for applications - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2026/02/28 06:14:00 UTC, 0 replies.
- Re: [PR] [FLINK-38990][Runtime/Checkpointing] Support configurable initial delay for first checkpoint trigger [flink] - posted by "Myracle (via GitHub)" <gi...@apache.org> on 2026/02/28 07:53:00 UTC, 1 replies.
- Re: [PR] [FLINK-38974][runtime] Handle jobs in running applications during HA recovery [flink] - posted by "zhuzhurk (via GitHub)" <gi...@apache.org> on 2026/02/28 08:07:30 UTC, 1 replies.
- [jira] [Created] (FLINK-39179) Add REPLACE INTO filtering in handleQueryEvent to fix pt-table-checksum DML parsing failure - posted by "MengHui Yu (Jira)" <ji...@apache.org> on 2026/02/28 08:17:00 UTC, 0 replies.
- [PR] [FLINK-39179][mysql] Add REPLACE INTO filtering in handleQueryEvent to fix pt-table-checksum DML parsing [flink-cdc] - posted by "e-mhui (via GitHub)" <gi...@apache.org> on 2026/02/28 08:24:33 UTC, 0 replies.
- [jira] [Updated] (FLINK-39179) Add REPLACE INTO filtering in handleQueryEvent to fix pt-table-checksum DML parsing failure - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/28 08:25:00 UTC, 0 replies.
- [I] [Feature] Support python 3.12 [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2026/02/28 08:39:03 UTC, 0 replies.
- [PR] [infra] Support python 3.12. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2026/02/28 08:40:47 UTC, 0 replies.
- [jira] [Commented] (FLINK-39041) Rebuild REST API docs pages to supplement the missing content. - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/02/28 09:36:00 UTC, 0 replies.
- [PR] [FLINK-39163][python] Support ML_PREDICT in Python API [flink] - posted by "bgeng777 (via GitHub)" <gi...@apache.org> on 2026/02/28 09:38:54 UTC, 1 replies.
- [jira] [Updated] (FLINK-39163) Support ML_PREDICT in Flink Python API - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/28 09:39:00 UTC, 0 replies.
- [PR] [FLINK-39176][runtime] Integrate NodeHealthManager with Slot Filtering [flink] - posted by "featzhang (via GitHub)" <gi...@apache.org> on 2026/02/28 13:05:41 UTC, 1 replies.
- [jira] [Updated] (FLINK-39176) Introduce Node Health Management & Quarantine Framework for ResourceManager - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/02/28 13:06:00 UTC, 0 replies.
- [PR] Typo fix [flink-connector-http] - posted by "atpugtihsrah (via GitHub)" <gi...@apache.org> on 2026/02/28 13:07:22 UTC, 0 replies.
- [PR] [FLINK-39176][runtime] Add REST API for Node Quarantine [flink] - posted by "featzhang (via GitHub)" <gi...@apache.org> on 2026/02/28 13:20:11 UTC, 1 replies.
- [PR] [FLINK-39071][oracle-cdc] Fix Oracle pipeline connector wrong field case [flink-cdc] - posted by "Hisoka-X (via GitHub)" <gi...@apache.org> on 2026/02/28 13:21:36 UTC, 0 replies.
- Re: [PR] [FLINK-34644][runtime] Fix race condition in RestServerEndpoint shutdown [flink] - posted by "MartijnVisser (via GitHub)" <gi...@apache.org> on 2026/02/28 13:33:08 UTC, 0 replies.
- [jira] [Updated] (FLINK-34644) RestServerEndpointITCase.testShouldWaitForHandlersWhenClosing failed with ConnectionClosedException - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/02/28 13:34:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-34644) RestServerEndpointITCase.testShouldWaitForHandlersWhenClosing failed with ConnectionClosedException - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/02/28 13:34:00 UTC, 0 replies.
- [PR] [chore][test] Fix flaky postgres pipeline test case [flink-cdc] - posted by "Hisoka-X (via GitHub)" <gi...@apache.org> on 2026/02/28 13:36:07 UTC, 0 replies.
- [jira] [Resolved] (FLINK-34644) RestServerEndpointITCase.testShouldWaitForHandlersWhenClosing failed with ConnectionClosedException - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/02/28 13:45:00 UTC, 0 replies.
- [D] [Feature] Enhance the quickstart experience [flink-agents] - posted by "JinkunLiu (via GitHub)" <gi...@apache.org> on 2026/02/28 13:45:26 UTC, 3 replies.
- Re: [PR] [FLINK-3154][runtime] Upgrade from Kryo v2 + Chill 0.7.6 to Kryo v5 w… [flink] - posted by "holleyross80-ai (via GitHub)" <gi...@apache.org> on 2026/02/28 13:55:19 UTC, 0 replies.
- [jira] [Created] (FLINK-39180) RestClientTest.testRestClientClosedHandling fails with wrong assertion - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/02/28 13:56:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39180) RestClientTest.testRestClientClosedHandling fails with wrong assertion - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/02/28 13:57:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-39180) RestClientTest.testRestClientClosedHandling fails with wrong assertion - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/02/28 13:59:00 UTC, 0 replies.
- [PR] [FLINK-39180][tests] Fix flaky RestClientTest.testRestClientClosedHandling [flink] - posted by "MartijnVisser (via GitHub)" <gi...@apache.org> on 2026/02/28 14:03:51 UTC, 2 replies.
- [jira] [Commented] (FLINK-38223) ExecutionGraphRestartTest and ExecutionGraphCoLocationRestartTest are flaky on master - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/02/28 14:14:00 UTC, 0 replies.
- Re: [PR] [hotfix] Install yamale to allow CI Kubenetes linting to work [flink-kubernetes-operator] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2026/02/28 15:07:12 UTC, 0 replies.
- [PR] Add OpenAI Responses API integration [Java] [flink-agents] - posted by "addu390 (via GitHub)" <gi...@apache.org> on 2026/02/28 16:07:19 UTC, 0 replies.
- [PR] [FLINK-39176][runtime] Add configuration support for management blocklist [flink] - posted by "featzhang (via GitHub)" <gi...@apache.org> on 2026/02/28 16:19:11 UTC, 1 replies.