mark-bathori commented on code in PR #6976:
URL: https://github.com/apache/nifi/pull/6976#discussion_r1142508295
##########
nifi-nar-bundles/nifi-iceberg-bundle/nifi-iceberg-processors/src/main/java/org/apache/nifi/processors/iceberg/PutIceberg.java:
##########
@@ -113,6 +116,42 @@ public class PutIceberg extends AbstractIcebergProcessor {
.addValidator(StandardValidators.LONG_VALIDATOR)
.build();
+ static final PropertyDescriptor NUMBER_OF_COMMIT_RETRIES = new
PropertyDescriptor.Builder()
+ .name("number-of-commit-retries")
+ .displayName("Number of Commit Retries")
+ .description("Number of times to retry a commit before failing.")
+ .required(true)
+ .defaultValue("3")
+ .addValidator(StandardValidators.INTEGER_VALIDATOR)
+ .build();
+
+ static final PropertyDescriptor MINIMUM_COMMIT_WAIT_TIME = new
PropertyDescriptor.Builder()
+ .name("minimum-commit-wait-time")
+ .displayName("Minimum Commit Wait Time")
+ .description("Minimum time to wait before retrying a commit.")
+ .required(true)
+ .defaultValue("100 ms")
+ .addValidator(StandardValidators.TIME_PERIOD_VALIDATOR)
+ .build();
+
+ static final PropertyDescriptor MAXIMUM_COMMIT_WAIT_TIME = new
PropertyDescriptor.Builder()
+ .name("maximum-commit-wait-time")
+ .displayName("Maximum Commit Wait Time")
+ .description("Maximum time to wait before retrying a commit.")
+ .required(true)
+ .defaultValue("1 min")
+ .addValidator(StandardValidators.TIME_PERIOD_VALIDATOR)
+ .build();
+
+ static final PropertyDescriptor MAXIMUM_COMMIT_DURATION = new
PropertyDescriptor.Builder()
+ .name("maximum-commit-duration")
+ .displayName("Maximum Commit Duration")
+ .description("Total retry timeout period for a commit.")
+ .required(true)
+ .defaultValue("30 min")
+ .addValidator(StandardValidators.TIME_PERIOD_VALIDATOR)
+ .build();
Review Comment:
Thanks @turcsanyip for the review. I've modified the defaults to your
recommended values.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
