(flink-kubernetes-operator) branch main updated: [FLINK-39752] Use same event recorder instance

[gyfora]

This is an automated email from the ASF dual-hosted git repository.

gyfora pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/flink-kubernetes-operator.git


The following commit(s) were added to refs/heads/main by this push:
     new 271e269a [FLINK-39752] Use same event recorder instance
271e269a is described below

commit 271e269abba59fc807bc533e49574db806b0dbb7
Author: Dennis-Mircea Ciupitu <dennis.mircea.ciup...@gmail.com>
AuthorDate: Thu Jun 4 15:27:46 2026 +0300

    [FLINK-39752] Use same event recorder instance
---
 .../main/java/org/apache/flink/kubernetes/operator/FlinkOperator.java   | 2 --
 1 file changed, 2 deletions(-)

diff --git 
a/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/FlinkOperator.java
 
b/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/FlinkOperator.java
index f2bb9286..cc15c5c8 100644
--- 
a/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/FlinkOperator.java
+++ 
b/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/FlinkOperator.java
@@ -207,7 +207,6 @@ public class FlinkOperator {
 
     @VisibleForTesting
     void registerSessionJobController() {
-        var eventRecorder = EventRecorder.create(client, listeners);
         var metricManager =
                 MetricManager.createFlinkSessionJobMetricManager(baseConfig, 
metricGroup);
         var statusRecorder = StatusRecorder.create(client, metricManager, 
listeners);
@@ -241,7 +240,6 @@ public class FlinkOperator {
                 
MetricManager.createFlinkStateSnapshotMetricManager(baseConfig, metricGroup);
         var statusRecorder =
                 StatusRecorder.createForFlinkStateSnapshot(client, 
metricManager, listeners);
-        var eventRecorder = EventRecorder.create(client, listeners);
         var reconciler = new StateSnapshotReconciler(ctxFactory, 
eventRecorder);
         var observer = new StateSnapshotObserver(ctxFactory, eventRecorder);
         var controller =