This is an automated email from the ASF dual-hosted git repository.
sivabalan 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 968bcea12a7 [MINOR] Avoiding warn log for succeeding in first attempt
(#9686)
968bcea12a7 is described below
commit 968bcea12a7960b61cb52ccc3c755fe9a854d42a
Author: Sivabalan Narayanan <[email protected]>
AuthorDate: Tue Sep 12 02:57:42 2023 -0400
[MINOR] Avoiding warn log for succeeding in first attempt (#9686)
---------
Co-authored-by: Danny Chan <[email protected]>
---
.../src/main/scala/org/apache/hudi/HoodieSparkSqlWriter.scala | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git
a/hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/HoodieSparkSqlWriter.scala
b/hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/HoodieSparkSqlWriter.scala
index 6d0ce7d16bf..7828cc7ee5a 100644
---
a/hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/HoodieSparkSqlWriter.scala
+++
b/hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/HoodieSparkSqlWriter.scala
@@ -130,7 +130,9 @@ object HoodieSparkSqlWriter {
while (counter <= maxRetry && !succeeded) {
try {
toReturn = writeInternal(sqlContext, mode, optParams, sourceDf,
streamingWritesParamsOpt, hoodieWriteClient)
- log.warn(s"Succeeded with attempt no $counter")
+ if (counter > 0) {
+ log.warn(s"Succeeded with attempt no $counter")
+ }
succeeded = true
} catch {
case e: HoodieWriteConflictException =>