This is an automated email from the ASF dual-hosted git repository.
danny0405 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 a313ffbb98c [HUDI-6532] Fix a typo in BaseFlinkCommitActionExecutor
(#9198)
a313ffbb98c is described below
commit a313ffbb98c5a6c4577690a05f70c934c303f8d7
Author: Stan <[email protected]>
AuthorDate: Sun Jul 16 11:23:59 2023 +0800
[HUDI-6532] Fix a typo in BaseFlinkCommitActionExecutor (#9198)
[HUDI-6532] Fix a typo in BaseFlinkCommitActionExecutor.
Signed-off-by: houhang <[email protected]>
---
.../apache/hudi/table/action/commit/BaseFlinkCommitActionExecutor.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/table/action/commit/BaseFlinkCommitActionExecutor.java
b/hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/table/action/commit/BaseFlinkCommitActionExecutor.java
index a44ca7ee419..5f9b71d4c9f 100644
---
a/hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/table/action/commit/BaseFlinkCommitActionExecutor.java
+++
b/hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/table/action/commit/BaseFlinkCommitActionExecutor.java
@@ -194,7 +194,7 @@ public abstract class BaseFlinkCommitActionExecutor<T>
extends
}
}
} catch (Throwable t) {
- String msg = "Error upsetting bucketType " + bucketType + " for
partition :" + partitionPath;
+ String msg = "Error upserting bucketType " + bucketType + " for
partition :" + partitionPath;
LOG.error(msg, t);
throw new HoodieUpsertException(msg, t);
}