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]> 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]> 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] >>> > >>> 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] >>>> > >>>> 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]> >>> >>>> wrote: >>>>> >>>>> +1 >>>>>> >>>>>> Regards >>>>>> Sandeep >>>>>> >>>>>> Regards, >>>>>> Sandeep >>>>>> >>>>>> On Wed, Oct 28, 2015 at 11:36 AM, Amol Kekre <[email protected]> >>>>>> >>>>> wrote: >>>>> >>>>>> +1 >>>>>>> >>>>>>> Amol >>>>>>> >>>>>>> On Tue, Oct 27, 2015 at 10:27 PM, Bhupesh Chawda < >>>>>>> >>>>>> [email protected]> >>>>>> >>>>>>> wrote: >>>>>>> >>>>>>> Hi All, >>>>>>>> >>>>>>>> Apache Samoa <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 >>>>>>>> Also, here is the JIRA in SAMOA project: >>>>>>>> https://issues.apache.org/jira/browse/SAMOA-49 >>>>>>>> >>>>>>>> Thanks. >>>>>>>> >>>>>>>> >
