You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user-zh@flink.apache.org by Danny Chan <yu...@gmail.com> on 2020/09/01 08:36:52 UTC

Re:flink-1.11连接hive或filesystem问题

1.  为了保证数据正确性 stream 写文件依赖了 checkpoint 机制，你可以将你的间隔时间和 checkpoint 时间保持一致
2. 按逗号分隔是说 CSV format ?

Best,
Danny Chan
在 2020年8月31日 +0800 PM8:53，酷酷的浑蛋 <ap...@163.com>，写道：
> 1. Create hive表(...)with(...)
> 我发现写入hive只能根据checkpoint去提交分区？可以按照文件大小或者间隔时间来生成吗？
>
>
> 2. Create table (connector=filesystem，format=json) with(…)
> 这种方式format只能等于json？ 我怎么按照分隔符写入hdfs？