This is an automated email from the ASF dual-hosted git repository.
technoboy pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new 677f24acf4d namespace cli set-offload-policy's thresholdBytes support
negative and 0 (#17502)
677f24acf4d is described below
commit 677f24acf4d00ae863138707fc45028e301cce32
Author: YingQun Zhong <[email protected]>
AuthorDate: Wed Sep 21 11:07:24 2022 +0800
namespace cli set-offload-policy's thresholdBytes support negative and 0
(#17502)
---
.../src/main/java/org/apache/pulsar/admin/cli/CmdNamespaces.java | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
diff --git
a/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdNamespaces.java
b/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdNamespaces.java
index faebdae8290..7dee55f694d 100644
---
a/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdNamespaces.java
+++
b/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdNamespaces.java
@@ -2362,8 +2362,7 @@ public class CmdNamespaces extends CmdBase {
Long offloadAfterThresholdInBytes =
OffloadPoliciesImpl.DEFAULT_OFFLOAD_THRESHOLD_IN_BYTES;
if (StringUtils.isNotEmpty(offloadAfterThresholdStr)) {
long offloadAfterThreshold =
validateSizeString(offloadAfterThresholdStr);
- if (positiveCheck("OffloadAfterThreshold",
offloadAfterThreshold)
- && maxValueCheck("OffloadAfterThreshold",
offloadAfterThreshold, Long.MAX_VALUE)) {
+ if (maxValueCheck("OffloadAfterThreshold",
offloadAfterThreshold, Long.MAX_VALUE)) {
offloadAfterThresholdInBytes = offloadAfterThreshold;
}
}