活动
flink遇到的问题
1.测试flink sql的时候 Exception in thread "main" org.apache.flink
hive修复所有表
众所周知 hive是hive ，hdfs是hdfs，mysql是mysql。 但是某种意义上来说hive=hdfs(数据文件)+mysq
flink启动报错Failed to construct kafka producer
flink local模式下启动 sink2kafka报错，具体报错如下 提取报错信息 Failed to construct kaf
flink写入到kafka 大坑解析。
1.kafka能不能发送null消息？ 能！ 2 flink能不能发送null消息到kafka？ 不能！ 这里就
大数据应用——hbase shell操作
HBase 逻辑结构 HBase 物理存储结构 数据模型 1）Name Space 命名空间，类似于关系型数据库的 Data
Hbase出现ERROR: Can‘t get master address from ZooKeeper； znode data == null解决办法
问题描述如下： 出现此问题可能是zookeeper不稳定造成的，采用的是虚拟机，经常挂起的状态，使用hbase的list命令出现下面错误，这个可能是hbase的稳定性造成的，解决办法有两种。这里使用第一种办法就解决了。 解决方法：
【Hadoop】HDFS体系结构分析
文章目录1. NameNode2. Secondary NameNode3. DataNode HDFS主要包含NameNode、Secondary NameNode和DataNode三部分，且这三部分在分布式文件系统中分属不同的机器，
【Flume】Flume原理简述及示例实践
【Flume】Flume原理简述及示例实践
【Hadoop】MapReduce小文件问题解决方案（SequenceFile，MapFile）
【Hadoop】MapReduce小文件问题解决方案（SequenceFile，MapFile）
【Flume】高级组件之Channel Selectors及项目实践
【Flume】高级组件之Channel Selectors及项目实践
Elasticsearch exception [type=cluster_block_exception, reason=blocked by: [FORBIDDEN/12/index r【已解决】
亲测 2022/08/16 BJ文章目录异常原因解决异常原因集群存储资源高水位异常，默认当磁盘空间大于95%时，就会禁止写入。解决首先让es节点腾出足够的空间、删除磁盘数据 ; 扩容。执行恢复命令让es恢复到
elasticsearch分组求平均值
亲测，入门DSL语句文章目录DSL语句名词解释突击面试先通过 country 分组，再取score的平均数。先看结果。DSL语句名词解释size 表示展示多少条命中结果，这里是0，表示只展示聚合结果。doc_
11、hadoop环境下的Sequence File的读写与合并
文章目录Hadoop系列文章目录一、Sequence File的读写1、Sequence File的格式1）、未压缩格式2）、基于record压缩格式3）、基于block压缩格式2、Sequence File文件读写1）、pom.xml2
hadoop 的hdfsapi操作
hdfs 的api 相关操作一： hdfs api 操作1.1 读取内容：1.2 读取hdfs的数据1.3: 在hdfs上面的建立文件###1.4: put写入文件1.5 删除文件
大数据中常见的文件存储格式以及hadoop中支持的压缩算法
大数据中常见的文件存储格式以及hadoop中支持的压缩算法
NiFi FileFlow示例和NIFI模板示例
文章目录Apache NiFi系列文章一、FlowFile生成器示例1、GenerateFlowFile解析1）、描述2）、属性配置3）、应用场景2、ReplaceText解析1）、描述2）、属性配置3）、应用场景3、示例1）、创建Gen
6、NIFI综合应用场景-离线同步Mysql数据到HDFS中
文章目录Apache NiFi系列文章一、实现流程1、模板1）、模板12）、模板22、处理器流程1）、模板1处理流程2）、模板2处理流程二、处理器说明1、QueryDatabaseTable1）、描述2）、属性配置2、ConvertAvr
20、MapReduce 工作流介绍
文章目录Hadoop系列文章目录一、MapReduce 工作流介绍二、使用示例1、实现2、验证 本文介绍MapReduce 工作流。 本文前提：hadoop环境可用。一、MapReduce 工作流介绍多个MR作业，先后依次执行来计算得出
17、MapReduce的分区Partition介绍
文章目录Hadoop系列文章目录一、介绍1、数据分区2、Partition默认规则3、分区使用二、示例 本文介绍MR的分区Partition。 本文分为2个部分，即介绍与示例。 前提依赖：hadoop环境可正常使用。一、介绍1、数据分区
OpenStack排错记录---ResourceProviderCreationFailed和You are not authorized to perform the requested actio
前言： 最近在研究云原生里面的OpenStack，因此，使用脚本打算搭建一套测试学习用的OpenStack平台，但OpenStack平台
热门文章
java159-两个线程共同完成1到100计算
2023-03-13 09:29:37
58如何调出eclipse左边文件栏
2023-03-13 09:32:12
java163-同步方法锁
2023-03-07 10:04:03
java156-序列化
2023-03-10 10:21:07
java162-同步对象锁
2023-03-10 10:21:07
java157-线程的引入
2023-03-13 09:29:37
