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