Hi I want to convert Row dataType to JSON while converting r Apache Flink #troubleshooting

Hi I want to convert Row dataType to JSON while co...

Keyur Makwana

09/20/2023, 10:15 AM

Hi I want to convert Row dataType to JSON while converting result to datastream, Is there any way?

Copy code

DataStream<Row> dataStream = streamTableEnvironment.toChangelogStream(resultTable);

I want to do it like

Copy code

DataStream<JSON> dataStream = streamTableEnvironment.toChangelogStream(resultTable);

✅ 1

Keyur Makwana

09/20/2023, 11:18 AM

Main motive is to sink my data in JSON format when I do with Row it sink in String

Keyur Makwana

09/21/2023, 1:01 PM

Solved issue by converting my data to JSON_object and again get first field