You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@spark.apache.org by "meiyoula (JIRA)" <ji...@apache.org> on 2015/08/04 03:49:04 UTC
[jira] [Created] (SPARK-9585) HiveHBaseTableInputFormat can'be
cached
meiyoula created SPARK-9585:
-------------------------------
Summary: HiveHBaseTableInputFormat can'be cached
Key: SPARK-9585
URL: https://issues.apache.org/jira/browse/SPARK-9585
Project: Spark
Issue Type: Bug
Components: Spark Core
Reporter: meiyoula
Below exception occurs in Spark On HBase function.
{quote}
java.lang.RuntimeException: java.util.concurrent.RejectedExecutionException: Task org.apache.hadoop.hbase.client.ResultBoundedCompletionService$QueueingFuture@11c6577 rejected from java.util.concurrent.ThreadPoolExecutor@3414350b[Terminated, pool size = 0, active threads = 0, queued tasks = 0, completed tasks = 17451]
{quote}
When an executor has many cores, the tasks belongs to same RDD will using the same InputFormat. But the HiveHBaseTableInputFormat is not thread safety.
So I think we should add a config to enable cache InputFormat or not.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscribe@spark.apache.org
For additional commands, e-mail: issues-help@spark.apache.org