This is an automated email from the ASF dual-hosted git repository. yuzhaojing pushed a commit to branch release-0.12.1 in repository https://gitbox.apache.org/repos/asf/hudi.git
commit c8a52837013618e301e306b040907eaabc48c161 Author: 申胜利 <[email protected]> AuthorDate: Thu Sep 29 23:17:15 2022 +0800 [HUDI-4951] Fix incorrect use of Long.getLong() (#6828) --- .../src/main/java/org/apache/hudi/client/BaseHoodieWriteClient.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/BaseHoodieWriteClient.java b/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/BaseHoodieWriteClient.java index 8c8cf67d61..d9f260e633 100644 --- a/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/BaseHoodieWriteClient.java +++ b/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/BaseHoodieWriteClient.java @@ -1694,7 +1694,7 @@ public abstract class BaseHoodieWriteClient<T extends HoodieRecordPayload, I, K, throw new HoodieCommitException("Failed to commit " + instantTime + " unable to save inflight metadata ", io); } Map<String, String> extraMeta = new HashMap<>(); - extraMeta.put(SerDeHelper.LATEST_SCHEMA, SerDeHelper.toJson(newSchema.setSchemaId(Long.getLong(instantTime)))); + extraMeta.put(SerDeHelper.LATEST_SCHEMA, SerDeHelper.toJson(newSchema.setSchemaId(Long.parseLong(instantTime)))); // try to save history schemas FileBasedInternalSchemaStorageManager schemasManager = new FileBasedInternalSchemaStorageManager(metaClient); schemasManager.persistHistorySchemaStr(instantTime, SerDeHelper.inheritSchemas(newSchema, historySchemaStr));
