This is an automated email from the ASF dual-hosted git repository. liuxun pushed a commit to branch fix-cache in repository https://gitbox.apache.org/repos/asf/gravitino.git
commit 7943882627078ecddd0f34e0d27f302ff550bd25 Author: Xun <[email protected]> AuthorDate: Mon Sep 1 21:02:07 2025 +0800 fix follow comments --- .../org/apache/gravitino/client/integration/test/PolicyIT.java | 10 +++++----- .../java/org/apache/gravitino/cache/ReverseIndexCache.java | 4 ++-- 2 files changed, 7 insertions(+), 7 deletions(-) diff --git a/clients/client-java/src/test/java/org/apache/gravitino/client/integration/test/PolicyIT.java b/clients/client-java/src/test/java/org/apache/gravitino/client/integration/test/PolicyIT.java index 784a578823..1dc520c07a 100644 --- a/clients/client-java/src/test/java/org/apache/gravitino/client/integration/test/PolicyIT.java +++ b/clients/client-java/src/test/java/org/apache/gravitino/client/integration/test/PolicyIT.java @@ -468,11 +468,11 @@ public class PolicyIT extends BaseIT { // Test disable the policy then list again // todo: uncomment after the bug is fixed // https://github.com/apache/gravitino/issues/7787#issue-3255540700 - // Assertions.assertDoesNotThrow(() -> metalake.disablePolicy(policy1.name())); - // Policy[] policies8 = relationalCatalog.supportsPolicies().listPolicyInfos(); - // Assertions.assertEquals(1, policies8.length); - // Assertions.assertEquals(policy1.name(), policies8[0].name()); - // Assertions.assertFalse(policies8[0].enabled()); + Assertions.assertDoesNotThrow(() -> metalake.disablePolicy(policy1.name())); + Policy[] policies8 = relationalCatalog.supportsPolicies().listPolicyInfos(); + Assertions.assertEquals(1, policies8.length); + Assertions.assertEquals(policy1.name(), policies8[0].name()); + Assertions.assertFalse(policies8[0].enabled()); // Test get associated policy for catalog Policy policy = relationalCatalog.supportsPolicies().getPolicy(policy1.name()); diff --git a/core/src/main/java/org/apache/gravitino/cache/ReverseIndexCache.java b/core/src/main/java/org/apache/gravitino/cache/ReverseIndexCache.java index 5df0222ce5..6d958ce0b8 100644 --- a/core/src/main/java/org/apache/gravitino/cache/ReverseIndexCache.java +++ b/core/src/main/java/org/apache/gravitino/cache/ReverseIndexCache.java @@ -80,9 +80,9 @@ public class ReverseIndexCache { String strEntityCacheKey = entityCacheKey.toString(); List<EntityCacheKey> entityKeys = Lists.newArrayList(reverseIndex.getValuesForKeysStartingWith(strEntityCacheKey)); - String strEntityCacheKeyNo = + String strEntityCacheKeySerialNumber = String.format("%s-%d", strEntityCacheKey, entityKeys.size()); - reverseIndex.put(strEntityCacheKeyNo, key); + reverseIndex.put(strEntityCacheKeySerialNumber, key); } public void put(Entity entity, EntityCacheRelationKey key) {
