Revert "Add synchronized"

This reverts commit aac200a.
apache · Aug 12, 2024 · b636f58 · b636f58
1 parent 311db73
commit b636f58
Showing 1 changed file with 2 additions and 4 deletions.
diff --git a/common/src/main/scala/org/apache/spark/sql/comet/execution/shuffle/ArrowReaderIterator.scala b/common/src/main/scala/org/apache/spark/sql/comet/execution/shuffle/ArrowReaderIterator.scala
@@ -40,10 +40,8 @@ class ArrowReaderIterator(channel: ReadableByteChannel, source: String)
     // Release the previous batch.
     // If it is not released, when closing the reader, arrow library will complain about
     // memory leak.
-    synchronized {
-      if (currentBatch != null) {
-        currentBatch.close()
-      }
+    if (currentBatch != null) {
+      currentBatch.close()
     }
 
     batch = nextBatch()