voonhous commented on code in PR #17718:
URL: https://github.com/apache/hudi/pull/17718#discussion_r2648810058
##########
hudi-spark-datasource/hudi-spark/src/main/java/org/apache/hudi/cli/HDFSParquetImporterUtils.java:
##########
@@ -128,7 +127,7 @@ public int dataImport(JavaSparkContext jsc) {
FileSystem fs = HadoopFSUtils.getFs(this.targetPath,
jsc.hadoopConfiguration());
this.props = this.propsFilePath == null || this.propsFilePath.isEmpty() ?
buildProperties(this.configs)
: readConfig(fs.getConf(), new StoragePath(this.propsFilePath),
this.configs).getProps(true);
- LOG.info("Starting data import with configs : " + props.toString());
+ log.info("Starting data import with configs : " + props.toString());
Review Comment:
Done!
##########
hudi-spark-datasource/hudi-spark/src/main/java/org/apache/hudi/cli/BootstrapExecutorUtils.java:
##########
@@ -159,7 +157,7 @@ public BootstrapExecutorUtils(Config cfg, JavaSparkContext
jssc, FileSystem fs,
builder =
builder.withSchema(schemaProvider.getTargetSchema().toString());
}
this.bootstrapConfig = builder.build();
- LOG.info("Created bootstrap executor with configs : " +
bootstrapConfig.getProps());
+ log.info("Created bootstrap executor with configs : " +
bootstrapConfig.getProps());
Review Comment:
Done!
##########
hudi-spark-datasource/hudi-spark/src/test/java/HoodieJavaApp.java:
##########
@@ -170,7 +168,7 @@ public void run() throws Exception {
// new dataset if needed
writer.save(tablePath); // ultimately where the dataset will be placed
String commitInstantTime1 = HoodieDataSourceHelpers.latestCommit(fs,
tablePath);
- LOG.info("First commit at instant time :" + commitInstantTime1);
+ log.info("First commit at instant time :" + commitInstantTime1);
Review Comment:
Done!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
