抱歉，是我搞错了。
实际上是写入数据的。我在 windows 下做测试，刷新下文件的大小始终是 0 ， 只有编辑看下那个文件显示的文件大小才会变更。
wangl...@geekplus.com.cn
Sender: Alec Chen
Send Time: 2019-08-09 10:17
Receiver: user-zh
Subject: Re: Re: CsvTableSink 目录没有写入具体的数据
没数据是因为没有trigger执行, 参考sample code from doc(
https://ci.apache.org/projects/flink/flink
ot;};
> TypeInformation[] fieldTypes = {Types.INT};
> tableEnv.registerTableSink("RubberOrders", fieldNames, fieldTypes,
> csvSink);
> tableEnv.sqlUpdate(
> "INSERT INTO RubberOrders SELECT pick_task_id FROM
> t_pick_task");
>
&g
, fieldNames, fieldTypes,
csvSink);
tableEnv.sqlUpdate(
"INSERT INTO RubberOrders SELECT pick_task_id FROM
t_pick_task");
wangl...@geekplus.com.cn
Sender: Alec Chen
Send Time: 2019-08-08 21:01
Receiver: user-zh
Subject: Re: CsvTableSink 目录没有写入具体的数据
完整代码发一
完整代码发一下
wangl...@geekplus.com.cn 于2019年8月8日周四 下午7:37写道：
>
> 我按官网上的
> https://ci.apache.org/projects/flink/flink-docs-stable/dev/table/sql.html#specifying-a-query
> 例子写的代码
> 但运行后 CsvTableSink 指定的目录只生成了空文件，没有具体的内容，这是为什么呢？
>
>
>
> wangl...@geekplus.com.cn
>
我按官网上的
https://ci.apache.org/projects/flink/flink-docs-stable/dev/table/sql.html#specifying-a-query
例子写的代码
但运行后 CsvTableSink 指定的目录只生成了空文件，没有具体的内容，这是为什么呢？
wangl...@geekplus.com.cn
