rgnjjn9hyw-del commented on issue #12887:
URL: https://github.com/apache/seatunnel/issues/12887#issuecomment-6261421732

   PG云实时同步到本地doris
   ## 第一步:SSH 隧道
   ## 第二步:Debezium 侧增加心跳 + 连接探活(加到 debezium 配置块)
   ```
   debezium = {
     "publication.name" = "seatunnel_cdc_pub"
     "publication.autocreate.mode" = "disabled"
     "slot.name" = "seatunnel_slot_long"
     "slot.autocreate.mode" = "disabled"
     "heartbeat.interval.ms" = "10000"
     "status.update.interval.ms" = "10000"
     # 新增:连接探活,避免死连接挂住
     "shturl.cc/ggpDzr531YC" = "15000"
     "shturl.cc/RIpIHw" = "10000"
   }
   ```
   `heartbeat` 会定时往 PG 写心跳记录,**让复制流不会长时间静默,防止 ssh 隧道判定空闲切断**,这个对你 ssh 隧道场景非常关键。
   
   ## 第三步:SeaTunnel 引擎侧重试策略(Zeta)
   
   SeaTunnel CDC source 默认重试次数有限,遇到 Connection reset 直接失败。
   env 里增加:
   
   ```
   env {
     execution.parallelism = 1
     job.mode = "STREAMING"
     checkpoint.interval = 5000
     job.retry.times = 3
     job.retry.interval = 5000
   }
   ```
   
   > 
   > `job.retry.times`:任务整体失败后自动重试;注意:是整个 source task 重启,不是只重建 debezium 连接。


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]

Reply via email to