
当前,中国正加快部署推进新基建,培育壮大数字经济新动能,中国建筑业迎来战略发展机遇期。在此背景下,如何抓住数字化转型....
[root@mihaoyu151 ~]# ll /opt/install/total 2597160-rw-r--r--. 1 root root 16870735 Nov 23 07:42 sqoop-1.4.6.bin__hadoo
节点数据清空处理 文章目录 节点数据清空处理1、查询集群原来的配置2、清空节点数据3、检查是否排空数据4、数据清空失败场....
上次发的是1.10的flink,当时版本的flink不支持hive数据更新后依然以最新数据和kafka关联。 本次以1.12.2版本,java代码形式....
前言:因为公司需要一个kafka延时消息的组件服务,看了下市面上的实现kafka延时消息的实现,感觉都比较复杂难理解,自己就去....
前几天心血来潮,突然想学习一下大数据,去百度和知乎看了一些大神的建议,决定从Hadoop入手。由于好久不用Linux,这次配置....
前提条件 安装node.js 安装elasticdump插件 npm installnpm install elasticdump -g 出现下面界面,证明安装插件安装成功 ....
问题描述 今天使用hive动态分区向表插入数据时,一直报错java heap space或者GC overhead limit exceeded。排查了好久,发现....
执行下 hadoop fs -du -h /user/spark/applicationHistory hadoop fs -du -h /user/spark 执行 再执行 hadoop fs -du -h /....
近期在学习ElasticSearch,便在windows下搭建了一个分布式集群,练习一些常用的DSL(类似于SQL)和Java API。 1. 安装包下载....
节点:一个运行中的elasticsearch 实例称为一个节点, 一个集群是由一个或多个cluster.name(集群名称)配置的节点组成 查看集....
HIVE / impala 适用insert overwrite删除部分数据 适用:无分区表 insert overwrite table table_name select * from t....
项目场景: 公司要学习 kylin 在下个项目中使用,安装启动时遇到了一些问题 问题描述: 报错信息为: Exception in thread "....
文章目录 一、软件安装1. jdk 安装2. ES7.15.2 安装3. Mysql 8.0 安装4. canal下载 二、Mysql 配置2.1. 开启binlog2.2.....
方法1:设置重启restart.sh脚本,crontab 设置定时任务,定时重启。 restart.sh #!/bin/shexport JAVA_HOME=/opt/jdk1.8.0_20....
基于RocketMQ可以实现分布式事务的最终一致性解决方案,它使用TransactionMQProducer发送事务消息,事务消息的状态包括:Unk....
T行业作为当今发展前途最大的几大行业之一,获得了前所未有的广泛关注,且随着科技的发展,这一趋势将更加明显。 但是,对于....
需要从Kafka读取数据的应用程序使用KafkaConsumer来订阅Kafka主题并从这些主题接收消息。 从Kafka读取数据与从其他消息系统....
前言 技术如同手中的水有了生命似的,汇聚在了一起。为了方便大家学习与工作查询资料。现生成大数据命令文档供大家参考。 本....