itpux01: itpux01#mysql的itpux01库 对应Postgresql的mydb库itpux01 schema。itpux02: itpux02#mysql的itpux02库 对应Postgresql的mydb库itpux02 schema。itpux03: itpux03#mysql的itpux03库 对应Postgresql的mydb库itpux03 schema。

建议：根据并发调整（如 4MB），公式参考：work_mem = (总内存 - shared_buffers) / (max_connections * 2)。建议：通常设为 shared_buffers 的 1/32（若 shared_buffers=4GB，设为 128MB）。风险：可能丢失少量事务。建议：设为物理内存的 25%-30%（若总内存≥8GB，可设为 4GB）。建议：设为物理内存的

oracle rac -磁盘设备共享

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

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

flink 1.20 mysql source 自定义开发

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

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

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

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