Revision 753e129f3a980760d4dc674e88ed334cf54c54ed authored by Shixiong Zhu on 27 April 2017, 20:55:03 UTC, committed by Tathagata Das on 27 April 2017, 20:55:19 UTC
## What changes were proposed in this pull request? This PR changes Executor's threads to `UninterruptibleThread` so that we can use `runUninterruptibly` in `CachedKafkaConsumer`. However, this is just best effort to avoid hanging forever. If the user uses`CachedKafkaConsumer` in another thread (e.g., create a new thread or Future), the potential hang may still happen. ## How was this patch tested? The new added test. Author: Shixiong Zhu <shixiong@databricks.com> Closes #17761 from zsxwing/int. (cherry picked from commit 01c999e7f94d5e6c2fce67304dc62351dfbdf963) Signed-off-by: Tathagata Das <tathagata.das1565@gmail.com>
1 parent 4512e2a
Computing file changes ...
