CDC升级方案

1、以下目录的
/data01/datafocus/share/runtime/python3/lib/python3.8/site-packages/pyflink/opt/
/data01/datafocus/share/thirdparty/flink-1.20.0/opt

删除
flink-sql-connector-mongodb-cdc-3.2.1.jar
flink-sql-connector-mysql-cdc-3.2.1.jar
flink-sql-connector-oceanbase-cdc-3.2.1.jar
flink-sql-connector-oracle-cdc-3.2.1.jar
flink-sql-connector-postgres-cdc-3.2.1.jar
flink-sql-connector-sqlserver-cdc-2.4.2.jar
新增
flink-sql-connector-sqlserver-cdc-3.3.0.jar
flink-sql-connector-oracle-cdc-3.3.0.jar
flink-sql-connector-mongodb-cdc-3.3.0.jar
flink-sql-connector-postgres-cdc-3.3.0.jar
flink-sql-connector-oceanbase-cdc-3.3.0.jar
flink-sql-connector-mysql-cdc-3.3.0.jar

2.新增
/data01/datafocus/share/data/cdc-client/flink-cdc-3.3.0
删除
/data01/datafocus/share/data/cdc-client/flink-cdc-3.2.1

3.pipeline-lib 的jar加入flink-cdc-3.3.0-bin.tar解压后lib目录

4.环境变量修改
etlworker
FLINK_CDC_HOME=/srv/datafocus/data/cdc-client/flink-cdc-3.3.0
PWD=//srv/datafocus/data/cdc-client/flink-cdc-3.3.0/bin
OLDPWD=//srv/datafocus/data/cdc-client/flink-cdc-3.3.0

etlserver:
FLINK_CDC_HOME=/srv/datafocus/data/cdc-client/flink-cdc-3.3.0