Flink CDC 实时抽取 Oracle 数据-排错&调优

-- 假设我们已经有了一个运行中的 Flink 作业，并且我们想要调整与 Oracle CDC 相关的配置。
-- 以下是一些调优和排错的示例 SQL 代码：
 
-- 调整 Checkpoint 的间隔时间
ALTER TABLE source_table_name SET ('execution.checkpointing.interval' = '1 min');
 
-- 调整状态后端的内存大小
ALTER TABLE source_table_name SET ('table.exec.state.memory.process' = '50 mb', 'table.exec.state.memory.managed' = '100 mb');
 
-- 调整 RocksDB 状态后端的配置
ALTER TABLE source_table_name SET ('table.exec.state.backend' = 'rocksdb', 'table.exec.state.rocksdb.local-recovery' = 'true');
 
-- 调整并行度
ALTER TABLE source_table_name SET ('parallelism' = '8');
 
-- 排查问题时，可以查看作业的日志
-- 使用 Flink Web UI 或者 CLI 命令行工具来查看作业日志
 
-- 如果作业遇到了内存不足的问题，可以尝试增加 Task Manager 的堆内存
ALTER TABLE source_table_name SET ('taskmanager.memory.process.size' = '2048m');
 
-- 如果作业处于稳定状态，但是数据抽取延迟较高，可以调整水印的类型，从而改善性能
ALTER TABLE source_table_name SET ('connector.start-up.mode' = 'initial');
 
-- 注意：上述调优和排错的方法可能需要根据实际的作业情况和Oracle数据库的特点进行调整。

这段代码展示了如何在Flink中针对CDC作业进行配置调整，包括调整Checkpoint间隔、内存状态大小、RocksDB状态后端配置和并行度等。同时，提供了查看日志的方法，以便排查问题。在实际操作中，这些调整和排错方法需要根据具体的作业状况和资源情况来执行。