[hudi] branch master updated: Remove minlog.Log (#7441)

[forwardxu]

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

forwardxu 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 60cabeb208c Remove minlog.Log (#7441)
60cabeb208c is described below

commit 60cabeb208cf2809448ecd1ef61e42ad16702982
Author: cxzl25 <cxz...@users.noreply.github.com>
AuthorDate: Wed Dec 28 12:53:11 2022 +0800

    Remove minlog.Log (#7441)
---
 .../main/java/org/apache/hudi/table/marker/WriteMarkersFactory.java  | 5 ++---
 .../org/apache/hudi/utilities/sources/S3EventsHoodieIncrSource.java  | 3 +--
 2 files changed, 3 insertions(+), 5 deletions(-)

diff --git 
a/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/marker/WriteMarkersFactory.java
 
b/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/marker/WriteMarkersFactory.java
index dfd55f29581..625ed182278 100644
--- 
a/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/marker/WriteMarkersFactory.java
+++ 
b/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/marker/WriteMarkersFactory.java
@@ -24,7 +24,6 @@ import org.apache.hudi.common.table.marker.MarkerType;
 import org.apache.hudi.exception.HoodieException;
 import org.apache.hudi.table.HoodieTable;
 
-import com.esotericsoftware.minlog.Log;
 import org.apache.log4j.LogManager;
 import org.apache.log4j.Logger;
 
@@ -47,14 +46,14 @@ public class WriteMarkersFactory {
         return new DirectWriteMarkers(table, instantTime);
       case TIMELINE_SERVER_BASED:
         if (!table.getConfig().isEmbeddedTimelineServerEnabled()) {
-          Log.warn("Timeline-server-based markers are configured as the marker 
type "
+          LOG.warn("Timeline-server-based markers are configured as the marker 
type "
               + "but embedded timeline server is not enabled.  Falling back to 
direct markers.");
           return new DirectWriteMarkers(table, instantTime);
         }
         String basePath = table.getMetaClient().getBasePath();
         if (StorageSchemes.HDFS.getScheme().equals(
             FSUtils.getFs(basePath, 
table.getContext().getHadoopConf().newCopy()).getScheme())) {
-          Log.warn("Timeline-server-based markers are not supported for HDFS: "
+          LOG.warn("Timeline-server-based markers are not supported for HDFS: "
               + "base path " + basePath + ".  Falling back to direct 
markers.");
           return new DirectWriteMarkers(table, instantTime);
         }
diff --git 
a/hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/S3EventsHoodieIncrSource.java
 
b/hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/S3EventsHoodieIncrSource.java
index 7b8232f6194..53865e7dec8 100644
--- 
a/hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/S3EventsHoodieIncrSource.java
+++ 
b/hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/S3EventsHoodieIncrSource.java
@@ -32,7 +32,6 @@ import org.apache.hudi.exception.HoodieIOException;
 import org.apache.hudi.utilities.schema.SchemaProvider;
 import org.apache.hudi.utilities.sources.helpers.IncrSourceHelper;
 
-import com.esotericsoftware.minlog.Log;
 import com.fasterxml.jackson.databind.ObjectMapper;
 import org.apache.hadoop.conf.Configuration;
 import org.apache.hadoop.fs.FileSystem;
@@ -109,7 +108,7 @@ public class S3EventsHoodieIncrSource extends 
HoodieIncrSource {
       } catch (IOException e) {
         throw new HoodieException(String.format("Failed to parse sparkOptions: 
%s", props.getString(Config.SPARK_DATASOURCE_OPTIONS)), e);
       }
-      Log.info(String.format("sparkOptions loaded: %s", sparkOptionsMap));
+      LOG.info(String.format("sparkOptions loaded: %s", sparkOptionsMap));
       dataFrameReader = dataFrameReader.options(sparkOptionsMap);
     }
     return dataFrameReader;