lukecwik commented on PR #23859: URL: https://github.com/apache/beam/pull/23859#issuecomment-1298849333
Thanks, didn't expect the awaitTermination call to happen if the isShutdown/isTerminated would have returned true. We can always incorporate a new WatchDog based upon https://github.com/googleapis/gax-java/pull/1859 into Beam until we migrate to a version of gax that includes the fix. If we do so, should we use a FixedWatchDogProvider that watches multiple streams or stick with the instantiating one? -- 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]
