
文章目录 前言一、简单介绍MQ二、安装1.安装Docker(安装步骤省略,网上很多)2.Docker安装Rabbitmq3.查看是否启动成功http://....
冷热分离架构介绍 冷热分离是目前ES非常火的一个架构,它充分的利用的集群机器的优劣来实现资源的调度分配。ES集群的索引写....
Dubbo+Zookeeper 自己编写代码一直正确,研究半天,换一个包就解决了 发现是导入注解包错误了 注: 因为maven导入报的时候,....
spark连接hive: shell窗口下: 将core-site.xml、hdfs-site.xml、hive-site.xml复制到spark下的conf目录下,如果需要其它第....
返回给前端的实体类 @Data@AllArgsConstructor@NoArgsConstructorpublic class PageResult { private Long total; pri....
问题描述: 1、提交job运行,没有输出结果 2、前往Jobhistory查看运行日志 3、查看日志详情,报beyond the 'VIRTUAL....
目录 Hive数仓ETL过程 Hive数仓ETL过程 Synchronize industrial chain data to HDFS hadoop distcp hdfs://10.xx.xx.x:8020/....
线程通信之wait¬ify 在前面几节我们说过,java中每个线程在工作的时候,都会为其在栈区分配私有的线程栈,将共享变量拷贝....
背景介绍 原生对象存储服务的索引是扁平化的组织形式,在传统文件语义下的 List 和 Rename 操作性能表现上存在短板。腾讯云....
1.流量削峰 2.应用解耦 3.异步处理 之前A过一段时间调用B的api,现在A调用B,A不用等待B,接着可以去做其他的事 八大特性 1.....
报错原因 这个是消费数据格式和发送数据格式不一致转换失败导致 解决办法 原配置文件 spring: kafka: bootstrap-servers....
需求说明: 一、启用kafka进行数据传输 二、启用多进程进行生产及消费 难点说明: 一、kafka运行环境搭建 二、python操作kaf....
[root@hadoop10 hadoop-3.1.3]# sbin/start-dfs.sh Starting namenodes on [hadoop10]ERROR: Attempting to operate on hdfs nam
前提:Hadoop和zookeeper已经安装完成并且可以正常使用 1、启动hadoop start-all.sh 验证 http://master:50070 2、启动zooke....
背景: win10 VMware Workstation Pro16 CentOs-6.7 学习Spark的DStream流 问题描述: 执行命令“nc -lk 9999”启动....
1.分布式服务治理方案 1.1.简述几个名词 什么是服务治理 ? 反过来读一下:治理服务。分布式服务治理方案就是通过什么方案....
原始数据 HDFS words hellotomhellojerryhellokittyhelloworldhellotom Map阶段 1.每次读一行数据, 2.拆分每行数据, 3....
一、基本介绍 1.1 基本介绍 Fork/Join框架是Java 7提供的一个用于并行执行任务的框架, 核心思想就是把大任务分割成若干个小....
报错: elasticsearch.client.transport.NoNodeAvailableException: None of the configured nodes are available 环境: ....
1,kafka如何保证消息的顺序性 kafka 写入partion时指定一个key,列如订单id,那么消费者从partion中取出数据的时候肯定是有....