Hi Ivan,
Is your question how to parse the JSON string in PyFlink? If so, maybe you
could take a look at this [1].
Regards,
Dian
[1]
https://stackoverflow.com/questions/71820015/how-to-reference-nested-json-within-pyflink-sql-when-json-schema-varies
On Fri, Jun 10, 2022 at 7:40 PM
Hello,
I have a flink table source working using
"""
create table source (
ts TIMESTAMP(3),
log_line STRING,
WATERMARK FOR ts AS ts - INTERVAL '1' SECOND
) with (
'connector'='lokitail', 'query'='blah', 'url'='blah'
)
""")
It uses a simple custom
