[pulsar] branch master updated: Remove unused listener to reduce creating executor pool. (#11215)

[mmerli]

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

mmerli pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/master by this push:
     new c1c0e90  Remove unused listener to reduce creating executor pool. 
(#11215)
c1c0e90 is described below

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

    Remove unused listener to reduce creating executor pool. (#11215)
---
 .../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();