issues  

Messages by Date

• 2026/07/14 [jira] [Commented] (FLINK-36298) NullPointerException in Calcite causes a PyFlink test failure Martijn Visser (Jira)
• 2026/07/14 [jira] (FLINK-36298) NullPointerException in Calcite causes a PyFlink test failure Martijn Visser (Jira)
• 2026/07/14 [jira] [Commented] (FLINK-36298) NullPointerException in Calcite causes a PyFlink test failure Martijn Visser (Jira)
• 2026/07/14 Re: [PR] [FLINK-40089][table] Implement JSON_LENGTH function [flink] via GitHub
• 2026/07/14 Re: [PR] [FLINK-37925][table] Support casting from VARIANT to primitive types [flink] via GitHub
• 2026/07/14 Re: [PR] [FLINK-37925][table] Support casting from VARIANT to primitive types [flink] via GitHub
• 2026/07/14 [D] [Discussion][Observability 1/2] Recording Agent Traces in the Event Log [flink-agents] via GitHub
• 2026/07/14 Re: [PR] [FLINK-40089][table] Implement JSON_LENGTH function [flink] via GitHub
• 2026/07/14 Re: [PR] [FLINK-40089][table] Implement JSON_LENGTH function [flink] via GitHub
• 2026/07/14 Re: [PR] [FLINK-40089][table] Implement JSON_LENGTH function [flink] via GitHub
• 2026/07/14 Re: [PR] [FLINK-40089][table] Implement JSON_LENGTH function [flink] via GitHub
• 2026/07/14 Re: [PR] [FLINK-40089][table] Implement JSON_LENGTH function [flink] via GitHub
• 2026/07/14 Re: [PR] [FLINK-40089][table] Implement JSON_LENGTH function [flink] via GitHub
• 2026/07/14 Re: [D] [Discussion] Pluggable model routing — API & design (PR #852 follow-up) [flink-agents] via GitHub
• 2026/07/14 Re: [PR] [FLINK-38783][runtime] Improved TieredStorageResourceRegistry Thread-Safety/Concurrency [flink] via GitHub
• 2026/07/14 [PR] [tools] Keep install plan edits consistent [flink-agents] via GitHub
• 2026/07/14 Re: [PR] [FLINK-40131][docs] Document LATERAL SNAPSHOT join [flink] via GitHub
• 2026/07/14 [jira] [Updated] (FLINK-40131) Add documentation for LATERAL SNAPSHOT join ASF GitHub Bot (Jira)
• 2026/07/14 [PR] [FLINK-40131][docs] Document LATERAL SNAPSHOT join [flink] via GitHub
• 2026/07/14 [jira] [Updated] (FLINK-40144) Avoid query database when only get table column ASF GitHub Bot (Jira)
• 2026/07/14 [PR] [FLINK-40144]Avoid query database when only get table column [flink-connector-jdbc] via GitHub
• 2026/07/14 [jira] [Created] (FLINK-40144) Avoid query database when only get table column ouyangwulin (Jira)
• 2026/07/14 Re: [PR] [FLINK-31931] Return 404 for a gone TaskManager and stop the Web UI from re-polling it [flink] via GitHub
• 2026/07/14 Re: [PR] [FLINK-40134][ci] Bump maven-rat-plugin to 0.17 [flink] via GitHub
• 2026/07/14 Re: [PR] [BP-2.3][FLINK-40086][runtime] Adds error handling to newly added preCompletionAction [flink] via GitHub
• 2026/07/14 Re: [PR] [FLINK-40093][runtime] Resume idle splits by alignment check if previously paused [flink] via GitHub
• 2026/07/14 Re: [PR] [FLINK-40093][runtime] Resume idle splits by alignment check if previously paused [flink] via GitHub
• 2026/07/14 Re: [PR] [FLINK-40113][checkpoint] Reject restore when operators on a keyed vertex disagree on max parallelism [flink] via GitHub
• 2026/07/14 Re: [I] [Tech Debt] Harden Ollama install and bound runtime for integration-test CI jobs [flink-agents] via GitHub
• 2026/07/14 Re: [PR] [BP-2.3][FLINK-40086][runtime] Adds error handling to newly added preCompletionAction [flink] via GitHub
• 2026/07/14 [jira] [Updated] (FLINK-40086) Harden Execution#transitionState implementation by guarding preCompletionAction Matthias Pohl (Jira)
• 2026/07/14 Re: [PR] Adding JDBC Connector v4.1.0 [flink-web] via GitHub
• 2026/07/13 Re: [PR] [FLINK-39198] Fix data loss during restoration from checkpoint in TIMESTAMP startup mode. [flink-cdc] via GitHub
• 2026/07/13 Re: [PR] Adding JDBC Connector v4.1.0 [flink-web] via GitHub
• 2026/07/13 Re: [PR] [runtime] CDC YAML supports inline Python UDF definition [flink-cdc] via GitHub
• 2026/07/13 Re: [PR] [FLINK-40093][runtime] Resume idle splits by alignment check if previously paused [flink] via GitHub
• 2026/07/13 Re: [PR] [FLINK-40093][runtime] Resume idle splits by alignment check if previously paused [flink] via GitHub
• 2026/07/13 Re: [PR] [FLINK-40093][runtime] Resume idle splits by alignment check if previously paused [flink] via GitHub
• 2026/07/13 Re: [PR] [FLINK-40093][runtime] Resume idle splits by alignment check if previously paused [flink] via GitHub
• 2026/07/13 Re: [PR] [FLINK-40093][runtime] Resume idle splits by alignment check if previously paused [flink] via GitHub
• 2026/07/13 Re: [PR] [FLINK-39198] Fix data loss during restoration from checkpoint in TIMESTAMP startup mode. [flink-cdc] via GitHub
• 2026/07/13 Re: [PR] Adding JDBC Connector v3.4.0 [flink-web] via GitHub
• 2026/07/13 [jira] [Closed] (FLINK-39777) Support configurable HashFunction strategies in PrePartitionOperator Yanquan Lv (Jira)
• 2026/07/13 Re: [PR] Adding JDBC Connector v3.4.0 [flink-web] via GitHub
• 2026/07/13 Re: [PR] [FLINK-39777] Support configurable HashFunction strategies in PrePartitionOperator [flink-cdc] via GitHub
• 2026/07/13 Re: [PR] Adding JDBC Connector v3.4.0 [flink-web] via GitHub
• 2026/07/13 [jira] [Commented] (FLINK-40120) Persist RowData field names in RowDataSerializerSnapshot Weiqing Yang (Jira)
• 2026/07/13 Re: [PR] [FLINK-40143] [core] Fix displayed restart strategy for config option based restart strategies [flink] via GitHub
• 2026/07/13 [jira] [Updated] (FLINK-40143) Dashboard shows incorrect restart strategy for jobs configured with restart-strategy options ASF GitHub Bot (Jira)
• 2026/07/13 [PR] [FLINK-40143] [core] Fix displayed restart strategy for config option based restart strategies [flink] via GitHub
• 2026/07/13 Re: [PR] [FLINK-40120][table] Persist RowData field names in RowDataSerializerSnapshot [flink] via GitHub
• 2026/07/13 Re: [I] [Tech Debt] Update install.sh after releasing 0.3.0 [flink-agents] via GitHub
• 2026/07/13 Re: [PR] [runtime] send Kafka tombstones on state pruning for durable log compaction [flink-agents] via GitHub
• 2026/07/13 Re: [I] [Feature] [integration] [java] Integrate built-in Google Gemini chat model [flink-agents] via GitHub
• 2026/07/13 [PR] [docs][integration] Document Gemini chat model integration [flink-agents] via GitHub
• 2026/07/13 Re: [PR] [tools] Update install.sh for Flink Agents 0.3.0 and Python 3.12 [flink-agents] via GitHub
• 2026/07/13 Re: [PR] [Flink-38911][cdc connector mysql] mysql-cdc-connector datastream support scan.binlog.newly-added-table.enabled [flink-cdc] via GitHub
• 2026/07/13 [jira] [Created] (FLINK-40143) Dashboard shows incorrect restart strategy for jobs configured with restart-strategy options caosurong (Jira)
• 2026/07/13 Re: [PR] [FLINK-38647][CDC] Improve error message for null before/after struct… [flink-cdc] via GitHub
• 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: [PR] [FLINK-38647][CDC] Improve error message for null before/after struct… [flink-cdc] via GitHub
• 2026/07/13 Re: [PR] [FLINK-39198] Fix data loss during restoration from checkpoint in TIMESTAMP startup mode. [flink-cdc] via GitHub
• 2026/07/13 Re: [PR] [FLINK-39198] Fix data loss during restoration from checkpoint in TIMESTAMP startup mode. [flink-cdc] via GitHub
• 2026/07/13 Re: [PR] [docs] Improve Incremental Snapshot Reading formatting and references [flink-cdc] via GitHub
• 2026/07/13 Re: [PR] [ci] Exclude Flink compatibility modules from Javadoc [flink-cdc] via GitHub
• 2026/07/13 Re: [PR] [docs] Improve Incremental Snapshot Reading formatting and references [flink-cdc] via GitHub
• 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 Re: [PR] [docs] Improve Incremental Snapshot Reading formatting and references [flink-cdc] via GitHub
• 2026/07/13 Re: [PR] [FLINK-39775][mysql] Release snapshot split metadata after entering the stream phase [flink-cdc] via GitHub
• 2026/07/13 Re: [PR] [FLINK-39775][mysql] Release snapshot split metadata after entering the stream phase [flink-cdc] via GitHub
• 2026/07/13 Re: [PR] [FLINK-39775][mysql] Release snapshot split metadata after entering the stream phase [flink-cdc] via GitHub
• 2026/07/13 [jira] [Closed] (FLINK-40140) Extract reader recovery gating from DynamicKafkaSourceEnumerator into a ReaderRecoveryCoordinator Sylwester Lachiewicz (Jira)
• 2026/07/13 [jira] [Created] (FLINK-40140) Extract reader recovery gating from DynamicKafkaSourceEnumerator into a ReaderRecoveryCoordinator Sylwester Lachiewicz (Jira)
• 2026/07/13 Re: [PR] [FLINK-39837] Reassign retained dynamic Kafka offsets upon readd [flink-connector-kafka] via GitHub
• 2026/07/13 [jira] [Updated] (FLINK-40139) Add default JUnit test timeout to fail hung tests fast ASF GitHub Bot (Jira)
• 2026/07/13 Re: [PR] [FLINK-40139] Add default JUnit test timeout to fail hung tests fast [flink-connector-kafka] via GitHub
• 2026/07/13 Re: [PR] [FLINK-39837] Reassign retained dynamic Kafka offsets upon readd [flink-connector-kafka] via GitHub
• 2026/07/13 [jira] [Created] (FLINK-40139) Add default JUnit test timeout to fail hung tests fast Sylwester Lachiewicz (Jira)
• 2026/07/13 [jira] [Updated] (FLINK-40137) Extract ReaderRecoveryCoordinator from DynamicKafkaSourceEnumerator ASF GitHub Bot (Jira)
• 2026/07/13 Re: [PR] [FLINK-40137] Extract ReaderRecoveryCoordinator from DynamicKafkaSourceEnumerator [flink-connector-kafka] via GitHub
• 2026/07/13 [jira] [Updated] (FLINK-40136) DynamicKafkaSourceEnumeratorTest flaky due to ConcurrentModificationException in metadata event polling ASF GitHub Bot (Jira)
• 2026/07/13 Re: [PR] [FLINK-40136] Fix flaky ConcurrentModificationException in DynamicKafkaSourceEnumeratorTest [flink-connector-kafka] via GitHub
• 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: [PR] [FLINK-37925][table] Support casting from VARIANT to primitive types [flink] via GitHub
• 2026/07/13 Re: [PR] [FLINK-37925][table] Support casting from VARIANT to primitive types [flink] via GitHub
• 2026/07/13 Re: [PR] [FLINK-37925][table] Support casting from VARIANT to primitive types [flink] via GitHub
• 2026/07/13 Re: [PR] [FLINK-39984][runtime][webUI] Dispatch thread dump to ioExecutor and support SAFE/FULL modes [flink] via GitHub
• 2026/07/13 Re: [PR] [FLINK-40034][runtime-web] Refresh web-dashboard lint tooling to prettier 3 and stylelint 17 [flink] via GitHub
• 2026/07/13 [PR] [FLINK-31931] Return 404 for a gone TaskManager and stop the Web UI from re-polling it [flink] via GitHub
• 2026/07/13 Re: [PR] [FLINK-31931] Return 404 for a gone TaskManager and stop the Web UI from re-polling it [flink] via GitHub
• 2026/07/13 Re: [PR] [FLINK-31931] Return 404 for a gone TaskManager and stop the Web UI from re-polling it [flink] via GitHub
• 2026/07/13 Re: [PR] [hotfix] Extract ReaderRecoveryCoordinator from DynamicKafkaSourceEnumerator [flink-connector-kafka] via GitHub
• 2026/07/13 Re: [PR] [FLINK-37925][table] Support casting from VARIANT to primitive types [flink] via GitHub
• 2026/07/13 Re: [PR] [hotfix] Fix flaky ConcurrentModificationException in DynamicKafkaSourceEnumeratorTest [flink-connector-kafka] via GitHub
• 2026/07/13 Re: [PR] [FLINK-37925][table] Support casting from VARIANT to primitive types [flink] via GitHub
• 2026/07/13 [jira] [Assigned] (FLINK-40135) [PyFlink] Prevent Beam state access after runner shutdown Bowen Li (Jira)
• 2026/07/13 [jira] [Created] (FLINK-40135) [PyFlink] Prevent Beam state access after runner shutdown Bowen Li (Jira)
• 2026/07/13 Re: [PR] [FLINK-40134][ci] Bump maven-rat-plugin to 0.17 [flink] via GitHub
• 2026/07/13 Re: [PR] [FLINK-40134][ci] Bump maven-rat-plugin to 0.17 [flink] via GitHub
• 2026/07/13 [jira] [Updated] (FLINK-40134) Bump maven-rat-plugin to 0.17 ASF GitHub Bot (Jira)
• 2026/07/13 [PR] [FLINK-40134][ci] Bump maven-rat-plugin to 0.17 [flink] via GitHub
• 2026/07/13 [jira] [Created] (FLINK-40134) Bump maven-rat-plugin to 0.17 Sergey Nuyanzin (Jira)
• 2026/07/13 Re: [PR] [FLINK-39837] Reassign retained dynamic Kafka offsets upon readd [flink-connector-kafka] via GitHub
• 2026/07/13 Re: [PR] Adding JDBC Connector v4.1.0 [flink-web] via GitHub
• 2026/07/13 [PR] [hotfix] Extract ReaderRecoveryCoordinator from DynamicKafkaSourceEnumerator [flink-connector-kafka] via GitHub
• 2026/07/13 [PR] [hotfix] Add default JUnit test timeout to fail hung tests fast [flink-connector-kafka] via GitHub
• 2026/07/13 Re: [PR] [FLINK-39622] [postgres] Fix O(N²) JDBC metadata lookups in CustomPostgresSchema d… [flink-cdc] via GitHub
• 2026/07/13 [jira] [Closed] (FLINK-40036) Support injecting a custom MockEnvironment into multi-input operator test harnesses Roman Khachatryan (Jira)
• 2026/07/13 [jira] [Assigned] (FLINK-40036) Support injecting a custom MockEnvironment into multi-input operator test harnesses Roman Khachatryan (Jira)
• 2026/07/13 [jira] [Updated] (FLINK-40036) Support injecting a custom MockEnvironment into multi-input operator test harnesses Roman Khachatryan (Jira)
• 2026/07/13 Re: [PR] [FLINK-40036][tests] Support custom MockEnvironment in multi-input harness… [flink] via GitHub
• 2026/07/13 Re: [PR] [FLINK-40121] Update to Flink 2.3.0 [flink-connector-kafka] via GitHub
• 2026/07/13 Re: [PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink] via GitHub
• 2026/07/13 Re: [PR] [FLINK-40113][checkpoint] Reject restore when operators on a keyed vertex disagree on max parallelism [flink] via GitHub
• 2026/07/13 Re: [PR] [FLINK-40113][checkpoint] Reject restore when operators on a keyed vertex disagree on max parallelism [flink] via GitHub
• 2026/07/13 Re: [PR] [api][routing] Pluggable in-chat LLM routing (ChatModelRouter + RoutingStrategy) [flink-agents] via GitHub
• 2026/07/13 Re: [PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink] via GitHub
• 2026/07/13 [D] [Discussion] Pluggable model routing — API & design (PR #852 follow-up) [flink-agents] via GitHub
• 2026/07/13 [jira] [Resolved] (FLINK-39783) Add translation rules to convert lateral call of SNAPSHOT function into join operator Fabian Hueske (Jira)
• 2026/07/13 Re: [PR] [FLINK-40093][runtime] Resume idle splits by alignment check if previously paused [flink] via GitHub
• 2026/07/13 Re: [PR] [FLINK-39783][table] Translate LATERAL SNAPSHOT to LateralSnapshotJoinOperator [flink] via GitHub
• 2026/07/13 [PR] Yd/fix observed generation suspended [flink-kubernetes-operator] via GitHub
• 2026/07/13 Re: [PR] [FLINK-31951][format] Reset decoder on Avro deserialization failure [flink] via GitHub
• 2026/07/13 Re: [PR] [FLINK-40113][checkpoint] Reject restore when operators on a keyed vertex disagree on max parallelism [flink] via GitHub
• 2026/07/13 Re: [PR] [FLINK-31951][format] Reset decoder on Avro deserialization failure [flink] via GitHub
• 2026/07/13 Re: [PR] [FLINK-39704][runtime/jobmaster] Preserve globally terminal job result across leadership revocation [flink] via GitHub
• 2026/07/13 [jira] [Assigned] (FLINK-31931) Exception history page should not link to a non-existent TM log page. Martijn Visser (Jira)
• 2026/07/13 [jira] [Commented] (FLINK-40120) Persist RowData field names in RowDataSerializerSnapshot Gyula Fora (Jira)
• 2026/07/13 [jira] [Resolved] (FLINK-40035) Add smoke-level component specs for the web-dashboard Martijn Visser (Jira)
• 2026/07/13 [jira] [Assigned] (FLINK-40113) State restore does not validate max-parallelism agreement between operators sharing a vertex Piotr Nowojski (Jira)
• 2026/07/13 Re: [PR] Bump undici and @angular-devkit/build-angular in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/07/13 Re: [PR] Bump esbuild and @angular-devkit/build-angular in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/07/13 Re: [PR] Bump esbuild and @angular-devkit/build-angular in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/07/13 Re: [PR] Bump undici and @angular-devkit/build-angular in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/07/13 [jira] [Updated] (FLINK-40035) Add smoke-level component specs for the web-dashboard Martijn Visser (Jira)
• 2026/07/13 [jira] [Commented] (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/13 [jira] [Updated] (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/13 Re: [PR] [FLINK-40035][runtime-web] Add Vitest smoke tests for the web-dashboard [flink] via GitHub
• 2026/07/13 Re: [PR] [BP-2.3][FLINK-40124][ci] Do not store cache on every run if no dependency changed [flink] via GitHub
• 2026/07/13 Re: [PR] [FLINK-37925][table] Support casting from VARIANT to primitive types [flink] via GitHub
• 2026/07/13 [jira] [Commented] (FLINK-39943) IS [NOT ]JSON changed nullability after upgrade to Calcite 1.38.0 Fabian Hueske (Jira)
• 2026/07/13 Re: [PR] [FLINK-37925][table] Support casting from VARIANT to primitive types [flink] via GitHub
• 2026/07/13 Re: [PR] [FLINK-37925][table] Support casting from VARIANT to primitive types [flink] via GitHub
• 2026/07/13 [jira] [Assigned] (FLINK-39943) IS [NOT ]JSON changed nullability after upgrade to Calcite 1.38.0 Fabian Hueske (Jira)
• 2026/07/13 Re: [PR] [FLINK-37925][table] Support casting from VARIANT to primitive types [flink] via GitHub
• 2026/07/13 Re: [PR] [BP-2.3][FLINK-40124][ci] Do not store cache on every run if no dependency changed [flink] via GitHub
• 2026/07/13 Re: [PR] [BP-2.2][FLINK-40086][runtime] Adds error handling to newly added preCompletionAction [flink] via GitHub
• 2026/07/13 Re: [PR] [BP-1.20][FLINK-40086][runtime] Adds error handling to newly added preCompletionAction [flink] via GitHub
• 2026/07/13 Re: [PR] [BP-2.3][FLINK-40086][runtime] Adds error handling to newly added preCompletionAction [flink] via GitHub
• 2026/07/13 Re: [PR] [FLINK-37925][table] Support casting from VARIANT to primitive types [flink] via GitHub
• 2026/07/13 Re: [PR] [FLINK-37925][table] Support casting from VARIANT to primitive types [flink] via GitHub
• 2026/07/13 Re: [PR] [FLINK-37925][table] Support casting from VARIANT to primitive types [flink] via GitHub
• 2026/07/13 Re: [PR] [FLINK-40089][table] Implement JSON_LENGTH function [flink] via GitHub
• 2026/07/13 [jira] [Closed] (FLINK-40066) flink-connector-mongodb: update flink-connector-parent to 2.0.0 and flink.version to 2.1.2 Ferenc Csaky (Jira)
• 2026/07/13 Re: [PR] [FLINK-40066][Connectors/MongoDB] Update flink-connector-parent to 2.0.0 and Flink to 2.1.2 [flink-connector-mongodb] via GitHub
• 2026/07/13 Re: [PR] [FLINK-40066][Connectors/MongoDB] Update flink-connector-parent to 2.0.0 and Flink to 2.1.2 [flink-connector-mongodb] via GitHub
• 2026/07/13 Re: [PR] [FLINK-40093][runtime] Resume idle splits by alignment check if previously paused [flink] via GitHub
• 2026/07/13 Re: [PR] [FLINK-31951][format] Reset decoder on Avro deserialization failure [flink] via GitHub
• 2026/07/13 Re: [PR] [tools] Update install.sh for Flink Agents 0.3.0 and Python 3.12 [flink-agents] via GitHub
• 2026/07/13 [jira] [Updated] (FLINK-40132) MixedKubernetesServerExtension teardown flaky with RejectedExecutionException from Fabric8 Vert.x mock server shutdown Martijn Visser (Jira)
• 2026/07/13 Re: [PR] [FLINK-37925][table] Support casting from VARIANT to primitive types [flink] via GitHub
• 2026/07/13 [jira] [Created] (FLINK-40133) Update HBase version to 2.6.6 Ferenc Csaky (Jira)
• 2026/07/13 Re: [D] Parallel Tool Call Execution [flink-agents] via GitHub
• 2026/07/13 [jira] [Updated] (FLINK-40133) Update HBase version to 2.6.6 Ferenc Csaky (Jira)
• 2026/07/13 [jira] [Updated] (FLINK-40133) Update HBase version to 2.6.6 Ferenc Csaky (Jira)
• 2026/07/13 Re: [PR] [FLINK-37925][table] Support casting from VARIANT to primitive types [flink] via GitHub
• 2026/07/13 Re: [PR] [FLINK-39198] Fix data loss during restoration from checkpoint in TIMESTAMP startup mode. [flink-cdc] via GitHub
• 2026/07/13 Re: [PR] [FLINK-39198] Fix data loss during restoration from checkpoint in TIMESTAMP startup mode. [flink-cdc] via GitHub
• 2026/07/13 Re: [PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink] via GitHub
• 2026/07/13 [jira] [Updated] (FLINK-40132) MixedKubernetesServerExtension teardown flaky with RejectedExecutionException from Fabric8 Vert.x mock server shutdown Martijn Visser (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] [Commented] (FLINK-39947) Fix the flaky test case in class TaskExecutorPartitionLifecycleTest Martijn Visser (Jira)
• 2026/07/13 Re: [PR] [FLINK-37925][table] Support casting from VARIANT to primitive types [flink] via GitHub
• 2026/07/13 [jira] [Updated] (FLINK-37925) Support type casting between variant and primitive type ASF GitHub Bot (Jira)
• 2026/07/13 [PR] [FLINK-37925][table] Support casting from VARIANT to primitive types [flink] via GitHub
• 2026/07/13 Re: [PR] [tools] Update install.sh for Flink Agents 0.3.0 and Python 3.12 [flink-agents] via GitHub
• 2026/07/13 [jira] [Resolved] (FLINK-39760) Fix missing JTS core dependency of PostgreSQL YAML connector Yanquan Lv (Jira)
• 2026/07/13 [jira] [Resolved] (FLINK-40130) Fix missing primary key type compatibility check of Paimon sink Yanquan Lv (Jira)
• 2026/07/13 Re: [PR] [FLINK-39783][table] Translate LATERAL SNAPSHOT to LateralSnapshotJoinOperator [flink] via GitHub
• 2026/07/13 Re: [PR] [FLINK-40130][connect/paimon] Fix missing primary key type compatibility check of Paimon sink [flink-cdc] via GitHub
• 2026/07/13 Re: [PR] [FLINK-39775][mysql] Release snapshot split metadata after entering the stream phase [flink-cdc] via GitHub
• 2026/07/13 Re: [PR] [FLINK-39775][mysql] Release snapshot split metadata after entering the stream phase [flink-cdc] via GitHub
• 2026/07/13 Re: [PR] [FLINK-39775][mysql] Release snapshot split metadata after entering the stream phase [flink-cdc] via GitHub
• 2026/07/13 Re: [PR] [FLINK-39775][mysql] Release snapshot split metadata after entering the stream phase [flink-cdc] via GitHub
• 2026/07/13 Re: [PR] [docs] Improve Incremental Snapshot Reading formatting and references [flink-cdc] via GitHub
• 2026/07/13 Re: [PR] [FLINK-20454][formats] Add metadata support for Debezium Avro [flink] via GitHub
• 2026/07/13 [PR] [docs] Improve Incremental Snapshot Reading formatting and references [flink-cdc] via GitHub
• 2026/07/13 [jira] [Assigned] (FLINK-40131) Add documentation for LATERAL SNAPSHOT join Fabian Hueske (Jira)
• 2026/07/13 [jira] [Created] (FLINK-40131) Add documentation for LATERAL SNAPSHOT join Fabian Hueske (Jira)
• 2026/07/13 Re: [PR] [api][integrations] Support models' native structured output (foundation + OpenAI) [flink-agents] via GitHub
• 2026/07/13 [jira] [Comment Edited] (FLINK-39049) Introduce built-in functions `VARIANT_GET` and `TRY_VARIANT_GET ` to extract values from a variant Ramin Gharib (Jira)
• 2026/07/13 [jira] [Updated] (FLINK-40128) Implement Topic integrity checks in Kafka Connector - Static source Roman Khachatryan (Jira)
• 2026/07/13 [jira] [Updated] (FLINK-40129) Implement Topic integrity checks in Kafka Connector - Dynamic source Roman Khachatryan (Jira)
• 2026/07/13 [jira] [Assigned] (FLINK-40129) Implement Topic integrity checks in Kafka Connector - Dynamic source Roman Khachatryan (Jira)
• 2026/07/13 [jira] [Assigned] (FLINK-40128) Implement Topic integrity checks in Kafka Connector - Static source Roman Khachatryan (Jira)
• 2026/07/13 [jira] [Assigned] (FLINK-40126) Implement Topic integrity checks in Kafka Connector Roman Khachatryan (Jira)
• 2026/07/13 [jira] [Comment Edited] (FLINK-39049) Introduce built-in functions `VARIANT_GET` and `TRY_VARIANT_GET ` to extract values from a variant Ramin Gharib (Jira)
• 2026/07/13 [jira] [Commented] (FLINK-39049) Introduce built-in functions `VARIANT_GET` and `TRY_VARIANT_GET ` to extract values from a variant Ramin Gharib (Jira)

• Earlier messages
• Later messages