[pulsar] 02/05: Remove unused listener to reduce creating executor pool. (#11215)

[penghui]

This is an automated email from the ASF dual-hosted git repository.

penghui pushed a commit to branch branch-2.8
in repository https://gitbox.apache.org/repos/asf/pulsar.git

commit 1b3582c28630f0603657b7395790f5f621dd3084
Author: Tboy <techno...@apache.org>
AuthorDate: Sun Jul 4 16:22:50 2021 +0800

    Remove unused listener to reduce creating executor pool. (#11215)
    
    
    (cherry picked from commit c1c0e9085a4c4e57d83e9ab67d53163afe48f3d4)
---
 .../offload/filesystem/impl/FileSystemManagedLedgerOffloader.java      | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git 
a/tiered-storage/file-system/src/main/java/org/apache/bookkeeper/mledger/offload/filesystem/impl/FileSystemManagedLedgerOffloader.java
 
b/tiered-storage/file-system/src/main/java/org/apache/bookkeeper/mledger/offload/filesystem/impl/FileSystemManagedLedgerOffloader.java
index 922332b..ddf83aa 100644
--- 
a/tiered-storage/file-system/src/main/java/org/apache/bookkeeper/mledger/offload/filesystem/impl/FileSystemManagedLedgerOffloader.java
+++ 
b/tiered-storage/file-system/src/main/java/org/apache/bookkeeper/mledger/offload/filesystem/impl/FileSystemManagedLedgerOffloader.java
@@ -203,8 +203,7 @@ public class FileSystemManagedLedgerOffloader implements 
LedgerOffloader {
                     semaphore.acquire();
                     countDownLatch = new CountDownLatch(1);
                     
assignmentScheduler.chooseThread(ledgerId).submit(FileSystemWriter.create(ledgerEntriesOnce,
 dataWriter, semaphore,
-                            countDownLatch, haveOffloadEntryNumber, 
this)).addListener(() -> {
-                    }, Executors.newSingleThreadExecutor());
+                            countDownLatch, haveOffloadEntryNumber, this));
                     needToOffloadFirstEntryNumber = end + 1;
                 } while (needToOffloadFirstEntryNumber - 1 != 
readHandle.getLastAddConfirmed() && fileSystemWriteException == null);
                 countDownLatch.await();