Hussein,
To use a JsonRowDeserializationSchema you'll need to use the Table API, and
not DataStream.
You'll want to use a JsonRowSchemaConverter to convert your json schema
into the TypeInformation needed by Flink, which is done for you by
the JsonRowDeserializationSchema builder:
json_row_s
For questions like this one, please address them to either Stack Overflow
or the user mailing list, but not both at once. Those two forums are
appropriate places to get help with using Flink's APIs. And once you've
asked a question, please allow some days for folks to respond before trying
again.
[apache-flink]An input of GenericTypeInfo cannot be converted to Table.
Please specify the type of the input with a RowTypeInfo
https://stackoverflow.com/q/50718451/6059691?sem=2
