In a low probability case when the thread was not sleeping at the time of interrupt, the interrupted exception will not be thrown. Instead of interrupting shall we use an atomic boolean etc to terminate the while loop? Alternatively we can also check on Thread.currentThread().isInterrupted() .
[ Full content available at: https://github.com/apache/beam/pull/6385 ] This message was relayed via gitbox.apache.org for [email protected]
