问答 2022-06-28 来自:开发者社区

1.13.6版本 flink sql 写hive 任务正常,hdfs上有文件,但是发现缺乏_SU

1.13.6版本 flink sql 写hive 任务正常,hdfs上有文件,但是发现缺乏_SUCCESS 标记文件,与hive分区也没有创建 ,有谁知道什么原因?

问答 2021-12-07 来自:开发者社区

flink的sql写hdfs如何指定文件名称

flinksql写HDFS后自动生成的名称:part-c4a19762-bde3-4f37-8b3c-b92d182b450c-task-0-file-0 然后发现我读取的时候麻烦了,请问如何指定flink的sql写hdfs如何指定文件名称 陈 *来自志愿者整理的flink邮件归档

问答 2021-12-06 来自:开发者社区

flink 1.11 使用sql写入hdfs无法自动提交分区

我在用flink 1.11 的sql从kafka消费然后写入hdfs的过程中,发现没法自动提交分区,请问这个是什么原因呢?谢谢 我的checkpoint设置了间隔10s,对于如下的配置,正常应该是每隔10在hdfs相应的分区下会有_SUCCESS文件,但是实际上过了好久也没有,ORC格式的结果数据是正常写入了。 public static void main(String[] args) t...

问答 2021-12-05 来自:开发者社区

flink sql 写hdfs问题,如何解决?

flink.version=1.12.0 Create table t1( a varchar )with ( connector=kafka format=json ) Create table t2( a varchar )with ( connector=filesystem format=csv ) SQL: Insert into t2 select a from t1 发送: ...

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

阿里云存储服务

阿里云存储基于飞天盘古2.0分布式存储系统,产品多种多样,充分满足用户数据存储和迁移上云需求。

+关注