From 240e54b6009a0880028b4077a40ecfe7fae76a09 Mon Sep 17 00:00:00 2001 From: fengyubiao Date: Tue, 31 Jan 2023 17:50:40 +0800 Subject: [PATCH] [fix] [admin] setOffloadThreshold response before it's finished --- .../org/apache/pulsar/broker/admin/impl/NamespacesBase.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/NamespacesBase.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/NamespacesBase.java index 114efea82ef49..324c84048751f 100644 --- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/NamespacesBase.java +++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/NamespacesBase.java @@ -2047,7 +2047,7 @@ protected CompletableFuture internalSetOffloadThresholdInSecondsAsync(long validateNamespacePolicyOperationAsync(namespaceName, PolicyName.OFFLOAD, PolicyOperation.WRITE) .thenApply(v -> validatePoliciesReadOnlyAccessAsync()) - .thenApply(v -> updatePoliciesAsync(namespaceName, + .thenCompose(v -> updatePoliciesAsync(namespaceName, policies -> { if (policies.offload_policies == null) { policies.offload_policies = new OffloadPoliciesImpl();