fix flink

apache · Dec 31, 2024 · 7dc3531 · 7dc3531
1 parent e2de372
commit 7dc3531
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...n/src/main/java/org/apache/celeborn/plugin/flink/network/FlinkTransportClientFactory.java b/...n/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);
     this.bufferSizeBytes = bufferSizeBytes;
   }