Hi François, I wasn't exactly sure this is a JSON object or JSON string you are trying to process. For a JSON string this [1] article might help. For a JSON object, I am assuming you are trying to convert it into a TableSource and processing using Table/SQL API, you could probably use the example here [2]
BTW, a very remote hunch, this might be just a stringify issue how you print the row out. -- Rong [1]: https://stackoverflow.com/questions/49380778/how-to-stream-a-json-using-flink [2]: https://ci.apache.org/projects/flink/flink-docs-release-1.3/dev/table/sourceSinks.html#table-sources-sinks On Wed, Feb 6, 2019 at 3:06 AM françois lacombe < francois.laco...@dcbrain.com> wrote: > Hi all, > > I currently get a json string from my pgsql source with nested objects to > be converted into Flink's Row. > Nested json objects should go in nested Rows. > An avro schema rules the structure my source should conform to. > > According to this json : > { > "a":"b", > "c":"d", > "e":{ > "f":"g" > } > } > > ("b", "d", Row("g")) is expected as a result according to my avro schema. > > I wrote a recursive method which iterate over json objects and put nested > Rows at right indices in their parent but here is what outputs : ("b", "d", > "g") > Child Row is appended to the parent. I don't understand why. > Obviously, process is crashing arguing the top level Row arity doesn't > match serializers. > > Is there some native methods in Flink to achieve that? > I don't feel so comfortable to have written my own json processor for this > job. > > Do you have any hint which can help please ? > > All the best > > François > > > > <http://www.dcbrain.com/> <https://twitter.com/dcbrain_feed?lang=fr> > <https://www.linkedin.com/company/dcbrain> > <https://www.youtube.com/channel/UCSJrWPBLQ58fHPN8lP_SEGw> > > [image: Arbre vert.jpg] Pensez à la planète, imprimer ce papier que si > nécessaire >
