Bhupesh, You can get more details here http://docs.datatorrent.com/troubleshooting/#application-throwing-following-kryo-exception <http://docs.datatorrent.com/troubleshooting/#application-throwing-following-kryo-exception>
Thanks - Gaurav > On Jan 12, 2016, at 9:36 AM, Gaurav Gupta <[email protected]> wrote: > > Bhupesh, > > There are following two ways > > 1. If you can change the classes, add default constructor to these classes. > 2. If you can’t change the classes, you can use custom serializer for these > classes using Kryo’s @Bind annotation > > @Bind(JavaSerializer.class) > SetMultimap<String, String> someMap; > > This will work when there is an existing alternative serializer for the > type in question. > > Thanks > - Gaurav > >> On Jan 12, 2016, at 5:00 AM, Bhupesh Chawda <[email protected] >> <mailto:[email protected]>> wrote: >> >> Hi All, >> >> I am facing an issue with Kryo where some classes (which are a part of >> operators in Dag) in the imported jars do not have a zero-argument >> constructor. This results in a KryoException. >> >> Any suggestions on how to handle this? >> In general how can we deal with classes which do not have default >> constructors, without modifying them? >> >> Thanks. >> -Bhupesh >> >> On Thu, Oct 29, 2015 at 10:10 PM, Vlad Rozov <[email protected] >> <mailto:[email protected]>> >> wrote: >> >>> +1 >>> >>> >>> On 10/29/15 08:47, Pramod Immaneni wrote: >>> >>>> +1 >>>> >>>> On Thu, Oct 29, 2015 at 8:34 AM, Amol Kekre <[email protected] >>>> <mailto:[email protected]>> wrote: >>>> >>>> Samoa can be used to test iteration support as that feature gets >>>>> developed. >>>>> >>>>> Amol >>>>> >>>>> >>>>> On Thu, Oct 29, 2015 at 5:12 AM, Bhupesh Chawda <[email protected] >>>>> <mailto:[email protected]> >>>>>> >>>>> wrote: >>>>> >>>>> Yes, iteration support will be needed for quite a few algorithms. >>>>>> >>>>>> Thanks. >>>>>> Bhupesh >>>>>> >>>>>> On Wed, Oct 28, 2015 at 7:20 PM, Sandesh Hegde <[email protected] >>>>>> <mailto:[email protected]> >>>>>>> >>>>>> wrote: >>>>>> >>>>>> Does it need iteration support? Good idea to discuss this feature in >>>>>>> >>>>>> both >>>>>> >>>>>>> the mailing list together. >>>>>>> >>>>>>> Adding Samoa mailing list. >>>>>>> >>>>>>> On Wed, Oct 28, 2015, 4:28 AM Sandeep Deshmukh < >>>>>>> >>>>>> [email protected] <mailto:[email protected]>> >>>>> >>>>>> wrote: >>>>>>> >>>>>>> +1 >>>>>>>> >>>>>>>> Regards >>>>>>>> Sandeep >>>>>>>> >>>>>>>> Regards, >>>>>>>> Sandeep >>>>>>>> >>>>>>>> On Wed, Oct 28, 2015 at 11:36 AM, Amol Kekre <[email protected] >>>>>>>> <mailto:[email protected]>> >>>>>>>> >>>>>>> wrote: >>>>>>> >>>>>>>> +1 >>>>>>>>> >>>>>>>>> Amol >>>>>>>>> >>>>>>>>> On Tue, Oct 27, 2015 at 10:27 PM, Bhupesh Chawda < >>>>>>>>> >>>>>>>> [email protected] <mailto:[email protected]>> >>>>>>>> >>>>>>>>> wrote: >>>>>>>>> >>>>>>>>> Hi All, >>>>>>>>>> >>>>>>>>>> Apache Samoa <https://samoa.incubator.apache.org/ >>>>>>>>>> <https://samoa.incubator.apache.org/>> is a >>>>>>>>>> >>>>>>>>> distributed >>>>>> >>>>>>> streaming machine learning framework that contains a programming >>>>>>>>>> abstraction for distributed streaming machine learning >>>>>>>>>> >>>>>>>>> algorithms. >>>>> >>>>>> Apache >>>>>>>> >>>>>>>>> SAMOA enables development of new ML algorithms without directly >>>>>>>>>> >>>>>>>>> dealing >>>>>>> >>>>>>>> with the complexity of underlying distributed stream processing >>>>>>>>>> >>>>>>>>> engines >>>>>>> >>>>>>>> (DSPEe, such as Apache Storm, Apache S4, and Apache Samza). >>>>>>>>>> >>>>>>>>> Apache >>>>> >>>>>> SAMOA >>>>>>>> >>>>>>>>> users can develop distributed streaming ML algorithms once and >>>>>>>>>> >>>>>>>>> execute >>>>>>> >>>>>>>> them >>>>>>>>> >>>>>>>>>> on multiple DSPEs. >>>>>>>>>> >>>>>>>>>> Apache Samoa currently has integrations with Apache Storm, Apache >>>>>>>>>> >>>>>>>>> Flink, >>>>>>>> >>>>>>>>> Apache S4 and Apache Samza. This means the ML algorithms >>>>>>>>>> >>>>>>>>> developed >>>>> >>>>>> on >>>>>> >>>>>>> Apache Samoa can run on these platforms without any change in the >>>>>>>>>> algorithms. >>>>>>>>>> It would be a good idea to integrate Apache Apex as a distributed >>>>>>>>>> >>>>>>>>> stream >>>>>>>> >>>>>>>>> processing engine (DSPE) into Apache Samoa which would allow >>>>>>>>>> >>>>>>>>> users >>>>> >>>>>> to >>>>>> >>>>>>> run >>>>>>>> >>>>>>>>> ML algorithms developed in Samoa on Apache Apex. >>>>>>>>>> >>>>>>>>>> Here is the Apex JIRA for integration work: >>>>>>>>>> https://malhar.atlassian.net/browse/APEX-202 >>>>>>>>>> <https://malhar.atlassian.net/browse/APEX-202> >>>>>>>>>> Also, here is the JIRA in SAMOA project: >>>>>>>>>> https://issues.apache.org/jira/browse/SAMOA-49 >>>>>>>>>> >>>>>>>>>> Thanks. >>>>>>>>>> >>>>>>>>>> >>> >
