You are viewing a plain text version of this content. The canonical link for it is here.
- [DISCUSS] Extension to Flip 528 - Support COMPILE PLAN '/p' FOR EXECUTE syntax - posted by Ryan van Huuksloot via dev <de...@flink.apache.org> on 2026/05/01 03:56:26 UTC, 0 replies.
- [DISCUSS] Add a parser-aware SQL script splitting endpoint to the REST SQL Gateway - posted by Ryan van Huuksloot via dev <de...@flink.apache.org> on 2026/05/01 04:14:22 UTC, 0 replies.
- [jira] [Created] (FLINK-39586) CombinedWatermarkStatus.updateCombinedWatermark() fails to mark idle when partialWatermarks is empty - posted by "Chen Zhang (Jira)" <ji...@apache.org> on 2026/05/01 04:24:00 UTC, 0 replies.
- Re: [VOTE] Release 2.2.1, release candidate #2 - posted by Gustavo de Morais <gu...@gmail.com> on 2026/05/01 11:29:31 UTC, 2 replies.
- [jira] [Created] (FLINK-39587) [Web dashboard] Prettier rules not enforced in CI; cache hides drift - posted by "Purushottam Sinha (Jira)" <ji...@apache.org> on 2026/05/01 13:52:00 UTC, 0 replies.
- Re: [DISCUSS] Declarative Error Handling in Flink SQL via ON ERROR Clause - posted by Robin Moffatt via dev <de...@flink.apache.org> on 2026/05/01 14:45:28 UTC, 1 replies.
- [jira] [Created] (FLINK-39588) Migrate the DataGen table connector off deprecated source APIs - posted by "Dennis-Mircea Ciupitu (Jira)" <ji...@apache.org> on 2026/05/01 15:15:00 UTC, 0 replies.
- Re: [DISCUSS] Compress file benchmark regression resolution for Flink 2.3 release - posted by Hao Li <li...@gmail.com> on 2026/05/01 16:56:48 UTC, 2 replies.
- [jira] [Created] (FLINK-39589) Window TVF aggregation emits incorrect results with RocksDB state backend - posted by "Kanchi Masalia (Jira)" <ji...@apache.org> on 2026/05/01 17:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39590) Connection catalog manager changes - posted by "Hao Li (Jira)" <ji...@apache.org> on 2026/05/01 17:45:00 UTC, 0 replies.
- [DISCUSS] FLIP-XXX: Top-N Job Health Dashboard in the Web UI - posted by FeatZhang <fe...@apache.org> on 2026/05/02 17:51:42 UTC, 0 replies.
- Re: [DISCUSS] FLINK-39455: Add support for Java based AssociativeMergeOperator via JNI  - posted by Soumitra Kumar <ku...@gmail.com> on 2026/05/02 23:31:28 UTC, 0 replies.
- Re: [VOTE] Release 1.20.4, release candidate #1 - posted by Sergey Nuyanzin <sn...@gmail.com> on 2026/05/03 07:42:27 UTC, 3 replies.
- [jira] [Created] (FLINK-39591) Bump actions v4 to v5 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/05/03 17:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39592) Optimize connection to redis cluster - posted by "Samrat Deb (Jira)" <ji...@apache.org> on 2026/05/03 17:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39593) Structurally use FetchManager for source - posted by "Samrat Deb (Jira)" <ji...@apache.org> on 2026/05/03 17:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39594) Add MetricGroup support for redis-streams source - posted by "Samrat Deb (Jira)" <ji...@apache.org> on 2026/05/03 18:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39595) Use GHA cache per branch - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/05/03 18:29:00 UTC, 0 replies.
- [VOTE] Release 2.2.1, release candidate #3 - posted by Sergey Nuyanzin <sn...@gmail.com> on 2026/05/03 18:38:50 UTC, 9 replies.
- Re: [VOTE] Release 2.1.2, release candidate #1 - posted by Sergey Nuyanzin <sn...@gmail.com> on 2026/05/03 18:41:59 UTC, 1 replies.
- [jira] [Created] (FLINK-39596) Watermark Strategy for redis-stream source - posted by "Samrat Deb (Jira)" <ji...@apache.org> on 2026/05/03 18:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39597) Make consumer-group as required field for connector - posted by "Samrat Deb (Jira)" <ji...@apache.org> on 2026/05/03 18:51:00 UTC, 0 replies.
- [VOTE] Release 2.1.2, release candidate #2 - posted by Sergey Nuyanzin <sn...@gmail.com> on 2026/05/03 18:52:39 UTC, 9 replies.
- [jira] [Created] (FLINK-39598) Update jline to 3.30.9 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/05/03 19:04:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing - posted by Jark Wu <im...@gmail.com> on 2026/05/04 04:14:48 UTC, 22 replies.
- [jira] [Created] (FLINK-39599) Expose pendingRecords metrics in FLINK Kinesis Connector - posted by "David (Jira)" <ji...@apache.org> on 2026/05/04 06:47:00 UTC, 0 replies.
- [VOTE] Apache Flink Kubernetes Operator Release 1.15.0, release candidate #1 - posted by Gyula Fóra <gy...@gmail.com> on 2026/05/04 08:27:56 UTC, 5 replies.
- [RESULT] [VOTE] Release 1.20.4, release candidate #1 - posted by Sergey Nuyanzin <sn...@gmail.com> on 2026/05/04 10:56:25 UTC, 0 replies.
- [VOTE] FLIP-572: Introduce Flink-Kafka Transactions Management Tool - posted by Aleksandr Savonin <sa...@gmail.com> on 2026/05/04 12:02:55 UTC, 9 replies.
- Re: [DISCUSS] FLIP-562: Topic integrity checks in Kafka Connector - posted by Aleksandr Savonin <sa...@gmail.com> on 2026/05/04 12:10:11 UTC, 2 replies.
- Re: Flink Kubernetes Operator 1.15.0 release planning - posted by Ryan van Huuksloot via dev <de...@flink.apache.org> on 2026/05/04 14:13:24 UTC, 1 replies.
- Re: [DISCUSS] FLIP-572: Introduce Flink-Kafka Transactions Management Tool - posted by Ryan van Huuksloot via dev <de...@flink.apache.org> on 2026/05/04 14:33:40 UTC, 4 replies.
- [DISCUSS] FLINK-25672: FileSource enumerator remembers paths of all already processed files - posted by Sophia Izokun via dev <de...@flink.apache.org> on 2026/05/04 15:09:20 UTC, 0 replies.
- [jira] [Created] (FLINK-39600) FLIP-568: Strict BYTES-to-STRING CAST with UTF-8 Validation Utilities - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2026/05/04 15:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39601) Add UTF-8 validation utilities and StringData.fromUtf8Bytes connector API - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2026/05/04 15:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39602) Add IS_VALID_UTF8 and MAKE_VALID_UTF8 built-in functions - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2026/05/04 15:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39603) Optimize NativeS3InputStream via seeks and reduce IOPS - posted by "Samrat Deb (Jira)" <ji...@apache.org> on 2026/05/04 17:35:00 UTC, 0 replies.
- Re: FLIP-504: Blue/Green Deployments for Flink on Kubernetes - Phase 2 (WIP/Draft PR) - posted by Sergio Chong Loo <sc...@apple.com> on 2026/05/04 17:56:58 UTC, 1 replies.
- [DISCUSS] Request for help with publishing docker images - posted by Sergey Nuyanzin <sn...@gmail.com> on 2026/05/04 21:39:58 UTC, 1 replies.
- [jira] [Created] (FLINK-39604) Extend DESCRIBE FUNCTION EXTENDED to support PTF fields - posted by "Natea Eshetu Beshada (Jira)" <ji...@apache.org> on 2026/05/04 21:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39605) Implement Avro Variant Confluent format for dynamic schema deserialization - posted by "Swapna Marru (Jira)" <ji...@apache.org> on 2026/05/05 00:18:00 UTC, 0 replies.
- [DISCUSS] FLIP-XXX Support ReducingMergeState and AggregatingMergeState backed by Java based associative merge operators - posted by Soumitra Kumar <ku...@gmail.com> on 2026/05/05 03:49:54 UTC, 5 replies.
- [jira] [Created] (FLINK-39606) Allow callers of ShowCreateUtil.buildShowCreateMaterializedTableRow to suppress FRESHNESS and REFRESH_MODE clauses - posted by "Ramin Gharib (Jira)" <ji...@apache.org> on 2026/05/05 09:48:00 UTC, 0 replies.
- [DISCUSS] FLIP-576 Filesystem-Plugin Observability (flink-s3-fs-native) - posted by Samrat Deb <de...@gmail.com> on 2026/05/05 09:57:20 UTC, 11 replies.
- [DISCUSS] Release flink-connector-pulsar for Flink 1.20 - posted by Ferenc Csaky <fe...@pm.me> on 2026/05/05 16:29:49 UTC, 1 replies.
- [jira] [Created] (FLINK-39607) Add right Nullable annotation and precondition for config - posted by "Samrat Deb (Jira)" <ji...@apache.org> on 2026/05/05 17:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39608) KafkaDatasetFacet should extend DatasetConfigFacet to avoid classloader issues with OpenLineage - posted by "Swapna Marru (Jira)" <ji...@apache.org> on 2026/05/05 17:49:00 UTC, 0 replies.
- Hackathon at Community Over Code Glasgow — is Flink interested? - posted by Rich Bowen <rb...@rcbowen.com> on 2026/05/05 19:23:08 UTC, 1 replies.
- [jira] [Created] (FLINK-39609) update Dynamic Kafka Source doc with new python/sql examples and other improvement details - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2026/05/05 22:56:00 UTC, 0 replies.
- [SUMMARY] Release 2.3 sync, blocked on cross-team testing - posted by David Anderson <da...@apache.org> on 2026/05/06 02:22:00 UTC, 3 replies.
- [jira] [Created] (FLINK-39610) Mongo CDC connector supports specifying SSL context - posted by "Xiqian Yu (Jira)" <ji...@apache.org> on 2026/05/06 03:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39611) [Model] Add sequence ID auto-increment support for Triton inference - posted by "featzhang (Jira)" <ji...@apache.org> on 2026/05/06 04:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39612) [Model] Add HTTP connection pool management for Triton inference - posted by "featzhang (Jira)" <ji...@apache.org> on 2026/05/06 04:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39613) Flink pipeline cdc primary-keys / partition-keys cannot resolve backtick-quoted identifiers that are used as projection aliases - posted by "Ran Tao (Jira)" <ji...@apache.org> on 2026/05/06 06:25:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-XXX: Filter-Aware Source Reuse in Table Planner - posted by Hongshun Wang <lo...@gmail.com> on 2026/05/06 07:36:48 UTC, 1 replies.
- Re:Re: [DISCUSS] FLIP-XXX: Support Watermark Definition in SQL Views - posted by Xuyang <xy...@163.com> on 2026/05/06 08:38:33 UTC, 8 replies.
- [ANNOUNCE] Apache Flink 1.20.4 released - posted by Sergey Nuyanzin <sn...@gmail.com> on 2026/05/06 10:45:53 UTC, 6 replies.
- [ANNOUNCE] New Apache Flink PMC Member – David Anderson - posted by Timo Walther <tw...@apache.org> on 2026/05/06 13:15:33 UTC, 22 replies.
- [jira] [Created] (FLINK-39614) Support TO_CHANGELOG: retract stream -> retract stream with set semantics - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2026/05/06 13:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39615) Translate documentation in changelog.md to chinese - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2026/05/06 14:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39616) Add instructions on how to fix ordering with ORDER BY when using FROM_CHANGELOG - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2026/05/06 14:55:00 UTC, 0 replies.
- [FLINK-30514] Review request for HybridSourceReader bug fix - posted by yu...@gmail.com on 2026/05/06 15:02:25 UTC, 1 replies.
- Re: [VOTE] Release 2.0.2, release candidate #4 - posted by Fabian Hueske <fh...@apache.org> on 2026/05/06 15:49:06 UTC, 6 replies.
- [jira] [Created] (FLINK-39617) Add batch REST endpoints for aggregated subtask metrics across multiple job vertices - posted by "Herbert Wang (Jira)" <ji...@apache.org> on 2026/05/06 16:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39618) FlinkDeployment deletion deadlocks when FlinkSessionJobs are running with default block-on-* options - posted by "Dennis-Mircea Ciupitu (Jira)" <ji...@apache.org> on 2026/05/06 18:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39619) Add release note for flink 2.3 release - posted by "Hao Li (Jira)" <ji...@apache.org> on 2026/05/06 21:47:01 UTC, 0 replies.
- [jira] [Created] (FLINK-39620) Cumulative window re-emits old windows after recovery due to stale InternalTimerService.currentWatermark in GlobalAggCombiner - posted by "haiqingchen (Jira)" <ji...@apache.org> on 2026/05/07 02:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39621) Incremental-snapshot based sources may get stuck in binlog-backfill stage - posted by "Xiqian Yu (Jira)" <ji...@apache.org> on 2026/05/07 03:02:00 UTC, 0 replies.
- 退订 - posted by "18889827342@139.com" <18...@139.com> on 2026/05/07 08:35:48 UTC, 0 replies.
- [VOTE] Apache Flink Kubernetes Operator Release 1.15.0, release candidate #2 - posted by Gyula Fóra <gy...@gmail.com> on 2026/05/07 11:05:19 UTC, 6 replies.
- [jira] [Created] (FLINK-39622) [postgres] CustomPostgresSchema re-reads JDBC metadata for every split, causing O(N²) snapshot startup - posted by "Tomás Miguez (Jira)" <ji...@apache.org> on 2026/05/07 15:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39623) Strict UTF-8 validation in CAST(BYTES AS STRING) - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2026/05/07 15:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39624) `TtlListState.asyncGet()` returns a non-null wrapper around a null inner iterator, causing NPE in `onNext`/`isEmpty` when the state is empty - posted by "Csanád Bakos (Jira)" <ji...@apache.org> on 2026/05/07 18:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39625) Support GPU-based model inference via sidecar/actor pattern - posted by "featzhang (Jira)" <ji...@apache.org> on 2026/05/08 00:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39626) Extend ResourceProfile to declare GPU resources on TaskManager - posted by "featzhang (Jira)" <ji...@apache.org> on 2026/05/08 00:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39627) Introduce flink-gpu-sidecar module with service skeleton - posted by "featzhang (Jira)" <ji...@apache.org> on 2026/05/08 00:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39628) Implement asynchronous batched inference RPC in GPU sidecar - posted by "featzhang (Jira)" <ji...@apache.org> on 2026/05/08 00:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39630) Schedule GPU-affinity operators via ResourceManager - posted by "featzhang (Jira)" <ji...@apache.org> on 2026/05/08 00:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39629) Add Async I/O operator that invokes GPU sidecar from DataStream API - posted by "featzhang (Jira)" <ji...@apache.org> on 2026/05/08 00:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39631) Integrate GPU sidecar inference with Table/SQL and provide end-to-end example - posted by "featzhang (Jira)" <ji...@apache.org> on 2026/05/08 00:21:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-XXX: Support Window Stagger in FlinkSQL and introduce KEY_BASED deterministic stagger - posted by Feng Jin <ji...@gmail.com> on 2026/05/08 02:16:57 UTC, 6 replies.
- [jira] [Created] (FLINK-39632) Add fromChangelog() / toChangelog() convenience methods to PartitionedTable - posted by "Ramin Gharib (Jira)" <ji...@apache.org> on 2026/05/08 06:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39633) PostgreSQL CDC backfill throws NullPointerException when WAL stream carries records for other captured tables - posted by "Di Wu (Jira)" <ji...@apache.org> on 2026/05/08 07:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39634) Savepoint Table API connector incorrectly infers map state key type - posted by "Ilya Soin (Jira)" <ji...@apache.org> on 2026/05/08 09:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39635) [security] Support comma-separated list in security.ssl.protocol - posted by "Imre Balassa (Jira)" <ji...@apache.org> on 2026/05/08 09:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39636) Add "produces_full_deletes" parameter in TO_CHANGELOG - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2026/05/08 13:22:00 UTC, 0 replies.
- Re: [VOTE] FLIP-570: Support Runtime Data Sampling for Operators with WebUI Visualization - posted by Yuepeng Pan <hi...@gmail.com> on 2026/05/08 13:57:44 UTC, 3 replies.
- [jira] [Created] (FLINK-39637) Filter push-down for the savepoint table connector - posted by "Ilya Soin (Jira)" <ji...@apache.org> on 2026/05/08 14:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39638) Make codegen reuse result of JSON parse in JSON_VALUE, JSON_QUERY - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/05/08 14:13:00 UTC, 0 replies.
- Help Needed for Release2.3: Confirm Cross-Team Testing for FLINK-39464 & FLINK-39461 - posted by Yuepeng Pan <hi...@gmail.com> on 2026/05/08 14:51:16 UTC, 0 replies.
- [jira] [Created] (FLINK-39639) Split assignment accepted after source finished reading leads to silent data loss - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2026/05/08 15:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39640) Bump Flink 1.20.0 to 1.20.3 and upgrade maven-shade-plugin to 3.6.0 - posted by "Jayesh Lalwani (Jira)" <ji...@apache.org> on 2026/05/08 17:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39641) Fix unstable position of the Rescales tab - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/05/09 02:13:00 UTC, 0 replies.
- [DISCUSS] FLIP-XXX: Support Pluggable Storage Backend for HistoryServer - posted by zihao chen <is...@gmail.com> on 2026/05/09 03:37:08 UTC, 5 replies.
- [DISCUSS] FLIP-XXX: Introduce Lazy Loading for HistoryServer - posted by zihao chen <is...@gmail.com> on 2026/05/09 03:43:22 UTC, 4 replies.
- [jira] [Created] (FLINK-39642) Fix Illegal argument error message - posted by "Samrat Deb (Jira)" <ji...@apache.org> on 2026/05/09 07:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39643) [docs] Fix and improve MongoDB connector documentation - posted by "featzhang (Jira)" <ji...@apache.org> on 2026/05/09 12:30:00 UTC, 0 replies.
- [RESULT][VOTE] Release 2.0.2, release candidate #4 - posted by Sergey Nuyanzin <sn...@gmail.com> on 2026/05/09 18:22:07 UTC, 0 replies.
- [jira] [Created] (FLINK-39644) Upgrade aws sdk version to 2.44.x to add enhanced S3 Transfer Manager performance - posted by "Samrat Deb (Jira)" <ji...@apache.org> on 2026/05/10 04:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39645) HybridSourceReader.snapshotState() loses recovered splits when currentReader is null - posted by "Chen Zhang (Jira)" <ji...@apache.org> on 2026/05/10 06:13:00 UTC, 1 replies.
- [jira] [Created] (FLINK-39646) Update flink-python-example to Flink 2.2 - posted by "Aleksandr Savonin (Jira)" <ji...@apache.org> on 2026/05/10 19:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39647) Upgrade presto hive - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/05/10 21:44:00 UTC, 0 replies.
- [DISSCUSS] FLIP-XXX: Async MongoDB Sink with Error Classification and Shared Connection Pool - posted by FeatZhang <fe...@apache.org> on 2026/05/11 05:30:28 UTC, 1 replies.
- [jira] [Created] (FLINK-39648) Validate literal regex patterns at plan time and stop logging on the hot path for the regex function family - posted by "Ramin Gharib (Jira)" <ji...@apache.org> on 2026/05/11 07:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39649) REGEXP_EXTRACT plan-time validation and hot-path log cleanup - posted by "Ramin Gharib (Jira)" <ji...@apache.org> on 2026/05/11 07:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39650) REGEXP_REPLACE does not validate literal regex patterns at plan time, recompiles per record, and logs errors on the hot path - posted by "Ramin Gharib (Jira)" <ji...@apache.org> on 2026/05/11 07:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39651) REGEXP predicate does not validate literal regex patterns at plan time and logs errors on the hot path - posted by "Ramin Gharib (Jira)" <ji...@apache.org> on 2026/05/11 07:40:00 UTC, 0 replies.
- [DISCUSS] Status of the Azure CI → GitHub Actions migration (FLINK-33901) - posted by Michele Guerriero <mi...@gmail.com> on 2026/05/11 07:41:40 UTC, 1 replies.
- [jira] [Created] (FLINK-39652) Improve documentation for regexp functions - posted by "Ramin Gharib (Jira)" <ji...@apache.org> on 2026/05/11 07:42:00 UTC, 0 replies.
- [ANNOUNCE] Apache Flink 2.0.2 released - posted by Sergey Nuyanzin <sn...@gmail.com> on 2026/05/11 08:06:13 UTC, 1 replies.
- [RESULT][VOTE] Release 2.1.2, release candidate #2 - posted by Sergey Nuyanzin <sn...@gmail.com> on 2026/05/11 08:09:12 UTC, 0 replies.
- [jira] [Created] (FLINK-39653) [Connectors/Opensearch] Move to Flink to 2.0.0 - Fix Violations of ArchUnit architecture rule enforced in Flink 2.x - posted by "Taranpreet Kaur (Jira)" <ji...@apache.org> on 2026/05/11 11:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39654) Add JDK 25 CI test lane - posted by "Junqing Li (Jira)" <ji...@apache.org> on 2026/05/11 11:36:00 UTC, 0 replies.
- [ANNOUNCE] Apache Flink 2.1.2 released - posted by Sergey Nuyanzin <sn...@gmail.com> on 2026/05/11 12:30:22 UTC, 1 replies.
- [RESULT][VOTE] Release 2.2.1, release candidate #3 - posted by Sergey Nuyanzin <sn...@gmail.com> on 2026/05/11 12:38:22 UTC, 0 replies.
- Re: [DISCUSS] FLIP-569: Sunset the Stateful Functions (StateFun) Sub-project - posted by Oleksandr Kazimirov <ka...@gmail.com> on 2026/05/11 18:50:44 UTC, 0 replies.
- [jira] [Created] (FLINK-39655) Remove deprecated CatalogLock and ManagedTable APIs (FLIP-346) - posted by "Jayesh Lalwani (Jira)" <ji...@apache.org> on 2026/05/11 23:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39656) Remove legacy getTableFactory() override - posted by "Jayesh Lalwani (Jira)" <ji...@apache.org> on 2026/05/11 23:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39657) Migrate CatalogTable.of() to CatalogTable.newBuilder() - posted by "Jayesh Lalwani (Jira)" <ji...@apache.org> on 2026/05/11 23:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39658) Upgrade flink-connector-hive from Flink 2.0-preview1 to Flink 2.0.x - posted by "Jayesh Lalwani (Jira)" <ji...@apache.org> on 2026/05/11 23:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39659) Add JDK 17 test support with proper --add-opens documentation - posted by "Jayesh Lalwani (Jira)" <ji...@apache.org> on 2026/05/11 23:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39660) Kinesis Connector - Cascading failure in EFO subscription lifecycle - posted by "Chenyuan Lee (Jira)" <ji...@apache.org> on 2026/05/12 01:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39661) Support all converters for standalone ALTER MATERIALIZED TABLE statements - posted by "Ramin Gharib (Jira)" <ji...@apache.org> on 2026/05/12 08:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39662) Support ALTER MATERIALIZED TABLE ... SET ('k' = 'v') conversion - posted by "Ramin Gharib (Jira)" <ji...@apache.org> on 2026/05/12 08:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39663) Support ALTER MATERIALIZED TABLE ... RESET ('k') conversion - posted by "Ramin Gharib (Jira)" <ji...@apache.org> on 2026/05/12 08:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39664) Support ALTER MATERIALIZED TABLE ... SET FRESHNESS = ... conversion - posted by "Ramin Gharib (Jira)" <ji...@apache.org> on 2026/05/12 08:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39665) Support ALTER MATERIALIZED TABLE ... SET REFRESH_MODE = FULL | CONTINUOUS conversion - posted by "Ramin Gharib (Jira)" <ji...@apache.org> on 2026/05/12 08:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39666) Fix TO_TIMESTAMP_LTZ multiple edge-case bugs in precision handling - posted by "Ramin Gharib (Jira)" <ji...@apache.org> on 2026/05/12 10:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39667) NGINX Ingress Retirement - posted by "Dominik (Jira)" <ji...@apache.org> on 2026/05/12 12:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39668) Add get kafka offsets SQL table function - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2026/05/12 14:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39669) BatchPhysicalCorrelateRule / StreamPhysicalCorrelateRule drop right-side projection when a Calc sits between Correlate and TableFunctionScan - posted by "Venkata krishnan Sowrirajan (Jira)" <ji...@apache.org> on 2026/05/12 17:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39670) Bump Flink-controlled Java dependencies to resolve CVEs Part 2 (kafka-clients, okhttp, zookeeper, wiremock) - posted by "Purushottam Sinha (Jira)" <ji...@apache.org> on 2026/05/12 17:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39671) Adopt jackson-bom in flink-model-triton for unified version management - posted by "Purushottam Sinha (Jira)" <ji...@apache.org> on 2026/05/12 18:18:00 UTC, 0 replies.
- [VOTE] Release flink-connector-kafka v5.0.0, release candidate #1 - posted by Ferenc Csaky <fe...@pm.me> on 2026/05/12 21:50:56 UTC, 8 replies.
- [jira] [Created] (FLINK-39672) Update doc about Java Records - posted by "Mingliang Liu (Jira)" <ji...@apache.org> on 2026/05/12 23:10:00 UTC, 0 replies.
- [SUMMARY] Release 2.3 SYNC: In Creating RC0 and Cross-team Testing - posted by Yuepeng Pan <hi...@gmail.com> on 2026/05/13 04:42:36 UTC, 0 replies.
- [jira] [Created] (FLINK-39673) SQL jobs may ignore user-configured claim mode with deprecated config key - posted by "Han Yin (Jira)" <ji...@apache.org> on 2026/05/13 06:01:00 UTC, 0 replies.
- [DISCUSS] FLIP-578: In-place Table to Materialized Table conversion - posted by Ramin Gharib <ra...@gmail.com> on 2026/05/13 10:57:08 UTC, 8 replies.
- [jira] [Created] (FLINK-39674) flink-avro-confluent-registry uses an obsolete schema registry client - posted by "Alex Rovner (Jira)" <ji...@apache.org> on 2026/05/13 11:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39675) http-generic-json-url query param configuration not required. - posted by "David Radley (Jira)" <ji...@apache.org> on 2026/05/13 12:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39676) Add documentation for specifying Query Creators - posted by "Nic Townsend (Jira)" <ji...@apache.org> on 2026/05/13 14:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39677) ARRAY_SORT fails at runtime with "Comparison method violates its general contract!" on arrays with duplicate elements - posted by "Jim Hughes (Jira)" <ji...@apache.org> on 2026/05/13 17:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39678) Connection factory discovery through SPI - posted by "Hao Li (Jira)" <ji...@apache.org> on 2026/05/13 17:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39679) Error with implicit casting - posted by "Alan Sheinberg (Jira)" <ji...@apache.org> on 2026/05/13 17:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39680) Enable unaligned checkpoint for pointwise connection by FORCE_UNALIGNED - posted by "Gen Luo (Jira)" <ji...@apache.org> on 2026/05/14 11:41:00 UTC, 0 replies.
- [VOTE] Release flink-connector-pulsar v4.2.0, release candidate #1 - posted by Ferenc Csaky <fe...@pm.me> on 2026/05/14 12:33:50 UTC, 4 replies.
- [VOTE] FLIP-576 Filesystem-Plugin Observability (flink-s3-fs-native) - posted by Samrat Deb <de...@gmail.com> on 2026/05/14 12:52:08 UTC, 3 replies.
- [jira] [Created] (FLINK-39681) Bump flink to 2.2.1 - posted by "Fan Deng (Jira)" <ji...@apache.org> on 2026/05/15 03:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39682) Unable to invoke TO_DATE with TIMESTAMP types - posted by "Xiqian Yu (Jira)" <ji...@apache.org> on 2026/05/15 07:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39683) Publish the flink-cdc-dist jar to the Maven repository - posted by "melin (Jira)" <ji...@apache.org> on 2026/05/15 08:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39684) YAML PaimonWriter throws NullPointerException when handling REPLACE event - posted by "Xiqian Yu (Jira)" <ji...@apache.org> on 2026/05/15 08:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39685) Redact sensitive options in SHOW CREATE and DESCRIBE CATALOG statements - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2026/05/15 09:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39686) URI used as URL in SessionContext causes ArrayStoreException - posted by "wangzhao (Jira)" <ji...@apache.org> on 2026/05/15 10:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39687) URI used as URL in SessionContext causes ArrayStoreException - posted by "wangzhao (Jira)" <ji...@apache.org> on 2026/05/15 10:05:00 UTC, 0 replies.
- [NOTICE] Removal of Apache Flink 1.13.0-1.13.5 from PyPI - posted by Sergey Nuyanzin <sn...@gmail.com> on 2026/05/15 10:17:48 UTC, 1 replies.
- [jira] [Created] (FLINK-39688) Share a single PluginManager across operator and webhook startup - posted by "Dennis-Mircea Ciupitu (Jira)" <ji...@apache.org> on 2026/05/15 12:10:00 UTC, 0 replies.
- [ANNOUNCE] Apache Flink 2.2.1 released - posted by Sergey Nuyanzin <sn...@apache.org> on 2026/05/15 14:26:59 UTC, 0 replies.
- [DISCUSS] FLIP-579: LATERAL SNAPSHOT Join - posted by Fabian Hueske <fh...@apache.org> on 2026/05/15 14:38:42 UTC, 8 replies.
- CVE-2026-35194: Apache Flink: Remote code execution via SQL injection in code generation - posted by Martijn Visser <ma...@apache.org> on 2026/05/15 15:06:51 UTC, 0 replies.
- [jira] [Created] (FLINK-39689) Standardize the place holders characters used in http-generic-json-url query creator to use {{ and }} - posted by "David Radley (Jira)" <ji...@apache.org> on 2026/05/15 15:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39690) Use imgae from official hugo images - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/05/15 19:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39691) Fix "mim" typo in AggregatedMetric.toString() in operator and autoscaler-standalone modules - posted by "Pavel Zeger (Jira)" <ji...@apache.org> on 2026/05/16 10:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39692) Several catch blocks log the message but discard the captured exception - posted by "Pavel Zeger (Jira)" <ji...@apache.org> on 2026/05/16 10:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39693) Bump jackson, log4j, assertj to address CVEs - posted by "Purushottam Sinha (Jira)" <ji...@apache.org> on 2026/05/16 14:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39694) Outer join on nested field fails with Conversion to relational algebra failed to preserve datatypes - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/05/17 11:05:07 UTC, 0 replies.
- [jira] [Created] (FLINK-39695) Outer join on nested field fails with Conversion to relational algebra failed to preserve datatypes - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/05/17 11:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39696) Distributed SchemaOperator emits FlushEvent with schema operator subtaskId instead of upstream sourcePartition - posted by "Ran Tao (Jira)" <ji...@apache.org> on 2026/05/18 02:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39697) Update Pulsar connector to Flink 2.2.1 - posted by "Fan Deng (Jira)" <ji...@apache.org> on 2026/05/18 07:32:00 UTC, 0 replies.
- [DISCUSS] FLINK-36456 — Datadog reporter: support DD_API_KEY env var - posted by Thierno BARRY via dev <de...@flink.apache.org> on 2026/05/18 07:59:30 UTC, 1 replies.
- [jira] [Created] (FLINK-39698) Fix incorrect content in SQLServer CDC connector documentation - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2026/05/18 09:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39699) Kafka connector CI failed on the main branch - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2026/05/18 10:19:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-XXX: Expose per downstream target numRecordsOut metric - posted by Dennis-Mircea Ciupitu <de...@gmail.com> on 2026/05/18 12:23:39 UTC, 1 replies.
- [jira] [Created] (FLINK-39700) Fix name-based column matching in materialized table schema diff - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2026/05/18 12:27:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-XXX: Composable Parallelism Alignment Modes for Flink Autoscaler - posted by Dennis-Mircea Ciupitu <de...@gmail.com> on 2026/05/18 12:35:23 UTC, 0 replies.
- [jira] [Created] (FLINK-39701) Fix Concurrency Annotation in native-s3-fs - posted by "Samrat Deb (Jira)" <ji...@apache.org> on 2026/05/18 13:20:00 UTC, 0 replies.
- [RESULT] [VOTE] FLIP-572: Introduce Flink-Kafka Transactions Management Tool - posted by Aleksandr Savonin <sa...@gmail.com> on 2026/05/18 18:20:29 UTC, 0 replies.
- [jira] [Created] (FLINK-39702) Exclude netty 3.x from hadoop - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/05/18 19:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39703) Fix flaky KafkaWriterFaultToleranceITCase#testFlushExceptionWhenKafkaUnavailable - posted by "Aleksandr Savonin (Jira)" <ji...@apache.org> on 2026/05/18 20:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39704) Kubernetes HA can recover a globally terminal FAILED application job after leadership revoke/reacquire - posted by "Prashant Bhardwaj (Jira)" <ji...@apache.org> on 2026/05/18 21:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39705) Remove not needed ZooKeeper references from flink-connector-kafka - posted by "Aleksandr Savonin (Jira)" <ji...@apache.org> on 2026/05/18 21:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39706) Remove flink 2.1 testing from es connector main branch - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2026/05/19 03:45:00 UTC, 0 replies.
- State TTL support gap in DataStream API V2 (FLINK-34547) - posted by khertz11 <kh...@proton.me> on 2026/05/19 10:23:38 UTC, 0 replies.
- [jira] [Created] (FLINK-39707) Update Flink Connector OpenSearch to Flink Connector Parent POM 2.0 - posted by "Mukul Gupta (Jira)" <ji...@apache.org> on 2026/05/19 11:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39708) Support TO_CHANGELOG retract/upsert stream -> upsert stream with set semantics - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2026/05/19 12:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39709) Update documentation for native-s3-fs - posted by "Samrat Deb (Jira)" <ji...@apache.org> on 2026/05/19 13:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39710) Release Testing: Verify FLIP-565: Improve ProcessTableFunctions for late data handling and state access - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/05/19 13:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39711) Allow setting maxExceptions on JobExceptionsMessageParameters / ApplicationExceptionsMessageParameters - posted by "Aleksandr Savonin (Jira)" <ji...@apache.org> on 2026/05/19 18:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39712) Fix flaky DynamicKafkaSourceITTest - posted by "Aleksandr Savonin (Jira)" <ji...@apache.org> on 2026/05/19 18:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39713) flink-kubernetes-operator: Bump log4j, jackson, and Beam to retire CVEs - posted by "Purushottam Sinha (Jira)" <ji...@apache.org> on 2026/05/19 19:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39714) Backport AGENTS.md to active branches 1.20, 2.0, and 2.2 - posted by "Mingliang Liu (Jira)" <ji...@apache.org> on 2026/05/19 21:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39715) [Table/Planner] IndexOutOfBoundsException in FlinkExpandConversionRule for ORDER BY followed by global aggregate in batch mode - posted by "Yaoxuan Wu (Jira)" <ji...@apache.org> on 2026/05/19 22:58:00 UTC, 0 replies.
- [SUMMARY] Release 2.3 sync - posted by Hao Li <li...@gmail.com> on 2026/05/19 23:53:19 UTC, 2 replies.
- [jira] [Created] (FLINK-39716) ES timeout related config used the wrong time unit - posted by "reswqa (Jira)" <ji...@apache.org> on 2026/05/20 06:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39717) Document SET/RESET key handling for ALTER TABLE, CATALOG, MODEL and DATABASE - posted by "Ramin Gharib (Jira)" <ji...@apache.org> on 2026/05/20 07:31:00 UTC, 0 replies.
- Flink CEP: can CEP reliably implement "condition true for T minutes" ? - posted by rohit patil <ro...@gmail.com> on 2026/05/20 08:46:49 UTC, 1 replies.
- [jira] [Created] (FLINK-39718) [pipeline][paimon] Paimon sink fails with distributed source when target table does not exist - posted by "Ran Tao (Jira)" <ji...@apache.org> on 2026/05/20 09:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39719) TemporalRowTimeJoinOperator produces wrong results for late probe-side records - posted by "Fabian Hueske (Jira)" <ji...@apache.org> on 2026/05/20 10:56:00 UTC, 0 replies.
- 回复：[DISCUSS] FLIP-XXX: Support Window Stagger in FlinkSQL and introduce KEY_BASED deterministic stagger - posted by rocxing <ro...@foxmail.com> on 2026/05/20 13:31:53 UTC, 0 replies.
- Re: Java 25 Support - posted by Martijn Visser <ma...@apache.org> on 2026/05/20 14:20:17 UTC, 2 replies.
- [jira] [Created] (FLINK-39720) SubQueryDecorrelator produces incorrect plans for correlated EXISTS with HAVING on aggregate outputs - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2026/05/21 06:26:00 UTC, 0 replies.
- [VOTE] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing - posted by Guowei Ma <gu...@gmail.com> on 2026/05/21 07:57:25 UTC, 25 replies.
- [jira] [Created] (FLINK-39721) Flink CDC YAML framework should be compatibility with Flink 1.18. - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2026/05/21 09:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39722) Support Fluss CDC Yaml Source - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2026/05/21 09:30:00 UTC, 0 replies.
- Apache infrastructure PR wanting to change default rulesets. - posted by David Radley <da...@uk.ibm.com> on 2026/05/21 09:40:11 UTC, 0 replies.
- [ANNOUNCE] New Apache Flink Committer - Gustavo de Morais - posted by Timo Walther <tw...@apache.org> on 2026/05/21 09:59:48 UTC, 11 replies.
- Public CA single-purpose EKU - posted by Gyula Komlossi <gy...@gmail.com> on 2026/05/21 12:29:45 UTC, 0 replies.
- [jira] [Created] (FLINK-39723) KafkaTableITCase.testExactlyOnceSink fails due to transactional ID reuse across test runs - posted by "Aleksandr Savonin (Jira)" <ji...@apache.org> on 2026/05/21 13:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39724) CsvFormatReader produces a stream which fails get_type() and assign_timestamps_and_watermarks() - posted by "Andrew Feng (Jira)" <ji...@apache.org> on 2026/05/21 14:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39725) from_source does not use timestamp assigner in pyflink - posted by "Andrew Feng (Jira)" <ji...@apache.org> on 2026/05/21 15:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39726) Update create table syntax with using connection - posted by "Hao Li (Jira)" <ji...@apache.org> on 2026/05/21 15:51:00 UTC, 0 replies.
- The Flink blog - posted by David Radley <da...@uk.ibm.com> on 2026/05/21 16:35:56 UTC, 0 replies.
- [jira] [Created] (FLINK-39727) flink-kubernetes-operator: Bump fabric8 and operator-sdk to retire transitive CVEs - posted by "Purushottam Sinha (Jira)" <ji...@apache.org> on 2026/05/21 17:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39728) KafkaPartitionSplitReader.pauseOrResumeSplits throws IllegalStateException on concurrently unassigned partitions - posted by "Jim Hughes (Jira)" <ji...@apache.org> on 2026/05/21 18:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39729) CorrelateRestoreTest.testRestore[8] (CORRELATE_WITH_LITERAL_AGG) is flaky due to non-deterministic changelog ordering - posted by "Jim Hughes (Jira)" <ji...@apache.org> on 2026/05/21 20:53:00 UTC, 0 replies.
- [DISCUSS] FLIP-580 AsyncTableFunction supports user-defined timeout handling logic. - posted by Kui Yuan <ca...@gmail.com> on 2026/05/22 03:14:05 UTC, 8 replies.
- [jira] [Created] (FLINK-39730) ApplicationExceptionsHandler silently ignores maxExceptions parameter; ApplicationExceptionsMessageParameters is unreachable via typed REST client - posted by "Jubin Soni (Jira)" <ji...@apache.org> on 2026/05/22 06:39:00 UTC, 0 replies.
- [VOTE] Release flink-connector-http v1.0.0, release candidate 2 - posted by David Radley <da...@uk.ibm.com> on 2026/05/22 08:00:54 UTC, 4 replies.
- [jira] [Created] (FLINK-39731) SqlValidatorImpl should reject MATCH_RECOGNIZE with duplicate MEASURE - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/05/22 08:04:00 UTC, 0 replies.
- Slack invitation - posted by Alexis Sarda-Espinosa <sa...@gmail.com> on 2026/05/22 08:52:53 UTC, 3 replies.
- [jira] [Created] (FLINK-39732) Introduce TableDiscoverer SPI for flexible table subscription (with default JdbcTableDiscoverer) - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2026/05/22 09:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39733) Do not use net.jcip.annotations - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/05/22 10:15:00 UTC, 0 replies.
- Flink Consumption of ASF Shared GitHub-hosted Runners - posted by Robert Thomson <bt...@apache.org> on 2026/05/22 11:46:45 UTC, 2 replies.
- [RESULT][VOTE] Apache Flink Kubernetes Operator Release 1.15.0, release candidate #2 - posted by Gabor Somogyi <ga...@gmail.com> on 2026/05/22 12:06:55 UTC, 0 replies.
- [REVIEW] - posted by Pavel Zeger <pa...@gmail.com> on 2026/05/22 12:39:46 UTC, 0 replies.
- [jira] [Created] (FLINK-39734) Exclude 2.1 and 2.2 from GHA nightly - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/05/22 13:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39735) Expose input upsert key on TableSemantics for ProcessTableFunctions - posted by "Ramin Gharib (Jira)" <ji...@apache.org> on 2026/05/22 14:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39736) Do not allow security manager for jdk24+ - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/05/22 15:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39737) Add native s3 connector throttling support - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2026/05/22 15:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39738) React to checkpoint ACK RPC failures - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2026/05/22 19:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39739) Add java25 to docker imae - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/05/22 22:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39740) LinkedMultiSetState updates highestSqnAndSizeState unconditionally - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2026/05/22 22:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39741) Add generic type hints to DataStream functions in functions.py - posted by "Vaibhav S Gowda (Jira)" <ji...@apache.org> on 2026/05/23 06:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39742) FlinkImageBuilder checks for Java 25 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/05/23 20:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39743) Incorrect Expected Processing Rate Computation - posted by "Devika Sudheer (Jira)" <ji...@apache.org> on 2026/05/24 06:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39744) Release Testing: Verify FLIP-558: Improvements to SinkUpsertMaterializer and changelog disorder - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/05/24 13:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39745) Web dashboard: surface watermark lag as a per-job timeline - posted by "Purushottam Sinha (Jira)" <ji...@apache.org> on 2026/05/24 18:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39746) Add jdk25 profile in in common_docker.sh - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/05/24 21:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39747) Upgrade test to junit 5 - posted by "Fan Deng (Jira)" <ji...@apache.org> on 2026/05/25 03:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39748) Postgres CDC snapshot produces wrong values for TIMESTAMP / TIMESTAMPTZ / DATE columns with historical dates - posted by "Di Wu (Jira)" <ji...@apache.org> on 2026/05/25 08:57:00 UTC, 0 replies.
- [DISCUSS] Release Flink 1.20.5 - posted by Yunfeng Zhou <fl...@gmail.com> on 2026/05/25 09:27:36 UTC, 1 replies.
- [jira] [Created] (FLINK-39749) [mysql-cdc] Introduce scan.incremental.snapshot.string-key.compare-mode to align Java and MySQL ordering for string chunk keys - posted by "Ziyan Lee (Jira)" <ji...@apache.org> on 2026/05/25 10:12:00 UTC, 0 replies.
- [VOTE] FLIP-581: Support Flexible Watermark Assignment via Built-in Function - posted by FeatZhang <fe...@apache.org> on 2026/05/25 10:45:31 UTC, 3 replies.
- [jira] [Created] (FLINK-39750) Drop FailsOnJava11 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/05/25 11:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39751) Introduce FailsOnJava25 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/05/25 11:40:00 UTC, 0 replies.
- [DISCUSS] Introducing DECLARE VARIABLE in Flink SQL - posted by Chanhae Oh <dh...@gmail.com> on 2026/05/25 12:36:05 UTC, 0 replies.
- [jira] [Created] (FLINK-39752) Thread EventRecorder through FlinkResourceContext instead of holding it on the factory - posted by "Dennis-Mircea Ciupitu (Jira)" <ji...@apache.org> on 2026/05/25 13:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39753) RocksDB ColumnFamilyOptions and LRUCache leak in Compactor - posted by "Keith Lee (Jira)" <ji...@apache.org> on 2026/05/25 17:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39754) DataOutputSerializer.resize() int overflow causes O(n²) growth near 2 GB - posted by "Saulius Valatka (Jira)" <ji...@apache.org> on 2026/05/25 18:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39755) RuntimeOpenRestAPIDocsCompletenessITCase fails for jdk 21+ - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/05/25 22:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39756) Fix unable to coerce complex types (ARRAY/MAP/ROW) to STRING - posted by "Mao Jiayi (Jira)" <ji...@apache.org> on 2026/05/26 01:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39757) Fix unable to coerce complex types (ARRAY/MAP/ROW) to STRING - posted by "Mao Jiayi (Jira)" <ji...@apache.org> on 2026/05/26 01:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39758) Fix unable to coerce complex types (ARRAY/MAP/ROW) to STRING - posted by "Mao Jiayi (Jira)" <ji...@apache.org> on 2026/05/26 01:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39759) Fix unable to coerce complex types (ARRAY/MAP/ROW) to STRING - posted by "Mao Jiayi (Jira)" <ji...@apache.org> on 2026/05/26 01:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39760) Fix unable to coerce complex types (ARRAY/MAP/ROW) to STRING - posted by "Mao Jiayi (Jira)" <ji...@apache.org> on 2026/05/26 01:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39761) Missing 'Connection: close' header on '304 Not Modified' responses causes proxy connection pool poisoning - posted by "Nagy Attila Bálint (Jira)" <ji...@apache.org> on 2026/05/26 07:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39762) Wget is absent for java25 docker - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/05/26 09:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39763) Allow inferring constants with `IS NOT DISTINCT FROM` - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/05/26 09:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39764) Support dynamic table options in Table API - posted by "Mika Naylor (Jira)" <ji...@apache.org> on 2026/05/26 09:55:00 UTC, 0 replies.
- [VOTE] FLIP-569: Sunset the Stateful Functions (StateFun) Sub-project - posted by Martijn Visser <ma...@apache.org> on 2026/05/26 12:19:42 UTC, 1 replies.
- [jira] [Created] (FLINK-39765) Add FLIP-314 lineage support (LineageVertexProvider) to MySQL CDC source connector - posted by "Jaskaran Singh Kukreja (Jira)" <ji...@apache.org> on 2026/05/26 13:45:00 UTC, 0 replies.
- [DISCUSS] CEP NFA partial match accumulation causes unbounded memory/CPU growth for high-frequency start events - posted by 1193179897 <li...@foxmail.com> on 2026/05/26 13:51:39 UTC, 0 replies.
- [ANNOUNCE] Apache Flink Kubernetes Operator 1.15.0 released - posted by Gyula Fóra <gy...@apache.org> on 2026/05/26 14:28:45 UTC, 0 replies.
- [jira] [Created] (FLINK-39766) Remove AggregatedMetric copy that made redundant by Flink 1.20 dependency upgrade - posted by "Aleksandr Savonin (Jira)" <ji...@apache.org> on 2026/05/26 14:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39767) [JUnit5 Migration] Module: flink-statebackend-forst - posted by "Purushottam Sinha (Jira)" <ji...@apache.org> on 2026/05/26 14:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39768) Module: flink-avro - migrate AvroStreamingFileSinkITCase straggler - posted by "Purushottam Sinha (Jira)" <ji...@apache.org> on 2026/05/26 15:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39770) [JUnit5 Migration] Module: flink-state-processing-api - posted by "Purushottam Sinha (Jira)" <ji...@apache.org> on 2026/05/26 15:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39769) [JUnit5 Migration] Module: flink-examples-streaming - posted by "Purushottam Sinha (Jira)" <ji...@apache.org> on 2026/05/26 15:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39772) [JUnit5 Migration] Module: flink-fs-tests - posted by "Purushottam Sinha (Jira)" <ji...@apache.org> on 2026/05/26 15:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39771) [JUnit5 Migration] Module: flink-cep - posted by "Purushottam Sinha (Jira)" <ji...@apache.org> on 2026/05/26 15:50:00 UTC, 0 replies.
- [DISCUSS] FLIP-582: Support RpcOperator Service - posted by Yi Zhang <zh...@163.com> on 2026/05/27 06:11:21 UTC, 5 replies.
- [jira] [Created] (FLINK-39773) ClusterEntryPointTest fails on java25 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/05/27 08:14:00 UTC, 0 replies.
- [DISCUSS] FLIP-XXX: Independent Checkpoint Based On Pipeline Region - posted by 熊饶饶 <xi...@gmail.com> on 2026/05/27 08:31:36 UTC, 2 replies.
- [jira] [Created] (FLINK-39774) Format YEAR-MONTH interval keys as months instead of days - posted by "Fan Deng (Jira)" <ji...@apache.org> on 2026/05/27 08:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39775) Snapshot split metadata is not released after switching to stream phase, causing large JobManager coordinator state and OOM with many snapshot splits - posted by "yuanfenghu (Jira)" <ji...@apache.org> on 2026/05/27 09:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39776) Expose JobInfo on Source contexts - posted by "Aleksandr Savonin (Jira)" <ji...@apache.org> on 2026/05/27 11:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39777) Support configurable HashFunction strategies in PrePartitionOperator - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2026/05/27 12:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39778) Recoverable writer silently loses the in-flight tail on resume - posted by "Samrat Deb (Jira)" <ji...@apache.org> on 2026/05/27 13:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39779) FLIP-579: LATERAL SNAPSHOT Join - posted by "Fabian Hueske (Jira)" <ji...@apache.org> on 2026/05/27 13:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39780) Make TABLE keyword optional in LATERAL context - posted by "Fabian Hueske (Jira)" <ji...@apache.org> on 2026/05/27 13:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39781) Add operator for LATERAL SNAPSHOT Join - posted by "Fabian Hueske (Jira)" <ji...@apache.org> on 2026/05/27 13:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39782) Add SNAPSHOT built-in table function definition - posted by "Fabian Hueske (Jira)" <ji...@apache.org> on 2026/05/27 13:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39783) Add translation rules to convert lateral call of SNAPSHOT function into join operator - posted by "Fabian Hueske (Jira)" <ji...@apache.org> on 2026/05/27 13:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39784) Add translation rule to block usage of SNAPSHOT function outside of LATERAL context - posted by "Fabian Hueske (Jira)" <ji...@apache.org> on 2026/05/27 13:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39785) Add end-to-end tests for LATERAL SNAPSHOT join - posted by "Fabian Hueske (Jira)" <ji...@apache.org> on 2026/05/27 13:56:00 UTC, 0 replies.
- [DISCUSS] FLIP-583: Expose JobInfo on Source contexts - posted by Aleksandr Savonin <sa...@gmail.com> on 2026/05/27 13:57:27 UTC, 0 replies.
- [jira] [Created] (FLINK-39786) closeForCommit() leaks orphan multipart uploads on upload failure - posted by "Samrat Deb (Jira)" <ji...@apache.org> on 2026/05/27 14:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39787) Build broken for flink-benchmarks - posted by "David Anderson (Jira)" <ji...@apache.org> on 2026/05/27 14:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39788) Pekko error "Actor not found" when Kubernetes namespace starts from digit - posted by "Vladislav Keda (Jira)" <ji...@apache.org> on 2026/05/27 15:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39789) AvroSchemaConverter.convertToDataType(String) ignores local-timestamp-* and timestamp-nanos logical types, silently maps to BIGINT - posted by "Shekhar Prasad Rajak (Jira)" <ji...@apache.org> on 2026/05/27 15:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39790) State latency/size tracking metrics not exported without sampling - posted by "Efrat Levitan (Jira)" <ji...@apache.org> on 2026/05/27 18:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39791) Helm chart silently ignores defaultConfiguration.config.yaml; always mounts flink-conf.yaml from chart defaults - posted by "Gerk Elznik (Jira)" <ji...@apache.org> on 2026/05/28 00:07:00 UTC, 0 replies.
- [SUMMARY] Release 2.3 SYNC - posted by Yuepeng Pan <hi...@gmail.com> on 2026/05/28 01:17:13 UTC, 0 replies.
- [jira] [Created] (FLINK-39792) Add multi-headers metadata key to Kafka connector - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2026/05/28 06:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39793) Bump quartz to 2.5.2 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/05/28 08:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39794) StreamNetworkBenchmarkEnvironment uses InetAddress.getLocalHost(), causing SSL hostname-verification failures on cloud CI runners - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/05/28 08:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39795) MongoDB CDC does not use index when reading shard collection chunks - posted by "Xiqian Yu (Jira)" <ji...@apache.org> on 2026/05/28 11:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39796) Flink docker CI failure in master - posted by "Hao Li (Jira)" <ji...@apache.org> on 2026/05/28 18:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39797) [Flink CDC][Fluss] Support disabling automatic table creation and fail when target table does not exist - posted by "liting liu (Jira)" <ji...@apache.org> on 2026/05/29 04:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39798) Add uber jar for es8 module - posted by "reswqa (Jira)" <ji...@apache.org> on 2026/05/29 08:20:00 UTC, 0 replies.
- [VOTE] FLIP-584: Support Pluggable Storage Backend for HistoryServer - posted by zihao chen <is...@gmail.com> on 2026/05/29 08:41:26 UTC, 1 replies.
- [jira] [Created] (FLINK-39799) Preserve user-typed query text for materialized table and view definitions - posted by "Ramin Gharib (Jira)" <ji...@apache.org> on 2026/05/29 08:53:00 UTC, 0 replies.
- [VOTE] FLIP-578: In-place Table to Materialized Table conversion - posted by Ramin Gharib <ra...@gmail.com> on 2026/05/29 12:23:52 UTC, 0 replies.
- [jira] [Created] (FLINK-39800) Extend Restore test coverage for TO_CHANGELOG / FROM_CHANGELOG - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2026/05/29 14:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39801) Skip serializing empty partitionKeys / orderKeys / orderDirections in TABLE_ARG_CALL compiled plan - posted by "Ramin Gharib (Jira)" <ji...@apache.org> on 2026/05/29 15:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39802) Fix flaky ProfilingServiceTest.testRollingDeletion by isolating the test and applying Interface Segregation to ProfilingService - posted by "Nagy Attila Bálint (Jira)" <ji...@apache.org> on 2026/05/29 18:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39803) E2E tests fail due to native access and deprecated method warnings on JDK 25 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/05/29 20:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39804) Nested projection fields not pushed down to source - posted by "Daniel Rossos (Jira)" <ji...@apache.org> on 2026/05/29 21:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39805) FlinkConfigBuilder uses platform-default charset when writing log/pod-template files - posted by "Pavel Zeger (Jira)" <ji...@apache.org> on 2026/05/30 08:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39806) Add java25 required flags - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/05/30 08:51:00 UTC, 0 replies.