Thanks Davies. it turns out it was indeed and they fixed it in last night's
nightly build!
https://github.com/elasticsearch/elasticsearch-hadoop/issues/338
On Wed, Dec 10, 2014 at 2:52 AM, Davies Liu wrote:
> On Tue, Dec 9, 2014 at 11:32 AM, Mohamed Lrhazi
> wrote:
> > While trying simple exam
On Tue, Dec 9, 2014 at 11:32 AM, Mohamed Lrhazi
wrote:
> While trying simple examples of PySpark code, I systematically get these
> failures when I try this.. I dont see any prior exceptions in the output...
> How can I debug further to find root cause?
>
>
> es_rdd = sc.newAPIHadoopRDD(
> inp
somehow I now get a better error trace, I believe for the same root
issue... any advice of how to narrow this down further highly appreciated:
...
14/12/10 07:15:03 ERROR PythonRDD: Python worker exited unexpectedly
(crashed)
org.apache.spark.api.python.PythonException: Traceback (most recent cal
While trying simple examples of PySpark code, I systematically get these
failures when I try this.. I dont see any prior exceptions in the output...
How can I debug further to find root cause?
es_rdd = sc.newAPIHadoopRDD(
inputFormatClass="org.elasticsearch.hadoop.mr.EsInputFormat",
keyCl
