voonhous commented on code in PR #17718:
URL: https://github.com/apache/hudi/pull/17718#discussion_r2648810170
##########
hudi-spark-datasource/hudi-spark/src/test/java/HoodieJavaGenerateApp.java:
##########
@@ -132,7 +130,7 @@ private HoodieTestDataGenerator getDataGenerate() {
*/
private DataFrameWriter<Row> updateHiveSyncConfig(DataFrameWriter<Row>
writer) {
if (enableHiveSync) {
- LOG.info("Enabling Hive sync to " + hiveJdbcUrl);
+ log.info("Enabling Hive sync to " + hiveJdbcUrl);
Review Comment:
Done!
##########
hudi-spark-datasource/hudi-spark/src/test/java/HoodieJavaGenerateApp.java:
##########
@@ -194,6 +192,6 @@ private void insert(SparkSession spark) throws IOException {
writer.save(tablePath); // ultimately where the dataset will be placed
FileSystem fs = FileSystem.get(jssc.hadoopConfiguration());
String commitInstantTime1 = HoodieDataSourceHelpers.latestCommit(fs,
tablePath);
- LOG.info("Commit at instant time :" + commitInstantTime1);
+ log.info("Commit at instant time :" + commitInstantTime1);
Review Comment:
Done!
##########
hudi-spark-datasource/hudi-spark/src/test/java/HoodieJavaStreamingApp.java:
##########
@@ -307,7 +304,7 @@ public int addInputAndValidateIngestion(SparkSession spark,
FileSystem fs, Strin
Thread.sleep(3000);
waitTillNCommits(fs, numExpCommits, 180, 3);
commitInstantTime2 = HoodieDataSourceHelpers.listCommitsSince(fs,
tablePath, commitInstantTime1).stream().sorted().findFirst().get();
- LOG.info("Second commit at instant time :" + commitInstantTime2);
+ log.info("Second commit at instant time :" + commitInstantTime2);
Review Comment:
Done!
##########
hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/functional/TestHoodieBackedMetadata.java:
##########
@@ -2317,7 +2316,7 @@ public void testMultiWriterForDoubleLocking() throws
Exception {
// Ensure all commits were synced to the Metadata Table
HoodieTableMetaClient metadataMetaClient =
createMetaClient(metadataTableBasePath);
- LOG.warn("total commits in metadata table " +
metadataMetaClient.getActiveTimeline().getCommitsTimeline().countInstants());
+ log.warn("total commits in metadata table " +
metadataMetaClient.getActiveTimeline().getCommitsTimeline().countInstants());
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]
