Skip to content

Commit fb55d64

Browse files
authored
[Fix] fix copy&paste typo in BackendClient (#622)
1 parent 3e6e0ab commit fb55d64

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

flink-doris-connector/src/main/java/org/apache/doris/flink/backend/BackendClient.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -71,7 +71,7 @@ public BackendClient(Routing routing, DorisReadOptions readOptions) {
7171
? ConfigurationOptions.DORIS_REQUEST_RETRIES_DEFAULT
7272
: readOptions.getRequestRetries();
7373
this.thriftMaxMessageSize =
74-
readOptions.getRequestRetries() == null
74+
readOptions.getThriftMaxMessageSize() == null
7575
? ConfigurationOptions.DORIS_THRIFT_MAX_MESSAGE_SIZE_DEFAULT
7676
: readOptions.getThriftMaxMessageSize();
7777
logger.trace(

0 commit comments

Comments
 (0)