You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@doris.apache.org by ji...@apache.org on 2022/07/25 11:31:30 UTC
[doris-flink-connector] branch master updated: Solve the exception caused by MaxRetries = 0 (#50)
This is an automated email from the ASF dual-hosted git repository.
jiafengzheng pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris-flink-connector.git
The following commit(s) were added to refs/heads/master by this push:
new 0b47e8a Solve the exception caused by MaxRetries = 0 (#50)
0b47e8a is described below
commit 0b47e8aaaae6f05941b41afe6cf271c44821cc1c
Author: yeyudefeng <52...@users.noreply.github.com>
AuthorDate: Mon Jul 25 19:31:25 2022 +0800
Solve the exception caused by MaxRetries = 0 (#50)
Solve the exception caused by MaxRetries = 0
---
.../main/java/org/apache/doris/flink/sink/committer/DorisCommitter.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/flink-doris-connector/src/main/java/org/apache/doris/flink/sink/committer/DorisCommitter.java b/flink-doris-connector/src/main/java/org/apache/doris/flink/sink/committer/DorisCommitter.java
index dfcc0bc..3dc4eb7 100644
--- a/flink-doris-connector/src/main/java/org/apache/doris/flink/sink/committer/DorisCommitter.java
+++ b/flink-doris-connector/src/main/java/org/apache/doris/flink/sink/committer/DorisCommitter.java
@@ -79,7 +79,7 @@ public class DorisCommitter implements Committer<DorisCommittable> {
int retry = 0;
String hostPort = committable.getHostPort();
CloseableHttpResponse response = null;
- while (retry++ < maxRetry) {
+ while (retry++ <= maxRetry) {
HttpPutBuilder putBuilder = new HttpPutBuilder();
putBuilder.setUrl(String.format(commitPattern, hostPort, committable.getDb()))
.baseAuth(dorisOptions.getUsername(), dorisOptions.getPassword())
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org