【代码】paimon表做flink维表 实时join。

【代码】flink sql消费kafka 消费位置常用配置。

HDFS的IO吞吐性能可以通过TestDFSIO进行测试。TestDFSIO是一个分布式任务，存在任务调度及结果汇总阶段，计算集群吞吐均值时会略低于HDFS吞吐限速。在进行顺序读与随机读的测试之前需要确保HDFS之上已有指定的待测数据，如果没有待测数据请使用顺序写命令生成。-nrFiles表示文件数量，-fileSize表示文件大小，-random表示随机读写。

insert into 语句报错:This command is not allowed on an ACID table dws.broadpos_rep_copy with a non-ACID transaction manager. Failed command

【代码】flink udf 返回多列 demo。

[迁移ClickHouse数据到StarRocks](https://help.aliyun.com/zh/emr/emr-serverless-starrocks/user-guide/migrate-data-from-clickhouse-to-serverless-starrocks#b9af71a0e3dpw)- 经测试存在bigint转换问题 官方已于23年 9.8日修复 等待下个版本

注意版本太低没用。

测试 清空hive分区表(分区>1000) 最优方案。

官方文档地址https://ververica.github.io/flink-cdc-connectors/release-2.0/GithubRelease 2.0.0https://github.com/ververica/flink-cdc-connectors1.0 2.0区别1.0需要全局锁或者表锁. 2.0不需要锁.1.0和2.0都需要开启binlog.