Hi team,
I am converting Table to Datastream, My table has a inner nested object but when I convert to Datastream from table it gives me below error, Can anyone help me to resolve the same?
✅ 1
Keyur Makwana
07/14/2023, 6:25 AM
This is how I convert table to Datastream
DataStream<Row> dataStream = tableEnv.toDataStream(table);
Keyur Makwana
07/14/2023, 6:26 AM
Is there any configuration that I need to give to DTO?
Keyur Makwana
07/14/2023, 8:11 AM
I have tried by registering it as a POJO using below command
executionEnvironment.getConfig().registerPojoType(UserIdentity.class);
But then in the output I am receiving only object of the DTO not the content
Keyur Makwana
07/14/2023, 8:54 AM
Issue has been resolved by putting ToString method in the DTO