lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[MINOR] cleanup redundant comment and unused variable and fix typo (#1435)

Browse Source
This commit is contained in:
Zhiyuan Zhao
2020-03-22 11:12:06 +08:00
committed by GitHub
parent c5030f77a0
commit 8b00791ef4
3 changed files with 1 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
hudi-utilities/src/main/java/org/apache/hudi/utilities/deltastreamer/DeltaSync.java
View File

@@ -303,7 +303,6 @@ public class DeltaSync implements Serializable {
t, HOODIE_RECORD_STRUCT_NAME, HOODIE_RECORD_NAMESPACE).toJavaRDD()); 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 // Use Transformed Row's schema if not overridden. If target schema is not specified
// default to RowBasedSchemaProvider // default to RowBasedSchemaProvider
schemaProvider = this.schemaProvider == null || this.schemaProvider.getTargetSchema() == null schemaProvider = this.schemaProvider == null || this.schemaProvider.getTargetSchema() == null

2
hudi-utilities/src/main/java/org/apache/hudi/utilities/deltastreamer/HoodieDeltaStreamer.java
View File

@@ -124,7 +124,7 @@ public class HoodieDeltaStreamer implements Serializable {
throw ex; throw ex;
} finally { } finally {
deltaSyncService.close(); deltaSyncService.close();
LOG.info("Shut down deltastreamer"); LOG.info("Shut down delta streamer");
} }
} }
} }

3
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/Source.java
View File

@@ -22,8 +22,6 @@ import org.apache.hudi.common.util.Option;
import org.apache.hudi.common.util.TypedProperties; import org.apache.hudi.common.util.TypedProperties;
import org.apache.hudi.utilities.schema.SchemaProvider; 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.api.java.JavaSparkContext;
import org.apache.spark.sql.SparkSession; 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. * Represents a source from which we can tail data. Assumes a constructor that takes properties.
*/ */
public abstract class Source<T> implements Serializable { public abstract class Source<T> implements Serializable {
private static final Logger LOG = LogManager.getLogger(Source.class);
public enum SourceType { public enum SourceType {
JSON, AVRO, ROW JSON, AVRO, ROW