{"action":"created","issue":{"url":"https://api.github.com/repos/apache/spark/issues/11423","repository_url":"https://api.github.com/repos/apache/spark","labels_url":"https://api.github.com/repos/apache/spark/issues/11423/labels{/name}","comments_url":"https://api.github.com/repos/apache/spark/issues/11423/comments","events_url":"https://api.github.com/repos/apache/spark/issues/11423/events","html_url":"https://github.com/apache/spark/pull/11423","id":137152065,"number":11423,"title":"[SPARK-13398][STREAMING] Move away from thread pool task support to forkjoin","user":{"login":"holdenk","id":59893,"avatar_url":"https://avatars.githubusercontent.com/u/59893?v=3","gravatar_id":"","url":"https://api.github.com/users/holdenk","html_url":"https://github.com/holdenk","followers_url":"https://api.github.com/users/holdenk/followers","following_url":"https://api.github.com/users/holdenk/following{/other_user}","gists_url":"https://api.github.com/users/holdenk/gists{/gist_id}","starred_url":"https://api.github.com/users/holdenk/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/holdenk/subscriptions","organizations_url":"https://api.github.com/users/holdenk/orgs","repos_url":"https://api.github.com/users/holdenk/repos","events_url":"https://api.github.com/users/holdenk/events{/privacy}","received_events_url":"https://api.github.com/users/holdenk/received_events","type":"User","site_admin":false},"labels":[],"state":"open","locked":false,"assignee":null,"milestone":null,"comments":8,"created_at":"2016-02-29T05:05:41Z","updated_at":"2016-03-04T02:19:34Z","closed_at":null,"pull_request":{"url":"https://api.github.com/repos/apache/spark/pulls/11423","html_url":"https://github.com/apache/spark/pull/11423","diff_url":"https://github.com/apache/spark/pull/11423.diff","patch_url":"https://github.com/apache/spark/pull/11423.patch"},"body":"## What changes were proposed in this pull request?\r\n\r\nRemove old deprecated ThreadPoolExecutor and replace with ExecutionContext using a ForkJoinPool. The downside of this is that scala's ForkJoinPool doesn't give us a way to specify the thread pool name (and is a wrapper of Java's in 2.12) except by providing a custom factory. Note that we can't use Java's ForkJoinPool directly in Scala 2.11 since it uses a ExecutionContext which reports system parallelism. One other implicit change that happens is the old ExecutionContext would have reported a different default parallelism since it used system parallelism rather than threadpool parallelism (this was likely not intended but also likely not a huge difference).\r\n\r\nThe previous version of this PR attempted to use an execution context constructed on the ThreadPool (but not the deprecated ThreadPoolExecutor class) so as to keep the ability to have human readable named threads but this reported system parallelism.\r\n\r\n## How was this patch tested?\r\n\r\nunit tests: streaming/testOnly org.apache.spark.streaming.util.*\r\n"},"comment":{"url":"https://api.github.com/repos/apache/spark/issues/comments/192064713","html_url":"https://github.com/apache/spark/pull/11423#issuecomment-192064713","issue_url":"https://api.github.com/repos/apache/spark/issues/11423","id":192064713,"user":{"login":"SparkQA","id":8108735,"avatar_url":"https://avatars.githubusercontent.com/u/8108735?v=3","gravatar_id":"","url":"https://api.github.com/users/SparkQA","html_url":"https://github.com/SparkQA","followers_url":"https://api.github.com/users/SparkQA/followers","following_url":"https://api.github.com/users/SparkQA/following{/other_user}","gists_url":"https://api.github.com/users/SparkQA/gists{/gist_id}","starred_url":"https://api.github.com/users/SparkQA/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/SparkQA/subscriptions","organizations_url":"https://api.github.com/users/SparkQA/orgs","repos_url":"https://api.github.com/users/SparkQA/repos","events_url":"https://api.github.com/users/SparkQA/events{/privacy}","received_events_url":"https://api.github.com/users/SparkQA/received_events","type":"User","site_admin":false},"created_at":"2016-03-04T02:19:34Z","updated_at":"2016-03-04T02:19:34Z","body":"**[Test build #52420 has finished](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/52420/consoleFull)** for PR 11423 at commit [`6e8e7e0`](https://github.com/apache/spark/commit/6e8e7e0d484184030a6d519dad1dbef665758331).\n * This patch passes all tests.\n * This patch merges cleanly.\n * This patch adds no public classes."}}