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月
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
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