Hi Kamil,
AFAIK, it should still not support Avro format in Python StreamingFileSink in
the Python DataStream API. However, I guess you could convert DataStream to
Table[1] and then you could use all the connectors supported in the Table &
SQL. In this case, you could use the FileSystem connect
Hello,
I'm trying to save my data stream to an Avro file on HDFS. In Flink
documentation I can only see explanations for Java/Scala. However, I can't
seem to find a way to do it in PyFlink. Is this possible to do in PyFlink
currently?
Kind Regards
Kamil
