dev

Messages by Date

2026/07/13 Re: [VOTE] FLIP-599: State Catalog Attila Mészáros
2026/07/13 Re: [DISCUSS] State Schema Evolution for RowData Leonard Xu
2026/07/13 Re: [VOTE] FLIP-497: Early Fire Support for Flink SQL Interval Join Yuepeng Pan
2026/07/13 Re: [VOTE] Release flink-connector-jdbc v4.1.0, release candidate #4 Leonard Xu
2026/07/13 Re: [VOTE] FLIP-599: State Catalog Han Yin
2026/07/13 [VOTE] FLIP-497: Early Fire Support for Flink SQL Interval Join Weiqing Yang
2026/07/13 [jira] [Created] (FLINK-40143) Dashboard shows incorrect restart strategy for jobs configured with restart-strategy options caosurong (Jira)
2026/07/13 [jira] [Created] (FLINK-40142) [Table SQL / API] Support partition transform expressions in PARTITIONED BY clause liting liu (Jira)
2026/07/13 Re: [DISCUSS] State Schema Evolution for RowData Shengkai Fang
2026/07/13 Re: [VOTE] FLIP-599: State Catalog Shengkai Fang
2026/07/13 Re: [DISCUSS] Breaking change: Make IS JSON / IS NOT JSON return NULL for NULL input dylanhz
2026/07/13 [jira] [Created] (FLINK-40141) Make IS_DECIMAL, IS_DIGIT, and IS_ALPHA return NULL for NULL input dylanhz (Jira)
2026/07/13 [jira] [Created] (FLINK-40140) Extract reader recovery gating from DynamicKafkaSourceEnumerator into a ReaderRecoveryCoordinator Sylwester Lachiewicz (Jira)
2026/07/13 [jira] [Created] (FLINK-40139) Add default JUnit test timeout to fail hung tests fast Sylwester Lachiewicz (Jira)
2026/07/13 [jira] [Created] (FLINK-40138) Migration test snapshot generator does not drive the JUnit 5 lifecycle, breaking snapshot generation for JUnit-5-migrated tests in flink-tests David Anderson (Jira)
2026/07/13 [jira] [Created] (FLINK-40137) Extract ReaderRecoveryCoordinator from DynamicKafkaSourceEnumerator Sylwester Lachiewicz (Jira)
2026/07/13 [jira] [Created] (FLINK-40136) DynamicKafkaSourceEnumeratorTest flaky due to ConcurrentModificationException in metadata event polling Sylwester Lachiewicz (Jira)
2026/07/13 Re: [VOTE] Release flink-connector-jdbc v3.4.0, release candidate #4 Rich Bowen
2026/07/13 [jira] [Created] (FLINK-40135) [PyFlink] Prevent Beam state access after runner shutdown Bowen Li (Jira)
2026/07/13 [jira] [Created] (FLINK-40134) Bump maven-rat-plugin to 0.17 Sergey Nuyanzin (Jira)
2026/07/13 Re: [VOTE] Release flink-connector-jdbc v4.1.0, release candidate #4 Rich Bowen
2026/07/13 Re: [VOTE] Release flink-connector-jdbc v4.1.0, release candidate #4 Ferenc Csaky
2026/07/13 [VOTE] FLIP-599: State Catalog Gyula Fóra
2026/07/13 Re: [VOTE] Release flink-connector-jdbc v4.1.0, release candidate #4 Rui Fan
2026/07/13 Re: [VOTE] Release flink-connector-jdbc v3.4.0, release candidate #4 Rui Fan
2026/07/13 Re: [DISCUSS] FLIP-597: [Filesystems] Hadoop-less Flink filesystems Aleksandr Iushmanov
2026/07/13 Re: [DISCUSS] Breaking change: Make IS JSON / IS NOT JSON return NULL for NULL input Fabian Hueske
2026/07/13 [jira] [Created] (FLINK-40133) Update HBase version to 2.6.6 Ferenc Csaky (Jira)
2026/07/13 [jira] [Created] (FLINK-40132) MixedKubernetesServerExtension teardown flaky with RejectedExecutionException from Fabric8 Vert.x mock server shutdown Martijn Visser (Jira)
2026/07/13 [jira] [Created] (FLINK-40131) Add documentation for LATERAL SNAPSHOT join Fabian Hueske (Jira)
2026/07/12 [jira] [Created] (FLINK-40130) Fix missing primary key type compatibility check of Paimon sink Mao Jiayi (Jira)
2026/07/12 Re: [VOTE] FLIP-591: Introducing Python DataFrame API in PyFlink Zander Matheson
2026/07/12 RE: [VOTE] FLIP-591: Introducing Python DataFrame API in PyFlink Matt Belle via dev
2026/07/12 [jira] [Created] (FLINK-40128) Implement Topic integrity checks in Kafka Connector - Datasteam Efrat Levitan (Jira)
2026/07/12 [jira] [Created] (FLINK-40129) Implement Topic integrity checks in Kafka Connector - Dynamic source Efrat Levitan (Jira)
2026/07/12 [jira] [Created] (FLINK-40127) JDBC connector: 37 files ship without the required ASF license header Purushottam Sinha (Jira)
2026/07/12 [jira] [Created] (FLINK-40126) Implement Topic integrity checks in Kafka Connector Efrat Levitan (Jira)
2026/07/12 Re: [VOTE] Release flink-connector-jdbc v4.1.0, release candidate #4 ChanBin Oh
2026/07/12 Re: [VOTE] Release flink-connector-jdbc v4.1.0, release candidate #4 ChanBin Oh
2026/07/12 Re: [VOTE] Release flink-connector-jdbc v3.4.0, release candidate #4 ChanBin Oh
2026/07/12 [jira] [Created] (FLINK-40125) Add auto cancel for concurrently run jobs Sergey Nuyanzin (Jira)
2026/07/12 [jira] [Created] (FLINK-40124) Maven package cache in job_init action re-saves on every CI run instead of only when dependencies change Sergey Nuyanzin (Jira)
2026/07/12 Re: [VOTE] FLIP-562: Topic integrity checks in Kafka Connector Efrat Levitan
2026/07/11 Re: [DISCUSS] FLIP-597: [Filesystems] Hadoop-less Flink filesystems Samrat Deb
2026/07/11 Re: [VOTE] Release flink-connector-jdbc v3.4.0, release candidate #4 P Sinha
2026/07/11 Re: [VOTE] Release flink-connector-jdbc v4.1.0, release candidate #4 P Sinha
2026/07/11 Re: [DISCUSS] Breaking change: Make IS JSON / IS NOT JSON return NULL for NULL input dylanhz
2026/07/11 [jira] [Created] (FLINK-40123) heck_logs_for_exceptions false-positives on S3A stream_write_exceptions counter, flaking test_kubernetes_materialized_table.sh Shekhar Prasad Rajak (Jira)
2026/07/10 [jira] [Created] (FLINK-40122) Expose a public getter for the persisted RowData field names Weiqing Yang (Jira)
2026/07/10 Re: [VOTE] FLIP-591: Introducing Python DataFrame API in PyFlink Guowei Ma
2026/07/10 [jira] [Created] (FLINK-40121) Update Flink Connector Kafka to use Flink 2.3 Sylwester Lachiewicz (Jira)
2026/07/10 Re: [DISCUSS] FLIP-599: State Catalog Weiqing Yang
2026/07/10 [jira] [Created] (FLINK-40120) Persist RowData field names in RowDataSerializerSnapshot Weiqing Yang (Jira)
2026/07/10 Re: Re: [DISCUSS] (Restarted) FLIP-497: Early Fire Support for Flink SQL Interval Join Weiqing Yang
2026/07/10 [jira] [Created] (FLINK-40119) Blue/Green: after an aborted transition, the next deploy deletes Blue immediately instead of waiting the deletion delay Calico Shop (Jira)
2026/07/10 [jira] [Created] (FLINK-40118) Web dashboard: SubTask TimeLine shows "N - undefined" instead of the task endpoint Purushottam Sinha (Jira)
2026/07/10 [jira] [Created] (FLINK-40117) Web dashboard: extend Vitest smoke-test coverage to remaining high-traffic views Purushottam Sinha (Jira)
2026/07/10 Re: [DISCUSS] FLIP-599: State Catalog Gyula Fóra
2026/07/10 Re: [DISCUSS] Breaking change: Make IS JSON / IS NOT JSON return NULL for NULL input Sergey Nuyanzin
2026/07/10 [jira] [Created] (FLINK-40116) Support more predicates for filter pushdown during savepoint scan Ilya Soin (Jira)
2026/07/10 Re: [DISCUSS] Breaking change: Make IS JSON / IS NOT JSON return NULL for NULL input Timo Walther
2026/07/10 [RESULT][VOTE] FLIP-600: Independent Checkpoint Based On Pipeline Region 熊饶饶
2026/07/10 Re: [VOTE] FLIP-600: Independent Checkpoint Based On Pipeline Region 熊饶饶
2026/07/09 Re: [VOTE] FLIP-591: Introducing Python DataFrame API in PyFlink Yong Fang
2026/07/09 [VOTE] FLIP-591: Introducing Python DataFrame API in PyFlink Dian Fu
2026/07/09 Re: [DISCUSS] FLIP-XXX: Extended JDBC Scan Partitioning Options for Efficient Data Ingestion Chanhae Oh
2026/07/09 Re: [DISCUSS] FLIP-599: State Catalog gyula . fora
2026/07/09 Re: [VOTE] FLIP-600: Independent Checkpoint Based On Pipeline Region Zhu Zhu
2026/07/09 Re: Re: [DISCUSS] Add UDF Metrics Weiqing Yang
2026/07/09 [jira] [Created] (FLINK-40115) Document timestamp reliability for bounded-out-of-orderness watermarks Hancheng Deng (Jira)
2026/07/09 Re: [DISCUSS] FLIP-599: State Catalog Weiqing Yang
2026/07/09 [jira] [Created] (FLINK-40114) Leader information permanently erased when a change event races a pending confirmation Prashant Bhardwaj (Jira)
2026/07/09 [jira] [Created] (FLINK-40113) State restore does not validate max-parallelism agreement between operators sharing a vertex Rion Williams (Jira)
2026/07/09 [VOTE] Release flink-connector-jdbc v4.1.0, release candidate #4 Yuepeng Pan
2026/07/09 [VOTE] Release flink-connector-jdbc v3.4.0, release candidate #4 Yuepeng Pan
2026/07/09 Re: [VOTE] Release flink-connector-jdbc v4.1.0, release candidate #3 Yuepeng Pan
2026/07/09 Re: [VOTE] Release flink-connector-jdbc v3.4.0, release candidate #3 Yuepeng Pan
2026/07/09 Re: [DISCUSS] FLIP-XXX: Extended JDBC Scan Partitioning Options for Efficient Data Ingestion João Boto
2026/07/09 Re: [VOTE] Release flink-connector-jdbc v3.4.0, release candidate #3 João Boto
2026/07/09 [jira] [Created] (FLINK-40111) Keyless upsert sink should fall back to retract when the input has no upsert key Gustavo de Morais (Jira)
2026/07/09 [jira] [Created] (FLINK-40112) Report a changelog mode mismatch instead of a generic planning error Gustavo de Morais (Jira)
2026/07/09 [jira] [Created] (FLINK-40110) Connectors/OpenSearch: Bump flink.version to 2.1.2 in flink-connector-opensearch Purushottam Sinha (Jira)
2026/07/09 [DISCUSS] Breaking change: Make IS JSON / IS NOT JSON return NULL for NULL input Fabian Hueske
2026/07/09 [jira] [Created] (FLINK-40109) YARNSessionFIFOSecuredITCase.testDetachedMode is flaky: Kerberos keytab check runs before the YARN application is killed Martijn Visser (Jira)
2026/07/09 Re: [VOTE] Release flink-connector-jdbc v3.4.0, release candidate #3 Yuepeng Pan
2026/07/09 Re: [VOTE] FLIP-600: Independent Checkpoint Based On Pipeline Region Yuepeng Pan
2026/07/09 [jira] [Created] (FLINK-40108) Add Splitters for snapshot a table or database Jira
2026/07/09 [jira] [Created] (FLINK-40107) Group example modules under an examples aggregator pom Dennis-Mircea Ciupitu (Jira)
2026/07/09 [jira] [Created] (FLINK-40106) Move FlinkResourceValidator and FlinkResourceMutator to the api module Dennis-Mircea Ciupitu (Jira)
2026/07/09 Re: [VOTE] FLIP-600: Independent Checkpoint Based On Pipeline Region Leonard Xu
2026/07/09 [jira] [Created] (FLINK-40105) Support configuring Kubernetes memory request factor for JobManager and TaskManager xiechenling (Jira)
2026/07/08 [jira] [Created] (FLINK-40104) Logging framework JARs are placed under $FLINK_HOME/log instead of the operator lib directory Dennis-Mircea Ciupitu (Jira)
2026/07/08 [jira] [Created] (FLINK-40103) Upgrade operator to Java Operator SDK version 5.4 Jira
2026/07/08 Re: [DISCUSS] State Schema Evolution for RowData Weiqing Yang
2026/07/08 Re: [VOTE] FLIP-600: Independent Checkpoint Based On Pipeline Region Charles Zhang
2026/07/08 Re: [VOTE] FLIP-600: Independent Checkpoint Based On Pipeline Region yue ma
2026/07/08 [jira] [Created] (FLINK-40102) MySQL CDC Source: Support batch emitting CreateTableEvents to reduce schema coordination overhead ericzeng (Jira)
2026/07/08 Re: Re: [DISCUSS] (Restarted) FLIP-497: Early Fire Support for Flink SQL Interval Join Weiqing Yang
2026/07/08 Re: [VOTE] Release flink-connector-jdbc v3.4.0, release candidate #3 João Boto
2026/07/08 Re: [VOTE] FLIP-600: Independent Checkpoint Based On Pipeline Region Weiqing Yang
2026/07/08 Re: [DISCUSS] FLIP-XXX: GEOGRAPHY type in Flink SQL and Table API David Chaava via dev
2026/07/08 [jira] [Created] (FLINK-40101) Watermark forwarding can stall indefinitely under interruptible timers with a large due-timer backlog Piotr Nowojski (Jira)
2026/07/08 Re: Re: [DISCUSS] (Restarted) FLIP-497: Early Fire Support for Flink SQL Interval Join Xingcan Cui
2026/07/08 Re: [VOTE] FLIP-600: Independent Checkpoint Based On Pipeline Region Zakelly Lan
2026/07/08 [DISCUSS] FLIP-601: Cloud-Agnostic Client-Side Encryption for SDK-Native Filesystems Aleksandr Iushmanov
2026/07/08 Re: [DISCUSS] FLIP-599: State Catalog Jingsong Li
2026/07/08 Re: [VOTE] FLIP-600: Independent Checkpoint Based On Pipeline Region Rui Fan
2026/07/08 [jira] [Created] (FLINK-40100) Reduce ArchUnit violations: remove direct usage of Flink-internal/shaded APIs in flink-connector-http Bharath Reddy Gunapati (Jira)
2026/07/08 Re: [VOTE] Release flink-connector-jdbc v3.4.0, release candidate #3 Chanhae Oh
2026/07/08 Re: [VOTE] FLIP-600: Independent Checkpoint Based On Pipeline Region zihao chen
2026/07/08 [jira] [Created] (FLINK-40099) YARNSessionFIFOSecuredITCase.testDetachedMode is flaky: Kerberos keytab log check reads a killed TaskManager's log Ramin Gharib (Jira)
2026/07/08 Re: [DISCUSS] FLIP-XXX: Extended JDBC Scan Partitioning Options for Efficient Data Ingestion Chanhae Oh
2026/07/08 Re: [DISCUSS] FLIP-599: State Catalog Gyula Fóra
2026/07/08 [jira] [Created] (FLINK-40098) Add FailingCheckpointedSource test utility for exactly-once source tests Martijn Visser (Jira)
2026/07/08 Re: [DISCUSS] FLIP-599: State Catalog Gyula Fóra
2026/07/08 [jira] [Created] (FLINK-40097) FLIP-585: Introduce Lazy Loading for HistoryServer chenzihao (Jira)
2026/07/08 [RESULT][VOTE] FLIP-585: Introduce Lazy Loading for HistoryServer zihao chen
2026/07/08 [jira] [Created] (FLINK-40096) Migrate EXPLAIN CTAS/RTAS Explain tests to Java Ramin Gharib (Jira)
2026/07/08 Re: [VOTE] FLIP-600: Independent Checkpoint Based On Pipeline Region Roman Khachatryan
2026/07/07 [jira] [Created] (FLINK-40095) JSON aggregation functions failing in group window aggregate Xuyang Zhong (Jira)
2026/07/07 Re: [DISCUSS] FLIP-XXX: Extended JDBC Scan Partitioning Options for Efficient Data Ingestion Leonard Xu
2026/07/07 Re: [VOTE] Release flink-connector-jdbc v3.4.0, release candidate #3 Yuepeng Pan
2026/07/07 Re: [VOTE] Release flink-connector-jdbc v3.4.0, release candidate #3 Weiqing Yang
2026/07/07 Re: [VOTE] FLIP-600: Independent Checkpoint Based On Pipeline Region Gen Luo
2026/07/07 Re: [DISCUSS] FLIP-XXX Support ReducingMergeState and AggregatingMergeState backed by Java based associative merge operators Soumitra Kumar
2026/07/07 Re: [VOTE] FLIP-600: Independent Checkpoint Based On Pipeline Region Yuan Mei
2026/07/07 Re: [DISCUSS] FLIP-XXX: Extended JDBC Scan Partitioning Options for Efficient Data Ingestion Youngil Kim
2026/07/07 Re: [DISCUSS] FLIP-599: State Catalog Shengkai Fang
2026/07/07 Re: [DISCUSS] FLIP-XXX: Extended JDBC Scan Partitioning Options for Efficient Data Ingestion Chanhae Oh
2026/07/07 Re: Re: [DISCUSS] (Restarted) FLIP-497: Early Fire Support for Flink SQL Interval Join Weiqing Yang
2026/07/07 Re: Re: [DISCUSS] (Restarted) FLIP-497: Early Fire Support for Flink SQL Interval Join Yuepeng Pan
2026/07/07 Re: [DISCUSS] FLIP-599: State Catalog Jingsong Li
2026/07/07 Re: Re: [DISCUSS] (Restarted) FLIP-497: Early Fire Support for Flink SQL Interval Join Xingcan Cui
2026/07/07 [jira] [Created] (FLINK-40094) DynamicKafkaSource should mark removed split outputs idle before release Xin Gao (Jira)
2026/07/07 Re: [DISCUSS] FLIP-599: State Catalog Roman Khachatryan
2026/07/07 [jira] [Created] (FLINK-40093) Race condition between watermark alignment and idleness detection locks split in idle Efrat Levitan (Jira)
2026/07/07 [VOTE] Release flink-connector-jdbc v3.4.0, release candidate #3 Yuepeng Pan
2026/07/07 [jira] [Created] (FLINK-40092) BlueGreen transition should finalize immediately after deleting previous deployment Calico Shop (Jira)
2026/07/07 Re: [VOTE] Release flink-connector-jdbc v4.1.0, release candidate #3 Chanhae Oh
2026/07/07 [jira] [Created] (FLINK-40091) upgrade paimon to 1.4.2 peiyu (Jira)
2026/07/07 [jira] [Created] (FLINK-40090) Modernize cryptography export notice in distribution README Martijn Visser (Jira)
2026/07/07 [jira] [Created] (FLINK-40089) Add JSON_LENGTH function Gustavo de Morais (Jira)
2026/07/07 [jira] [Created] (FLINK-40088) RestClientITCase.testHttpsConnectionWithDefaultCerts is flaky due to GitHub rate limiting (HTTP 429) Martijn Visser (Jira)
2026/07/07 Re: [DISCUSS] FLIP-XXX: Extended JDBC Scan Partitioning Options for Efficient Data Ingestion ChanBin Oh
2026/07/07 Re: [DISCUSS] FLIP-XXX: Extended JDBC Scan Partitioning Options for Efficient Data Ingestion 주수민
2026/07/07 [DISCUSS] FLIP-XXX: Extended JDBC Scan Partitioning Options for Efficient Data Ingestion Chanhae Oh
2026/07/07 Re: Re: [DISCUSS] FLIP-591: Introducing Python DataFrame API in PyFlink Dian Fu
2026/07/07 Re: [DISCUSS] FLIP-599: State Catalog Gyula Fóra
2026/07/07 Re: [VOTE] FLIP-600: Independent Checkpoint Based On Pipeline Region Guowei Ma
2026/07/07 [jira] [Created] (FLINK-40087) MySqlDefaultValueConverter fails to parse charset-introducer default values wrapped in double quotes and/or containing padding spaces (e.g. `_UTF8MB4" 0 "`) Xin Gong (Jira)
2026/07/07 Re: [DISCUSS] FLIP-599: State Catalog Gyula Fóra
2026/07/07 [jira] [Created] (FLINK-40086) Harden Execution#transitionState implementation by guarding preCompletionAction Matthias Pohl (Jira)
2026/07/06 [jira] [Created] (FLINK-40085) Introduce e2e test for es8 sink reswqa (Jira)
2026/07/06 [VOTE] FLIP-600: Independent Checkpoint Based On Pipeline Region 熊饶饶
2026/07/06 Re: [DISCUSS] FLIP-599: State Catalog Shengkai Fang
2026/07/06 Re: [VOTE] Release flink-connector-jdbc v3.4.0, release candidate #2 Yuepeng Pan
2026/07/06 Re: Help Needed for JDBC Release v3.4.0 Yuepeng Pan
2026/07/06 Re: [DISCUSS] FLIP-599: State Catalog Roman Khachatryan
2026/07/06 Re: [DISCUSS] FLIP-XXX Support ReducingMergeState and AggregatingMergeState backed by Java based associative merge operators Roman Khachatryan
2026/07/06 Re: Help Needed for JDBC Release v3.4.0 Weiqing Yang
2026/07/06 Re: [DISCUSS] FLIP-XXX: GEOGRAPHY type in Flink SQL and Table API Talat Uyarer
2026/07/06 [jira] [Created] (FLINK-40084) maven-shade-plugin does not respect multi release jars Sergey Nuyanzin (Jira)
2026/07/06 [jira] [Created] (FLINK-40083) Launch the SeaweedFS S3 test backend via weed mini and bump the image to 4.38 Chris Lu (Jira)
2026/07/06 Re: Re: [DISCUSS] (Restarted) FLIP-497: Early Fire Support for Flink SQL Interval Join Weiqing Yang
2026/07/06 Re: Help Needed for JDBC Release v3.4.0 Ferenc Csaky
2026/07/06 [VOTE] Release flink-connector-jdbc v3.4.0, release candidate #2 Yuepeng Pan
2026/07/06 [VOTE] Release flink-connector-jdbc v4.1.0, release candidate #3 Yuepeng Pan
2026/07/06 Help Needed for JDBC Release v3.4.0 Yuepeng Pan
2026/07/06 [jira] [Created] (FLINK-40082) InvalidProgramException when performing LEFT JOIN with a lookup table that has a computed field for Watermark extraction based on metadata field (HEADERS) Fred Teunissen (Jira)
2026/07/06 Re: FLIP-504: Blue/Green Deployments for Flink on Kubernetes - Phase 2 (WIP/Draft PR) Sergio Chong Loo
2026/07/06 [RESULT] [VOTE] FLIP-588: Support per-job delegation tokens Aleksandr Savonin
2026/07/06 Re: [DISCUSS] FLIP-599: State Catalog Gyula Fóra
2026/07/06 [jira] [Created] (FLINK-40081) Enable the spilling backend for checkpointing during recovery Rui Fan (Jira)
2026/07/06 [jira] [Created] (FLINK-40080) Drain spilled channel state into input channels and replay spilled slices into checkpoints Rui Fan (Jira)
2026/07/06 [jira] [Created] (FLINK-40079) Enforce disableSystemArguments consistently for all PTF translation paths Fabian Hueske (Jira)
2026/07/06 [DISCUSS] FLIP-XXX: Flink Kubernetes Operator Autotuning Redesign Dennis-Mircea Ciupitu
2026/07/06 Re:Re: [DISCUSS] (Restarted) FLIP-497: Early Fire Support for Flink SQL Interval Join Xuyang
2026/07/06 [jira] [Created] (FLINK-40078) Lost non-loss-tolerant OperatorEvent to an already-failing task triggers a failover that masks the original failure cause Martijn Visser (Jira)
2026/07/06 [jira] [Created] (FLINK-40077) CommonExecSinkITCase.testNullEnforcer fails intermittently: lost NoMoreSplitsEvent failover masks the NOT NULL enforcer cause Martijn Visser (Jira)
2026/07/06 [jira] [Created] (FLINK-40076) RescaleTimelineITCase.testRecordNonTerminatedRescaleMergingWithNewRecoverableFailureTriggerCause fails intermittently: snapshot taken before recoverable failover is merged into in-progress rescale Martijn Visser (Jira)
2026/07/05 Re: [DISCUSS] (Restarted) FLIP-497: Early Fire Support for Flink SQL Interval Join Weiqing Yang
2026/07/05 [jira] [Created] (FLINK-40075) Optimize WELFORD_M2 aggregate accumulator by using RowData instead of STRUCTURED POJO accumulator dylanhz (Jira)
2026/07/05 Re: [VOTE] FLIP-585: Introduce Lazy Loading for HistoryServer Junrui Lee
2026/07/05 Re: [VOTE] FLIP-585: Introduce Lazy Loading for HistoryServer weijie guo
2026/07/05 Re: [DISCUSS] FLIP-XXX Support ReducingMergeState and AggregatingMergeState backed by Java based associative merge operators Soumitra Kumar
2026/07/05 [jira] [Created] (FLINK-40074) SinkV2ITCase.writerAndCommitterExecuteInStreamingModeWithScaling fails on @TempDir cleanup race (Failed to delete temp directory) Martijn Visser (Jira)
2026/07/05 Re: [DISCUSS] FLIP-599: State Catalog Zakelly Lan
2026/07/04 [jira] [Created] (FLINK-40073) Delete and Force Push Protections for Default and Release Branches Harshit Gupta (Jira)
2026/07/04 RE: Apache infrastructure PR wanting to change default rulesets. Harshit Gupta via dev
2026/07/04 [jira] [Created] (FLINK-40072) request.timeout is declared as a Duration option but parsed as integer seconds, crashing at query time on any unit-suffixed value Bharath Reddy Gunapati (Jira)
2026/07/04 Re: [DISCUSS] FLIP-XXX: Independent Checkpoint Based On Pipeline Region 熊饶饶
2026/07/03 退订林
2026/07/03 退订林
2026/07/03 [jira] [Created] (FLINK-40071) Bump jackson-bom to 2.21.4 Purushottam Sinha (Jira)
2026/07/03 [jira] [Created] (FLINK-40070) DynamicParameterITCase hangs when the JobManager startup banner rolls to a numbered log file Martijn Visser (Jira)
2026/07/03 [jira] [Created] (FLINK-40069) OpenTelemetryMetricReporterProtocolTest fails with "No content to map due to end-of-input" due to OTel collector readiness race Martijn Visser (Jira)
2026/07/03 [jira] [Created] (FLINK-40068) KeyedComplexChainTest.testMigrationAndRestore fails with NoResourceAvailableException when the window apply-assertion crashes the MiniCluster TaskManager Martijn Visser (Jira)
2026/07/03 [jira] [Created] (FLINK-40067) RescaleTimelineITCase.testRescaleTerminatedByJobFinished fails due to race between cooldown-driven rescale termination and job finish Martijn Visser (Jira)
2026/07/03 [jira] [Created] (FLINK-40066) flink-connector-mongodb: update flink-connector-parent to 2.0.0 and flink.version to 2.1.2 Purushottam Sinha (Jira)
2026/07/03 [jira] [Created] (FLINK-40065) flink-connector-aws: update flink-connector-parent to 2.0.0 and flink.version to 2.1. Purushottam Sinha (Jira)