在使用flinksql读取kafka数据写入hbase时候报错,请帮忙看一下是什么问题
在使用flinksql读取kafka数据写入hbase时候报错
在使用flinksql读取kafka数据写入hbase时候报错,请帮忙看一下是什么问题
- 写回答
- 好问题 0 提建议
- 追加酬金
- 关注问题
分享- 邀请回答
-
0条回答 默认 最新
- 2022-07-13 20:33回答 3 已采纳 restclient异常，先看看taskmanager和jobmanager是否正常，然后你可以在jobmanager的节点上访问webUI查看job状态，又或者直接查看宿主机上的日志排查问题
- 2022-08-26 11:43回答 1 已采纳 不是大小写问题，你的json里面是大写，代码里面是小写，改一下试试
- 2022-01-28 09:47回答 1 已采纳 那最后写入到库了吗，如果写不进去，上游kafka肯定会延迟越来越大的，可以在sink里多打印下错误，或者设置写入超时时间，问题应该在写入
- 2022-03-30 10:33fyl005的博客 1、查询 flink 1.12 的官网，找寻flink sql 连接 Hbase 的信息。 Apache Flink 1.12 Documentation: HBase SQL Connector 根据 Hbase 版本需要下载依赖 官网中的连接信息 -- register the HBase table '...
- 2021-08-18 11:07回答 2 已采纳 你的包是不是导错了。删除你导入的包，把下面的包复制放你程序中。 import org.apache.flink.api.common.typeinfo.TypeInformation; import
- 2019-10-30 14:39回答 1 已采纳 **DEMO** ``` def main(args: Array[String]): Unit = { val env = StreamExecutionEnviron
- 2022-05-15 21:27回答 1 已采纳 删除异常的主题“movie_real_topic”试试.\bin\kafka-topics --delete --topic movie_real_topic --zookeeper localhos
- 2022-07-11 15:25MIDSUMMER_yy的博客 Flink 1.12 读取kafka 写入hbase | 自定义HbaseSink | 含源码
- 2021-07-02 11:07回答 2 已采纳 对kafka来说，只要这条数据发出去了，就算消费了，你消费者怎么处理，和kafka无关了。对消费者来说， 你只需要消费下一条就行了。至于偏移量， 你第一次消费的时候，是要发送偏移的，这个你消费者要本地
- 2022-04-24 14:53回答 2 已采纳 这样好像不行，你可以换一种思路。 写linux脚本，定时提交作业 Linux Crontab 定时任务 麻烦采纳一下，你的采纳，是对我最好的鼓励，谢谢！
- 2022-09-01 17:56回答 2 已采纳 似乎是权限问题，你可以看看报错的文件路径权限组看看，使用 ls -l /home/…
- 2022-04-26 14:47路人君� 。的博客 创建kafka消费者对象和hbase实例： Properties procounsumer = new Properties(); //kafka是服务器地址 procounsumer.put("zookeeper.connect", "dap03:2181/kafka"); //定义消费者组 procounsumer.put(...
- 2023-02-02 16:54回答 4 已采纳 ''该回答引用ChatGPT''如对你的问题有帮助，请点击右侧采纳即可！没有使用ZooKeeper的话，一种可行的方案是利用ClickHouse的复制功能实现双机数据同步。ClickHouse的复制功
- 2019-07-23 18:19快乐崇拜234的博客 文章目录概述环境说明代码编写写入hbase 概述 环境说明 scala: 2.12.8 linux下scala安装部署 flink : 1.8.1 Flink1.8.1 集群部署 kafka_2.12-2.2.0 kafka_2.12-2.2.0 集群部署 hbase 2.1 hbase 2.1 环境搭建–完全...
- 2021-11-29 20:44落幕7的博客 文章目录Flink从kafka读数据写入HBase读取Hbase数据 Flink从kafka读数据写入HBase Flink官网帮助文档链接 先导入依赖 <dependency> <groupId>org.apache.flink</groupId> <artifactId>...
- 没有解决我的问题, 去提问
问题事件
系统已结题
5月17日
创建了问题
5月9日
悬赏问题
- ¥30 comsol仿真等离激元
- ¥15 静电纺丝煅烧后如何得到柔性纤维
- ¥15 (标签-react native|关键词-镜像源)
- ¥100 照片生成3D人脸视频
- ¥15 伪装视频时长问题修改MP4的时长问题，
- ¥15 JETSON NANO
- ¥15 VS开发qt时如何在paintgl函数中用pushbutton控制切换纹理
- ¥20 关于 openpyxl 处理excel文件地问题
- ¥15 MS中不知道高分子的构型怎么构建模型
- ¥60 QQOP数据，什么是op数据号，怎么提取op数据！能不能大量提取(语言-c语言)