问答 2024-05-14 来自:开发者社区

想问下有没有大佬尝试过Flink SQL,在kinit场景下批写hive表的呢?

想问下有没有大佬尝试过Flink SQL,在kinit场景下批写hive表的呢?我这里用的是Flink1.18.1 + hive 3.1.3,测试下来【流读】【流写】【批读】hive都没有问题,仅在【批写】场景下,所有Task Finish后JM无法初始化HiveMetaStoreClient,报错【GSS initiate failed】,进而报错【Failed to finalize exe....

问答 2022-08-15 来自:开发者社区

flink 写hive表,开启文件合并没生效是什么原因?

flink 写hive表,开启文件合并没生效是什么原因?

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

flink 1.11 streaming 写入hive 5min表相关问题

现象: CREATE TABLE test.xxx_5min ( ...... ) PARTITIONED BY (dt string , hm string) stored as orc TBLPROPERTIES( 'sink.partition-commit.trigger'='process-time', 'sink.partition-commit.delay'='5 min'...

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

flink 1.11.2 创建hive表的问题

大佬好,我在使用create table if not  exists创建hive表时,对于已存在的hive表,在hive的日志中会抛出AlreadyExistsException(message:Table  bm_tsk_001 already exists异常,查看源码发现if not  exists貌似只是用于判断捕获异常后是否抛出,对于这个问题有建议的解决方...

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

请问flink 什么时候支持读写ACID的hive表?

我们使用 flink.1.12 读取 ACID hive table 时报错(Reading or writing ACID table %s is not supported),我们尝试修改源码放开这个限制也会出现后续的一些错误如(cast转换 BytesColumnVector 为 LongColumnVector 出错)。 背景:目前我们生产想采用 flink 做 ETL 等数据迁移工作,....

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

产品推荐

实时计算 Flink

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

+关注
AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等