Can anyone please help me with this issue
On Aug 31, 2017 5:20 PM, "Vinay Patil" wrote:
> Hi,
>
> After adding the following two lines the serialization trace does not show
> the Schema related classes:
>
> env.getConfig().registerTypeWithKryoSerializer(GenericData.Array.class,
> Serializers.Spe
Hi,
After adding the following two lines the serialization trace does not show
the Schema related classes:
env.getConfig().registerTypeWithKryoSerializer(GenericData.Array.class,
Serializers.SpecificInstanceCollectionSerializerForArrayList.class);
env.getConfig().addDefaultKryoSerializer(
Hi Robert,
The test case code is as follows:
GenericRecord testData = new GenericData.Record(avroSchema);
SingleOutputStreamOperator testStream =
env.fromElements(testData)
.map(new DummyOperator(...));
Iterator
Hi Vinay,
could you provide the full stack trace and the Data types you are using in
your streaming application, to fully understand the problem?
Regards,
Robert
On Fri, Aug 25, 2017 at 6:51 PM, vinay patil
wrote:
> Hi Guys,
>
> I am using DataStreamUtils for unit testing, the test case succe
