pan3793 commented on code in PR #3043:
URL: https://github.com/apache/celeborn/pull/3043#discussion_r1900852331
##########
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/network/FlinkTransportClientFactory.java:
##########
@@ -45,7 +45,7 @@ public FlinkTransportClientFactory(
TransportContext context, List<TransportClientBootstrap> bootstraps, int
bufferSizeBytes) {
super(context, bootstraps);
bufferSuppliers = JavaUtils.newConcurrentHashMap();
- this.pooledAllocator = new UnpooledByteBufAllocator(true);
+ this.allocator = new UnpooledByteBufAllocator(true);
Review Comment:
@FMX Thanks for the information. BTW, it's better to leave some brief
comments to explain the special logic
--
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]
