apacheGH-36332: [Java] Fix Spark integration failure due to Netty ver…

…sion upgrade
danepitkin · Jul 5, 2023 · 2176273 · 2176273
1 parent ea5ce03
commit 2176273
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/java/memory/memory-netty/src/main/java/io/netty/buffer/PooledByteBufAllocatorL.java b/java/memory/memory-netty/src/main/java/io/netty/buffer/PooledByteBufAllocatorL.java
@@ -161,8 +161,7 @@ public InnerAllocator() {
     }
 
     private UnsafeDirectLittleEndian newDirectBufferL(int initialCapacity, int maxCapacity) {
-      PoolArenasCache cache = threadCache();
-      PoolArena<ByteBuffer> directArena = cache.directArena;
+      PoolArena<ByteBuffer> directArena = threadCache().directArena;
 
       if (directArena != null) {
 
@@ -178,7 +177,7 @@ private UnsafeDirectLittleEndian newDirectBufferL(int initialCapacity, int maxCa
               hugeBufferSize);
         } else {
           // within chunk, use arena.
-          ByteBuf buf = directArena.allocate(cache, initialCapacity, maxCapacity);
+          ByteBuf buf = directArena.allocate(threadCache(), initialCapacity, maxCapacity);
           if (!(buf instanceof PooledUnsafeDirectByteBuf)) {
             fail();
           }