基于 MySQL 生成日期維度數(shù)據(jù)創(chuàng)建日期維度數(shù)據(jù)表DROP TABLE IF EXISTS `date_dim`;CREATE TABLE IF NOT EXISTS `d...
Flink自身提供了遠程提交任務(wù)的環(huán)境,源碼如下: 請查看StreamExecutionEnvironment 類中 createRemoteEnvironment 方法 遠...
方法一: 使用 log4j.properties在 src/main/resources 中添加 log4j.properties 文件###################...
下載 imply 安裝包[root@node01 opt]# wget https://static.imply.io/release/imply-3.3.3.tar.gz ...
創(chuàng)建 JsonKuduOperationsProducer.java 用于處理 Json 字符串寫入Kuduimport com.alibaba.fastjson.JSON;...
制作Flink的Parcel包和csd文件 將Parcel包和manifest.json文件部署到httpd服務(wù)中[root@node01 ~]# mkdir -p /var...
環(huán)境準備SQL Server 中創(chuàng)建測試庫表CREATE DATABASE test;CREATE TABLE [dbo].[cdc_test] ( [id] int I...
環(huán)境準備開啟MariaDB的Binlog日志修改/etc/my.conf文件,在配置文件[mysqld]下增加如下配置server-id=999log-bin=mysql-b...
查看庫表是否啟動 CDC-- 查看數(shù)據(jù)庫是否啟用cdcSELECT name,is_cdc_enabled FROM sys.databases WHERE is_cdc_e...
修改 maven 的倉庫地址[root@node01 cloudera]# cat /usr/share/maven/conf/settings.xml... </mirr...
配置java,maven等環(huán)境變量java:export JAVA_HOME=/usr/local/javaexport PATH=$JAVA_HOME/bin:$PATHe...
異常信息org.apache.nifi.controller.UninheritableFlowException: Failed to connect node to cl...
問題一: 查詢結(jié)果中 hits.total.value 值最大為10000的限制解決方法:請求時設(shè)置 "track_total_hits": trueRest 請求設(shè)置方法:...
使用 ZIP文件離線安裝 Oracle 客戶端下載所需的 Instant Client ZIP文件。[root@cdh01 ~]# mkdir /opt/oracle[roo...
添加 ExecuteSQL 處理器添加 ExecuteSQL 到面板image配置 ExecuteSQLimage配置 DBCPConnectionPool更改 DBCPCo...
下載 MariaDB 安裝包下載地址: https://downloads.mariadb.org/ 卸載系統(tǒng)自帶的mysql#檢查mariadb是否存在[root@cdh0...
NiFi 架構(gòu)imageNiFi在主機操作系統(tǒng)上的JVM內(nèi)執(zhí)行。JVM上NiFi的主要組件如下:Web ServerWeb服務(wù)器的目的是托管NiFi基于HTTP的命令和控制A...
示例代碼import org.apache.log4j.{Level, Logger}import org.apache.spark.SparkConfimport org....