This is an automated email from the ASF dual-hosted git repository.
rgoers pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/flume.git
The following commit(s) were added to refs/heads/trunk by this push:
new 7b552af0d fix a code typo
new 375ecb2d8 Merge pull request #392 from
yangjf2019/hotfix-flume-code-typo
7b552af0d is described below
commit 7b552af0dd154497533d523f72b57905b3dd2150
Author: yangjf2019 <[email protected]>
AuthorDate: Tue Nov 22 16:24:33 2022 +0800
fix a code typo
---
flume-ng-sdk/src/main/java/org/apache/flume/api/AbstractRpcClient.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/flume-ng-sdk/src/main/java/org/apache/flume/api/AbstractRpcClient.java
b/flume-ng-sdk/src/main/java/org/apache/flume/api/AbstractRpcClient.java
index b28d4e54d..ac6646b42 100644
--- a/flume-ng-sdk/src/main/java/org/apache/flume/api/AbstractRpcClient.java
+++ b/flume-ng-sdk/src/main/java/org/apache/flume/api/AbstractRpcClient.java
@@ -83,7 +83,7 @@ public abstract class AbstractRpcClient implements RpcClient {
batchSize = parsedBatch;
}
} catch (NumberFormatException e) {
- logger.warn("Batchsize is not valid for RpcClient: " + strBatchSize +
+ logger.warn("BatchSize is not valid for RpcClient: " + strBatchSize +
". Default value assigned.", e);
}
}