This is an automated email from the ASF dual-hosted git repository.
diwu 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 fb55d647 [Fix] fix copy&paste typo in BackendClient (#622)
fb55d647 is described below
commit fb55d64708176ee1df6985cd5ed2a8d734766912
Author: keytouch <[email protected]>
AuthorDate: Fri Nov 21 11:18:04 2025 +0800
[Fix] fix copy&paste typo in BackendClient (#622)
---
.../src/main/java/org/apache/doris/flink/backend/BackendClient.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/flink-doris-connector/src/main/java/org/apache/doris/flink/backend/BackendClient.java
b/flink-doris-connector/src/main/java/org/apache/doris/flink/backend/BackendClient.java
index c97ed202..c9b0ada6 100644
---
a/flink-doris-connector/src/main/java/org/apache/doris/flink/backend/BackendClient.java
+++
b/flink-doris-connector/src/main/java/org/apache/doris/flink/backend/BackendClient.java
@@ -71,7 +71,7 @@ public class BackendClient {
? ConfigurationOptions.DORIS_REQUEST_RETRIES_DEFAULT
: readOptions.getRequestRetries();
this.thriftMaxMessageSize =
- readOptions.getRequestRetries() == null
+ readOptions.getThriftMaxMessageSize() == null
?
ConfigurationOptions.DORIS_THRIFT_MAX_MESSAGE_SIZE_DEFAULT
: readOptions.getThriftMaxMessageSize();
logger.trace(
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
