(hudi) branch master updated: [MINOR] add logger to CompactionPlanOperator & ClusteringPlanOperator (#10562)

[danny0405]

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

danny0405 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git


The following commit(s) were added to refs/heads/master by this push:
     new ce0024ebe33 [MINOR] add logger to CompactionPlanOperator & 
ClusteringPlanOperator (#10562)
ce0024ebe33 is described below

commit ce0024ebe3308bf1a0a931816b0cf45ec616b4c8
Author: Dongsj <90449228+eric9...@users.noreply.github.com>
AuthorDate: Fri Jan 26 10:19:05 2024 +0800

    [MINOR] add logger to CompactionPlanOperator & ClusteringPlanOperator 
(#10562)
    
    Co-authored-by: dongsj <don...@asiainfo.com>
---
 .../java/org/apache/hudi/sink/clustering/ClusteringPlanOperator.java   | 3 +++
 .../main/java/org/apache/hudi/sink/compact/CompactionPlanOperator.java | 3 +++
 2 files changed, 6 insertions(+)

diff --git 
a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/clustering/ClusteringPlanOperator.java
 
b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/clustering/ClusteringPlanOperator.java
index c16f8ed7080..327d688f951 100644
--- 
a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/clustering/ClusteringPlanOperator.java
+++ 
b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/clustering/ClusteringPlanOperator.java
@@ -39,6 +39,8 @@ import 
org.apache.flink.streaming.api.operators.AbstractStreamOperator;
 import org.apache.flink.streaming.api.operators.OneInputStreamOperator;
 import org.apache.flink.streaming.api.operators.Output;
 import org.apache.flink.streaming.runtime.streamrecord.StreamRecord;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 import java.util.List;
 
@@ -49,6 +51,7 @@ import java.util.List;
  */
 public class ClusteringPlanOperator extends 
AbstractStreamOperator<ClusteringPlanEvent>
     implements OneInputStreamOperator<Object, ClusteringPlanEvent> {
+  private static final Logger LOG = 
LoggerFactory.getLogger(ClusteringPlanOperator.class);
 
   /**
    * Config options.
diff --git 
a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/compact/CompactionPlanOperator.java
 
b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/compact/CompactionPlanOperator.java
index 00591806cc8..3cbd70a5f03 100644
--- 
a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/compact/CompactionPlanOperator.java
+++ 
b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/compact/CompactionPlanOperator.java
@@ -38,6 +38,8 @@ import 
org.apache.flink.streaming.api.operators.BoundedOneInput;
 import org.apache.flink.streaming.api.operators.OneInputStreamOperator;
 import org.apache.flink.streaming.api.operators.Output;
 import org.apache.flink.streaming.runtime.streamrecord.StreamRecord;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 import java.io.IOException;
 import java.util.List;
@@ -51,6 +53,7 @@ import static java.util.stream.Collectors.toList;
  */
 public class CompactionPlanOperator extends 
AbstractStreamOperator<CompactionPlanEvent>
     implements OneInputStreamOperator<Object, CompactionPlanEvent>, 
BoundedOneInput {
+  private static final Logger LOG = 
LoggerFactory.getLogger(CompactionPlanOperator.class);
 
   /**
    * Config options.