From fb117f535ff4025703e107a57cb7e4348e7b2e92 Mon Sep 17 00:00:00 2001 From: WJL3333 Date: Tue, 3 Aug 2021 00:22:00 +0800 Subject: [PATCH] [fix] OffloadPoliciesImplBuilder missing method and not implements OffloadPolicies.Builder (#11453) * org.apache.pulsar.common.policies.data.OffloadPoliciesImplBuilder not implement OffloadPolicies.Builder and missing the method setS3ManagedLedgerOffloadRoleSessionName (cherry picked from commit b046233c898963cfb0b9da04e12db1465ce75876) --- .../pulsar/common/policies/data/OffloadPoliciesImpl.java | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/OffloadPoliciesImpl.java b/pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/OffloadPoliciesImpl.java index f7f4477eb61f2..68761a6d3006e 100644 --- a/pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/OffloadPoliciesImpl.java +++ b/pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/OffloadPoliciesImpl.java @@ -472,7 +472,7 @@ private static Object getCompatibleValue(Properties properties, Field field) { return value((String) object, field); } - public static class OffloadPoliciesImplBuilder { + public static class OffloadPoliciesImplBuilder implements OffloadPolicies.Builder { private OffloadPoliciesImpl impl = new OffloadPoliciesImpl(); public OffloadPoliciesImplBuilder offloadersDirectory(String offloadersDirectory) { @@ -550,6 +550,12 @@ public OffloadPoliciesImplBuilder s3ManagedLedgerOffloadRole(String s3ManagedLed return this; } + @Override + public Builder setS3ManagedLedgerOffloadRoleSessionName(String s3ManagedLedgerOffloadRoleSessionName) { + impl.s3ManagedLedgerOffloadRoleSessionName = s3ManagedLedgerOffloadRoleSessionName; + return this; + } + public OffloadPoliciesImplBuilder s3ManagedLedgerOffloadRoleSessionName(String s3ManagedLedgerOffloadRoleSessionName) { impl.s3ManagedLedgerOffloadRoleSessionName = s3ManagedLedgerOffloadRoleSessionName; return this;