dev

Messages by Date

2026/08/27 [jira] [Created] (FLINK-40488) Comparison and ordering for UUID Ramin Gharib (Jira)
2026/08/27 Re: [DISCUSS] FLIP-XXX : Running Flink jobs in MiniCluster using the Kubernetes Operator Robert Metzger
2026/08/27 退订黄新儿
2026/08/27 [jira] [Created] (FLINK-40484) Run UnalignedCheckpointTestBase with DefaultScheduler instead of skipping it under AdaptiveScheduler Rui Fan (Jira)
2026/08/27 Re: [VOTE] Release flink-shaded 22.0, release candidate #1 Rui Fan
2026/08/27 Re: [VOTE] Release flink-shaded 22.0, release candidate #1 Samrat Deb
2026/08/27 [jira] [Created] (FLINK-40483) Support batch Top-N optimization for ROW_NUMBER() Timo Theusner (Jira)
2026/08/27 Re: [DISCUSS] Planning Flink 2.4 Yuepeng Pan
2026/08/27 [VOTE] Apache Flink Kubernetes Operator Release 1.16.0, release candidate #3 Gyula Fóra
2026/08/27 Re: [VOTE] Release flink-shaded 22.0, release candidate #1 Yuepeng Pan
2026/08/27 [jira] [Created] (FLINK-40482) DefaultCheckpointPlanCalculator misclassifies FAILED/CANCELED tasks as finished Rui Fan (Jira)
2026/08/27 [jira] [Created] (FLINK-40481) SHOW CREATE MATERIALIZED TABLE displays a future timestamp for FROM_NOW(<interval>) instead of past Arvid Heise (Jira)
2026/08/27 [DISCUSS] Planning Flink 2.4 Mika Naylor
2026/08/27 [jira] [Created] (FLINK-40480) [doc] CDC Yaml supports fluss source. Hongshun Wang (Jira)
2026/08/27 Re: [DISCUSS] Bump the build/enforced Maven version from 3.8.6 to 3.9.x Sergey Nuyanzin
2026/08/27 Re: [ANNOUNCE] New Apache Flink Committer - Weiqing Yang Efrat Levitan
2026/08/27 [RESULT][VOTE] FLIP-604: Complete VARIANT Primitive Coverage with UUID and Timestamps Ramin Gharib
2026/08/27 Re: [ANNOUNCE] New Apache Flink Committer - Weiqing Yang Leonard Xu
2026/08/27 Re: [ANNOUNCE] New Apache Flink Committer - Weiqing Yang Gustavo de Morais
2026/08/26 Re: [ANNOUNCE] New Apache Flink Committer - Weiqing Yang Ramin Gharib
2026/08/26 [jira] [Created] (FLINK-40479) FROM_CHANGELOG accepts error_handling but still fails the job on unmapped op codes Rango (Jira)
2026/08/26 Re: [ANNOUNCE] New Apache Flink Committer - Weiqing Yang Zhe Wang
2026/08/26 Re: [ANNOUNCE] New Apache Flink Committer - Weiqing Yang Samrat Deb
2026/08/26 RE: [ANNOUNCE] New Apache Flink Committer - Weiqing Yang wenjin
2026/08/26 [ANNOUNCE] New Apache Flink Committer - Weiqing Yang Xintong Song
2026/08/26 [DISCUSS] Cluster overhead/waste in large shared Flink clusters Yanis Djeridi via dev
2026/08/26 [jira] [Created] (FLINK-40478) HistoryServer should log its effective configuration at startup Archit Goyal (Jira)
2026/08/26 [jira] [Created] (FLINK-40477) Partial deletes fail sink NOT NULL enforcement Fabian Hueske (Jira)
2026/08/26 Re: [VOTE] FLIP-595: Differentiate monotonic and non-monotonic counters in Flink metrics Rui Fan
2026/08/26 [jira] [Created] (FLINK-40476) Clarify that the Changelog state backend requires CLAIM restore mode (NO_CLAIM unsupported) Santwana Verma (Jira)
2026/08/26 [jira] [Created] (FLINK-40475) StatusWatermarkValve loses or stalls watermarks when subpartitions realign after idleness Martijn Visser (Jira)
2026/08/26 [VOTE] FLIP-595: Differentiate monotonic and non-monotonic counters in Flink metrics Efrat Levitan
2026/08/26 Re: Re:[DISCUSS] FLIP-605: State catch-up of streaming jobs state using BATCH execution mode Piotr Nowojski
2026/08/26 [DISCUSS] FLIP-609: Type Inference for Python User Defined Functions Mika Naylor
2026/08/26 Re: [VOTE] Apache Flink Kubernetes Operator Release 1.16.0, release candidate #2 Gyula Fóra
2026/08/26 Re: [VOTE] Apache Flink Kubernetes Operator Release 1.16.0, release candidate #2 Dennis-Mircea Ciupitu
2026/08/26 [jira] [Created] (FLINK-40474) Autoscaler parallelism overrides serialized in the operator's YAML dialect break job submission for Flink 1.x jobs Dennis-Mircea Ciupitu (Jira)
2026/08/26 [jira] [Created] (FLINK-40473) YARN application mode fails to locate flink-cdc-dist jar when the jar name carries a Flink version suffix XiaodongHuan (Jira)
2026/08/25 Re: [DISCUSS] Use Project Lombok in Flink beyond tests Gyula Fóra
2026/08/25 Re: [DISCUSS] Use Project Lombok in Flink beyond tests Samrat Deb
2026/08/25 [jira] [Created] (FLINK-40472) Add Arrow-native vectorized UDF support to DataFrame API Liu Liu (Jira)
2026/08/25 [jira] [Created] (FLINK-40471) Add per-UDF concurrency and batch size support Liu Liu (Jira)
2026/08/25 [jira] [Created] (FLINK-40470) Savepoint redeploy loops forever when the deployment attempt fails hyeon kim (Jira)
2026/08/25 [jira] [Created] (FLINK-40468) Partial deletes cause NPE if value type is declared as NOT NULL Fabian Hueske (Jira)
2026/08/25 Re: [DISCUSS] FLIP-XXX : Running Flink jobs in MiniCluster using the Kubernetes Operator Dale Lane
2026/08/25 [jira] [Created] (FLINK-40469) DynamicKafkaSource can lose splits when checkpointing during recovery reassignment Aleksandr Savonin (Jira)
2026/08/25 [jira] [Created] (FLINK-40467) Flink 2.3 Application Mode managed by the kubernetes operator can start without submitting the new job after savepoint redeploy Josh Keegan (Jira)
2026/08/25 Re: [DISCUSS] FLIP-607: Migrate Flink off end-of-life OkHttp; keep it off the core classpath Martijn Visser
2026/08/25 Re: [DISCUSS] FLIP-XXX : Running Flink jobs in MiniCluster using the Kubernetes Operator Dennis-Mircea Ciupitu
2026/08/25 [jira] [Created] (FLINK-40466) Refactor defining table arguments in PTF Test Harness builder for more complex table arguments Mika Naylor (Jira)
2026/08/25 Re: [VOTE] Apache Flink Kubernetes Operator Release 1.16.0, release candidate #2 Samrat Deb
2026/08/25 Re: [VOTE] Apache Flink Kubernetes Operator Release 1.16.0, release candidate #2 Mate Czagany
2026/08/25 Re: [DISCUSS] Bump the build/enforced Maven version from 3.8.6 to 3.9.x Martijn Visser
2026/08/25 [jira] [Created] (FLINK-40465) Flink 2.0 job configuration response cannot be parsed by the operator Mate Czagany (Jira)
2026/08/25 [jira] [Created] (FLINK-40464) [CI][Release][Python] Drop support for manylinux 2014 Florian Vazelle (Jira)
2026/08/25 Re: [VOTE] FLIP-604: Complete VARIANT Primitive Coverage with UUID and Timestamps Moritz Manner
2026/08/24 Re: [VOTE] Apache Flink Kubernetes Operator Release 1.16.0, release candidate #2 Weiqing Yang
2026/08/24 Re: [VOTE] Release flink-shaded 22.0, release candidate #1 Leonard Xu
2026/08/24 Re: [VOTE] FLIP-604: Complete VARIANT Primitive Coverage with UUID and Timestamps Leonard Xu
2026/08/24 Re: [VOTE] FLIP-604: Complete VARIANT Primitive Coverage with UUID and Timestamps Jingsong Li
2026/08/24 [jira] [Created] (FLINK-40461) Add config option for labels on operator generated events Jira
2026/08/24 Re: [VOTE] FLIP-604: Complete VARIANT Primitive Coverage with UUID and Timestamps Mate Czagany
2026/08/24 [jira] [Created] (FLINK-40463) Widen JSON_VALUE and JSON_QUERY RETURNING type support Chris Johnson (Jira)
2026/08/24 Re: [DISCUSS] FLIP-607: Migrate Flink off end-of-life OkHttp; keep it off the core classpath Mate Czagany
2026/08/24 Re: [VOTE] FLIP-604: Complete VARIANT Primitive Coverage with UUID and Timestamps David Anderson
2026/08/24 Re: [VOTE] Release flink-shaded 22.0, release candidate #1 Mate Czagany
2026/08/24 [jira] [Created] (FLINK-40462) Nightly "Build Python Wheels on linux" fails building pillow from source (glibc_version_fix.h not found) Sergey Nuyanzin (Jira)
2026/08/24 RE: [VOTE] FLIP-604: Complete VARIANT Primitive Coverage with UUID and Timestamps Moritz Manner
2026/08/24 [jira] [Created] (FLINK-40460) Upgrade archive-producing Maven plugins to reproducible-capable versions Martijn Visser (Jira)
2026/08/24 Re: [DISCUSS] FLIP-XXX Monotonic Counters support Efrat Levitan
2026/08/24 Re: [DISCUSS] FLIP-XXX : Running Flink jobs in MiniCluster using the Kubernetes Operator Dale Lane
2026/08/24 Re: [VOTE] FLIP-604: Complete VARIANT Primitive Coverage with UUID and Timestamps Sergey Nuyanzin
2026/08/24 [VOTE] Release flink-shaded 22.0, release candidate #1 Sergey Nuyanzin
2026/08/24 [jira] [Created] (FLINK-40459) Bump the build/enforced Maven version from 3.8.6 to 3.9.x Martijn Visser (Jira)
2026/08/24 Re: [VOTE] FLIP-604: Complete VARIANT Primitive Coverage with UUID and Timestamps Gustavo de Morais
2026/08/24 Re: [VOTE] FLIP-604: Complete VARIANT Primitive Coverage with UUID and Timestamps Timo Walther
2026/08/24 [VOTE] FLIP-604: Complete VARIANT Primitive Coverage with UUID and Timestamps Ramin Gharib
2026/08/24 Re: [DISCUSS] FLIP-604: Complete VARIANT Primitive Coverage with UUID and Timestamps Ramin Gharib
2026/08/23 [jira] [Created] (FLINK-40458) Shade commons-lang and commons-lang3 in flink-sql-connector-hive liting liu (Jira)
2026/08/23 Re: [DISCUSS] FLIP-607: Migrate Flink off end-of-life OkHttp; keep it off the core classpath Zhe Wang
2026/08/23 [DISCUSS] FLIP-XXX : Remote Artifact Fetch for Session-Mode Job Submission Dale Lane
2026/08/21 [jira] [Created] (FLINK-40457) Bump pekko to 1.7.0 Sergey Nuyanzin (Jira)
2026/08/21 Re: [DISCUSS] Use Project Lombok in Flink beyond tests Aleksandr Iushmanov
2026/08/21 [jira] [Created] (FLINK-40454) java.lang.NoSuchMethodError: '...Configuration.getInteger(..)' in FlinkConfigManager Vladislav Keda (Jira)
2026/08/21 Re: [DISCUSS] FLIP-XXXX: Higher-Order Functions in Flink SQL (TRANSFORM and ARRAY_FILTER) David Anderson
2026/08/21 [jira] [Created] (FLINK-40456) AsyncWaitOperator can permanently drop an element's result when a timeout races with a retry Sergey Nuyanzin (Jira)
2026/08/21 [VOTE] Apache Flink Kubernetes Operator Release 1.16.0, release candidate #2 Gyula Fóra
2026/08/21 Re: [DISCUSS] FLIP-XXXX: Higher-Order Functions in Flink SQL (TRANSFORM and ARRAY_FILTER) Gustavo de Morais
2026/08/21 Re: [DISCUSS] FLIP-XXX: Flink Kubernetes Operator Autotuning Redesign Dennis-Mircea Ciupitu
2026/08/21 [jira] [Created] (FLINK-40455) Decoupling Autotuning from the Autoscaling logic Dennis-Mircea Ciupitu (Jira)
2026/08/21 Re: [DISCUSS] FLIP-XXX: Flink Kubernetes Operator Autotuning Redesign Gyula Fóra
2026/08/21 Re: [DISCUSS] Use Project Lombok in Flink beyond tests Ferenc Csaky
2026/08/21 [jira] [Created] (FLINK-40453) [postgres] Avoid eagerly loading all table schemas when initializing PostgresPipelineRecordEmitter YangyangHu (Jira)
2026/08/21 [jira] [Created] (FLINK-40452) Cap exception fetching by size, not line count Robert Metzger (Jira)
2026/08/20 [jira] [Created] (FLINK-40451) E2E test timeout keeps CI running until the timeout ends, even after the test passes Sergey Nuyanzin (Jira)
2026/08/20 [jira] [Created] (FLINK-40446) UnalignedCheckpointRescaleWithMixedExchangesITCase is unstable: @TempDir cleanup races with post-cancel async checkpoint Rui Fan (Jira)
2026/08/20 Re: [DISCUSS] Use Project Lombok in Flink beyond tests Martijn Visser
2026/08/20 Re: Re:[DISCUSS] FLIP-605: State catch-up of streaming jobs state using BATCH execution mode Zhe Wang
2026/08/20 [jira] [Created] (FLINK-40450) Planner tests miss direct flink-table-code-splitter test dependency Shekhar Prasad Rajak (Jira)
2026/08/20 Re: [DISCUSS] Use Project Lombok in Flink beyond tests Sergey Nuyanzin
2026/08/20 [jira] [Created] (FLINK-40449) Reject non-temporal streaming sort during planning instead of at job submission Martijn Visser (Jira)
2026/08/20 Re: [DISCUSS] Use Project Lombok in Flink beyond tests Ferenc Csaky
2026/08/20 [jira] [Created] (FLINK-40448) Pin resolved address during operator artifact fetch to prevent DNS rebinding Purushottam Sinha (Jira)
2026/08/20 [jira] [Created] (FLINK-40447) Keyless upsert sink can silently drop retract semantics when upsert-key metadata is empty or mixed Gustavo de Morais (Jira)
2026/08/20 [jira] [Created] (FLINK-40445) Autoscaler: integration test for Kafka/Pulsar source partition-metric detection Purushottam Sinha (Jira)
2026/08/20 Re: [DISCUSS] FLIP-XXX : Running Flink jobs in MiniCluster using the Kubernetes Operator Gyula Fóra
2026/08/20 Re: [DISCUSS] FLIP-XXX : Running Flink jobs in MiniCluster using the Kubernetes Operator Dale Lane
2026/08/20 [DISCUSS] Splitting FLINK-37357 / PR #26201 into smaller migration tasks Hirson Zhang
2026/08/19 Re: Reopening FLIP-505 (Flink History Server Remote Fetch) archit goyal
2026/08/19 Re: [DISCUSS] FLIP-563: Support provided lib archives for YARN application mode archit goyal
2026/08/19 [jira] [Created] (FLINK-40444) OBJECT_UPDATE returns incorrect results for some structured types sepuri sai krishna (Jira)
2026/08/19 [jira] [Created] (FLINK-40443) Harden autoscaler metrics name parsing against complex regex Robert Metzger (Jira)
2026/08/19 [jira] [Created] (FLINK-40442) State Processor API re-derives a key's key-group from hashCode() instead of reusing the one it read the key from — breaks reading old state after any hashCode() change Grzegorz Liter (Jira)
2026/08/19 Re: [DISCUSS] Bump the build/enforced Maven version from 3.8.6 to 3.9.x Sergey Nuyanzin
2026/08/19 RE: [DISCUSS] Bump the build/enforced Maven version from 3.8.6 to 3.9.x David Radley
2026/08/19 [jira] [Created] (FLINK-40441) Shade com.zaxxer (HikariCP) for pg pipeline connector to avoid cross-connector conflicts Zhuojun Jiang (Jira)
2026/08/19 Re: [DISCUSS] Bump the build/enforced Maven version from 3.8.6 to 3.9.x Martijn Visser
2026/08/19 [flink-connector-kafka] CI rerun and merge permissions for PR #267 Hi, jigar bhati
2026/08/19 Re: [DISCUSS] FLIP-607: Migrate Flink off end-of-life OkHttp; keep it off the core classpath Robert Metzger
2026/08/19 Re: [VOTE] Apache Flink Kubernetes Operator Release 1.16.0, release candidate #1 Gyula Fóra
2026/08/19 Re: [VOTE] Apache Flink Kubernetes Operator Release 1.16.0, release candidate #1 Robert Metzger
2026/08/19 [DISCUSS] FLIP-607: Migrate Flink off end-of-life OkHttp; keep it off the core classpath Martijn Visser
2026/08/18 [jira] [Created] (FLINK-40440) Add LLM prediction support to DataFrame API Liu Liu (Jira)
2026/08/18 [jira] [Created] (FLINK-40439) Add model provider management to DataFrame API Liu Liu (Jira)
2026/08/18 [jira] [Created] (FLINK-40438) Add DataFrame inspection and rich display APIs Liu Liu (Jira)
2026/08/18 [jira] [Created] (FLINK-40437) Add iteration and bounded retrieval to DataFrame API Liu Liu (Jira)
2026/08/18 [jira] [Created] (FLINK-40435) Add explode support to DataFrame API Liu Liu (Jira)
2026/08/18 [jira] [Created] (FLINK-40436) Add UDAF support to DataFrame API Liu Liu (Jira)
2026/08/18 [jira] [Created] (FLINK-40434) Add flat_map support to DataFrame API Liu Liu (Jira)
2026/08/18 [jira] [Created] (FLINK-40432) Parallel snapshot/CDC split by long handle space is skewed for AUTO_INCREMENT PKs and can OOM lifulong (Jira)
2026/08/18 [jira] [Created] (FLINK-40433) Add map and map_batches support to DataFrame API Liu Liu (Jira)
2026/08/18 [jira] [Created] (FLINK-40431) Add UDF support to PyFlink DataFrame API Liu Liu (Jira)
2026/08/18 [jira] [Created] (FLINK-40429) Add StatementSet support for multi-sink DataFrame writes Liu Liu (Jira)
2026/08/18 [jira] [Created] (FLINK-40430) Add configuration support to DataFrame API Liu Liu (Jira)
2026/08/18 [jira] [Created] (FLINK-40428) Remove Calcite's LogicalSnapshot Sergey Nuyanzin (Jira)
2026/08/18 [jira] [Created] (FLINK-40427) Add catalog management and catalog table I/O to DataFrame API Liu Liu (Jira)
2026/08/18 [jira] [Created] (FLINK-40426) Add Parquet and JSON filesystem I/O APIs to DataFrame API Liu Liu (Jira)
2026/08/18 [jira] [Created] (FLINK-40424) Add windowing TVF support to DataFrame API Liu Liu (Jira)
2026/08/18 [jira] [Created] (FLINK-40425) Add OVER window aggregation support to DataFrame API Liu Liu (Jira)
2026/08/18 [jira] [Created] (FLINK-40423) Add Top-N support to DataFrame API Liu Liu (Jira)
2026/08/18 [jira] [Created] (FLINK-40422) Add slicing APIs to DataFrame API Liu Liu (Jira)
2026/08/18 [jira] [Created] (FLINK-40421) Support sorting in DataFrame API Liu Liu (Jira)
2026/08/18 [jira] [Created] (FLINK-40420) Add set operations to DataFrame API Liu Liu (Jira)
2026/08/18 [jira] [Created] (FLINK-40419) Add regular join support to DataFrame API Liu Liu (Jira)
2026/08/18 [jira] [Created] (FLINK-40418) Support attribute-based column access on DataFrame Liu Liu (Jira)
2026/08/18 [jira] [Created] (FLINK-40417) Add remaining basic functionality to DataFrame API Liu Liu (Jira)
2026/08/18 [jira] [Created] (FLINK-40416) Add built-in text AI functions to Pipeline transforms Mao Jiayi (Jira)
2026/08/18 [jira] [Created] (FLINK-40415) PyFlink tests failed on Python 3.9 Dian Fu (Jira)
2026/08/18 Re: [DISCUSS] Bump the build/enforced Maven version from 3.8.6 to 3.9.x David Anderson
2026/08/18 [DISCUSS] Use Project Lombok in Flink beyond tests Samrat Deb
2026/08/18 Re: FLIP-504: Blue/Green Deployments for Flink on Kubernetes - Phase 2 (WIP/Draft PR) Sergio Chong Loo
2026/08/18 [jira] [Created] (FLINK-40414) Autoscaler state ConfigMap is treated as trusted input Dennis-Mircea Ciupitu (Jira)
2026/08/18 [jira] [Created] (FLINK-40413) Autoscaling example classes leak into the operator javadoc site Dennis-Mircea Ciupitu (Jira)
2026/08/18 Re: [DISCUSS] Bump the build/enforced Maven version from 3.8.6 to 3.9.x Gabor Somogyi
2026/08/18 Re: [DISCUSS] Flink Kubernetes Operator: One-shot statelessRestartNonce Luca Castelli via dev
2026/08/18 [DISCUSS] Bump the build/enforced Maven version from 3.8.6 to 3.9.x Martijn Visser
2026/08/18 Re: [DISCUSS] Release flink-shaded 22.0 Mate Czagany
2026/08/18 [jira] [Created] (FLINK-40412) Autoscaler: unfiltered configOverrides merge lets tenants set arbitrary Flink config Purushottam Sinha (Jira)
2026/08/18 [jira] [Created] (FLINK-40411) Introduce an OpenAI-compatible model client for Flink CDC Pipeline Mao Jiayi (Jira)
2026/08/18 [jira] [Created] (FLINK-40410) ClassCastException when constant-folding a VARIANT expression before another constant expression Moritz Manner (Jira)
2026/08/18 Re: [DISCUSS] FLIP-XXX : Running Flink jobs in MiniCluster using the Kubernetes Operator Dale Lane
2026/08/18 [jira] [Created] (FLINK-40409) Introduce inline Python UDF definition in YAML pipeline Xiqian Yu (Jira)
2026/08/18 [jira] [Created] (FLINK-40408) Fix NOTICE files to match dependencies for Flink Kubernetes Operator Mate Czagany (Jira)
2026/08/18 [jira] [Created] (FLINK-40407) [FLINK-autoscaler] Add reason tags to `autoscaler.scalings` counter to explain why scaling was triggered Kaustubh Butte (Jira)
2026/08/17 [jira] [Created] (FLINK-40406) CI: Maven build has no retry on transient Central failures, causing spurious PR failures Purushottam Sinha (Jira)
2026/08/17 [jira] [Created] (FLINK-40405) [FLINK-autoscaler] Add reason tags to `autoscaler.balanced` counter to distinguish genuinely balanced from blocked scaling Kaustubh Butte (Jira)
2026/08/17 [jira] [Created] (FLINK-40404) Split Python wheel releases for connector (e.g. kafka) Joey Pereira (Jira)
2026/08/17 Re: [DISCUSS] Release flink-shaded 22.0 P Sinha
2026/08/17 Re: [VOTE] Apache Flink Kubernetes Operator Release 1.16.0, release candidate #1 Mate Czagany
2026/08/17 [jira] [Created] (FLINK-40403) MetricStore.TaskMetricStore recompiles subtask-index regexes on every metric fetch, starving the REST thread pool on high-parallelism jobs Tim Steinbach (Jira)
2026/08/17 [jira] [Created] (FLINK-40402) Add connect / read timeout to K8s operator artifact fetcher Robert Metzger (Jira)
2026/08/17 [jira] [Created] (FLINK-40401) Protect against large autoscaler config maps Robert Metzger (Jira)
2026/08/17 [jira] [Created] (FLINK-40400) Harden job artifact fetching in kubernetes operator Robert Metzger (Jira)
2026/08/17 [VOTE] Apache Flink Kubernetes Operator Release 1.16.0, release candidate #1 Gyula Fóra
2026/08/16 退订 arctan(∞)
2026/08/16 [jira] [Created] (FLINK-40399) Separate the SavepointKeyFilter runtime contract from push-down planning Ilya Soin (Jira)
2026/08/16 Re: [DISCUSS] Release flink-shaded 22.0 Ferenc Csaky
2026/08/16 Re: [DISCUSS] FLIP-XXX : Running Flink jobs in MiniCluster using the Kubernetes Operator Dale Lane
2026/08/16 Re: [DISCUSS] FLIP-XXX : Running Flink jobs in MiniCluster using the Kubernetes Operator Dale Lane
2026/08/16 退订 18524655605
2026/08/16 [jira] [Created] (FLINK-40398) flink-connector-kafka DynamicKafkaSourceReaderTest.testHandleSourceEventRetainsRemovedClusterOffsetsUntilExpired flakiness Efrat Levitan (Jira)
2026/08/16 [jira] [Created] (FLINK-40397) Add currentBinlogPositionLag metric for MySQL binlog reader wangkang (Jira)
2026/08/14 Re: Re:[DISCUSS] FLIP-605: State catch-up of streaming jobs state using BATCH execution mode Mate Czagany
2026/08/14 [DISCUSS] Release flink-shaded 22.0 Sergey Nuyanzin
2026/08/14 Re: [DISCUSS] FLIP-XXX : Running Flink jobs in MiniCluster using the Kubernetes Operator Robert Metzger
2026/08/14 Re: [DISCUSS] FLIP-597: [Filesystems] Hadoop-less Flink filesystems Aleksandr Iushmanov
2026/08/14 [jira] [Created] (FLINK-40396) Create SplitReaders on the split fetcher thread instead of the caller thread Edson Wang (Jira)
2026/08/14 [jira] [Created] (FLINK-40395) Add documentation for extended scan partitioning modes Chanhae Oh (Jira)
2026/08/14 [jira] [Created] (FLINK-40394) Support extended scan partitioning modes in JdbcDynamicTableSource Chanhae Oh (Jira)
2026/08/14 [jira] [Created] (FLINK-40393) Add PhysicalIdSplitterEnumerator and PhysicalIdPartitionDialect with PostgreSQL and Oracle implementations Chanhae Oh (Jira)
2026/08/14 [jira] [Created] (FLINK-40392) Add AbstractDynamicSplitterEnumerator and BoundaryQuerySplitterEnumerator Chanhae Oh (Jira)
2026/08/14 Re: Re:[DISCUSS] FLIP-605: State catch-up of streaming jobs state using BATCH execution mode Roman Khachatryan
2026/08/14 Re: [DISCUSS] FLIP-XXX : Running Flink jobs in MiniCluster using the Kubernetes Operator Gyula Fóra
2026/08/14 [jira] [Created] (FLINK-40391) PTF table argument with a non-default conversion class might fail Sergey Nuyanzin (Jira)
2026/08/14 [jira] [Created] (FLINK-40390) Validate JSON_LENGTH path prefixes at plan time and reuse the shared JSON codegen Gustavo de Morais (Jira)
2026/08/14 Re: [DISCUSS] FLIP-XXX : Running Flink jobs in MiniCluster using the Kubernetes Operator Gyula Fóra
2026/08/14 [jira] [Created] (FLINK-40389) Source parallelism is not capped at the partition count Dennis-Mircea Ciupitu (Jira)
2026/08/14 [jira] [Created] (FLINK-40388) FlinkDeployment deletion can remain stuck when savepoint-on-deletion is enabled and the job is not running Avi Sanwal (Jira)
2026/08/13 [DISCUSS] Race condition in JobManager final savepoint could cause data duplication or incorrect job state, with Flink Kubernetes Operator Han You
2026/08/13 [DISCUSS] Race condition in JobManager final savepoint could cause data duplication or incorrect job state, with Flink Kubernetes Operator Han You via dev