From cb19a319e3ca39a268edb1fc4f42ce9f8ba8e6e5 Mon Sep 17 00:00:00 2001
From: WJL3333 <wjl_is_213@163.com>
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
---
 .../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 9f1d74a9977826..e1da6a1c73741f 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;