侧边栏壁纸
博主头像
★街角晚灯★博主等级

博观而约取 厚积而薄发

  • 累计撰写 450 篇文章
  • 累计创建 183 个标签
  • 累计收到 0 条评论

目 录CONTENT

文章目录

Docker - StarRocks部署(支持集群)

WinJay
2023-07-21 / 0 评论 / 0 点赞 / 86 阅读 / 105454 字 / 正在检测是否收录...
温馨提示:
文章发布较早,内容可能过时,阅读注意甄别。。。。
docker run -p 9030:9030 \
-p 8030:8030 -p 8040:8040 \
-itd \
-v `pwd`/start.sh:/data/deploy/start_fe_be.sh \
--name StarRocks-AllinOne \
starrocks.docker.scarf.sh/starrocks/allin1-ubuntu

Docker - StarRocks部署(支持集群)

image-20230721142803052 img

StarRocks介绍

StarRocks 是一款高性能分析型数据仓库,使用向量化、MPP 架构、可实时更新的列式存储引擎等技术实现多维、实时、高并发的数据分析。StarRocks 既支持从各类实时和离线的数据源高效导入数据,也支持直接分析数据湖上各种格式的数据。StarRocks 兼容 MySQL 协议,可使用 MySQL 客户端和常用 BI 工具对接。同时 StarRocks 具备水平扩展,高可用、高可靠、易运维等特性。广泛应用于实时数仓、OLAP 报表、数据湖分析等场景。

  • StarRocks是新一代极速全场景MPP(Massively Parallel Processing)数据库,致力于构建极速和统一分析体验。

  • StarRocks兼容MySQL协议,可使用MySQL客户端和常用BI工具对接StarRocks来分析数据。

  • StarRocks采用分布式架构:

    • 对数据表进行水平划分并以多副本存储。

    • 实例规模可以灵活伸缩,支持10 PB级别的数据分析。

    • 支持MPP框架,并行加速计算。

    • 支持多副本,具有弹性容错能力。

StarRocks特性

架构精简

  • StarRocks内部通过MPP计算框架完成SQL的具体执行工作。MPP框架能够充分的利用多节点的计算能力,整个查询可以并行执行,从而实现良好的交互式分析体验。
  • StarRocks实例不需要依赖任何其他组件,易部署、易维护和极简的架构设计,降低了StarRocks系统的复杂度和维护成本,同时也提升了系统的可靠性和扩展性。管理员只需要专注于StarRocks系统,无需学习和管理任何其他外部系统。

全面向量化引擎

StarRocks的计算层全面采用了向量化技术,将所有算子、函数、扫描过滤和导入导出模块进行了系统性优化。通过列式的内存布局、适配CPU的SIMD指令集等手段,充分发挥了现代CPU的并行计算能力,从而实现亚秒级别的多维分析能力。

智能查询优化

StarRocks通过CBO优化器(Cost Based Optimizer)可以对复杂查询自动优化。无需人工干预,就可以通过统计信息合理估算执行成本,生成更优的执行计划,大大提高了AdHoc和ETL场景的数据分析效率。

联邦查询

StarRocks支持使用外表的方式进行联邦查询,当前可以支持Hive、MySQL、Elasticsearch、Iceberg和Hudi类型的外表,您无需通过数据导入,可以直接进行数据查询加速。

高效更新

StarRocks支持明细模型、聚合模型、主键模型和更新模型,其中主键模型可以按照主键进行Upsert或Delete操作,通过存储和索引的优化可以在并发更新的同时实现高效的查询优化,更好的服务实时数仓的场景。

智能物化视图

  • StarRocks支持智能的物化视图。您可以通过创建物化视图,预先计算生成预聚合表用于加速聚合类查询请求。
  • StarRocks的物化视图能够在数据导入时自动完成汇聚,与原始表数据保持一致。
  • 查询的时候,您无需指定物化视图,StarRocks能够自动选择最优的物化视图来满足查询请求。

标准SQL

  • StarRocks支持标准的SQL语法,包括聚合、JOIN、排序、窗口函数和自定义函数等功能。
  • StarRocks可以完整支持TPC-H的22个SQL和TPC-DS的99个SQL。
  • StarRocks兼容MySQL协议语法,可以使用现有的各种客户端工具、BI软件访问StarRocks,对StarRocks中的数据进行拖拽式分析。

流批一体

  • StarRocks支持实时和批量两种数据导入方式。
  • StarRocks支持的数据源有Kafka、HDFS和本地文件。
  • StarRocks支持的数据格式有ORC、Parquet和CSV等。
  • StarRocks可以实时消费Kafka数据来完成数据导入,保证数据不丢不重(exactly once)。
  • StarRocks也可以从本地或者远程(HDFS)批量导入数据。

高可用易扩展

  • StarRocks的元数据和数据都是多副本存储,并且实例中服务有热备,多实例部署,避免了单点故障。
  • 实例具有自愈能力,可弹性恢复,节点的宕机、下线和异常都不会影响StarRocks实例服务的整体稳定性。
  • StarRocks采用分布式架构,存储容量和计算能力可近乎线性水平扩展。StarRocks单实例的节点规模可扩展到数百节点,数据规模可达到10 PB级别。
  • 扩缩容期间无需停服,可以正常提供查询服务。
  • StarRocks中表模式热变更,可通过一条简单SQL命令动态地修改表的定义,例如增加列、减少列和新建物化视图等。同时,处于模式变更中的表也可以正常导入和查询数据。

数据湖分析

StarRocks不仅能高效的分析本地存储的数据,也可以作为计算引擎直接分析数据湖中的数据,支持Apache Hive、Apache Iceberg、Apache Hudi等数据组织结构;支持Parquet、ORC、CSV等文件格式;也支持HDFS、S3、OSS等存储方式。

在数据湖分析场景中,StarRocks主要负责数据的计算分析,而数据湖则主要负责数据的存储、组织和维护。使用数据湖的优势在于可以使用开放的存储格式和灵活多变的Schema定义方式,可以让BI、AI、AdHoc、报表等业务维持在统一的单点身份可信(Single Source of Truth),而StarRocks作为数据湖的计算引擎,可以充分发挥向量化引擎和CBO(Cost Based Optimizer)的优势,大大提升了数据湖分析的性能。

-----------------

官方文档:

StarRocks 简介

注1:所有配置参数

注2:部署常见问题

注3:分区分桶原则(CSDN:流木随风)

硬件要求:部署BE服务的机器 CPU 需支持 AVX2 指令集,查看命令cat /proc/cpuinfo | grep avx2 有结果输出即表明CPU支持。如果无输出,建议更换支持AVX2的机器。



概念介绍

StarRocks架构的核心为FE(Frontend)和BE(Backend)两类进程,不依赖任何外部组件,方便部署与维护。FE和BE都可以在线水平扩展,元数据和业务数据都有副本机制,确保整个系统无单点。StarRocks提供MySQL协议接口,支持标准的SQL语法,可以通过MySQL客户端方便地查询和分析StarRocks中的数据。

  • FE、BE、Broker、CN
名词描述
FEFrontEnd简称FE,是StarRocks的前端节点,负责管理元数据,管理客户端连接,进行查询规划,查询调度等工作。
BEBackEnd简称BE,是StarRocks的后端节点,负责数据存储,计算执行,以及compaction,副本管理等工作。
BrokerBroker,是StarRocks中和外部HDFS/对象存储等外部数据对接的中转服务,辅助提供导入导出功能。
CN【公测】CN 节点(Compute Node)是一种无状态的计算服务,自身不维护数据,可以承担部分 SQL 计算。
  • 分区、分桶、副本数
名词描述
PARTITION BY RANGE()分区,⽤于将数据划分成不同的区间。分区的主要作⽤是将⼀张表按照分区键拆分成不同的管理单元。当前分区键仅支持日期类型和整数类型
DISTRIBUTED BY HASH()分区的下⼀级是分桶,StarRocks 采⽤ Hash 算法作为分桶算法。在同⼀分区内,分桶键哈希值相同的数据形成 Tablet。分桶数量(建议)= BE节点数量 * CPU 核数
replication_num副本数,就是同一个Tablet保存的份数。

FE

FE是StarRocks的前端节点,负责管理元数据、管理客户端连接、进行查询规划、查询调度等工作。每个FE节点都会在内存保留一份完整的元数据,这样每个FE节点都能够提供无差别的服务。

FE根据配置有Follower和Observer两种角色。Follower会通过类Paxos的Berkeley DB Java Edition(BDBJE)协议选举出一个Leader。三者详细介绍如下:

  • Leader
    • 提供元数据读写服务。仅Leader节点会对元数据进行写操作,Follower和Observer只有读取权限。Follower和Observer将元数据写入请求路由到Leader节点,Leader更新完数据后,会通过BDB JE同步给Follower和Observer。必须有半数以上的Follower节点同步成功才算元数据写入成功。
    • Leader从Follower中选出,进行选主需要实例中有半数以上的Follower节点存活。如果Leader节点失败,则Follower会发起新一轮选举。
  • Follower
    • 只有元数据读取权限,无写入权限。通过回放Leader的元数据日志来异步同步数据。
    • 参与Leader选举,必须有半数以上的Follower节点存活才能进行选主。
  • Observer
    • 主要用于扩展实例的查询并发能力,可选部署。
    • 不参与选主,不会增加实例选主压力。
    • 通过回放Leader的元数据日志来异步同步数据。

BE

BE是StarRocks的后端节点,负责数据存储、SQL执行等工作。

  • 数据存储方面,StarRocks的BE节点都是完全对等的,FE按照一定策略将数据分配到对应的BE节点。BE负责将导入数据写成对应的格式存储,并生成相关索引。

    在进行Stream Load导入数据时,FE会选定一个BE节点作为Coordinator BE,负责将数据分发到其他BE节点,导入的最终结果由Coordinator BE返回。

  • 在执行SQL计算时,一条SQL语句首先会按照具体的语义规划成逻辑执行单元,然后再按照数据的分布情况拆分成具体的物理执行单元。物理执行单元会在对应的数据存储节点上执行,实现本地计算,避免数据的传输与拷贝,从而极大的提升了查询性能。


一、拉取镜像

  • 前端节点,负责管理元数据,管理客户端连接,进行查询规划,查询调度等工作

docker pull renzicu/starrocks-fe:2.5.0

docker pull starrocks/fe-ubuntu:3.0.0

  • 后端节点,负责数据存储,计算执行,以及compaction,副本管理等工作.

docker pull renzicu/starrocks-be:2.5.0

docker pull starrocks/be-ubuntu:3.0.0

# 机器 CPU 不支持 AVX2 指令集,下面的BE命令都需要换成此镜像
docker pull renzicu/starrocks-be-noavx:2.5.0

# 和外部HDFS/对象存储等外部数据对接的中转服务,辅助提供导入导出功能
docker pull renzicu/starrocks-broker:2.5.0

二、准备工作

将容器中配置文件映射到本地,方便日后调整配置参数

# 本地存储StarRocks根目录
export StarRocks_Home='/mnt/Docker/017.Temp_StarRocks/'
export StarRocks_Ver='3.0.0'
# 提前创建需要保存配置文件的目录,示自己情况创建
mkdir -p $StarRocks_Home/fe-v3/conf $StarRocks_Home/be-v3/conf $StarRocks_Home/broker/conf

# 创建临时容器,导出FE配置文件
docker create --name Starrocks-Fe-V3 starrocks/fe-ubuntu:${StarRocks_Ver} \
  && docker cp  Starrocks-Fe-V3:/starrocks/conf/fe.conf $StarRocks_Home/fe-v3/conf/fe.conf \
  && docker rm  Starrocks-Fe-V3
  
  

# 创建临时容器,导出BE配置文件
docker create --name  Starrocks-Be-V3 starrocks/fe-ubuntu:${StarRocks_Ver} \
  && docker cp Starrocks-Be-V3:/starrocks/conf/be.conf $StarRocks_Home/be-v3/conf/be.conf \
  && docker rm Starrocks-Be-V3
  
  
  
# 创建临时容器,导出Broker配置文件
docker create --name starrocks-broker renzicu/starrocks-broker:${StarRocks_Ver} \
  && docker cp starrocks-broker:/starrocks/conf/apache_hdfs_broker.conf $StarRocks_Home/broker/conf/apache_hdfs_broker.conf \
  && docker rm starrocks-broker

image-20230522151215469

三、FE启动和配置

注意

当新的FE节点首次被添加到已有集群并启动时,您需要指定集群中现有的一个节点作为 helper 节点,并从该节点获得集群的所有 FE 节点的配置信息,才能建立通信连接。因此,在首次启动新 FE 节点时候,您需要通过命令行指定 –helper 参数。详见官方文档:部署 FE 高可用集群

当一台机器拥有多个非回环 IP 地址时,需要在 FE 配置文件 conf/fe.conf 中设置 priority_networks,为该节点设定唯一 IP。

添加节点到现有集群步骤(顺序不能乱,否则会加入集群失败)

  1. 先执行SQL语句添加节点 ALTER SYSTEM ADD FOLLOWER/OBSERVER "host:edit_log_port";
  2. 然后再启动程序并指定 –helper 参数。

加入集群失败后,可使用如下方法重新加入

  1. 执行SQL语句删除节点 ALTER SYSTEM DROP FOLLOWER/OBSERVER "host:edit_log_port";
  2. 清除容器内/starrocks/meta/*目录和/starrocks/HELPER_READY文件。
  3. 执行SQL语句添加节点 ALTER SYSTEM ADD FOLLOWER/OBSERVER "host:edit_log_port";
  4. 重启先前创建的容器

作者封装的镜像对参数做了包装,见示例中-e OPTS=参数

  • 预期网络创建

docker network create --subnet=172.19.0.0/24 Flink_Network

docker run -itd \
# http_port、query_port
-p 8030:8030 -p 9030:9030 \
# edit_log_port、rpc_port
-p 9010:9010 -p 9020:9020 \
--restart unless-stopped \
--name starrocks-fe1 \
# -e OPTS="--helper 172.17.0.1:9010" \
-v /etc/localtime:/etc/localtime:ro \
-v /mnt/Docker/017.StarRocks-V2/fe/conf/fe.conf:/starrocks/conf/fe.conf \
-v /mnt/Docker/017.StarRocks-V2/fe/meta:/starrocks/meta \
-v /mnt/Docker/017.StarRocks-V2/fe/log:/starrocks/log \
renzicu/starrocks-fe:2.5.0
  • 定制版启动

docker run -itd \
-p 8030:8030 -p 9030:9030 \
-p 9010:9010 -p 9020:9020 \
--restart unless-stopped \
--name Starrocks-Fe-V2-1 \
-v /etc/localtime:/etc/localtime:ro \
-v /mnt/000.Docker/017.StarRocks-V2/fe/conf/fe.conf:/starrocks/conf/fe.conf \
-v /mnt/000.Docker/017.StarRocks-V2/fe/meta:/starrocks/meta \
-v /mnt/000.Docker/017.StarRocks-V2/fe/log:/starrocks/log \
--network 017starrocks-v2_Flink_Network \
renzicu/starrocks-fe:2.5.0

docker run -itd \
-p 8030:8030 -p 9030:9030 \
-p 9010:9010 -p 9020:9020 \
--restart unless-stopped \
--name Starrocks-Fe-V2 \
-v /etc/localtime:/etc/localtime:ro \
-v ./fe/conf/fe.conf:/starrocks/conf/fe.conf \
-v ./fe/meta:/starrocks/meta \
-v ./fe/log:/starrocks/log \
--network 017starrocks-v2_Flink_Network \
renzicu/starrocks-fe:2.5.0


docker run -itd \
-p 8032:8030 -p 9032:9030 \
-p 9012:9010 -p 9022:9020 \
--restart unless-stopped \
--name Starrocks-Fe-V2-2 \
-v /etc/localtime:/etc/localtime:ro \
renzicu/starrocks-fe:2.5.0



docker run -itd \
-p 8033:8030 -p 9033:9030 \
-p 9013:9010 -p 9023:9020 \
--restart unless-stopped \
--name Starrocks-Fe-V2-3 \
-v /etc/localtime:/etc/localtime:ro \
renzicu/starrocks-fe:2.5.0




docker run -itd \
-p 8034:8030 -p 9034:9030 \
-p 9014:9010 -p 9024:9020 \
--restart unless-stopped \
--name Starrocks-Fe-V2-4 \
-v /etc/localtime:/etc/localtime:ro \
renzicu/starrocks-fe:2.5.0


docker run -itd \
-p 8035:8030 -p 9035:9030 \
-p 9015:9010 -p 9025:9020 \
--restart unless-stopped \
--name Starrocks-Fe-V2-5 \
-v /etc/localtime:/etc/localtime:ro \
renzicu/starrocks-fe:2.5.0


  • 预期网络创建

docker network create --subnet=172.19.0.0/24 Flink_Network

  • V 3.0.0启动方式

#!/bin/bash
# author:WinJayX
# date:2020-05-07
# Maintainer WinJayX <WinJayX@Gmail.com>
# func:Docker Demo
# !!! -p 参数说明 -p :前的为宿主机的端口,后的为容器业务所需的端口!!!
# --privileged=true 特权模式 --restart unless-stopped 重启策略,除非停止的状态
docker stop Starrocks-Fe-V3-1
docker rm -f Starrocks-Fe-V3-1
docker container run -itd \
    --user root \
    -p 8030:8030 \
    -p 9030:9030 \
    -p 9010:9010 \
    -p 9020:9020 \
    --ip 172.19.0.11 \
    --net Flink_Network \
    --restart unless-stopped \
    --name Starrocks-Fe-V3-1 \
    --volume /etc/localtime:/etc/localtime:ro \
    --volume `pwd`/SR_Data/fe_data/log-1/:/opt/starrocks/fe/log/\
    --volume `pwd`/SR_Data/fe_data/meta-1/:/opt/starrocks/fe/meta/ \
    starrocks/fe-ubuntu:3.0.1 /bin/bash -c /opt/starrocks/fe/bin/start_fe.sh --daemon

docker stop Starrocks-Fe-V3-2
docker rm -f Starrocks-Fe-V3-2
docker container run -itd \
    --user root \
    -p 8032:8030 \
    -p 9032:9030 \
    -p 9012:9010 \
    -p 9022:9020 \
    --ip 172.19.0.12 \
    --net Flink_Network \
    --restart unless-stopped \
    --name Starrocks-Fe-V3-2 \
    --volume /etc/localtime:/etc/localtime:ro \
    --volume `pwd`/SR_Data/fe_data/log-2/:/opt/starrocks/fe/log/\
    --volume `pwd`/SR_Data/fe_data/meta-2/:/opt/starrocks/fe/meta/ \
    starrocks/fe-ubuntu:3.0.1 /bin/bash -c /opt/starrocks/fe/bin/start_fe.sh --helper Starrocks-Fe-V3-1:9010 --daemon


docker stop Starrocks-Fe-V3-3
docker rm -f Starrocks-Fe-V3-3
docker container run -itd \
    --user root \
    -p 8033:8030 \
    -p 9033:9030 \
    -p 9013:9010 \
    -p 9023:9020 \
    --ip 172.19.0.13 \
    --net Flink_Network \
    --restart unless-stopped \
    --name Starrocks-Fe-V3-3 \
    --volume /etc/localtime:/etc/localtime:ro \
    --volume `pwd`/SR_Data/fe_data/log-3/:/opt/starrocks/fe/log/\
    --volume `pwd`/SR_Data/fe_data/meta-3/:/opt/starrocks/fe/meta/ \
    starrocks/fe-ubuntu:3.0.1 /bin/bash -c /opt/starrocks/fe/bin/start_fe.sh --helper Starrocks-Fe-V3-1:9010 --daemon


-v /etc/localtime:/etc/localtime:ro \
-v /mnt/Docker/017.StarRocks-V2/fe/conf/fe.conf:/starrocks/conf/fe.conf \
-v /mnt/Docker/017.StarRocks-V2/fe/meta:/starrocks/meta \
-v /mnt/Docker/017.StarRocks-V2/fe/log:/starrocks/log \
renzicu/starrocks-fe:2.5.0

image-20230522151300818

当 Docker 容器成功启动后,运行以下命令连接 StarRocks。详细权限配置见官网:用户权限及认证

  • 容器内执行
  -- 容器内已集成mysql,可在容器内执行。默认用户root,密码为空
mysql -uroot -h127.0.0.1 -P9030
  -- 修改root密码
SET PASSWORD FOR 'root' = PASSWORD('xxxxxxxxxxxxxxx');
  
SET PASSWORD FOR 'root' = PASSWORD('P@88W0rd');
  
  -- 创建新用户lit_sr
  	CREATE USER lit_sr@'%' IDENTIFIED WITH mysql_native_password BY 'P@88W0rd';
  
  -- 删除用户 
  	DROP USER 'user_identity';
  -- 授予所有权限
  	GRANT SELECT_PRIV ON *.* TO 'lit_sr'@'%';
  
  -- -----------------------添加/删除 FE、BE、Broker-------------------
  -- 添加 Follower FE 节点
  ALTER SYSTEM ADD FOLLOWER "fe_host:edit_log_port"; 
  
  ALTER SYSTEM ADD FOLLOWER "starrocks-fe-2:9010"; 
  ALTER SYSTEM ADD FOLLOWER "starrocks-fe-3:9010"; 
  
  
  # V3-单独Docker部署的启动后添加
  ALTER SYSTEM ADD FOLLOWER "Starrocks-Fe-V3-2:9010"; 
  ALTER SYSTEM ADD FOLLOWER "Starrocks-Fe-V3-3:9010"; 
  
  -- 删除  Follower FE 节点
  ALTER SYSTEM DROP FOLLOWER "Starrocks-Fe-V3-2:9010"; 
  ALTER SYSTEM DROP FOLLOWER "Starrocks-Fe-V3-3:9010"; 
  
  -- 添加 Observer FE 节点
  ALTER SYSTEM ADD OBSERVER "fe_host:edit_log_port"; 
  
  ALTER SYSTEM ADD OBSERVER "172.18.0.19:9010"; 
  ALTER SYSTEM ADD OBSERVER "172.18.0.20:9010"; 
  
  
  
  
  
  -- 删除  Observer FE 节点
  ALTER SYSTEM DROP OBSERVER "fe_host:edit_log_port";
  
  -- 查看 FE 节点状态
  SHOW PROC '/frontends'\G;
  
  -- 添加 BE 节点,先将下面的BE容器启动完成后再操作。
  ALTER SYSTEM ADD BACKEND "be_host:heartbeat_port"; 
  
  ALTER SYSTEM ADD BACKEND "172.22.0.7:9050"; 
  ALTER SYSTEM ADD BACKEND "172.22.0.4:9050"; 
  ALTER SYSTEM ADD BACKEND "172.22.0.3:9050"; 
  ALTER SYSTEM ADD BACKEND "172.22.0.5:9050"; 
  ALTER SYSTEM ADD BACKEND "172.22.0.8:9050"; 
  
ALTER SYSTEM ADD BACKEND "starrocks-be-1:9050"; 
ALTER SYSTEM ADD BACKEND "starrocks-be-2:9050"; 
ALTER SYSTEM ADD BACKEND "starrocks-be-3:9050"; 
ALTER SYSTEM ADD BACKEND "starrocks-be-1:9050"; 
ALTER SYSTEM ADD BACKEND "starrocks-be-1:9050"; 



  # V3-单独Docker部署的启动后添加
ALTER SYSTEM ADD BACKEND "Starrocks-Be-V3-1:9050"; 
ALTER SYSTEM ADD BACKEND "Starrocks-Be-V3-2:9050"; 
ALTER SYSTEM ADD BACKEND "Starrocks-Be-V3-3:9050"; 

  
  
  -- 删除  BE 节点
  ALTER SYSTEM DROP BACKEND "be_host:heartbeat_port";
  
  -- 查看 BE 节点状态
  SHOW PROC '/backends'\G;
  
  -- 添加 Broker 节点
  ALTER SYSTEM ADD BROKER broker_name "broker_host:port"; 
  -- 删除  Broker 节点
  ALTER SYSTEM DROP BROKER broker_name "broker_host:port";
  
  -- 查看 Broker 节点状态
  SHOW PROC '/brokers'\G;

四、BE启动和配置

注意

当一台机器拥有多个非回环 IP 地址时,需要在 BE 配置文件 conf/be.conf 中设置 priority_networks,为该节点设定唯一 IP。 特别说明:CPU 不支持 AVX2,需使用renzicu/starrocks-be-noavx相对应版本镜像。

docker run -d \
# heartbeat_port、be_port
-p 9050:9050 -p 9060:9060 \
# webserver_port、brpc_port
-p 8040:8040 -p 8060:8060 \
--restart unless-stopped \
--name starrocks-be1 \
-v /etc/localtime:/etc/localtime:ro \
-v  /mnt/Docker/017.StarRocks-V2/be/conf/be.conf:/starrocks/conf/be.conf \
-v  /mnt/Docker/017.StarRocks-V2/be/storage:/starrocks/storage \
-v  /mnt/Docker/017.StarRocks-V2/be/log:/starrocks/log \
renzicu/starrocks-be:2.5.0
  • 定制化启动方式

docker run -d \
-p 9050:9050 -p 9060:9060 \
-p 8040:8040 -p 8060:8060 \
--restart unless-stopped \
--name Starrocks-Be-V2 \
-v /etc/localtime:/etc/localtime:ro \
-v  /mnt/Docker/017.StarRocks-V2/be/conf/be.conf:/starrocks/conf/be.conf \
-v  /mnt/Docker/017.StarRocks-V2/be/storage:/starrocks/storage \
-v  /mnt/Docker/017.StarRocks-V2/be/log:/starrocks/log \
renzicu/starrocks-be:2.5.0



docker run -d \
-p 9051:9050 -p 9061:9060 \
-p 8041:8040 -p 8061:8060 \
--restart unless-stopped \
--name Starrocks-Be-V2-2 \
-v /etc/localtime:/etc/localtime:ro \
renzicu/starrocks-be:2.5.0


docker run -d \
-p 9053:9050 -p 9063:9060 \
-p 8043:8040 -p 8063:8060 \
--restart unless-stopped \
--name Starrocks-Be-V2-3 \
-v /etc/localtime:/etc/localtime:ro \
renzicu/starrocks-be:2.5.0


docker run -d \
-p 9054:9050 -p 9064:9060 \
-p 8044:8040 -p 8064:8060 \
--restart unless-stopped \
--name Starrocks-Be-V2-4 \
-v /etc/localtime:/etc/localtime:ro \
renzicu/starrocks-be:2.5.0


docker run -d \
-p 9055:9050 -p 9065:9060 \
-p 8045:8040 -p 8065:8060 \
--restart unless-stopped \
--name Starrocks-Be-V2-5 \
-v /etc/localtime:/etc/localtime:ro \
renzicu/starrocks-be:2.5.0
  • V3.0.0启动方式

#!/bin/bash
# author:WinJayX
# date:2020-05-07
# Maintainer WinJayX <WinJayX@Gmail.com>
# func:Docker Demo
# !!! -p 参数说明 -p :前的为宿主机的端口,后的为容器业务所需的端口!!!
# --privileged=true 特权模式 --restart unless-stopped 重启策略,除非停止的状态
#    --volume /etc/localtime:/etc/localtime:ro \
docker stop Starrocks-Be-V3-1
docker rm -f Starrocks-Be-V3-1
docker container run -itd \
    --user root \
    -p 9050:9050 \
    -p 9060:9060 \
    -p 8040:8040 \
    -p 8060:8060 \
    --ip 172.19.0.21 \
    --net Flink_Network \
    --restart unless-stopped \
    --name Starrocks-Be-V3-1 \
    --volume /etc/localtime:/etc/localtime:ro \
    --volume `pwd`/SR_Data/be_data/log-1/:/opt/starrocks/be/log/ \
    --volume `pwd`/SR_Data/be_data/storage-1/:/opt/starrocks/be/storage/ \
    starrocks/be-ubuntu:3.0.1 /bin/bash -c /opt/starrocks/be/bin/start_be.sh --daemon


docker stop Starrocks-Be-V3-2
docker rm -f Starrocks-Be-V3-2
docker container run -itd \
    --user root \
    -p 9052:9050 \
    -p 9062:9060 \
    -p 8042:8040 \
    -p 8062:8060 \
    --ip 172.19.0.22 \
    --net Flink_Network \
    --restart always \
    --name Starrocks-Be-V3-2 \
    --volume /etc/localtime:/etc/localtime:ro \
    --volume `pwd`/SR_Data/be_data/log-2/:/opt/starrocks/be/log/ \
    --volume `pwd`/SR_Data/be_data/storage-2/:/opt/starrocks/be/storage/ \
    starrocks/be-ubuntu:3.0.1 /bin/bash -c /opt/starrocks/be/bin/start_be.sh --daemon


docker stop Starrocks-Be-V3-3
docker rm -f Starrocks-Be-V3-3
docker container run -itd \
    --user root \
    -p 9053:9050 \
    -p 9063:9060 \
    -p 8043:8040 \
    -p 8063:8060 \
    --ip 172.19.0.23 \
    --net Flink_Network \
    --restart always \
    --name Starrocks-Be-V3-3 \
    --volume /etc/localtime:/etc/localtime:ro \
    --volume `pwd`/SR_Data/be_data/log-3/:/opt/starrocks/be/log/ \
    --volume `pwd`/SR_Data/be_data/storage-3/:/opt/starrocks/be/storage/ \
    starrocks/be-ubuntu:3.0.1 /bin/bash -c /opt/starrocks/be/bin/start_be.sh --daemon

五、Broker启动和配置

docker run -d \
-p 8003:8000 \
--restart unless-stopped \
--name Starrocks-Broker-1 \
-v /etc/localtime:/etc/localtime:ro \
-v /mnt/Docker/017.StarRocks-V2/broker/conf/apache_hdfs_broker.conf:/starrocks/conf/apache_hdfs_broker.conf \
renzicu/starrocks-broker:2.5.0

六、访问测试

注:访问需要开放相应防火墙端口。

  • 通过StarRocks自带WebUI,8030端口访问 8030端口测试
  • 使用Mysql连接工具,9030端口访问。

附录一、相关端口介绍

实例对象端口名称默认端口通讯方向说明
FEhttp_port8030FE <–> FE FE <–> 用户FE 节点上 HTTP 服务器的端口。
FEquery_port9030FE <–> 用户FE 节点上 MySQL 服务器的端口。
FEedit_log_port9010FE <–> FEFE 所在 StarRocks 集群中各 Leader FE、Follower FE、Observer FE 之间通信端口。
FErpc_port9020BE <–> FE FE <–> FEFE 节点上 Thrift 服务器的端口。
BEheartbeat_port9050FE <–> BEBE上心跳服务端口(thrift),用于接收来自FE的心跳。
BEbe_port9060FE <–> BEBE 上 thrift server 的端口,用于接收来自 FE 的请求。
BEwebserver_port8040BE <–> BEBE上的HTTP Server 端口。
BEbrpc_port8060FE <–> BE BE <–> BEBE上的 BRPC 端口,可以查看 BRPC 的一些网络统计信息。
Brokerbroker_ipc_port8000FE <–> Broker BE <–> BrokerBroker上的thrift server,用于接收请求。

mysql -h172.17.16.66 -P9300 -uroot -pP@88W0rd < smt/result/flink-create.all.sql

负载

image-20230526145928790

Error

image-20230602164834504

20230602

  • CDC V2.2.0
2023-06-02 07:50:20,525 INFO  org.apache.flink.runtime.taskexecutor.TaskManagerRunner      [] - --------------------------------------------------------------------------------
2023-06-02 07:50:20,527 INFO  org.apache.flink.runtime.taskexecutor.TaskManagerRunner      [] -  Preconfiguration: 
2023-06-02 07:50:20,528 INFO  org.apache.flink.runtime.taskexecutor.TaskManagerRunner      [] - 


RESOURCE_PARAMS extraction logs:
jvm_params: -Xmx5007998883 -Xms5007998883 -XX:MaxDirectMemorySize=4429185024 -XX:MaxMetaspaceSize=268435456
dynamic_configs: -D taskmanager.memory.network.min=4294967296b -D taskmanager.cpu.cores=999.0 -D taskmanager.memory.task.off-heap.size=0b -D taskmanager.memory.jvm-metaspace.size=268435456b -D external-resources=none -D taskmanager.memory.jvm-overhead.min=1073741824b -D taskmanager.memory.framework.off-heap.size=134217728b -D taskmanager.memory.network.max=4294967296b -D taskmanager.memory.framework.heap.size=134217728b -D taskmanager.memory.managed.size=6291456093b -D taskmanager.memory.task.heap.size=4873781155b -D taskmanager.numberOfTaskSlots=999 -D taskmanager.memory.jvm-overhead.max=1073741824b
logs: WARNING: sun.reflect.Reflection.getCallerClass is not supported. This will impact performance.
INFO  [] - Loading configuration property: jobmanager.rpc.address, 92cd35079d84
INFO  [] - Loading configuration property: jobmanager.rpc.port, 6123
INFO  [] - Loading configuration property: jobmanager.bind-host, 0.0.0.0
INFO  [] - Loading configuration property: jobmanager.memory.process.size, 1600m
INFO  [] - Loading configuration property: taskmanager.bind-host, 0.0.0.0
INFO  [] - Loading configuration property: taskmanager.memory.process.size, 1728m
INFO  [] - Loading configuration property: taskmanager.numberOfTaskSlots, 1
INFO  [] - Loading configuration property: parallelism.default, 1
INFO  [] - Loading configuration property: jobmanager.execution.failover-strategy, region
INFO  [] - Loading configuration property: rest.address, 0.0.0.0
INFO  [] - Loading configuration property: rest.bind-address, 0.0.0.0
INFO  [] - Loading configuration property: blob.server.port, 6124
INFO  [] - Loading configuration property: query.server.port, 6125
INFO  [] - Loading configuration property: jobmanager.rpc.address, jobmanager
INFO  [] - Loading configuration property: taskmanager.numberOfTaskSlots, 999
INFO  [] - Loading configuration property: taskmanager.memory.process.size, 16280m
INFO  [] - Loading configuration property: taskmanager.memory.network.min, 4096mb
INFO  [] - Loading configuration property: taskmanager.memory.network.max, 8gb
INFO  [] - The derived from fraction jvm overhead memory (1.590gb (1707081753 bytes)) is greater than its max value 1024.000mb (1073741824 bytes), max value will be used instead
INFO  [] - The derived from fraction network memory (1.465gb (1572864023 bytes)) is less than its min value 4.000gb (4294967296 bytes), min value will be used instead
INFO  [] - Final TaskExecutor Memory configuration:
INFO  [] -   Total Process Memory:          15.898gb (17070817280 bytes)
INFO  [] -     Total Flink Memory:          14.648gb (15728640000 bytes)
INFO  [] -       Total JVM Heap Memory:     4.664gb (5007998883 bytes)
INFO  [] -         Framework:               128.000mb (134217728 bytes)
INFO  [] -         Task:                    4.539gb (4873781155 bytes)
INFO  [] -       Total Off-heap Memory:     9.984gb (10720641117 bytes)
INFO  [] -         Managed:                 5.859gb (6291456093 bytes)
INFO  [] -         Total JVM Direct Memory: 4.125gb (4429185024 bytes)
INFO  [] -           Framework:             128.000mb (134217728 bytes)
INFO  [] -           Task:                  0 bytes
INFO  [] -           Network:               4.000gb (4294967296 bytes)
INFO  [] -     JVM Metaspace:               256.000mb (268435456 bytes)
INFO  [] -     JVM Overhead:                1024.000mb (1073741824 bytes)

2023-06-02 07:50:20,529 INFO  org.apache.flink.runtime.taskexecutor.TaskManagerRunner      [] - --------------------------------------------------------------------------------
2023-06-02 07:50:20,529 INFO  org.apache.flink.runtime.taskexecutor.TaskManagerRunner      [] -  Starting TaskManager (Version: 1.15.4, Scala: 2.12, Rev:fc679b6, Date:2023-03-08T18:49:43+01:00)
2023-06-02 07:50:20,529 INFO  org.apache.flink.runtime.taskexecutor.TaskManagerRunner      [] -  OS current user: flink
2023-06-02 07:50:20,529 INFO  org.apache.flink.runtime.taskexecutor.TaskManagerRunner      [] -  Current Hadoop/Kerberos user: <no hadoop dependency found>
2023-06-02 07:50:20,530 INFO  org.apache.flink.runtime.taskexecutor.TaskManagerRunner      [] -  JVM: OpenJDK 64-Bit Server VM - Eclipse Adoptium - 11/11.0.18+10
2023-06-02 07:50:20,530 INFO  org.apache.flink.runtime.taskexecutor.TaskManagerRunner      [] -  Arch: amd64
2023-06-02 07:50:20,530 INFO  org.apache.flink.runtime.taskexecutor.TaskManagerRunner      [] -  Maximum heap size: 4776 MiBytes
2023-06-02 07:50:20,530 INFO  org.apache.flink.runtime.taskexecutor.TaskManagerRunner      [] -  JAVA_HOME: /opt/java/openjdk
2023-06-02 07:50:20,530 INFO  org.apache.flink.runtime.taskexecutor.TaskManagerRunner      [] -  No Hadoop Dependency available
2023-06-02 07:50:20,531 INFO  org.apache.flink.runtime.taskexecutor.TaskManagerRunner      [] -  JVM Options:
2023-06-02 07:50:20,531 INFO  org.apache.flink.runtime.taskexecutor.TaskManagerRunner      [] -     -XX:+UseG1GC
2023-06-02 07:50:20,531 INFO  org.apache.flink.runtime.taskexecutor.TaskManagerRunner      [] -     -Xmx5007998883
2023-06-02 07:50:20,531 INFO  org.apache.flink.runtime.taskexecutor.TaskManagerRunner      [] -     -Xms5007998883
2023-06-02 07:50:20,531 INFO  org.apache.flink.runtime.taskexecutor.TaskManagerRunner      [] -     -XX:MaxDirectMemorySize=4429185024
2023-06-02 07:50:20,531 INFO  org.apache.flink.runtime.taskexecutor.TaskManagerRunner      [] -     -XX:MaxMetaspaceSize=268435456
2023-06-02 07:50:20,532 INFO  org.apache.flink.runtime.taskexecutor.TaskManagerRunner      [] -     -Dlog.file=/opt/flink/log/flink--taskexecutor-0-92cd35079d84.log
2023-06-02 07:50:20,532 INFO  org.apache.flink.runtime.taskexecutor.TaskManagerRunner      [] -     -Dlog4j.configuration=file:/opt/flink/conf/log4j-console.properties
2023-06-02 07:50:20,532 INFO  org.apache.flink.runtime.taskexecutor.TaskManagerRunner      [] -     -Dlog4j.configurationFile=file:/opt/flink/conf/log4j-console.properties
2023-06-02 07:50:20,532 INFO  org.apache.flink.runtime.taskexecutor.TaskManagerRunner      [] -     -Dlogback.configurationFile=file:/opt/flink/conf/logback-console.xml
2023-06-02 07:50:20,532 INFO  org.apache.flink.runtime.taskexecutor.TaskManagerRunner      [] -  Program Arguments:
2023-06-02 07:50:20,534 INFO  org.apache.flink.runtime.taskexecutor.TaskManagerRunner      [] -     --configDir
2023-06-02 07:50:20,534 INFO  org.apache.flink.runtime.taskexecutor.TaskManagerRunner      [] -     /opt/flink/conf
2023-06-02 07:50:20,534 INFO  org.apache.flink.runtime.taskexecutor.TaskManagerRunner      [] -     -D
2023-06-02 07:50:20,535 INFO  org.apache.flink.runtime.taskexecutor.TaskManagerRunner      [] -     taskmanager.memory.network.min=4294967296b
2023-06-02 07:50:20,535 INFO  org.apache.flink.runtime.taskexecutor.TaskManagerRunner      [] -     -D
2023-06-02 07:50:20,535 INFO  org.apache.flink.runtime.taskexecutor.TaskManagerRunner      [] -     taskmanager.cpu.cores=999.0
2023-06-02 07:50:20,535 INFO  org.apache.flink.runtime.taskexecutor.TaskManagerRunner      [] -     -D
2023-06-02 07:50:20,535 INFO  org.apache.flink.runtime.taskexecutor.TaskManagerRunner      [] -     taskmanager.memory.task.off-heap.size=0b
2023-06-02 07:50:20,536 INFO  org.apache.flink.runtime.taskexecutor.TaskManagerRunner      [] -     -D
2023-06-02 07:50:20,536 INFO  org.apache.flink.runtime.taskexecutor.TaskManagerRunner      [] -     taskmanager.memory.jvm-metaspace.size=268435456b
2023-06-02 07:50:20,536 INFO  org.apache.flink.runtime.taskexecutor.TaskManagerRunner      [] -     -D
2023-06-02 07:50:20,536 INFO  org.apache.flink.runtime.taskexecutor.TaskManagerRunner      [] -     external-resources=none
2023-06-02 07:50:20,536 INFO  org.apache.flink.runtime.taskexecutor.TaskManagerRunner      [] -     -D
2023-06-02 07:50:20,536 INFO  org.apache.flink.runtime.taskexecutor.TaskManagerRunner      [] -     taskmanager.memory.jvm-overhead.min=1073741824b
2023-06-02 07:50:20,537 INFO  org.apache.flink.runtime.taskexecutor.TaskManagerRunner      [] -     -D
2023-06-02 07:50:20,537 INFO  org.apache.flink.runtime.taskexecutor.TaskManagerRunner      [] -     taskmanager.memory.framework.off-heap.size=134217728b
2023-06-02 07:50:20,537 INFO  org.apache.flink.runtime.taskexecutor.TaskManagerRunner      [] -     -D
2023-06-02 07:50:20,537 INFO  org.apache.flink.runtime.taskexecutor.TaskManagerRunner      [] -     taskmanager.memory.network.max=4294967296b
2023-06-02 07:50:20,537 INFO  org.apache.flink.runtime.taskexecutor.TaskManagerRunner      [] -     -D
2023-06-02 07:50:20,537 INFO  org.apache.flink.runtime.taskexecutor.TaskManagerRunner      [] -     taskmanager.memory.framework.heap.size=134217728b
2023-06-02 07:50:20,537 INFO  org.apache.flink.runtime.taskexecutor.TaskManagerRunner      [] -     -D
2023-06-02 07:50:20,538 INFO  org.apache.flink.runtime.taskexecutor.TaskManagerRunner      [] -     taskmanager.memory.managed.size=6291456093b
2023-06-02 07:50:20,538 INFO  org.apache.flink.runtime.taskexecutor.TaskManagerRunner      [] -     -D
2023-06-02 07:50:20,538 INFO  org.apache.flink.runtime.taskexecutor.TaskManagerRunner      [] -     taskmanager.memory.task.heap.size=4873781155b
2023-06-02 07:50:20,538 INFO  org.apache.flink.runtime.taskexecutor.TaskManagerRunner      [] -     -D
2023-06-02 07:50:20,538 INFO  org.apache.flink.runtime.taskexecutor.TaskManagerRunner      [] -     taskmanager.numberOfTaskSlots=999
2023-06-02 07:50:20,538 INFO  org.apache.flink.runtime.taskexecutor.TaskManagerRunner      [] -     -D
2023-06-02 07:50:20,538 INFO  org.apache.flink.runtime.taskexecutor.TaskManagerRunner      [] -     taskmanager.memory.jvm-overhead.max=1073741824b
2023-06-02 07:50:20,539 INFO  org.apache.flink.runtime.taskexecutor.TaskManagerRunner      [] -  Classpath: /opt/flink/lib/flink-cep-1.15.4.jar:/opt/flink/lib/flink-connector-files-1.15.4.jar:/opt/flink/lib/flink-connector-starrocks-1.2.6_flink-1.15.jar:/opt/flink/lib/flink-csv-1.15.4.jar:/opt/flink/lib/flink-json-1.15.4.jar:/opt/flink/lib/flink-scala_2.12-1.15.4.jar:/opt/flink/lib/flink-shaded-zookeeper-3.5.9.jar:/opt/flink/lib/flink-sql-connector-mysql-cdc-2.2.0.jar:/opt/flink/lib/flink-table-api-java-uber-1.15.4.jar:/opt/flink/lib/flink-table-planner-loader-1.15.4.jar:/opt/flink/lib/flink-table-runtime-1.15.4.jar:/opt/flink/lib/log4j-1.2-api-2.17.1.jar:/opt/flink/lib/log4j-api-2.17.1.jar:/opt/flink/lib/log4j-core-2.17.1.jar:/opt/flink/lib/log4j-slf4j-impl-2.17.1.jar:/opt/flink/lib/flink-dist-1.15.4.jar:::
2023-06-02 07:50:20,539 INFO  org.apache.flink.runtime.taskexecutor.TaskManagerRunner      [] - --------------------------------------------------------------------------------
2023-06-02 07:50:20,541 INFO  org.apache.flink.runtime.taskexecutor.TaskManagerRunner      [] - Registered UNIX signal handlers for [TERM, HUP, INT]
2023-06-02 07:50:20,544 INFO  org.apache.flink.runtime.taskexecutor.TaskManagerRunner      [] - Maximum number of open file descriptors is 1048576.
2023-06-02 07:50:20,556 INFO  org.apache.flink.configuration.GlobalConfiguration           [] - Loading configuration property: jobmanager.rpc.address, 92cd35079d84
2023-06-02 07:50:20,556 INFO  org.apache.flink.configuration.GlobalConfiguration           [] - Loading configuration property: jobmanager.rpc.port, 6123
2023-06-02 07:50:20,556 INFO  org.apache.flink.configuration.GlobalConfiguration           [] - Loading configuration property: jobmanager.bind-host, 0.0.0.0
2023-06-02 07:50:20,557 INFO  org.apache.flink.configuration.GlobalConfiguration           [] - Loading configuration property: jobmanager.memory.process.size, 1600m
2023-06-02 07:50:20,557 INFO  org.apache.flink.configuration.GlobalConfiguration           [] - Loading configuration property: taskmanager.bind-host, 0.0.0.0
2023-06-02 07:50:20,557 INFO  org.apache.flink.configuration.GlobalConfiguration           [] - Loading configuration property: taskmanager.memory.process.size, 1728m
2023-06-02 07:50:20,558 INFO  org.apache.flink.configuration.GlobalConfiguration           [] - Loading configuration property: taskmanager.numberOfTaskSlots, 1
2023-06-02 07:50:20,558 INFO  org.apache.flink.configuration.GlobalConfiguration           [] - Loading configuration property: parallelism.default, 1
2023-06-02 07:50:20,559 INFO  org.apache.flink.configuration.GlobalConfiguration           [] - Loading configuration property: jobmanager.execution.failover-strategy, region
2023-06-02 07:50:20,560 INFO  org.apache.flink.configuration.GlobalConfiguration           [] - Loading configuration property: rest.address, 0.0.0.0
2023-06-02 07:50:20,560 INFO  org.apache.flink.configuration.GlobalConfiguration           [] - Loading configuration property: rest.bind-address, 0.0.0.0
2023-06-02 07:50:20,561 INFO  org.apache.flink.configuration.GlobalConfiguration           [] - Loading configuration property: blob.server.port, 6124
2023-06-02 07:50:20,561 INFO  org.apache.flink.configuration.GlobalConfiguration           [] - Loading configuration property: query.server.port, 6125
2023-06-02 07:50:20,561 INFO  org.apache.flink.configuration.GlobalConfiguration           [] - Loading configuration property: jobmanager.rpc.address, jobmanager
2023-06-02 07:50:20,561 INFO  org.apache.flink.configuration.GlobalConfiguration           [] - Loading configuration property: taskmanager.numberOfTaskSlots, 999
2023-06-02 07:50:20,562 INFO  org.apache.flink.configuration.GlobalConfiguration           [] - Loading configuration property: taskmanager.memory.process.size, 16280m
2023-06-02 07:50:20,562 INFO  org.apache.flink.configuration.GlobalConfiguration           [] - Loading configuration property: taskmanager.memory.network.min, 4096mb
2023-06-02 07:50:20,562 INFO  org.apache.flink.configuration.GlobalConfiguration           [] - Loading configuration property: taskmanager.memory.network.max, 8gb
2023-06-02 07:50:20,617 INFO  org.apache.flink.core.fs.FileSystem                          [] - Hadoop is not in the classpath/dependencies. The extended set of supported File Systems via Hadoop is not available.
2023-06-02 07:50:20,674 INFO  org.apache.flink.runtime.state.changelog.StateChangelogStorageLoader [] - StateChangelogStorageLoader initialized with shortcut names {memory,filesystem}.
2023-06-02 07:50:20,679 INFO  org.apache.flink.runtime.state.changelog.StateChangelogStorageLoader [] - StateChangelogStorageLoader initialized with shortcut names {memory,filesystem}.
2023-06-02 07:50:20,694 INFO  org.apache.flink.runtime.security.modules.HadoopModuleFactory [] - Cannot create Hadoop Security Module because Hadoop cannot be found in the Classpath.
2023-06-02 07:50:20,707 INFO  org.apache.flink.runtime.security.modules.JaasModule         [] - Jaas file will be created as /tmp/jaas-11013723736024675138.conf.
2023-06-02 07:50:20,717 INFO  org.apache.flink.runtime.security.contexts.HadoopSecurityContextFactory [] - Cannot install HadoopSecurityContext because Hadoop cannot be found in the Classpath.
2023-06-02 07:50:21,205 INFO  org.apache.flink.runtime.util.LeaderRetrievalUtils           [] - Trying to select the network interface and address to use by connecting to the leading JobManager.
2023-06-02 07:50:21,205 INFO  org.apache.flink.runtime.util.LeaderRetrievalUtils           [] - TaskManager will try to connect for PT10S before falling back to heuristics
2023-06-02 07:50:21,648 INFO  org.apache.flink.runtime.net.ConnectionUtils                 [] - Trying to connect to address jobmanager/172.18.0.8:6123
2023-06-02 07:50:21,649 INFO  org.apache.flink.runtime.net.ConnectionUtils                 [] - Failed to connect to [jobmanager/172.18.0.8:6123] from local address [92cd35079d84/172.18.0.9] with timeout [200] due to: Connection refused (Connection refused)
2023-06-02 07:50:21,650 INFO  org.apache.flink.runtime.net.ConnectionUtils                 [] - Failed to connect to [jobmanager/172.18.0.8:6123] from local address [/172.18.0.9] with timeout [50] due to: Connection refused (Connection refused)
2023-06-02 07:50:21,652 INFO  org.apache.flink.runtime.net.ConnectionUtils                 [] - Failed to connect to [jobmanager/172.18.0.8:6123] from local address [/172.18.0.9] with timeout [50] due to: Connection refused (Connection refused)
2023-06-02 07:50:21,652 INFO  org.apache.flink.runtime.net.ConnectionUtils                 [] - Failed to connect to [jobmanager/172.18.0.8:6123] from local address [/127.0.0.1] with timeout [50] due to: Invalid argument (connect failed)
2023-06-02 07:50:21,653 INFO  org.apache.flink.runtime.net.ConnectionUtils                 [] - Failed to connect to [jobmanager/172.18.0.8:6123] from local address [/172.18.0.9] with timeout [1000] due to: Connection refused (Connection refused)
2023-06-02 07:50:21,654 INFO  org.apache.flink.runtime.net.ConnectionUtils                 [] - Failed to connect to [jobmanager/172.18.0.8:6123] from local address [/127.0.0.1] with timeout [1000] due to: Invalid argument (connect failed)
2023-06-02 07:50:21,755 INFO  org.apache.flink.runtime.net.ConnectionUtils                 [] - Trying to connect to address jobmanager/172.18.0.8:6123
2023-06-02 07:50:21,756 INFO  org.apache.flink.runtime.net.ConnectionUtils                 [] - Failed to connect to [jobmanager/172.18.0.8:6123] from local address [92cd35079d84/172.18.0.9] with timeout [200] due to: Connection refused (Connection refused)
2023-06-02 07:50:21,758 INFO  org.apache.flink.runtime.net.ConnectionUtils                 [] - Failed to connect to [jobmanager/172.18.0.8:6123] from local address [/172.18.0.9] with timeout [50] due to: Connection refused (Connection refused)
2023-06-02 07:50:21,759 INFO  org.apache.flink.runtime.net.ConnectionUtils                 [] - Failed to connect to [jobmanager/172.18.0.8:6123] from local address [/172.18.0.9] with timeout [50] due to: Connection refused (Connection refused)
2023-06-02 07:50:21,760 INFO  org.apache.flink.runtime.net.ConnectionUtils                 [] - Failed to connect to [jobmanager/172.18.0.8:6123] from local address [/127.0.0.1] with timeout [50] due to: Invalid argument (connect failed)
2023-06-02 07:50:21,761 INFO  org.apache.flink.runtime.net.ConnectionUtils                 [] - Failed to connect to [jobmanager/172.18.0.8:6123] from local address [/172.18.0.9] with timeout [1000] due to: Connection refused (Connection refused)
2023-06-02 07:50:21,762 INFO  org.apache.flink.runtime.net.ConnectionUtils                 [] - Failed to connect to [jobmanager/172.18.0.8:6123] from local address [/127.0.0.1] with timeout [1000] due to: Invalid argument (connect failed)
2023-06-02 07:50:21,962 INFO  org.apache.flink.runtime.net.ConnectionUtils                 [] - Trying to connect to address jobmanager/172.18.0.8:6123
2023-06-02 07:50:21,963 INFO  org.apache.flink.runtime.taskexecutor.TaskManagerRunner      [] - TaskManager will use hostname/address '92cd35079d84' (172.18.0.9) for communication.
2023-06-02 07:50:22,022 INFO  org.apache.flink.runtime.rpc.akka.AkkaRpcServiceUtils        [] - Trying to start actor system, external address 172.18.0.9:0, bind address 0.0.0.0:0.
2023-06-02 07:50:22,839 INFO  akka.event.slf4j.Slf4jLogger                                 [] - Slf4jLogger started
2023-06-02 07:50:22,901 INFO  akka.remote.RemoteActorRefProvider                           [] - Akka Cluster not in use - enabling unsafe features anyway because `akka.remote.use-unsafe-remote-features-outside-cluster` has been enabled.
2023-06-02 07:50:22,902 INFO  akka.remote.Remoting                                         [] - Starting remoting
2023-06-02 07:50:23,140 INFO  akka.remote.Remoting                                         [] - Remoting started; listening on addresses :[akka.tcp://flink@172.18.0.9:35157]
2023-06-02 07:50:23,325 INFO  org.apache.flink.runtime.rpc.akka.AkkaRpcServiceUtils        [] - Actor system started at akka.tcp://flink@172.18.0.9:35157
2023-06-02 07:50:23,350 INFO  org.apache.flink.runtime.taskexecutor.TaskManagerRunner      [] - Using working directory: WorkingDirectory(/tmp/tm_172.18.0.9:35157-8c33e7)
2023-06-02 07:50:23,361 INFO  org.apache.flink.runtime.metrics.MetricRegistryImpl          [] - No metrics reporter configured, no metrics will be exposed/reported.
2023-06-02 07:50:23,367 INFO  org.apache.flink.runtime.rpc.akka.AkkaRpcServiceUtils        [] - Trying to start actor system, external address 172.18.0.9:0, bind address 0.0.0.0:0.
2023-06-02 07:50:23,400 INFO  akka.event.slf4j.Slf4jLogger                                 [] - Slf4jLogger started
2023-06-02 07:50:23,406 INFO  akka.remote.RemoteActorRefProvider                           [] - Akka Cluster not in use - enabling unsafe features anyway because `akka.remote.use-unsafe-remote-features-outside-cluster` has been enabled.
2023-06-02 07:50:23,406 INFO  akka.remote.Remoting                                         [] - Starting remoting
2023-06-02 07:50:23,443 INFO  akka.remote.Remoting                                         [] - Remoting started; listening on addresses :[akka.tcp://flink-metrics@172.18.0.9:35858]
2023-06-02 07:50:23,456 INFO  org.apache.flink.runtime.rpc.akka.AkkaRpcServiceUtils        [] - Actor system started at akka.tcp://flink-metrics@172.18.0.9:35858
2023-06-02 07:50:23,476 INFO  org.apache.flink.runtime.rpc.akka.AkkaRpcService             [] - Starting RPC endpoint for org.apache.flink.runtime.metrics.dump.MetricQueryService at akka://flink-metrics/user/rpc/MetricQueryService_172.18.0.9:35157-8c33e7 .
2023-06-02 07:50:23,500 INFO  org.apache.flink.runtime.blob.PermanentBlobCache             [] - Created BLOB cache storage directory /tmp/tm_172.18.0.9:35157-8c33e7/blobStorage
2023-06-02 07:50:23,510 INFO  org.apache.flink.runtime.blob.TransientBlobCache             [] - Created BLOB cache storage directory /tmp/tm_172.18.0.9:35157-8c33e7/blobStorage
2023-06-02 07:50:23,518 INFO  org.apache.flink.runtime.externalresource.ExternalResourceUtils [] - Enabled external resources: []
2023-06-02 07:50:23,519 INFO  org.apache.flink.runtime.taskexecutor.TaskManagerRunner      [] - Starting TaskManager with ResourceID: 172.18.0.9:35157-8c33e7
2023-06-02 07:50:23,544 INFO  org.apache.flink.runtime.taskexecutor.TaskManagerServices    [] - Temporary file directory '/tmp': total 199 GB, usable 48 GB (24.12% usable)
2023-06-02 07:50:23,548 INFO  org.apache.flink.runtime.io.disk.iomanager.IOManager         [] - Created a new FileChannelManager for spilling of task related data to disk (joins, sorting, ...). Used directories:
	/tmp/flink-io-2b91090e-8361-483a-8bf5-6e9c6f1aa4b2
2023-06-02 07:50:23,562 INFO  org.apache.flink.runtime.io.network.netty.NettyConfig        [] - NettyConfig [server address: /0.0.0.0, server port: 0, ssl enabled: false, memory segment size (bytes): 32768, transport type: AUTO, number of server threads: 999 (manual), number of client threads: 999 (manual), server connect backlog: 0 (use Netty's default), client connect timeout (sec): 120, send/receive buffer size (bytes): 0 (use Netty's default)]
2023-06-02 07:50:23,667 INFO  org.apache.flink.runtime.io.network.NettyShuffleServiceFactory [] - Created a new FileChannelManager for storing result partitions of BLOCKING shuffles. Used directories:
	/tmp/flink-netty-shuffle-c7ce3290-f0c2-4415-b85d-a6cd6cc66353
2023-06-02 07:50:25,998 INFO  org.apache.flink.runtime.io.network.buffer.NetworkBufferPool [] - Allocated 4096 MB for network buffer pool (number of memory segments: 131072, bytes per segment: 32768).
2023-06-02 07:50:26,017 INFO  org.apache.flink.runtime.io.network.NettyShuffleEnvironment  [] - Starting the network environment and its components.
2023-06-02 07:50:26,228 INFO  org.apache.flink.runtime.io.network.netty.NettyClient        [] - Transport type 'auto': using EPOLL.
2023-06-02 07:50:26,231 INFO  org.apache.flink.runtime.io.network.netty.NettyClient        [] - Successful initialization (took 213 ms).
2023-06-02 07:50:26,461 INFO  org.apache.flink.runtime.io.network.netty.NettyServer        [] - Transport type 'auto': using EPOLL.
2023-06-02 07:50:26,521 INFO  org.apache.flink.runtime.io.network.netty.NettyServer        [] - Successful initialization (took 288 ms). Listening on SocketAddress /0.0.0.0:40618.
2023-06-02 07:50:26,523 INFO  org.apache.flink.runtime.taskexecutor.KvStateService         [] - Starting the kvState service and its components.
2023-06-02 07:50:26,557 INFO  org.apache.flink.runtime.rpc.akka.AkkaRpcService             [] - Starting RPC endpoint for org.apache.flink.runtime.taskexecutor.TaskExecutor at akka://flink/user/rpc/taskmanager_0 .
2023-06-02 07:50:26,581 INFO  org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService [] - Start job leader service.
2023-06-02 07:50:26,585 INFO  org.apache.flink.runtime.filecache.FileCache                 [] - User file cache uses directory /tmp/flink-dist-cache-0650c23c-1586-4e9f-a861-b1471e4a78f2
2023-06-02 07:50:26,588 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor           [] - Connecting to ResourceManager akka.tcp://flink@jobmanager:6123/user/rpc/resourcemanager_*(00000000000000000000000000000000).
2023-06-02 07:50:26,894 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor           [] - Resolved ResourceManager address, beginning registration
2023-06-02 07:50:27,057 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor           [] - Successful registration at resource manager akka.tcp://flink@jobmanager:6123/user/rpc/resourcemanager_* under registration id c4a599469947cfdd4bfb39a6a0a1dcc0.
2023-06-02 08:44:50,580 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor           [] - Receive slot request dc26e0fe0de1e153d5d029c1c4646e81 for job 27aca1c93e4339b22baaacbbb36d1152 from resource manager with leader id 00000000000000000000000000000000.
2023-06-02 08:44:50,594 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor           [] - Allocated slot for dc26e0fe0de1e153d5d029c1c4646e81.
2023-06-02 08:44:50,596 INFO  org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService [] - Add job 27aca1c93e4339b22baaacbbb36d1152 for job leader monitoring.
2023-06-02 08:44:50,597 INFO  org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService [] - Try to register at job manager akka.tcp://flink@jobmanager:6123/user/rpc/jobmanager_2 with leader id 00000000-0000-0000-0000-000000000000.
2023-06-02 08:44:50,632 INFO  org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService [] - Resolved JobManager address, beginning registration
2023-06-02 08:44:50,664 INFO  org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService [] - Successful registration at job manager akka.tcp://flink@jobmanager:6123/user/rpc/jobmanager_2 for job 27aca1c93e4339b22baaacbbb36d1152.
2023-06-02 08:44:50,665 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor           [] - Establish JobManager connection for job 27aca1c93e4339b22baaacbbb36d1152.
2023-06-02 08:44:50,671 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor           [] - Offer reserved slots to the leader of job 27aca1c93e4339b22baaacbbb36d1152.
2023-06-02 08:44:50,716 INFO  org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot dc26e0fe0de1e153d5d029c1c4646e81.
2023-06-02 08:44:50,744 INFO  org.apache.flink.runtime.state.changelog.StateChangelogStorageLoader [] - Creating a changelog storage with name 'memory'.
2023-06-02 08:44:50,760 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor           [] - Received task Source: as_person_assets_allot_src[1] -> ConstraintEnforcer[2] -> Sink: as_person_assets_allot_sink[2] (1/1)#0 (7c41006a36141aa60bb873b092c0d98a), deploy into slot with allocation id dc26e0fe0de1e153d5d029c1c4646e81.
2023-06-02 08:44:50,761 INFO  org.apache.flink.runtime.taskmanager.Task                    [] - Source: as_person_assets_allot_src[1] -> ConstraintEnforcer[2] -> Sink: as_person_assets_allot_sink[2] (1/1)#0 (7c41006a36141aa60bb873b092c0d98a) switched from CREATED to DEPLOYING.
2023-06-02 08:44:50,764 INFO  org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot dc26e0fe0de1e153d5d029c1c4646e81.
2023-06-02 08:44:50,769 INFO  org.apache.flink.runtime.taskmanager.Task                    [] - Loading JAR files for task Source: as_person_assets_allot_src[1] -> ConstraintEnforcer[2] -> Sink: as_person_assets_allot_sink[2] (1/1)#0 (7c41006a36141aa60bb873b092c0d98a) [DEPLOYING].
2023-06-02 08:44:50,773 INFO  org.apache.flink.runtime.blob.BlobClient                     [] - Downloading 27aca1c93e4339b22baaacbbb36d1152/p-7ae43ac11b505732642e76168fb8966c68a7a6e0-e81f4d2081892c6cabb9f46d61b3e734 from jobmanager/172.18.0.8:6124
2023-06-02 08:44:50,804 INFO  org.apache.flink.runtime.blob.BlobClient                     [] - Downloading 27aca1c93e4339b22baaacbbb36d1152/p-027ab2f212c11e0f1cb7a73827d21ca9d71679a8-c443612920f5d3e27453618fc8e2c195 from jobmanager/172.18.0.8:6124
2023-06-02 08:44:51,341 INFO  org.apache.flink.streaming.runtime.tasks.StreamTask          [] - No state backend has been configured, using default (HashMap) org.apache.flink.runtime.state.hashmap.HashMapStateBackend@53dcf3e7
2023-06-02 08:44:51,341 INFO  org.apache.flink.runtime.state.StateBackendLoader            [] - State backend loader loads the state backend as HashMapStateBackend
2023-06-02 08:44:51,342 INFO  org.apache.flink.streaming.runtime.tasks.StreamTask          [] - Checkpoint storage is set to 'jobmanager'
2023-06-02 08:44:51,356 INFO  org.apache.flink.runtime.taskmanager.Task                    [] - Source: as_person_assets_allot_src[1] -> ConstraintEnforcer[2] -> Sink: as_person_assets_allot_sink[2] (1/1)#0 (7c41006a36141aa60bb873b092c0d98a) switched from DEPLOYING to INITIALIZING.
2023-06-02 08:44:51,851 WARN  org.apache.flink.metrics.MetricGroup                         [] - Name collision: Group already contains a Metric with the name 'currentEmitEventTimeLag'. Metric will not be reported.[172.18.0.9, taskmanager, 172.18.0.9:35157-8c33e7, insert-into_default_catalog.flink_source_db.as_person_assets_allot_sink, Source: as_person_assets_allot_src[1], 0]
2023-06-02 08:44:51,851 WARN  org.apache.flink.metrics.MetricGroup                         [] - Name collision: Group already contains a Metric with the name 'sourceIdleTime'. Metric will not be reported.[172.18.0.9, taskmanager, 172.18.0.9:35157-8c33e7, insert-into_default_catalog.flink_source_db.as_person_assets_allot_sink, Source: as_person_assets_allot_src[1], 0]
2023-06-02 08:44:51,902 INFO  com.starrocks.connector.flink.manager.StarRocksSinkManagerV2 [] - Flink-StarRocks-Sink-Manager start, enableAutoCommit: true, streamLoader: com.starrocks.data.load.stream.TransactionStreamLoader
2023-06-02 08:44:51,902 INFO  com.starrocks.connector.flink.manager.StarRocksSinkManagerV2 [] - manager running, scanningFrequency : 50
2023-06-02 08:44:52,070 INFO  com.starrocks.data.load.stream.DefaultStreamLoader           [] - Default Stream Loader start, properties : {"connectTimeout":1000,"defaultTableProperties":{"chunkLimit":3221225472,"dataFormat":{},"database":"flink_source_db","enableUpsertDelete":true,"properties":{"columns":"`id`,`create_user_name`,`assets_ids`,`user_name`,`user_itcode`,`user_job_num`,`user_dept`,`user_dept_num`,`user_project`,`user_project_num`,`start_use_date`,`use_location`,`allot_approval_status`,`allot_process_instance_id`,`allot_revoke_node_id`,`status`,`create_by`,`create_time`,`update_by`,`update_time`,`__op`","db":"flink_source_db","table":"as_person_assets_allot"},"table":"as_person_assets_allot","uniqueKey":"flink_source_db-as_person_assets_allot"},"enableTransaction":true,"expectDelayTime":1000,"headers":{"format":"csv","strip_outer_array":"true"},"ioThreadCount":2,"jdbcUrl":"jdbc:mysql://10.17.0.28:9030","loadUrls":["http://10.17.0.28:8030"],"maxCacheBytes":94371840,"oldThreshold":0.9,"opAutoProjectionInJson":true,"regionBufferRatio":0.6,"scanningFrequency":50,"socketTimeout":0,"starRocksVersion":{"major":3,"minor":0,"patch":0},"tablePropertiesMap":{},"username":"root","version":"3.0.0 48f4d81d7b","writingThreshold":50,"youngThreshold":0.1}, defaultHeaders : [{"elements":[{"name":"csv","parameterCount":0,"parameters":[]}],"name":"format","value":"csv"},{"elements":[{"name":"Basic cm9vdDpQQDg4VzByZA","parameterCount":0,"parameters":[],"value":"="}],"name":"Authorization","value":"Basic cm9vdDpQQDg4VzByZA=="},{"elements":[{"name":"true","parameterCount":0,"parameters":[]}],"name":"strip_outer_array","value":"true"},{"elements":[{"name":"100-continue","parameterCount":0,"parameters":[]}],"name":"Expect","value":"100-continue"},{"elements":[{"name":"600","parameterCount":0,"parameters":[]}],"name":"timeout","value":"600"}]
2023-06-02 08:44:52,129 INFO  com.starrocks.connector.flink.table.sink.StarRocksDynamicSinkFunctionV2 [] - Open sink function v2
2023-06-02 08:44:52,147 INFO  org.apache.flink.runtime.taskmanager.Task                    [] - Source: as_person_assets_allot_src[1] -> ConstraintEnforcer[2] -> Sink: as_person_assets_allot_sink[2] (1/1)#0 (7c41006a36141aa60bb873b092c0d98a) switched from INITIALIZING to RUNNING.
2023-06-02 08:44:52,248 INFO  com.ververica.cdc.connectors.mysql.source.reader.MySqlSourceReader [] - Add Split: MySqlSnapshotSplit{tableId=flink_source_db.as_person_assets_allot, splitId='flink_source_db.as_person_assets_allot:0', splitKeyType=[`id` BIGINT NOT NULL], splitStart=null, splitEnd=null, highWatermark=null}
2023-06-02 08:44:52,249 INFO  org.apache.flink.connector.base.source.reader.SourceReaderBase [] - Adding split(s) to reader: [MySqlSnapshotSplit{tableId=flink_source_db.as_person_assets_allot, splitId='flink_source_db.as_person_assets_allot:0', splitKeyType=[`id` BIGINT NOT NULL], splitStart=null, splitEnd=null, highWatermark=null}]
2023-06-02 08:44:52,259 INFO  org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher [] - Starting split fetcher 0
2023-06-02 08:44:52,638 INFO  io.debezium.relational.history.DatabaseHistoryMetrics        [] - Started database history recovery
2023-06-02 08:44:52,641 INFO  io.debezium.relational.history.DatabaseHistoryMetrics        [] - Finished database history recovery of 0 change(s) in 2 ms
2023-06-02 08:44:52,702 INFO  com.ververica.cdc.connectors.mysql.debezium.task.MySqlSnapshotSplitReadTask [] - Snapshot step 1 - Determining low watermark {ts_sec=0, file=binlog.000006, pos=1264722, gtids=, row=0, event=0} for split MySqlSnapshotSplit{tableId=flink_source_db.as_person_assets_allot, splitId='flink_source_db.as_person_assets_allot:0', splitKeyType=[`id` BIGINT NOT NULL], splitStart=null, splitEnd=null, highWatermark=null}
2023-06-02 08:44:52,706 INFO  com.ververica.cdc.connectors.mysql.debezium.task.MySqlSnapshotSplitReadTask [] - Snapshot step 2 - Snapshotting data
2023-06-02 08:44:52,707 INFO  com.ververica.cdc.connectors.mysql.debezium.task.MySqlSnapshotSplitReadTask [] - Exporting data from split 'flink_source_db.as_person_assets_allot:0' of table flink_source_db.as_person_assets_allot
2023-06-02 08:44:52,708 INFO  com.ververica.cdc.connectors.mysql.debezium.task.MySqlSnapshotSplitReadTask [] - For split 'flink_source_db.as_person_assets_allot:0' of table flink_source_db.as_person_assets_allot using select statement: 'SELECT * FROM `flink_source_db`.`as_person_assets_allot`'
2023-06-02 08:44:52,827 INFO  com.ververica.cdc.connectors.mysql.debezium.task.MySqlSnapshotSplitReadTask [] - Finished exporting 115 records for split 'flink_source_db.as_person_assets_allot:0', total duration '00:00:00.119'
2023-06-02 08:44:52,829 INFO  com.ververica.cdc.connectors.mysql.debezium.task.MySqlSnapshotSplitReadTask [] - Snapshot step 3 - Determining high watermark {ts_sec=0, file=binlog.000006, pos=1264722, gtids=, row=0, event=0} for split MySqlSnapshotSplit{tableId=flink_source_db.as_person_assets_allot, splitId='flink_source_db.as_person_assets_allot:0', splitKeyType=[`id` BIGINT NOT NULL], splitStart=null, splitEnd=null, highWatermark=null}
2023-06-02 08:44:53,173 INFO  org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher [] - Finished reading from splits [flink_source_db.as_person_assets_allot:0]
2023-06-02 08:44:53,210 INFO  org.apache.flink.connector.base.source.reader.SourceReaderBase [] - Finished reading split(s) [flink_source_db.as_person_assets_allot:0]
2023-06-02 08:44:53,213 INFO  org.apache.flink.connector.base.source.reader.fetcher.SplitFetcherManager [] - Closing splitFetcher 0 because it is idle.
2023-06-02 08:44:53,213 INFO  org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher [] - Shutting down split fetcher 0
2023-06-02 08:44:53,214 INFO  com.ververica.cdc.connectors.mysql.source.reader.MySqlSplitReader [] - Close current debezium reader com.ververica.cdc.connectors.mysql.debezium.reader.SnapshotSplitReader
2023-06-02 08:44:53,231 INFO  io.debezium.jdbc.JdbcConnection                              [] - Connection gracefully closed
2023-06-02 08:44:53,233 INFO  org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher [] - Split fetcher 0 exited.
2023-06-02 08:44:53,433 INFO  com.ververica.cdc.connectors.mysql.source.reader.MySqlSourceReader [] - Add Split: MySqlBinlogSplit{splitId='binlog-split', offset={ts_sec=0, file=binlog.000006, pos=1264722, gtids=, row=0, event=0}, endOffset={ts_sec=0, file=, pos=-9223372036854775808, row=0, event=0}, isSuspended=false}
2023-06-02 08:44:53,434 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - Read list of available databases
2023-06-02 08:44:53,444 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 list of available databases is: [flink_source_db, information_schema, mysql, performance_schema, sys]
2023-06-02 08:44:53,444 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - Read list of available tables in each database
2023-06-02 08:44:53,447 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'flink_source_db.as_assets_apply_base' is filtered out of capturing
2023-06-02 08:44:53,447 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'flink_source_db.as_assets_apply_person' is filtered out of capturing
2023-06-02 08:44:53,448 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'flink_source_db.as_assets_apply_return' is filtered out of capturing
2023-06-02 08:44:53,448 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'flink_source_db.as_assets_apply_use' is filtered out of capturing
2023-06-02 08:44:53,448 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'flink_source_db.as_assets_cust_type' is filtered out of capturing
2023-06-02 08:44:53,448 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'flink_source_db.as_assets_manage' is filtered out of capturing
2023-06-02 08:44:53,448 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'flink_source_db.as_assets_receiver' is filtered out of capturing
2023-06-02 08:44:53,449 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'flink_source_db.as_assets_sf_cargo_detail' is filtered out of capturing
2023-06-02 08:44:53,449 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'flink_source_db.as_assets_sf_order' is filtered out of capturing
2023-06-02 08:44:53,449 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'flink_source_db.as_assets_sf_waybill_no_info' is filtered out of capturing
2023-06-02 08:44:53,449 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'flink_source_db.as_assets_sr_apply_base' is filtered out of capturing
2023-06-02 08:44:53,450 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'flink_source_db.as_assets_sr_apply_detail' is filtered out of capturing
2023-06-02 08:44:53,450 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'flink_source_db.as_assets_use_record' is filtered out of capturing
2023-06-02 08:44:53,450 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'flink_source_db.as_assets_use_record_shengchan' is filtered out of capturing
2023-06-02 08:44:53,450 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'flink_source_db.as_birthday_gift_apply' is filtered out of capturing
2023-06-02 08:44:53,450 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'flink_source_db.as_cost_allocation_info' is filtered out of capturing
2023-06-02 08:44:53,450 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'flink_source_db.as_cost_share_detail' is filtered out of capturing
2023-06-02 08:44:53,451 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'flink_source_db.as_cost_share_detail_base' is filtered out of capturing
2023-06-02 08:44:53,451 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'flink_source_db.as_cost_share_info' is filtered out of capturing
2023-06-02 08:44:53,451 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'flink_source_db.as_expressage_record' is filtered out of capturing
2023-06-02 08:44:53,451 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'flink_source_db.as_gift' is filtered out of capturing
2023-06-02 08:44:53,451 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 including 'flink_source_db.as_person_assets_allot' for further processing
2023-06-02 08:44:53,456 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'mysql.columns_priv' is filtered out of capturing
2023-06-02 08:44:53,456 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'mysql.component' is filtered out of capturing
2023-06-02 08:44:53,457 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'mysql.db' is filtered out of capturing
2023-06-02 08:44:53,457 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'mysql.default_roles' is filtered out of capturing
2023-06-02 08:44:53,457 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'mysql.engine_cost' is filtered out of capturing
2023-06-02 08:44:53,457 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'mysql.func' is filtered out of capturing
2023-06-02 08:44:53,457 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'mysql.general_log' is filtered out of capturing
2023-06-02 08:44:53,458 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'mysql.global_grants' is filtered out of capturing
2023-06-02 08:44:53,458 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'mysql.gtid_executed' is filtered out of capturing
2023-06-02 08:44:53,458 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'mysql.help_category' is filtered out of capturing
2023-06-02 08:44:53,458 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'mysql.help_keyword' is filtered out of capturing
2023-06-02 08:44:53,459 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'mysql.help_relation' is filtered out of capturing
2023-06-02 08:44:53,459 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'mysql.help_topic' is filtered out of capturing
2023-06-02 08:44:53,459 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'mysql.innodb_index_stats' is filtered out of capturing
2023-06-02 08:44:53,459 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'mysql.innodb_table_stats' is filtered out of capturing
2023-06-02 08:44:53,459 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'mysql.ndb_binlog_index' is filtered out of capturing
2023-06-02 08:44:53,460 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'mysql.password_history' is filtered out of capturing
2023-06-02 08:44:53,460 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'mysql.plugin' is filtered out of capturing
2023-06-02 08:44:53,460 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'mysql.procs_priv' is filtered out of capturing
2023-06-02 08:44:53,460 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'mysql.proxies_priv' is filtered out of capturing
2023-06-02 08:44:53,460 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'mysql.replication_asynchronous_connection_failover' is filtered out of capturing
2023-06-02 08:44:53,460 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'mysql.replication_asynchronous_connection_failover_managed' is filtered out of capturing
2023-06-02 08:44:53,461 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'mysql.replication_group_configuration_version' is filtered out of capturing
2023-06-02 08:44:53,461 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'mysql.replication_group_member_actions' is filtered out of capturing
2023-06-02 08:44:53,461 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'mysql.role_edges' is filtered out of capturing
2023-06-02 08:44:53,461 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'mysql.server_cost' is filtered out of capturing
2023-06-02 08:44:53,461 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'mysql.servers' is filtered out of capturing
2023-06-02 08:44:53,461 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'mysql.slave_master_info' is filtered out of capturing
2023-06-02 08:44:53,462 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'mysql.slave_relay_log_info' is filtered out of capturing
2023-06-02 08:44:53,462 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'mysql.slave_worker_info' is filtered out of capturing
2023-06-02 08:44:53,462 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'mysql.slow_log' is filtered out of capturing
2023-06-02 08:44:53,462 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'mysql.tables_priv' is filtered out of capturing
2023-06-02 08:44:53,462 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'mysql.time_zone' is filtered out of capturing
2023-06-02 08:44:53,462 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'mysql.time_zone_leap_second' is filtered out of capturing
2023-06-02 08:44:53,463 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'mysql.time_zone_name' is filtered out of capturing
2023-06-02 08:44:53,463 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'mysql.time_zone_transition' is filtered out of capturing
2023-06-02 08:44:53,463 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'mysql.time_zone_transition_type' is filtered out of capturing
2023-06-02 08:44:53,463 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'mysql.user' is filtered out of capturing
2023-06-02 08:44:53,466 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.accounts' is filtered out of capturing
2023-06-02 08:44:53,466 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.binary_log_transaction_compression_stats' is filtered out of capturing
2023-06-02 08:44:53,466 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.cond_instances' is filtered out of capturing
2023-06-02 08:44:53,466 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.data_lock_waits' is filtered out of capturing
2023-06-02 08:44:53,467 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.data_locks' is filtered out of capturing
2023-06-02 08:44:53,467 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.error_log' is filtered out of capturing
2023-06-02 08:44:53,467 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.events_errors_summary_by_account_by_error' is filtered out of capturing
2023-06-02 08:44:53,467 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.events_errors_summary_by_host_by_error' is filtered out of capturing
2023-06-02 08:44:53,467 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.events_errors_summary_by_thread_by_error' is filtered out of capturing
2023-06-02 08:44:53,467 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.events_errors_summary_by_user_by_error' is filtered out of capturing
2023-06-02 08:44:53,467 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.events_errors_summary_global_by_error' is filtered out of capturing
2023-06-02 08:44:53,467 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.events_stages_current' is filtered out of capturing
2023-06-02 08:44:53,468 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.events_stages_history' is filtered out of capturing
2023-06-02 08:44:53,468 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.events_stages_history_long' is filtered out of capturing
2023-06-02 08:44:53,468 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.events_stages_summary_by_account_by_event_name' is filtered out of capturing
2023-06-02 08:44:53,469 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.events_stages_summary_by_host_by_event_name' is filtered out of capturing
2023-06-02 08:44:53,469 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.events_stages_summary_by_thread_by_event_name' is filtered out of capturing
2023-06-02 08:44:53,469 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.events_stages_summary_by_user_by_event_name' is filtered out of capturing
2023-06-02 08:44:53,469 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.events_stages_summary_global_by_event_name' is filtered out of capturing
2023-06-02 08:44:53,469 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.events_statements_current' is filtered out of capturing
2023-06-02 08:44:53,469 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.events_statements_histogram_by_digest' is filtered out of capturing
2023-06-02 08:44:53,469 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.events_statements_histogram_global' is filtered out of capturing
2023-06-02 08:44:53,469 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.events_statements_history' is filtered out of capturing
2023-06-02 08:44:53,469 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.events_statements_history_long' is filtered out of capturing
2023-06-02 08:44:53,470 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.events_statements_summary_by_account_by_event_name' is filtered out of capturing
2023-06-02 08:44:53,470 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.events_statements_summary_by_digest' is filtered out of capturing
2023-06-02 08:44:53,470 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.events_statements_summary_by_host_by_event_name' is filtered out of capturing
2023-06-02 08:44:53,470 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.events_statements_summary_by_program' is filtered out of capturing
2023-06-02 08:44:53,470 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.events_statements_summary_by_thread_by_event_name' is filtered out of capturing
2023-06-02 08:44:53,470 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.events_statements_summary_by_user_by_event_name' is filtered out of capturing
2023-06-02 08:44:53,470 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.events_statements_summary_global_by_event_name' is filtered out of capturing
2023-06-02 08:44:53,470 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.events_transactions_current' is filtered out of capturing
2023-06-02 08:44:53,471 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.events_transactions_history' is filtered out of capturing
2023-06-02 08:44:53,471 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.events_transactions_history_long' is filtered out of capturing
2023-06-02 08:44:53,471 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.events_transactions_summary_by_account_by_event_name' is filtered out of capturing
2023-06-02 08:44:53,471 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.events_transactions_summary_by_host_by_event_name' is filtered out of capturing
2023-06-02 08:44:53,471 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.events_transactions_summary_by_thread_by_event_name' is filtered out of capturing
2023-06-02 08:44:53,471 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.events_transactions_summary_by_user_by_event_name' is filtered out of capturing
2023-06-02 08:44:53,471 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.events_transactions_summary_global_by_event_name' is filtered out of capturing
2023-06-02 08:44:53,471 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.events_waits_current' is filtered out of capturing
2023-06-02 08:44:53,471 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.events_waits_history' is filtered out of capturing
2023-06-02 08:44:53,472 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.events_waits_history_long' is filtered out of capturing
2023-06-02 08:44:53,472 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.events_waits_summary_by_account_by_event_name' is filtered out of capturing
2023-06-02 08:44:53,472 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.events_waits_summary_by_host_by_event_name' is filtered out of capturing
2023-06-02 08:44:53,472 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.events_waits_summary_by_instance' is filtered out of capturing
2023-06-02 08:44:53,472 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.events_waits_summary_by_thread_by_event_name' is filtered out of capturing
2023-06-02 08:44:53,472 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.events_waits_summary_by_user_by_event_name' is filtered out of capturing
2023-06-02 08:44:53,472 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.events_waits_summary_global_by_event_name' is filtered out of capturing
2023-06-02 08:44:53,472 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.file_instances' is filtered out of capturing
2023-06-02 08:44:53,472 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.file_summary_by_event_name' is filtered out of capturing
2023-06-02 08:44:53,472 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.file_summary_by_instance' is filtered out of capturing
2023-06-02 08:44:53,472 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.global_status' is filtered out of capturing
2023-06-02 08:44:53,473 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.global_variables' is filtered out of capturing
2023-06-02 08:44:53,473 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.host_cache' is filtered out of capturing
2023-06-02 08:44:53,473 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.hosts' is filtered out of capturing
2023-06-02 08:44:53,473 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.innodb_redo_log_files' is filtered out of capturing
2023-06-02 08:44:53,473 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.keyring_component_status' is filtered out of capturing
2023-06-02 08:44:53,473 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.keyring_keys' is filtered out of capturing
2023-06-02 08:44:53,473 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.log_status' is filtered out of capturing
2023-06-02 08:44:53,473 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.memory_summary_by_account_by_event_name' is filtered out of capturing
2023-06-02 08:44:53,473 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.memory_summary_by_host_by_event_name' is filtered out of capturing
2023-06-02 08:44:53,474 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.memory_summary_by_thread_by_event_name' is filtered out of capturing
2023-06-02 08:44:53,474 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.memory_summary_by_user_by_event_name' is filtered out of capturing
2023-06-02 08:44:53,474 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.memory_summary_global_by_event_name' is filtered out of capturing
2023-06-02 08:44:53,474 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.metadata_locks' is filtered out of capturing
2023-06-02 08:44:53,474 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.mutex_instances' is filtered out of capturing
2023-06-02 08:44:53,474 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.objects_summary_global_by_type' is filtered out of capturing
2023-06-02 08:44:53,474 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.performance_timers' is filtered out of capturing
2023-06-02 08:44:53,474 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.persisted_variables' is filtered out of capturing
2023-06-02 08:44:53,474 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.prepared_statements_instances' is filtered out of capturing
2023-06-02 08:44:53,475 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.processlist' is filtered out of capturing
2023-06-02 08:44:53,475 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.replication_applier_configuration' is filtered out of capturing
2023-06-02 08:44:53,475 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.replication_applier_filters' is filtered out of capturing
2023-06-02 08:44:53,475 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.replication_applier_global_filters' is filtered out of capturing
2023-06-02 08:44:53,475 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.replication_applier_status' is filtered out of capturing
2023-06-02 08:44:53,475 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.replication_applier_status_by_coordinator' is filtered out of capturing
2023-06-02 08:44:53,475 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.replication_applier_status_by_worker' is filtered out of capturing
2023-06-02 08:44:53,475 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.replication_asynchronous_connection_failover' is filtered out of capturing
2023-06-02 08:44:53,475 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.replication_asynchronous_connection_failover_managed' is filtered out of capturing
2023-06-02 08:44:53,475 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.replication_connection_configuration' is filtered out of capturing
2023-06-02 08:44:53,476 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.replication_connection_status' is filtered out of capturing
2023-06-02 08:44:53,476 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.replication_group_member_stats' is filtered out of capturing
2023-06-02 08:44:53,476 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.replication_group_members' is filtered out of capturing
2023-06-02 08:44:53,476 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.rwlock_instances' is filtered out of capturing
2023-06-02 08:44:53,476 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.session_account_connect_attrs' is filtered out of capturing
2023-06-02 08:44:53,476 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.session_connect_attrs' is filtered out of capturing
2023-06-02 08:44:53,476 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.session_status' is filtered out of capturing
2023-06-02 08:44:53,476 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.session_variables' is filtered out of capturing
2023-06-02 08:44:53,476 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.setup_actors' is filtered out of capturing
2023-06-02 08:44:53,476 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.setup_consumers' is filtered out of capturing
2023-06-02 08:44:53,476 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.setup_instruments' is filtered out of capturing
2023-06-02 08:44:53,477 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.setup_objects' is filtered out of capturing
2023-06-02 08:44:53,477 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.setup_threads' is filtered out of capturing
2023-06-02 08:44:53,477 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.socket_instances' is filtered out of capturing
2023-06-02 08:44:53,477 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.socket_summary_by_event_name' is filtered out of capturing
2023-06-02 08:44:53,477 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.socket_summary_by_instance' is filtered out of capturing
2023-06-02 08:44:53,477 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.status_by_account' is filtered out of capturing
2023-06-02 08:44:53,477 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.status_by_host' is filtered out of capturing
2023-06-02 08:44:53,477 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.status_by_thread' is filtered out of capturing
2023-06-02 08:44:53,477 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.status_by_user' is filtered out of capturing
2023-06-02 08:44:53,477 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.table_handles' is filtered out of capturing
2023-06-02 08:44:53,477 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.table_io_waits_summary_by_index_usage' is filtered out of capturing
2023-06-02 08:44:53,477 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.table_io_waits_summary_by_table' is filtered out of capturing
2023-06-02 08:44:53,478 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.table_lock_waits_summary_by_table' is filtered out of capturing
2023-06-02 08:44:53,478 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.threads' is filtered out of capturing
2023-06-02 08:44:53,478 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.tls_channel_status' is filtered out of capturing
2023-06-02 08:44:53,478 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.user_defined_functions' is filtered out of capturing
2023-06-02 08:44:53,478 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.user_variables_by_thread' is filtered out of capturing
2023-06-02 08:44:53,478 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.users' is filtered out of capturing
2023-06-02 08:44:53,478 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.variables_by_thread' is filtered out of capturing
2023-06-02 08:44:53,478 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'performance_schema.variables_info' is filtered out of capturing
2023-06-02 08:44:53,481 INFO  com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils [] - 	 'sys.sys_config' is filtered out of capturing
2023-06-02 08:44:53,495 WARN  io.debezium.relational.history.DatabaseHistoryMetrics        [] - Unable to register the MBean 'debezium.mysql:type=connector-metrics,context=schema-history,server=mysql_binlog_source': debezium.mysql:type=connector-metrics,context=schema-history,server=mysql_binlog_source
2023-06-02 08:44:54,092 INFO  com.ververica.cdc.connectors.mysql.source.reader.MySqlSourceReader [] - The table schema discovery for binlog split binlog-split success
2023-06-02 08:44:54,099 INFO  io.debezium.jdbc.JdbcConnection                              [] - Connection gracefully closed
2023-06-02 08:44:54,100 INFO  org.apache.flink.connector.base.source.reader.SourceReaderBase [] - Adding split(s) to reader: [MySqlBinlogSplit{splitId='binlog-split', offset={ts_sec=0, file=binlog.000006, pos=1264722, gtids=, row=0, event=0}, endOffset={ts_sec=0, file=, pos=-9223372036854775808, row=0, event=0}, isSuspended=false}]
2023-06-02 08:44:54,101 INFO  org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher [] - Starting split fetcher 1
2023-06-02 08:44:54,105 INFO  com.ververica.cdc.connectors.mysql.source.reader.MySqlSplitReader [] - BinlogSplitReader is created.
2023-06-02 08:44:54,121 WARN  io.debezium.relational.history.DatabaseHistoryMetrics        [] - Unable to register the MBean 'debezium.mysql:type=connector-metrics,context=schema-history,server=mysql_binlog_source': debezium.mysql:type=connector-metrics,context=schema-history,server=mysql_binlog_source
2023-06-02 08:44:54,121 INFO  io.debezium.connector.mysql.MySqlConnection                  [] - Get all known binlogs from MySQL
2023-06-02 08:44:54,149 INFO  com.ververica.cdc.connectors.mysql.debezium.task.context.StatefulTaskContext [] - MySQL has the binlog file 'binlog.000006' required by the connector
2023-06-02 08:44:54,149 INFO  io.debezium.relational.history.DatabaseHistoryMetrics        [] - Started database history recovery
2023-06-02 08:44:54,150 INFO  io.debezium.relational.history.DatabaseHistoryMetrics        [] - Finished database history recovery of 0 change(s) in 0 ms
2023-06-02 08:44:54,158 INFO  io.debezium.util.Threads                                     [] - Requested thread factory for connector MySqlConnector, id = mysql_binlog_source named = binlog-client
2023-06-02 08:44:54,165 INFO  com.starrocks.connector.flink.manager.TransactionTableRegion [] - Flush uniqueKey : flink_source_db-as_person_assets_allot, label : null, bytes : 22033
2023-06-02 08:44:54,168 INFO  com.starrocks.connector.flink.manager.TransactionTableRegion [] - Generate entity meta, db: flink_source_db, table: as_person_assets_allot, total rows : 115, entity rows : 115, entity bytes : 22148
2023-06-02 08:44:54,186 INFO  com.starrocks.data.load.stream.TransactionStreamLoader       [] - Transaction start, label : 713ed52f-36ca-4fd0-841b-44ed36fc63ee
2023-06-02 08:44:54,189 INFO  io.debezium.connector.mysql.MySqlStreamingChangeEventSource  [] - Skip 0 events on streaming start
2023-06-02 08:44:54,189 INFO  io.debezium.connector.mysql.MySqlStreamingChangeEventSource  [] - Skip 0 rows on streaming start
2023-06-02 08:44:54,190 INFO  io.debezium.util.Threads                                     [] - Creating thread debezium-mysqlconnector-mysql_binlog_source-binlog-client
2023-06-02 08:44:54,194 INFO  com.starrocks.data.load.stream.TransactionStreamLoader       [] - Transaction start, request : POST http://10.17.0.28:8030/api/transaction/begin HTTP/1.1
2023-06-02 08:44:54,194 INFO  io.debezium.util.Threads                                     [] - Creating thread debezium-mysqlconnector-mysql_binlog_source-binlog-client
2023-06-02 08:44:54,221 INFO  io.debezium.connector.mysql.MySqlStreamingChangeEventSource  [] - Connected to MySQL binlog at 10.17.0.28:3306, starting at MySqlOffsetContext [sourceInfoSchema=Schema{io.debezium.connector.mysql.Source:STRUCT}, sourceInfo=SourceInfo [currentGtid=null, currentBinlogFilename=binlog.000006, currentBinlogPosition=1264722, currentRowNumber=0, serverId=0, sourceTime=null, threadId=-1, currentQuery=null, tableIds=[], databaseName=null], partition={server=mysql_binlog_source}, snapshotCompleted=false, transactionContext=TransactionContext [currentTransactionId=null, perTableEventCount={}, totalEventCount=0], restartGtidSet=null, currentGtidSet=null, restartBinlogFilename=binlog.000006, restartBinlogPosition=1264722, restartRowsToSkip=0, restartEventsToSkip=0, currentEventLengthInBytes=0, inTransaction=false, transactionId=null]
2023-06-02 08:44:54,223 INFO  io.debezium.connector.mysql.MySqlStreamingChangeEventSource  [] - Waiting for keepalive thread to start
2023-06-02 08:44:54,223 INFO  io.debezium.util.Threads                                     [] - Creating thread debezium-mysqlconnector-mysql_binlog_source-binlog-client
2023-06-02 08:44:54,324 INFO  io.debezium.connector.mysql.MySqlStreamingChangeEventSource  [] - Keepalive thread is running
2023-06-02 08:44:54,598 INFO  com.starrocks.data.load.stream.TransactionStreamLoader       [] - Transaction started,  body : {
    "Status": "OK",
    "Message": "",
    "Label": "713ed52f-36ca-4fd0-841b-44ed36fc63ee",
    "TxnId": 2,
    "BeginTxnTimeMs": 70
}
2023-06-02 08:44:54,629 INFO  com.starrocks.data.load.stream.DefaultStreamLoader           [] - Stream loading, label : 713ed52f-36ca-4fd0-841b-44ed36fc63ee, region : flink_source_db-as_person_assets_allot, request : PUT http://10.17.0.28:8030/api/transaction/load HTTP/1.1
2023-06-02 08:44:54,785 INFO  com.starrocks.data.load.stream.http.StreamLoadEntity         [] - Entity write end, contentLength : 22148, total : 22148
2023-06-02 08:44:54,787 INFO  com.starrocks.data.load.stream.DefaultStreamLoader           [] - Stream load completed, label : 713ed52f-36ca-4fd0-841b-44ed36fc63ee, database : flink_source_db, table : as_person_assets_allot, body : {
    "Status": "OK",
    "Message": "",
    "Label": "713ed52f-36ca-4fd0-841b-44ed36fc63ee",
    "TxnId": 2,
    "LoadBytes": 22148,
    "StreamLoadPlanTimeMs": 129,
    "ReceivedDataTimeMs": 0
}
2023-06-02 08:44:54,819 INFO  com.starrocks.connector.flink.manager.StarRocksSinkManagerV2 [] - Receive load response, cacheByteBeforeFlush: 22033, currentCacheBytes: 0, totalFlushRows : 115
2023-06-02 08:44:54,821 INFO  com.starrocks.connector.flink.manager.TransactionTableRegion [] - Stream load flushed, db: flink_source_db, table: as_person_assets_allot, label : 713ed52f-36ca-4fd0-841b-44ed36fc63ee
2023-06-02 08:44:54,823 INFO  com.starrocks.connector.flink.manager.TransactionTableRegion [] - Stream load completed, db: flink_source_db, table: as_person_assets_allot, label : 713ed52f-36ca-4fd0-841b-44ed36fc63ee
2023-06-02 08:44:54,828 INFO  com.starrocks.data.load.stream.TransactionStreamLoader       [] - Transaction prepare, label : 713ed52f-36ca-4fd0-841b-44ed36fc63ee, request : POST http://10.17.0.28:8030/api/transaction/prepare HTTP/1.1
2023-06-02 08:44:54,940 INFO  com.starrocks.data.load.stream.TransactionStreamLoader       [] - Transaction prepared,  body : {
    "Status": "INTERNAL_ERROR",
    "Message": "too many filtered rows",
    "ErrorURL": "http://172.18.0.7:8040/api/_load_error_log?file=error_log_2d47645c7c4c0130_942ef90b057f5bb8"
}
2023-06-02 08:44:54,947 ERROR com.starrocks.data.load.stream.TransactionStreamLoader       [] - Transaction prepare failed, db: flink_source_db, table: as_person_assets_allot, label: 713ed52f-36ca-4fd0-841b-44ed36fc63ee, 
responseBody: {
    "Status": "INTERNAL_ERROR",
    "Message": "too many filtered rows",
    "ErrorURL": "http://172.18.0.7:8040/api/_load_error_log?file=error_log_2d47645c7c4c0130_942ef90b057f5bb8"
}
errorLog: Error: Value count does not match column count. Expect 21, but got 12. Row: 44	汪利君	10079	季平	jiping	10654	业务一处	210411	联想-百应	22030067	2022-12-20T00:00	联想全球总部西区
Error: Value count does not match column count. Expect 21, but got 10. Row: 	4	5467820	\N	1	10305	2022-12-20T17:12:31	10305	2022-12-20T17:12:31	0
Error: Value count does not match column count. Expect 21, but got 12. Row: 43	汪利君	10074	冉磊	ranlei	83280	业务一处	210411	联想-中国区	22030068	2022-12-20T00:00	联想-天府 成都
Error: Value count does not match column count. Expect 21, but got 10. Row: 	4	5465360	\N	1	10305	2022-12-20T17:11:14	10305	2022-12-20T17:11:14	

2023-06-02 08:44:54,948 ERROR com.starrocks.connector.flink.manager.TransactionTableRegion [] - TransactionTableRegion commit failed, db: flink_source_db, table: as_person_assets_allot, label: 713ed52f-36ca-4fd0-841b-44ed36fc63ee
com.starrocks.data.load.stream.exception.StreamLoadFailException: Failed to prepare transaction, please check taskmanager log for details, Transaction{database='flink_source_db', table='as_person_assets_allot', label='713ed52f-36ca-4fd0-841b-44ed36fc63ee', finish=false}
	at com.starrocks.connector.flink.manager.TransactionTableRegion.commit(TransactionTableRegion.java:253) ~[flink-connector-starrocks-1.2.6_flink-1.15.jar:?]
	at com.starrocks.connector.flink.manager.StarRocksSinkManagerV2.lambda$init$0(StarRocksSinkManagerV2.java:161) ~[flink-connector-starrocks-1.2.6_flink-1.15.jar:?]
	at java.lang.Thread.run(Unknown Source) [?:?]
2023-06-02 08:44:54,956 ERROR com.starrocks.connector.flink.manager.StarRocksSinkManagerV2 [] - Stream load failed
com.starrocks.data.load.stream.exception.StreamLoadFailException: Failed to prepare transaction, please check taskmanager log for details, Transaction{database='flink_source_db', table='as_person_assets_allot', label='713ed52f-36ca-4fd0-841b-44ed36fc63ee', finish=false}
	at com.starrocks.connector.flink.manager.TransactionTableRegion.commit(TransactionTableRegion.java:253) ~[flink-connector-starrocks-1.2.6_flink-1.15.jar:?]
	at com.starrocks.connector.flink.manager.StarRocksSinkManagerV2.lambda$init$0(StarRocksSinkManagerV2.java:161) ~[flink-connector-starrocks-1.2.6_flink-1.15.jar:?]
	at java.lang.Thread.run(Unknown Source) [?:?]

# 练习随记--
mysql -P9030 -h127.0.0.1 -uroot --prompt="StarRocks > "


172.18.0.12

mysql -P9030 -h10.17.0.23 -uroot --prompt="StarRocks > "
mysql -P9030 -h10.17.0.28 -uroot -pP@88W0rd  --prompt="StarRocks > "

mysql -P9033 -h<YourServerIPaddr> -uroot --prompt="StarRocks > "
mysql -h172.17.16.89 -P9030 -uroot -pP@88W0rd < ./result/starrocks-create.all.sql

mysql -h10.17.0.28 -P9030 -uroot -pP@88W0rd < ./result/starrocks-create.all.sql



mysql -P9030 -hfe-c-49dc31d44d5bf0f1-internal.starrocks.aliyuncs.com -plitSoft@2022 -uadmin --prompt="StarRocks > "



mysql -P9030 -hfe-c-49dc31d44d5bf0f1-internal.starrocks.aliyuncs.com -plitSoft@2022 -uadmin < starrocks-create.1.sql



as_assets_apply_base

mysql -P9030 -h<YourServerIPaddr> -pP@88W0rd -uroot --prompt="StarRocks > "

SET PASSWORD for root = PASSWORD('P@88W0rd');


  	CREATE USER lit_sr@'%' IDENTIFIED WITH mysql_native_password BY 'P@88W0rd'; 



  	/opt/flink/smt/result/flink-create.all.sql


mysql -h172.17.16.66 -P9030 -uroot -pP@88W0rd < starrocks-create.all.sql

mysql -h10.17.0.28 -P9030 -uroot -pP@88W0rd < starrocks-create.all.sql


底层数据库扩充,增加数据查询效率


helm install -n starrocks -f lit-values.yaml starrocks starrocks-community/kube-starrocks
0
  1. 支付宝打赏

    qrcode alipay
  2. 微信打赏

    qrcode weixin

评论区