[flink-kubernetes-operator] branch main updated: [chore] fix the LoggerFactory class in FlinkSessionJobReconciler

[mbalassi]

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

mbalassi 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 3b7a57b  [chore] fix the LoggerFactory class in 
FlinkSessionJobReconciler
3b7a57b is described below

commit 3b7a57b796845d1800db2df20b4ac88e418a6de9
Author: Hao Xin <haoxi...@gmail.com>
AuthorDate: Wed Apr 6 20:18:07 2022 +0800

    [chore] fix the LoggerFactory class in FlinkSessionJobReconciler
---
 .../operator/reconciler/sessionjob/FlinkSessionJobReconciler.java      | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git 
a/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/sessionjob/FlinkSessionJobReconciler.java
 
b/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/sessionjob/FlinkSessionJobReconciler.java
index 9bb5e4a..acd3500 100644
--- 
a/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/sessionjob/FlinkSessionJobReconciler.java
+++ 
b/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/sessionjob/FlinkSessionJobReconciler.java
@@ -26,7 +26,6 @@ import 
org.apache.flink.kubernetes.operator.crd.spec.FlinkSessionJobSpec;
 import 
org.apache.flink.kubernetes.operator.crd.status.JobManagerDeploymentStatus;
 import org.apache.flink.kubernetes.operator.reconciler.Reconciler;
 import org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils;
-import 
org.apache.flink.kubernetes.operator.reconciler.deployment.ApplicationReconciler;
 import org.apache.flink.kubernetes.operator.service.FlinkService;
 import org.apache.flink.kubernetes.operator.utils.FlinkUtils;
 import org.apache.flink.kubernetes.operator.utils.OperatorUtils;
@@ -42,7 +41,7 @@ import java.util.Optional;
 /** The reconciler for the {@link FlinkSessionJob}. */
 public class FlinkSessionJobReconciler implements Reconciler<FlinkSessionJob> {
 
-    private static final Logger LOG = 
LoggerFactory.getLogger(ApplicationReconciler.class);
+    private static final Logger LOG = 
LoggerFactory.getLogger(FlinkSessionJobReconciler.class);
 
     private final FlinkOperatorConfiguration operatorConfiguration;
     private final KubernetesClient kubernetesClient;