WatermarkStrategy.noWatermarks(), // JDBC 源通常不使用事件时间水印，可以使用 NoWatermarks。//获取flink 上下文环境。1 添加pom.xml 依赖。2 、操作mysql代码。

1 继承SourceFunction和ParallelSourceFunction。重新run()和cancel()方法。2 AccessSource 代码。3 Access代码。

flink 1.20 mysql source 自定义开发

pg_dump -h 连接串 -U 读写用户 -F c -b -v -N public 库名 > all_sch_except_pub.backup。pg_dump -h 连接串 -U 读写用户 -F c -b -v -n hr -n public 库名 > hr_payroll.backup。--on-conflict-do-nothing将ON CONFLICT DO NOTHING 添加到I

wa (iowait)：等待 I/O 操作完成的 CPU 时间百分比（高值可能表示磁盘瓶颈）。%iowaitCPU 等待 I/O 操作完成的时间占比（高值可能表示磁盘或网络瓶颈）。进程使用的虚拟内存大小（单位：KB）。1.3 CPU负载： 显示系统中等待运行和等待IO的进程数，可以反映CPU的繁忙程度。up 15 days, 3:22：系统已运行的时间（同 uptime 命令的输出）。1.4 CP

pg_dump -h 连接串 -U 读写用户 -F c -b -v -N public 库名 > all_sch_except_pub.backup。pg_dump -h 连接串 -U 读写用户 -F c -b -v -n hr -n public 库名 > hr_payroll.backup。--on-conflict-do-nothing将ON CONFLICT DO NOTHING 添加到I

fork: true#后台运行。#配置root和mongo用户环境变量。下载对应操作系统版本。