gaozhangmin opened a new issue #13276:
URL: https://github.com/apache/pulsar/issues/13276


   Unload namespace bundle time out
   ```
   10:45:39.731 [pulsar-io-4-68] WARN  
org.apache.pulsar.broker.service.BrokerService - Unloading of 
public/data-channel/0x39048e22_0x40000000 has timed out
   
   ```
   this log is logged by code
   ```
   public CompletableFuture<Integer> unloadServiceUnit(NamespaceBundle 
serviceUnit,
               boolean closeWithoutWaitingClientDisconnect, long timeout, 
TimeUnit unit) {
           CompletableFuture<Integer> future = unloadServiceUnit(serviceUnit, 
closeWithoutWaitingClientDisconnect);
           ScheduledFuture<?> taskTimeout = executor().schedule(() -> {
               if (!future.isDone()) {
                   log.warn("Unloading of {} has timed out", serviceUnit);
                   // Complete the future with no error
                   future.complete(0);
               }
           }, timeout, unit);
   
           future.whenComplete((r, ex) -> taskTimeout.cancel(true));
           return future;
       }
   ```
   I thought this timeout may be cause by unloadServiceUnit, but from log, I 
could see all topics are closed  very soon. I don't know why time out happened.


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]


Reply via email to