在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' );
前言： 在kafka集群工作过程中，难免会碰到某个kafka服务实例宕机或挂掉的情况，服务一旦挂掉，意味着某个分区中的leader或follower将不能正常工作了 具体来说，...
安装gi执行root.sh报错：PRCR-1079 : Failed to start resource ora.cvu安装gi执行root.sh报错：PRCC-1014 : LISTENER_SCA...
1) 根据group组查看消费情况（数值不准，仅可参考）根据之前的分析，只有driver的consumer会提交offset，因此通过./k...
说明上一篇文章中，我们介绍了clickhouse-backup工具。除了备份恢复，我们也可以使用该工具来迁移数据。这篇文章中，我们提供一个使用clickhouse-backup做集群迁移的方案。前置条...
一、简介 Cloudera公司推出，提供对HDFS、HBase数据的高性能、低延迟的交互式SQL查询功能。基于Hive，使用与Apache Hive相同的元数据，使用内存计算，兼顾数据仓...
1、背景在云服务环境中的 Kubernetes 集群里，通常可以用云服务提供商提供的负载均衡服务来暴露 Service，但是在本地没办法这样操作。而 OpenELB 可以让用户在裸金属服务器、边缘以及...
