####### 创建 JsonKuduOperationsProducer.java 用于处理 Json 字符串写入Kuduimport com.alibaba.fastjson.JSON;import org.apache.flume.Context;import org.apache.flume.Event;import org.apache.flume.FlumeException;impo

添加 ExecuteSQL 处理器添加 ExecuteSQL 到面板配置 ExecuteSQL配置 DBCPConnectionPool更改 DBCPConnectionPool 配置，直到将 state 从 Invalid 变为 Disable数据库连接池配置信息启用 DBCPConnectionPool任务成功或失败时的处理方式....

下载 MariaDB 安装包下载地址: https://downloads.mariadb.org/卸载系统自带的mysql#检查mariadb是否存在[root@cdh01 local]# rpm -qa | grep mariadbmariadb-libs-5.5.60-1.el7_5.x86_64#卸载[root@cdh01 local]# rpm -e --nodep...

[root@cdh04 ~]# mount /dev/cdrom /media/mount: /dev/sr0 写保护，将以只读方式挂载[root@cdh04 ~]# cd /media/[root@cdh04 media]# ll总用量 67745-r-xr-xr-x 1 root root2011 1月30 2015 manifest.txt-r--r--r--...

创建hive表merge_testbeeline -u jdbc:hive2://192.168.1.101:10000 -n hive -e "create table if not exists default.merge_test (id int,name String,age int,last_modify_time String)ROW F...

虚拟机静态ip地址设置准备Linux环境将虚拟机的网络模式选为NAT修改主机名vi /etc/sysconfig/networkNETWORKING = yesHOSTNAME = hadoop01修改IP两种方式：第一种：通过Linux图形界面进行修改进入Linux图形界面右键点击右上方的两个小电脑点击Edit connections选中当前网络S...

下载zookeeper安装包下载地址：https://archive.apache.org/dist/zookeeper/zookeeper-3.4.6/zookeeper-3.4.6.tar.gz环境准备1.准备三台虚拟机2.每台机器上都安装好jdk环境3.关闭防火墙上传zookeeper安装包解压[root@hadoop05 local]# tar -zxv...

[root@cdh04 ~]# mount /dev/cdrom /media/mount: /dev/sr0 写保护，将以只读方式挂载[root@cdh04 ~]# cd /media/[root@cdh04 media]# ll总用量 67745-r-xr-xr-x 1 root root2011 1月30 2015 manifest.txt-r--r--r--...

下载 MariaDB 安装包下载地址: https://downloads.mariadb.org/卸载系统自带的mysql#检查mariadb是否存在[root@cdh01 local]# rpm -qa | grep mariadbmariadb-libs-5.5.60-1.el7_5.x86_64#卸载[root@cdh01 local]# rpm -e --nodep...

package com.cloudera.testimport com.cloudera.utils.{JedisPoolUtils, PropertiesScalaUtils}import org.apache.kafka.clients.consumer.{ConsumerConfig, ConsumerRecord}import org.apache.kafka.common.Top...