This is an automated email from the ASF dual-hosted git repository. lzljs3620320 pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/paimon.git
commit 93666c23f0bbadc48e867f422c0b67a4565eab22 Author: Jingsong <[email protected]> AuthorDate: Sat May 4 21:38:42 2024 +0800 [core] Protect tagManager.createTag in TagAutoCreation Should not throw exception when tag exists --- paimon-core/src/main/java/org/apache/paimon/tag/TagAutoCreation.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/paimon-core/src/main/java/org/apache/paimon/tag/TagAutoCreation.java b/paimon-core/src/main/java/org/apache/paimon/tag/TagAutoCreation.java index 409ceb3dc..60f113761 100644 --- a/paimon-core/src/main/java/org/apache/paimon/tag/TagAutoCreation.java +++ b/paimon-core/src/main/java/org/apache/paimon/tag/TagAutoCreation.java @@ -152,7 +152,9 @@ public class TagAutoCreation { || isAfterOrEqual(time.minus(delay), periodHandler.nextTagTime(nextTag))) { LocalDateTime thisTag = periodHandler.normalizeToPreviousTag(time); String tagName = periodHandler.timeToTag(thisTag); - tagManager.createTag(snapshot, tagName, defaultTimeRetained, callbacks); + if (!tagManager.tagExists(tagName)) { + tagManager.createTag(snapshot, tagName, defaultTimeRetained, callbacks); + } nextTag = periodHandler.nextTagTime(thisTag); if (numRetainedMax != null) {
