issues
Thread
Date
Earlier messages
Later messages
Messages by Date
2026/07/09
Re: [PR] [FLINK-40065][Connectors/AWS] Update flink-connector-parent to 2.0.0 and Flink to 2.1.2 [flink-connector-aws]
via GitHub
2026/07/09
[jira] [Created] (FLINK-40108) Add Splitters for snapshot a table or database
Jira
2026/07/09
[jira] [Updated] (FLINK-40108) Add Splitters for snapshot a table or database
Jira
2026/07/09
Re: [PR] [FLINK-40065][Connectors/AWS] Update flink-connector-parent to 2.0.0 and Flink to 2.1.2 [flink-connector-aws]
via GitHub
2026/07/09
Re: [PR] [FLINK-40099] Fix flaky YARNSessionFIFOSecuredITCase by verifying Kerberos keytab logs before the application is killed [flink]
via GitHub
2026/07/09
Re: [PR] [tools] Update install.sh for Flink Agents 0.3.0 and Python 3.12 [flink-agents]
via GitHub
2026/07/09
Re: [PR] [hotfix] Fix typos in operator documentation, comments and scripts [flink-kubernetes-operator]
via GitHub
2026/07/09
[jira] [Closed] (FLINK-40104) Logging framework JARs are placed under $FLINK_HOME/log instead of the operator lib directory
Gyula Fora (Jira)
2026/07/09
Re: [PR] [FLINK-40099] Fix flaky YARNSessionFIFOSecuredITCase by verifying Kerberos keytab logs before the application is killed [flink]
via GitHub
2026/07/09
Re: [PR] [FLINK-40104] Logging framework JARs are placed under /log instead of the operator lib directory [flink-kubernetes-operator]
via GitHub
2026/07/09
Re: [PR] [hotfix] Fix typos in operator documentation, comments and scripts [flink-kubernetes-operator]
via GitHub
2026/07/09
Re: [PR] [FLINK-35890][cdc] Select only the increment but still enter the SNAPSHOT lead to ckp failed [flink-cdc]
via GitHub
2026/07/09
[jira] [Closed] (FLINK-40106) Move FlinkResourceValidator and FlinkResourceMutator to the api module
Gyula Fora (Jira)
2026/07/09
[jira] [Updated] (FLINK-40106) Move FlinkResourceValidator and FlinkResourceMutator to the api module
Gyula Fora (Jira)
2026/07/09
Re: [PR] [FLINK-40106] Move FlinkResourceValidator and FlinkResourceMutator to the api module [flink-kubernetes-operator]
via GitHub
2026/07/09
[jira] [Closed] (FLINK-40107) Group example modules under an examples aggregator pom
Gyula Fora (Jira)
2026/07/09
[jira] [Updated] (FLINK-40107) Group example modules under an examples aggregator pom
Gyula Fora (Jira)
2026/07/09
Re: [PR] [FLINK-40107] Group example modules under an examples aggregator pom [flink-kubernetes-operator]
via GitHub
2026/07/09
Re: [PR] [FLINK-39110] Add CRT support in native-s3-fs [flink]
via GitHub
2026/07/09
Re: [D] Parallel Tool Call Execution [flink-agents]
via GitHub
2026/07/09
Re: [PR] [hotfix] Cleanup compat test runs [flink-kubernetes-operator]
via GitHub
2026/07/09
[jira] [Reopened] (FLINK-39760) Fix missing JTS core dependency of PostgreSQL YAML connector
Mao Jiayi (Jira)
2026/07/09
[jira] [Updated] (FLINK-39760) Fix missing JTS core dependency of PostgreSQL YAML connector
Mao Jiayi (Jira)
2026/07/09
[jira] [Updated] (FLINK-40107) Group example modules under an examples aggregator pom
ASF GitHub Bot (Jira)
2026/07/09
[PR] [FLINK-40107] Group example modules under an examples aggregator pom [flink-kubernetes-operator]
via GitHub
2026/07/09
Re: [PR] [api][python][java] Track embedding token usage metrics [flink-agents]
via GitHub
2026/07/09
[jira] [Created] (FLINK-40107) Group example modules under an examples aggregator pom
Dennis-Mircea Ciupitu (Jira)
2026/07/09
[jira] [Resolved] (FLINK-40099) YARNSessionFIFOSecuredITCase.testDetachedMode is flaky: Kerberos keytab log check reads a killed TaskManager's log
Martijn Visser (Jira)
2026/07/09
[jira] [Commented] (FLINK-40099) YARNSessionFIFOSecuredITCase.testDetachedMode is flaky: Kerberos keytab log check reads a killed TaskManager's log
Martijn Visser (Jira)
2026/07/09
[jira] [Updated] (FLINK-40099) YARNSessionFIFOSecuredITCase.testDetachedMode is flaky: Kerberos keytab log check reads a killed TaskManager's log
Martijn Visser (Jira)
2026/07/09
Re: [PR] [FLINK-40099] Fix flaky YARNSessionFIFOSecuredITCase by verifying Kerberos keytab logs before the application is killed [flink]
via GitHub
2026/07/09
Re: [PR] [FLINK-40105][Deployment/Kubernetes] Support memory request factor for Kubernetes deployments [flink]
via GitHub
2026/07/09
[jira] [Resolved] (FLINK-39520) Preparatory refactoring for channel-state recovery: split the recovered-state handler, add InputGate#getChannel(InputChannelInfo)
Rui Fan (Jira)
2026/07/09
[jira] [Updated] (FLINK-40105) Support configuring Kubernetes memory request factor for JobManager and TaskManager
ASF GitHub Bot (Jira)
2026/07/09
[PR] [FLINK-40105][Deployment/Kubernetes] Support memory request factor for Kubernetes deployments [flink]
via GitHub
2026/07/09
[jira] [Updated] (FLINK-40106) Move FlinkResourceValidator and FlinkResourceMutator to the api module
ASF GitHub Bot (Jira)
2026/07/09
[PR] [FLINK-40106] Move FlinkResourceValidator and FlinkResourceMutator to the api module [flink-kubernetes-operator]
via GitHub
2026/07/09
[jira] [Created] (FLINK-40106) Move FlinkResourceValidator and FlinkResourceMutator to the api module
Dennis-Mircea Ciupitu (Jira)
2026/07/09
[jira] [Commented] (FLINK-40084) maven-shade-plugin does not respect multi release jars
Sergey Nuyanzin (Jira)
2026/07/09
[jira] [Resolved] (FLINK-40084) maven-shade-plugin does not respect multi release jars
Sergey Nuyanzin (Jira)
2026/07/09
Re: [PR] [FLINK-40084][build] maven-shade-plugin does not respect multi release jars [flink]
via GitHub
2026/07/09
[PR] [tools] Update install.sh for Flink Agents 0.3.0 and Python 3.12 [flink-agents]
via GitHub
2026/07/09
[jira] [Assigned] (FLINK-40076) RescaleTimelineITCase.testRecordNonTerminatedRescaleMergingWithNewRecoverableFailureTriggerCause fails intermittently: snapshot taken before recoverable failover is merged into in-progress rescale
Martijn Visser (Jira)
2026/07/09
Re: [PR] [FLINK-39520] Preparatory refactoring for channel state recovery (no behavior change) [flink]
via GitHub
2026/07/09
[jira] [Updated] (FLINK-40104) Logging framework JARs are placed under $FLINK_HOME/log instead of the operator lib directory
ASF GitHub Bot (Jira)
2026/07/09
[PR] [FLINK-40104] Logging framework JARs are placed under /log instead of the operator lib directory [flink-kubernetes-operator]
via GitHub
2026/07/09
[PR] [hotfix] Cleanup compat test runs [flink-kubernetes-operator]
via GitHub
2026/07/09
[jira] [Created] (FLINK-40105) Support configuring Kubernetes memory request factor for JobManager and TaskManager
xiechenling (Jira)
2026/07/09
Re: [PR] [FLINK-39225][model] Add retry with default value fallback for Triton inference failures [flink]
via GitHub
2026/07/09
Re: [PR] [FLINK-39051][Table SQL/Planner] Support APPROX_COUNT_DISTINCT aggregate function in streaming mode with Window TVF [flink]
via GitHub
2026/07/09
Re: [PR] Bump org.assertj:assertj-core from 3.24.2 to 3.27.7 [flink-connector-jdbc]
via GitHub
2026/07/09
[jira] [Updated] (FLINK-40104) Logging framework JARs are placed under $FLINK_HOME/log instead of the operator lib directory
Dennis-Mircea Ciupitu (Jira)
2026/07/09
Re: [D] Parallel Tool Call Execution [flink-agents]
via GitHub
2026/07/09
Re: [PR] [integration][openai] Align default parameters for openai chat model between java and python [flink-agents]
via GitHub
2026/07/09
Re: [PR] [FLINK-39783][table] Translate LATERAL SNAPSHOT to LateralSnapshotJoinOperator [flink]
via GitHub
2026/07/09
Re: [PR] [FLINK-39783][table] Translate LATERAL SNAPSHOT to LateralSnapshotJoinOperator [flink]
via GitHub
2026/07/08
Re: [PR] [FLINK-39783][table] Translate LATERAL SNAPSHOT to LateralSnapshotJoinOperator [flink]
via GitHub
2026/07/08
Re: [D] Parallel Tool Call Execution [flink-agents]
via GitHub
2026/07/08
Re: [PR] [FLINK-39783][table] Translate LATERAL SNAPSHOT to LateralSnapshotJoinOperator [flink]
via GitHub
2026/07/08
Re: [PR] [FLINK-39783][table] Translate LATERAL SNAPSHOT to LateralSnapshotJoinOperator [flink]
via GitHub
2026/07/08
Re: [PR] [api][runtime][python] Add memory events for agent memory observability [flink-agents]
via GitHub
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
Re: [PR] [FLINK-39783][table] Translate LATERAL SNAPSHOT to LateralSnapshotJoinOperator [flink]
via GitHub
2026/07/08
Re: [PR] [FLINK-40079][table] Reject PTF calls with sys-args if they are disabled [flink]
via GitHub
2026/07/08
[jira] [Updated] (FLINK-40103) Upgrade operator to Java Operator SDK version 5.4
ASF GitHub Bot (Jira)
2026/07/08
Re: [PR] [FLINK-39925][Autoscaler] Skip scaling decisions when vertex IO metrics are incomplete to prevent incorrect scale down [flink-kubernetes-operator]
via GitHub
2026/07/08
Re: [PR] [FLINK-40103] Bump JOSDK to 5.4.0 [flink-kubernetes-operator]
via GitHub
2026/07/08
[jira] [Created] (FLINK-40103) Upgrade operator to Java Operator SDK version 5.4
Jira
2026/07/08
Re: [PR] [api][python][java] Track embedding token usage metrics [flink-agents]
via GitHub
2026/07/08
Re: [PR] [FLINK-40076][tests] Fix race in RescaleTimelineITCase.testRecordNonTerminatedRescaleMergingWithNewRecoverableFailureTriggerCause [flink]
via GitHub
2026/07/08
[jira] [Resolved] (FLINK-38429) Improve perf for Elasticsearch 8 connector
reswqa (Jira)
2026/07/08
[jira] [Assigned] (FLINK-38429) Improve perf for Elasticsearch 8 connector
reswqa (Jira)
2026/07/08
Re: [PR] [FLINK-39110] Add CRT support in native-s3-fs [flink]
via GitHub
2026/07/08
Re: [PR] [FLINK-39110] Add CRT support in native-s3-fs [flink]
via GitHub
2026/07/08
[jira] [Commented] (FLINK-40096) Migrate EXPLAIN CTAS/RTAS Explain tests to Java
Sergey Nuyanzin (Jira)
2026/07/08
[jira] [Resolved] (FLINK-40096) Migrate EXPLAIN CTAS/RTAS Explain tests to Java
Sergey Nuyanzin (Jira)
2026/07/08
Re: [PR] [FLINK-40096] Migrate EXPLAIN CTAS/RTAS Explain tests to Java [flink]
via GitHub
2026/07/08
Re: [PR] [FLINK-38647] Support changelog-mode=upsert + null-tolerance [flink-cdc]
via GitHub
2026/07/08
Re: [PR] [FLINK-40055] Serialize managed cluster config in the target Flink version's YAML dialect [flink-kubernetes-operator]
via GitHub
2026/07/08
Re: [PR] [FLINK-40055] Serialize managed cluster config in the target Flink version's YAML dialect [flink-kubernetes-operator]
via GitHub
2026/07/08
Re: [PR] [FLINK-39791][helm] Honor defaultConfiguration.config.yaml and always mount config.yaml [flink-kubernetes-operator]
via GitHub
2026/07/08
Re: [PR] [FLINK-39791][helm] Honor defaultConfiguration.config.yaml and always mount config.yaml [flink-kubernetes-operator]
via GitHub
2026/07/08
Re: [PR] [FLINK-39791][helm] Honor defaultConfiguration.config.yaml and always mount config.yaml [flink-kubernetes-operator]
via GitHub
2026/07/08
Re: [PR] [FLINK-39791][helm] Honor defaultConfiguration.config.yaml and always mount config.yaml [flink-kubernetes-operator]
via GitHub
2026/07/08
Re: [PR] [FLINK-39791][helm] Honor defaultConfiguration.config.yaml and always mount config.yaml [flink-kubernetes-operator]
via GitHub
2026/07/08
Re: [PR] [api][runtime][python] Propagate metric groups to cross-language resources [flink-agents]
via GitHub
2026/07/08
Re: [PR] [FLINK-39791][helm] Honor defaultConfiguration.config.yaml and always mount config.yaml [flink-kubernetes-operator]
via GitHub
2026/07/08
Re: [PR] [FLINK-39791][helm] Honor defaultConfiguration.config.yaml and always mount config.yaml [flink-kubernetes-operator]
via GitHub
2026/07/08
Re: [PR] [FLINK-40055] Serialize managed cluster config in the target Flink version's YAML dialect [flink-kubernetes-operator]
via GitHub
2026/07/08
Re: [PR] [FLINK-40102][mysql]Support batch emitting CreateTableEvents to reduce schema coordination overhead [flink-cdc]
via GitHub
2026/07/08
Re: [PR] [FLINK-39791][helm] Honor defaultConfiguration.config.yaml and always mount config.yaml [flink-kubernetes-operator]
via GitHub
2026/07/08
[PR] [api][runtime][python] Add memory events for agent memory observability [flink-agents]
via GitHub
2026/07/08
Re: [PR] [api][python][java] Track embedding token usage metrics [flink-agents]
via GitHub
2026/07/08
Re: [I] [Tech Debt] Align default value for python and java openai chatmodel [flink-agents]
via GitHub
2026/07/08
Re: [PR] [FLINK-39193][Kafka Connector] Use reset strategy for missing specified offsets [flink-connector-kafka]
via GitHub
2026/07/08
[I] [Feature] Add memory events for agent memory observability [flink-agents]
via GitHub
2026/07/08
Re: [PR] [FLINK-40102][mysql]Support batch emitting CreateTableEvents to reduce schema coordination overhead [flink-cdc]
via GitHub
2026/07/08
Re: [PR] [FLINK-38429] Reuse OperationSerializer in Elasticsearch 8 connector to improve perf [flink-connector-elasticsearch]
via GitHub
2026/07/08
[PR] [BP-4.0][FLINK-38054] Fix OperationSerializer issue for es8 sink [flink-connector-elasticsearch]
via GitHub
2026/07/08
[PR] [BP-3.1][FLINK-38054] Fix OperationSerializer issue for es8 sink [flink-connector-elasticsearch]
via GitHub
2026/07/08
Re: [I] [Bug] byte[] memory values corrupted to base64 String on the durable-execution replay path [flink-agents]
via GitHub
2026/07/08
Re: [PR] [api][integrations] Support models' native structured output (foundation + OpenAI) [flink-agents]
via GitHub
2026/07/08
Re: [PR] [FLINK-40095][table-planner] Fix JSON aggregation functions failing in group window aggregate [flink]
via GitHub
2026/07/08
[jira] [Updated] (FLINK-40102) MySQL CDC Source: Support batch emitting CreateTableEvents to reduce schema coordination overhead
ASF GitHub Bot (Jira)
2026/07/08
[PR] [FLINK-40102]MySQL CDC Source: Support batch emitting CreateTableEvents to reduce schema coordination overhead [flink-cdc]
via GitHub
2026/07/08
Re: [PR] [FLINK-38071][table] Add opt-in UDF metrics (FLIP-485) [flink]
via GitHub
2026/07/08
[jira] [Created] (FLINK-40102) MySQL CDC Source: Support batch emitting CreateTableEvents to reduce schema coordination overhead
ericzeng (Jira)
2026/07/08
[jira] [Updated] (FLINK-38071) FLIP-485: Add UDF Metrics
ASF GitHub Bot (Jira)
2026/07/08
[PR] [FLINK-38071][table] Add opt-in UDF metrics (FLIP-485) [flink]
via GitHub
2026/07/08
Re: [PR] [FLINK-36581][cli] Allow passing Flink configuration by yaml job file [flink-cdc]
via GitHub
2026/07/08
Re: [PR] [FLINK-39520] Preparatory refactoring for channel state recovery (no behavior change) [flink]
via GitHub
2026/07/08
Re: [PR] [python] Backfill remote test coverage ahead of local execution path removal [flink-agents]
via GitHub
2026/07/08
Re: [PR] [python] Remove the Python local execution path [flink-agents]
via GitHub
2026/07/08
Re: [PR] [FLINK-39520] Preparatory refactoring for channel state recovery (no behavior change) [flink]
via GitHub
2026/07/08
Re: [I] [Bug] byte[] memory values corrupted to base64 String on the durable-execution replay path [flink-agents]
via GitHub
2026/07/08
Re: [PR] [Tech Debt] Avoid using reflection to load implementation classes of resources during the compilation phase [flink-agents]
via GitHub
2026/07/08
Re: [PR] [Tech Debt] Avoid using reflection to load implementation classes of resources during the compilation phase [flink-agents]
via GitHub
2026/07/08
Re: [PR] [FLINK-40094][Connectors/Kafka] Mark removed DynamicKafkaSource split outputs idle before release [flink-connector-kafka]
via GitHub
2026/07/08
Re: [PR] [FLINK-40094][Connectors/Kafka] Mark removed DynamicKafkaSource split outputs idle before release [flink-connector-kafka]
via GitHub
2026/07/08
Re: [D] Planning Flink Agents 0.4 [flink-agents]
via GitHub
2026/07/08
Re: [D] Planning Flink Agents 0.4 [flink-agents]
via GitHub
2026/07/08
Re: [PR] [FLINK-40089][table] Implement JSON_LENGTH function [flink]
via GitHub
2026/07/08
Re: [PR] [FLINK-39521][network] Push-based recovery support in input channels [flink]
via GitHub
2026/07/08
Re: [PR] ci: pin GitHub Actions to full commit SHAs [flink]
via GitHub
2026/07/08
Re: [PR] ci: pin GitHub Actions to full commit SHAs [flink]
via GitHub
2026/07/08
Re: [PR] [FLINK-40089][table] Implement JSON_LENGTH function [flink]
via GitHub
2026/07/08
Re: [D] Parallel Tool Call Execution [flink-agents]
via GitHub
2026/07/08
Re: [PR] [FLINK-40094][Connectors/Kafka] Mark removed DynamicKafkaSource split outputs idle before release [flink-connector-kafka]
via GitHub
2026/07/08
Re: [PR] [FLINK-39520] Preparatory refactoring for channel state recovery (no behavior change) [flink]
via GitHub
2026/07/08
Re: [PR] [FLINK-39837] Reassign retained dynamic Kafka offsets upon readd [flink-connector-kafka]
via GitHub
2026/07/08
[jira] [Updated] (FLINK-40076) RescaleTimelineITCase.testRecordNonTerminatedRescaleMergingWithNewRecoverableFailureTriggerCause fails intermittently: snapshot taken before recoverable failover is merged into in-progress rescale
Matthias Pohl (Jira)
2026/07/08
[jira] [Commented] (FLINK-40076) RescaleTimelineITCase.testRecordNonTerminatedRescaleMergingWithNewRecoverableFailureTriggerCause fails intermittently: snapshot taken before recoverable failover is merged into in-progress rescale
Matthias Pohl (Jira)
2026/07/08
Re: [PR] [FLINK-40076][tests] Fix race in RescaleTimelineITCase.testRecordNonTerminatedRescaleMergingWithNewRecoverableFailureTriggerCause [flink]
via GitHub
2026/07/08
Re: [PR] [FLINK-40093][Runtime] Resume idle splits by alignment check if previously paused [flink]
via GitHub
2026/07/08
Re: [PR] [FLINK-39110] Add CRT support in native-s3-fs [flink]
via GitHub
2026/07/08
Re: [PR] [FLINK-40094][Connectors/Kafka] Mark removed DynamicKafkaSource split outputs idle before release [flink-connector-kafka]
via GitHub
2026/07/08
Re: [PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink]
via GitHub
2026/07/08
Re: [PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink]
via GitHub
2026/07/08
Re: [PR] Bump JOSDK to 5.4.0 [flink-kubernetes-operator]
via GitHub
2026/07/08
[jira] [Assigned] (FLINK-40030) Add architecture tests to flink-connector-http
david radley (Jira)
2026/07/08
Re: [D] Parallel Tool Call Execution [flink-agents]
via GitHub
2026/07/08
[jira] [Updated] (FLINK-40101) Watermark forwarding can stall indefinitely under interruptible timers with a large due-timer backlog
Piotr Nowojski (Jira)
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: [PR] Bump JOSDK to 5.4.0 [flink-kubernetes-operator]
via GitHub
2026/07/08
Re: [PR] [FLINK-39191][runtime-web] Upgrade monaco-editor to 0.55.1 [flink]
via GitHub
2026/07/08
Re: [PR] [FLINK-40015] Introduce getFunctionOutput in PTF Test Harness [flink]
via GitHub
2026/07/08
Re: [PR] [hotfix] Add missing ASF license headers in backward-compatibility module [flink-connector-jdbc]
via GitHub
2026/07/08
[PR] Bump com.microsoft.sqlserver:mssql-jdbc from 10.2.1.jre8 to 11.2.0.jre8 in /flink-connector-jdbc-sqlserver [flink-connector-jdbc]
via GitHub
2026/07/08
Re: [PR] [hotfix] Add missing ASF license headers in backward-compatibility module [flink-connector-jdbc]
via GitHub
2026/07/08
Re: [PR] [hotfix] Add missing ASF license headers in backward-compatibility module [flink-connector-jdbc]
via GitHub
2026/07/08
Re: [D] Planning Flink Agents 0.4 [flink-agents]
via GitHub
2026/07/08
Re: [PR] [hotfix] Add missing ASF license headers in backward-compatibility module [flink-connector-jdbc]
via GitHub
2026/07/08
Re: [PR] [hotfix] Add missing ASF license headers in backward-compatibility module [flink-connector-jdbc]
via GitHub
2026/07/08
Re: [PR] [hotfix] Add missing ASF license headers in backward-compatibility module [flink-connector-jdbc]
via GitHub
2026/07/08
Re: [PR] [hotfix] Add missing ASF license headers in backward-compatibility module [flink-connector-jdbc]
via GitHub
2026/07/08
Re: [PR] [FLINK-40089][table] Implement JSON_LENGTH function [flink]
via GitHub
2026/07/08
Re: [D] Community Sync - 2026 [flink-agents]
via GitHub
2026/07/08
[jira] [Commented] (FLINK-40090) Modernize cryptography export notice in distribution README
Martijn Visser (Jira)
2026/07/08
Re: [PR] [FLINK-40072][connector-http] Read request.timeout as the declared Duration option [flink-connector-http]
via GitHub
2026/07/08
[jira] [Resolved] (FLINK-40090) Modernize cryptography export notice in distribution README
Martijn Visser (Jira)
2026/07/08
[jira] [Updated] (FLINK-40090) Modernize cryptography export notice in distribution README
Martijn Visser (Jira)
2026/07/08
Re: [PR] [FLINK-40090][docs] Add cryptography export notice to README [flink-shaded]
via GitHub
2026/07/08
Re: [PR] [FLINK-40090][docs] Modernize cryptography export notice in distribution README [flink]
via GitHub
2026/07/08
Re: [PR] [FLINK-40089][table] Implement JSON_LENGTH function [flink]
via GitHub
2026/07/08
[jira] [Commented] (FLINK-29267) Support external type systems in DDL
Dale Lane (Jira)
2026/07/08
Re: [PR] [FLINK-40030][connector-http] Add architecture tests [flink-connector-http]
via GitHub
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
[jira] [Resolved] (FLINK-40030) Add architecture tests to flink-connector-http
Bharath Reddy Gunapati (Jira)
2026/07/08
Re: [PR] [FLINK-40005][cdc-cli] CliExecutor application mode resolves pipeline definition from local path (k8s), remote path or inline content [flink-cdc]
via GitHub
2026/07/08
Re: [PR] [FLINK-40040][cdc-runtime] Wrap coordinator failure in SerializedThrowable across the RPC boundary [flink-cdc]
via GitHub
2026/07/08
Re: [PR] [FLINK-40095][table-planner] Fix JSON aggregation functions failing in group window aggregate [flink]
via GitHub
2026/07/08
Re: [PR] [FLINK-38054] flink-connector-elasticsearch8 use correct ClassLoader in OperationSerializer [flink-connector-elasticsearch]
via GitHub
2026/07/08
Re: [PR] [FLINK-38054] flink-connector-elasticsearch8 use correct ClassLoader in OperationSerializer [flink-connector-elasticsearch]
via GitHub
2026/07/08
[jira] [Resolved] (FLINK-38054) Kryo deserialization error in ElasticSearch 8 sink 3.1.0 with Flink 1.20.0
reswqa (Jira)
2026/07/08
Re: [PR] [FLINK-38054] Fix OperationSerializer issue for es8 sink [flink-connector-elasticsearch]
via GitHub
2026/07/08
Re: [PR] [FLINK-38054] Fix OperationSerializer issue for es8 sink [flink-connector-elasticsearch]
via GitHub
2026/07/08
[jira] [Commented] (FLINK-33186) CheckpointAfterAllTasksFinishedITCase.testRestoreAfterSomeTasksFinished fails on AZP
Martijn Visser (Jira)
2026/07/08
[jira] [Comment Edited] (FLINK-40093) Race condition between watermark alignment and idleness detection locks split in idle
Efrat Levitan (Jira)
2026/07/08
[jira] [Updated] (FLINK-33186) CheckpointAfterAllTasksFinishedITCase.testRestoreAfterSomeTasksFinished fails on AZP
Martijn Visser (Jira)
2026/07/08
[jira] [Commented] (FLINK-40093) Race condition between watermark alignment and idleness detection locks split in idle
Efrat Levitan (Jira)
2026/07/08
Re: [PR] [BP-2.2][FLINK-40093][runtime] Resume idle splits by alignment check if previously paused [flink]
via GitHub
2026/07/08
Re: [PR] [BP-2.3][FLINK-40093][runtime] Resume idle splits by alignment check if previously paused [flink]
via GitHub
2026/07/08
Re: [PR] [plan][runtime][java] Add CEL Action condition filtering [flink-agents]
via GitHub
2026/07/08
[PR] [BP-2.2][FLINK-40093][runtime] Resume idle splits by alignment check if previously paused [flink]
via GitHub
2026/07/08
Re: [PR] [FLINK-40089][table] Implement JSON_LENGTH function [flink]
via GitHub
2026/07/08
Re: [PR] [FLINK-40089][table] Implement JSON_LENGTH function [flink]
via GitHub
2026/07/08
Re: [PR] [FLINK-40093][Runtime] Resume idle splits by alignment check if previously paused [flink]
via GitHub
2026/07/08
[PR] [BP-2.3][FLINK-40093][runtime] Resume idle splits by alignment check if previously paused [flink]
via GitHub
2026/07/08
Re: [PR] [FLINK-40089][table] Implement JSON_LENGTH function [flink]
via GitHub
2026/07/08
[jira] [Updated] (FLINK-40093) Race condition between watermark alignment and idleness detection locks split in idle
ASF GitHub Bot (Jira)
2026/07/08
[PR] [FLINK-40093][Runtime] Resume idle splits by alignment check if previously paused [flink]
via GitHub
2026/07/08
[jira] [Commented] (FLINK-39049) Introduce built-in functions `VARIANT_GET` and `TRY_VARIANT_GET ` to extract values from a variant
Timo Walther (Jira)
2026/07/08
[jira] [Comment Edited] (FLINK-29267) Support external type systems in DDL
Dale Lane (Jira)
2026/07/08
[jira] [Comment Edited] (FLINK-29267) Support external type systems in DDL
Dale Lane (Jira)
2026/07/08
[jira] [Assigned] (FLINK-39049) Introduce built-in functions `VARIANT_GET` and `TRY_VARIANT_GET ` to extract values from a variant
Timo Walther (Jira)
2026/07/08
[jira] [Commented] (FLINK-29267) Support external type systems in DDL
Dale Lane (Jira)
2026/07/08
[jira] [Updated] (FLINK-40089) Add JSON_LENGTH function
ASF GitHub Bot (Jira)
2026/07/08
[PR] [FLINK-40089][table] Implement JSON_LENGTH function [flink]
via GitHub
2026/07/08
Re: [PR] [FLINK-40088][tests] Tolerate HTTP-level responses in RestClientITCase TLS check [flink]
via GitHub
2026/07/08
Re: [PR] [FLINK-36317][runtime] Populate ArchivedExecutionGraph with CheckpointStatsSnapshot in WaitingForResources state [flink]
via GitHub
Earlier messages
Later messages