在sql-client-defaults.yaml中添加以下配置
使用./bin/sql-client.sh 进入shell 执行以下sql，将mysql 表注册到flink
参考文档：https://nightlies.apache.org/flink/flink-docs-release-1.13/docs/connectors/table/jdbc/
CREATE TABLE user1 ( id int ) WITH ( 'connector' = 'jdbc', 'url' = 'jdbc:mysql://172.16.104.165:30066/test', 'table-name' = 'user', 'username' = 'root', 'password' = '123456' );
一、概述 在HDFS中数据和元数据分别由DataNode和NameNode负责，这些元数据每个对象一般占用大约150个字节。大量的小文件相对于大文件会占用大量的NameNode内存。对Na...
安装keepalivedyum 安装keepalivedyum install keepalivedkeepalived.conf配置文件进行调整，其中state设置主备状态，interface设置对...
1）Hadoop调度器重要分为三类：FIFO 、Capacity Scheduler（容量调度器）和Fair Sceduler（公平调度器）。Apache默认的资源调度器是容量调度器；CDH...
简介Keycloak是一个开源软件产品，旨在为现代的应用程序和服务，提供包含身份管理和访问管理功能的单点登录工具。截至2018年3月，红帽公司负责管理这一JBoss社区项目，并将其作为他们RH-SSO...
1、背景默认情况下apache hbase 使用hbck2时，无法使用-j 来加载hbck2的jar包，无法进行修复2、解决办法是由于默认情况下只使用自带的hbase hbck修复命令，大部分功能在2...
环境： CentOS 7.8 11.2.0.4.0 orclp:172.16.104.31一、准备1、依赖包检查pdksh 在 redhat 上叫 ksh检查是否有安装root# rpm -q bin...
