TCli.java:2050)
> at com.datatorrent.stram.cli.DTCli.launchAppPackage(DTCli.java:3456) at
> com.datatorrent.stram.cli.DTCli.access$7100(DTCli.java:106) at
> com.datatorrent.stram.cli.DTCli$LaunchCommand.execute(DTCli.java:1895) at
> com.datatorrent.stram.cli.DTCli$3.run(DTCli.java:1449) Ca
ugust, 20 2:33 AM
> To: users@apex.apache.org
> Subject: Re: kryo Serealization Exception
>
> Hi
>
> Another option is to create your own Java object and populate the fields
> you need for further processing from GenericRecord, and send it on the
> output port. You can use
Hi
Another option is to create your own Java object and populate the
fields you need for further processing from GenericRecord, and send it
on the output port. You can use this approach if you can not put the
operators in single container, because 1) you need to shuffle based on
key or 2)
Hi,
Can you please help resolve the below issue?
In our project we are using 'org.apache.avro.generic.GenericRecord' as Tuple
writing to a parquet file and we are using avro schema for each record. We are
getting the below exception, I suppose GenericRecord does not have no-arg
constructor,
