回答情况：
提问时间：
问题标签：
我正在尝试使用以下代码片段通过Kafka -> Flink -> Hive向Hive发送数据：final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment;
.setDrivername("org.apache.hive
浏览 0修改于2018-12-10得票数 0
在使用Flink的Hive连接器查询Hive时，我有以下异常：Distinct without an aggregation。Hive版本：2.1.1select devid as pdevid, at org.apache.flink.table.planner.dele
浏览 21修改于2022-07-16得票数 0
我想在Apache Flink中做流式作业，在Apache Flink(Scala)中做Kafka -> Flink -> HIVE。谁能给代码样本，因为他们的官方文件不是很清楚。
浏览 11提问于2020-07-09得票数 1
回答已采纳
0回答
2022-05-19T16:33:17,732 ERROR [ORC_GET_SPLITS #0] org.apache.hadoop.hive.ql.io.AcidUtils - Failed toregular API: Only supported for DFS; got class org.apache.hadoop.fs.cosnative.NativeCosFileSystem
flink1.10 版本读取hive 2.3.7 的数据 将hive下的以来全部copy 到 flink的依赖
浏览 573提问于2022-05-19
根据此链接，https://ci.apache.org/projects/flink/flink-docs-stable/dev/table/hive/#connecting-to-hive需要本地配置单元配置文件夹路径，但我需要在yarn提交Flink作业，因此Flink尝试在纱线容器中查找路径，例如/mnt/volume4/yarn/nm/use
浏览 26修改于2020-07-19得票数 0
回答已采纳
在idea中使用flink sql连接hive以后尝试建立外表关联hbase，报错Storage handler table is not supported
图片
浏览 156提问于2022-10-31
'properties.group.id' = 'xxx', 'format' = 'raw');) 'org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe'
STOREDAS
浏览 6提问于2022-05-07得票数 0
-- Example: <groupId>org.apache.flink</groupId> <version>${flink.version}</version应用程序jar可以
浏览 2提问于2021-04-08得票数 0
回答已采纳
当我使用pyflink hive sql read data insert into es时，抛出以下异常:环境: flink 1.11.2 flink-sql-connector-hive-3.1.2(HiveVectorizedOrcSplitReader.java:99) ~[flink-sql-connector-hive-3.1.2_2.11-1.11.2.jar:1.11.2]
at.nextBatch(OrcShimV210.java:35) ~[flink
浏览 338提问于2020-12-17得票数 0
您可以在Flink发行版中的/lib/目录中选择一个。
flink-sql-连接器-蜂窝-2.2.0(下载链接).
浏览 4提问于2021-04-02得票数 0
回答已采纳
(name, hive);
我的flink版本是1.15.2，而hive版本是3.1.2。pom.xml文件如下所示： <flink.version>1.15.2</flink.version>
<<
浏览 135提问于2022-10-25得票数 0
1回答
hadoop3.3.0 flink1.12 hive3.12我想集成hive和flink。: /cdc/apache-hive-3.1.2-bin/conf 我启动了flink sql客户端，但报告了以下错误。:211)
at org.apache.flink.table.catalog.hive.HiveCatalog.at org.apache.hadoop.hive.conf.HiveCon
浏览 0修改于2021-01-20得票数 1
我有以下代码来测试flink和hive集成。我通过flink run -m yarn-cluster ....提交申请。package org.example.app
import org.apache.flink.table.api.bridge.scala._im
浏览 48修改于2021-01-06得票数 0
此外，我还设置了一个本地Flink项目(使用Scala2.12的Java项目)。在我的IDE中，除了默认的Flink依赖项之外，我还添加了版本为2.8.3的flink-clients、flink-table-api-java-bridge、flink-table-planner、flink-connector-hive、hive-exec、hadoop-client、flink-hadoop-compatibility以及iceber
浏览 15提问于2022-03-16得票数 0
>1.14.0</flink.version> <scala.version>2.11.12</scala.version--Hive Dependency--> <groupId>org.apache.flink<
浏览 64修改于2021-12-14得票数 1
我试图连接卡夫卡与Flink和运行通过sql-client.sh。-2.0.0-cdh6.1.1.jar
current-database: default - name: myhive
type: hivehive-version
浏览 46修改于2021-12-01得票数 0
回答已采纳
2回答
version:flink 1.11hive1.2.1hadoop2.7.1Use 软件flink运行jar以运行提交程序，但有以下例外： at org.apache.flink.connectors.hive.read.HiveVectorizedOrcSplitReader<init>(HiveVectorizedOrcS
浏览 0修改于2020-10-14得票数 0
String name = "myhive"; String hiveConfDir = "/etc/hive/conf"; tblEnv.registerCatalog("myhive", hiv
浏览 769提问于2021-10-02得票数 0
回答已采纳
我正在尝试使用flink sql客户端执行单元查询，并修改sql defaults.yaml
处决：
use testdb
浏览 5修改于2020-12-23得票数 1
回答已采纳
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号