[hudi] branch master updated: [HUDI-6294] Fix log classname in SqlQuerySingleResultPreCommitValidator (#8853)

[yihua]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new 6671d1a2460 [HUDI-6294] Fix log classname in 
SqlQuerySingleResultPreCommitValidator (#8853)
6671d1a2460 is described below

commit 6671d1a24609aaefca32b6cb510e4f17e76c7092
Author: Kai Jiang <jiang...@gmail.com>
AuthorDate: Wed May 31 13:12:14 2023 -0700

    [HUDI-6294] Fix log classname in SqlQuerySingleResultPreCommitValidator 
(#8853)
    
    Co-authored-by: Y Ethan Guo <ethan.guoyi...@gmail.com>
---
 .../client/validator/SqlQuerySingleResultPreCommitValidator.java    | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/client/validator/SqlQuerySingleResultPreCommitValidator.java
 
b/hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/client/validator/SqlQuerySingleResultPreCommitValidator.java
index a2dbd12699f..0414e908528 100644
--- 
a/hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/client/validator/SqlQuerySingleResultPreCommitValidator.java
+++ 
b/hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/client/validator/SqlQuerySingleResultPreCommitValidator.java
@@ -40,7 +40,7 @@ import java.util.List;
  * Example configuration: "query1#expectedResult1;query2#expectedResult2;"
  */
 public class SqlQuerySingleResultPreCommitValidator<T, I, K, O extends 
HoodieData<WriteStatus>> extends SqlQueryPreCommitValidator<T, I, K, O> {
-  private static final Logger LOG = 
LoggerFactory.getLogger(SqlQueryInequalityPreCommitValidator.class);
+  private static final Logger LOG = 
LoggerFactory.getLogger(SqlQuerySingleResultPreCommitValidator.class);
 
   public SqlQuerySingleResultPreCommitValidator(HoodieSparkTable<T> table, 
HoodieEngineContext engineContext, HoodieWriteConfig config) {
     super(table, engineContext, config);
@@ -68,9 +68,9 @@ public class SqlQuerySingleResultPreCommitValidator<T, I, K, 
O extends HoodieDat
     }
     Object result = newRows.get(0).apply(0);
     if (result == null || !expectedResult.equals(result.toString())) {
-      LOG.error("Mismatch query result. Expected: " + expectedResult + " got " 
+ result + "Query: " + query);
+      LOG.error("Mismatch query result. Expected: " + expectedResult + " got " 
+ result + " on Query: " + query);
       throw new HoodieValidationException("Query validation failed for '" + 
query
-          + "'. Expected " + expectedResult + " rows, Found " + result);
+          + "'. Expected " + expectedResult + " row(s), Found " + result);
     } else {
       LOG.info("Query validation successful. Expected: " + expectedResult + " 
got " + result);
     }