AnujJain7 commented on pull request #2724:

   We are facing issue in PublishGCPubSub operator , some threads are going in 
hang state
   checking on thread dump get following error for those thread
   `{"stackTrace":"\"Timer-Driven Process Thread-50\" Id=8466 TIMED_WAITING  on 
null\n\tat java.lang.Thread.sleep(Native Method)\n\tat 
   Looking into code of at line number 166
   there is use of Thread.sleep with condition that messageIdFuture.isDone, 
seems like an issue 
    why we need to sleep the thread when the task is completed ?
   while (messageIdFuture.isDone()) {
   Looking forward to get response on this

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.

For queries about this service, please contact Infrastructure at:

Reply via email to