Re: Serialization stack error

2016-01-15 Thread Ted Yu
Here is signature for Get: public class Get extends Query implements Row, Comparable { It is not Serializable. FYI On Fri, Jan 15, 2016 at 6:37 AM, beeshma r wrote: > HI i am trying to get data from Solr server . > > This is my code > > /*input is JavaRDD li >

Serialization stack error

2016-01-15 Thread beeshma r
HI i am trying to get data from Solr server . This is my code /*input is JavaRDD li *output is JavaRDD for scanning Hbase*/ public static JavaRDD getdocs(JavaRDD li) { JavaRDD newdocs=li; JavaRDD n=newdocs.map(new Function(){ public Get

Re: Serialization stack error

2016-01-15 Thread Ted Yu
Can you encapsulate your map function such that it returns data type other than Get ? You can perform query to hbase but don't return Get. Cheers On Fri, Jan 15, 2016 at 6:46 AM, beeshma r wrote: > Hi Ted , > > Any suggestions for changing this piece of code? > > public

Re: Serialization stack error

2016-01-15 Thread beeshma r
Hi Ted , Any suggestions for changing this piece of code? public static JavaRDD getdocs(JavaRDD< SolrDocumentList> li) { JavaRDD newdocs=li; JavaRDD n=newdocs.map(new Function(){ public Get call(SolrDocumentList si) throws IOException