解决Flink Elasticsearch Sink报错 我的代码如下，代码几乎都是一样的，格式也与官网一致，以下是flink scala elasticsearch6.x版本，尝试过修改5版本的写法也都是一直是报错。elasticsearch登陆也都是正常的，甚至在本地安装es，尝试是否能跑通还是报错，报错内容也在下面。 elasticsearch sinkimport ja

这里写目录标题操作代码注：下载需求包安装sasl踩坑执行连接成功操作代码虚拟机开启相关进程，hadoop、hiveserver2操作代码很简单如下所示注意先不要运行，这里缺少相关需求包组件from pyhive import hiveconn = hive.Connection(host='192.168.56.21', port=10000, username='root',password='

zookeeper完全分布式环境搭建解压安装修改配置文件配置环境解压安装链接：https://pan.baidu.com/s/1wHXBf7RrXsF3GeBFlQnKvg提取码：d79d解压 tar -zxf zookeeper-3.4.5-cdh5.14.2.tar移动并重命名 mv zookeeper-3.4.5-cdh5.14.2 /opt/soft/zk345修改配置文件在zookeep

hive常用内置函数字符函数regexp_replace()regexp_extract()数学函数日期函数from_unixtime()unix_timestamp()datediff()date_add()date_sub()add_months()last_day()next_day()条件函数表生成函数字符函数字符函数作用说明concat()拼接instr()找字符串所在位置，如instr

CM+CDH大数据环境搭建最终完整版一、集群准备1. 连接工具同时发送指令2. 修改基础配置3. 集群规划4. 创建非root用户5. 配置ip地址和主机名映射关系6. 设置swap交换空间7. 关闭大页面压缩8. SeLinux 设置9. 免密登陆10. 时间同步11. 创建目录用于上传安装包12. 配置JDK13. 安装所需要的编译环境（可跳过）14. 安装mysql二、CM+CDH安装1.

pythonMatplotlib数据可视化基本操作matplotlib介绍柱状图 bar散点图 scatter饼图matplotlib介绍一个有效Python 2D绘图库、高版本也可以绘制部分3D图支持多种数据结构list，ndarray，Series，DataFrame柱状图 bar导入pandas,读表并选取需要的数据import pandas as pdjobs_csv = pd.read_

hadoop环境完全分布式搭建集群准备集群规划修改配置文件启动集群时间同步集群准备准备3台客户机（关闭防火墙、静态ip，主机映射、主机名称），主机名称分别hadoop1，hadoop2，hadoop3三台虚拟机安装好jdk，并配置环境变量配置ssh，免密登录（1）在每台虚拟机上vi /etc/hosts 将集群中的虚拟机ip地址和主机名绑定，如(2) 在每台虚拟机上生成公私钥  ssh-keyge

ClickHouse入门 虚拟机centos单点安装，DBeaver连接方式一、ClickHouse简介1. 什么是ClickHouseClickHouse是一个完全的列式数据库管理系统，主要用于在线分析处理查询（OLAP），能够使用SQL查询实时生成分析数据报告。它在大数据领域没有走Hadoop生态，而是采用Local attached storage作为存储，所以没有依赖Hadoop的局限性。

java连接hbase进行表数据操作注：pom依赖连接核心代码代码及建表操作新增数据put全表扫描过滤扫描filter注：window环境连接linux可能不能识别，为方便程序可以直接在ideal中运行，打开window/system32/drivers/hosts并修改host属性取消可读模式,在hosts文档末尾处添加需要连接虚拟机ip地址以及用户名，注意空格也是英文状态下的空格pom依赖??

如何使用Xshell连接CentOS7，方便快捷使用，提高效率首先需要打开你的virtual box，这里以虚拟机mybox0401为例登录进入后，输入ip a 查看你的ip地址打开xshell，点击新建命名并输入地址5.点击身份验证，进行如图操作，最后点连接或者确定最后如果出现ssh安全警告，点接受就可以了????连接成功后如下????????...