dttung2905 opened a new pull request, #13268:
URL: https://github.com/apache/iceberg/pull/13268
Hi team,
I add a few more configs:
```java
private static final String COMMIT_MAX_RETRIES_PROP =
"iceberg.control.commit.max-retries";
private static final int COMMIT_MAX_RETRIES_DEFAULT = 3;
private static final String COMMIT_MIN_RETRY_WAIT_MS_PROP =
"iceberg.control.commit.min-retry-wait-ms";
private static final int COMMIT_MIN_RETRY_WAIT_MS_DEFAULT = 100;
private static final String COMMIT_MAX_RETRY_WAIT_MS_PROP =
"iceberg.control.commit.max-retry-wait-ms";
private static final int COMMIT_MAX_RETRY_WAIT_MS_DEFAULT = 60_000;
private static final String COMMIT_TOTAL_RETRY_TIME_MS_PROP =
"iceberg.control.commit.total-retry-time-ms";
private static final int COMMIT_TOTAL_RETRY_TIME_MS_DEFAULT = 300_000; //
5 minutes
public static final String FAIL_ON_MAX_COMMIT_RETRIES =
"fail.on.max.commit.retries";
public static final boolean FAIL_ON_MAX_COMMIT_RETRIES_DEFAULT = false;
```
if we set `fail.on.max.commit.retries=true`, the connector task will fails
after some retries. The default value of `fail.on.max.commit.retries` is
`false` to maintain backward compatibility
Fixes https://github.com/apache/iceberg/issues/13117
--
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]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
