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 dfd55f2958125..625ed18227853 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.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 static WriteMarkers get(MarkerType markerType, HoodieTable table, String 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 7b8232f6194a3..53865e7dec8fc 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.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 @@ private DataFrameReader getDataFrameReader(String fileFormat) { } 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;