[incubator-hudi] branch master updated: [MINOR] cleanup redundant comment and unused variable and fix typo (#1435)

[vinoth]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new 8b00791  [MINOR] cleanup redundant comment and unused variable and fix 
typo (#1435)
8b00791 is described below

commit 8b00791ef47f708f54ffbfb5789ed65f958740b3
Author: Zhiyuan Zhao <49054376+zhaomin1...@users.noreply.github.com>
AuthorDate: Sun Mar 22 11:12:06 2020 +0800

    [MINOR] cleanup redundant comment and unused variable and fix typo (#1435)
---
 .../main/java/org/apache/hudi/utilities/deltastreamer/DeltaSync.java   | 1 -
 .../org/apache/hudi/utilities/deltastreamer/HoodieDeltaStreamer.java   | 2 +-
 .../src/main/java/org/apache/hudi/utilities/sources/Source.java        | 3 ---
 3 files changed, 1 insertion(+), 5 deletions(-)

diff --git 
a/hudi-utilities/src/main/java/org/apache/hudi/utilities/deltastreamer/DeltaSync.java
 
b/hudi-utilities/src/main/java/org/apache/hudi/utilities/deltastreamer/DeltaSync.java
index b8524ba..5a8510f 100644
--- 
a/hudi-utilities/src/main/java/org/apache/hudi/utilities/deltastreamer/DeltaSync.java
+++ 
b/hudi-utilities/src/main/java/org/apache/hudi/utilities/deltastreamer/DeltaSync.java
@@ -303,7 +303,6 @@ public class DeltaSync implements Serializable {
                 t, HOODIE_RECORD_STRUCT_NAME, 
HOODIE_RECORD_NAMESPACE).toJavaRDD());
       }
 
-      // Use Transformed Row's schema if not overridden
       // Use Transformed Row's schema if not overridden. If target schema is 
not specified
       // default to RowBasedSchemaProvider
       schemaProvider = this.schemaProvider == null || 
this.schemaProvider.getTargetSchema() == null
diff --git 
a/hudi-utilities/src/main/java/org/apache/hudi/utilities/deltastreamer/HoodieDeltaStreamer.java
 
b/hudi-utilities/src/main/java/org/apache/hudi/utilities/deltastreamer/HoodieDeltaStreamer.java
index bff2b41..5bf81c2 100644
--- 
a/hudi-utilities/src/main/java/org/apache/hudi/utilities/deltastreamer/HoodieDeltaStreamer.java
+++ 
b/hudi-utilities/src/main/java/org/apache/hudi/utilities/deltastreamer/HoodieDeltaStreamer.java
@@ -124,7 +124,7 @@ public class HoodieDeltaStreamer implements Serializable {
         throw ex;
       } finally {
         deltaSyncService.close();
-        LOG.info("Shut down deltastreamer");
+        LOG.info("Shut down delta streamer");
       }
     }
   }
diff --git 
a/hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/Source.java 
b/hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/Source.java
index 0760c73..5006916 100644
--- a/hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/Source.java
+++ b/hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/Source.java
@@ -22,8 +22,6 @@ import org.apache.hudi.common.util.Option;
 import org.apache.hudi.common.util.TypedProperties;
 import org.apache.hudi.utilities.schema.SchemaProvider;
 
-import org.apache.log4j.LogManager;
-import org.apache.log4j.Logger;
 import org.apache.spark.api.java.JavaSparkContext;
 import org.apache.spark.sql.SparkSession;
 
@@ -33,7 +31,6 @@ import java.io.Serializable;
  * Represents a source from which we can tail data. Assumes a constructor that 
takes properties.
  */
 public abstract class Source<T> implements Serializable {
-  private static final Logger LOG = LogManager.getLogger(Source.class);
 
   public enum SourceType {
     JSON, AVRO, ROW