Re: Flink: Not able to sink a stream into csv

2021-04-21 Thread Yik San Chan
table_env.execute_sql(""" > INSERT INTO print > SELECT id, data > FROM datagen > """).wait() > ``` > > [1] > https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/table/connectors/filesystem.html#rolling-policy > > 2021年4月

Re: Flink: Not able to sink a stream into csv

2021-04-21 Thread Dian Fu
uot;"" INSERT INTO print SELECT id, data FROM datagen """).wait() ``` [1] https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/table/connectors/filesystem.html#rolling-policy > 2021年4月21日 下午7:44,Yik San Chan 写道: > > The question is cross posted o

Flink: Not able to sink a stream into csv

2021-04-21 Thread Yik San Chan
The question is cross posted on Stack Overflow https://stackoverflow.com/questions/67195207/flink-not-able-to-sink-a-stream-into-csv . I am trying to sink a stream into filesystem in csv format using PyFlink, however it does not work. ```python # stream_to_csv.py from pyflink.table import