Validation error for linear retry duration

data-integrations · Dec 12, 2024 · e612cd0 · e612cd0
1 parent 5712df2
commit e612cd0
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/src/main/java/io/cdap/plugin/http/sink/batch/HTTPSinkConfig.java b/src/main/java/io/cdap/plugin/http/sink/batch/HTTPSinkConfig.java
@@ -475,6 +475,12 @@ public void validate(FailureCollector collector) {
               .withConfigProperty(MESSAGE_FORMAT);
     }
 
+    if (!containsMacro(PROPERTY_LINEAR_RETRY_INTERVAL) && Objects.nonNull(linearRetryInterval)
+            && linearRetryInterval < 0) {
+      collector.addFailure("Linear Retry Interval cannot be a negative number.", null)
+              .withConfigProperty(PROPERTY_LINEAR_RETRY_INTERVAL);
+    }
+
     if (!containsMacro(PROPERTY_MAX_RETRY_DURATION) && Objects.nonNull(maxRetryDuration) && maxRetryDuration < 0) {
       collector.addFailure("Max Retry Duration cannot be a negative number.", null)
               .withConfigProperty(PROPERTY_MAX_RETRY_DURATION);