Skip to content

Changes

Summary

  1. 调整信息 (details)
  2. 调整重试逻辑 (details)
  3. hotfix: 修复提交不生效问题 (details)
  4. hotfix:调整cdc (details)
  5. 重试验证数据库情况 (details)
  6. 调整归集日志结构 (details)
  7. hotfix: 调整批处理数量 (details)
  8. hotfix: 调优批处理 (details)
  9. hotfix: 异常的时候记录SQL语句以区分任务 (details)
Commit 02d3f94784d500ed1885e422cc8a9c7637053127 by linhancheng
调整信息
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/java/com/bcxin/tenant/data/etc/tasks/jobs/DataEtcJob.java
Commit aba19c9f405a92ccaf7be965b5691f4475548209 by linhancheng
调整重试逻辑
The file was modified src/streaming-event-platform/event-core/src/main/java/com/bcxin/event/core/utils/RetryUtil.java
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/java/com/bcxin/tenant/data/etc/tasks/components/CustomJdbcOutputFormat.java
Commit 6fad52a32262051f6e26a45ef7151d1c99a2dcf1 by linhancheng
hotfix: 修复提交不生效问题
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/java/com/bcxin/tenant/data/etc/tasks/components/CustomJdbcOutputFormat.java
Commit 2a50de0e6bec0f1149b4d6faa8a6f76b2e57c8ff by linhancheng
hotfix:调整cdc
The file was modified src/streaming-event-platform/event-tasks/flink-cdc-kafka-source-task/src/main/java/com/bcxin/flink/cdc/kafka/source/task/compnents/JdbcDbReaderComponent.java
Commit 4303b333eb03784e8e9cb5234077c0011f18c3cc by linhancheng
重试验证数据库情况
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/java/com/bcxin/tenant/data/etc/tasks/components/CustomJdbcOutputFormat.java
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/java/com/bcxin/tenant/data/etc/tasks/jobs/DataJobAbstract.java
Commit c9e1ec56f8c55d341b84c56b32278d1f166cf222 by linhancheng
调整归集日志结构
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/java/com/bcxin/tenant/data/etc/tasks/components/CustomJdbcOutputFormat.java
The file was modified "src/streaming-event-platform/docs/db/\345\275\222\351\233\206\347\232\204\346\211\247\350\241\214\346\227\245\345\277\227.sql"
Commit 597849249bdcf92e57d392e6f62fd7fba86527a9 by linhancheng
hotfix: 调整批处理数量
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/java/com/bcxin/tenant/data/etc/tasks/jobs/DataEtcJob.java
Commit 625189b4a23807ee5fb1f47f6ed5d1f73931daa9 by linhancheng
hotfix: 调优批处理
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/java/com/bcxin/tenant/data/etc/tasks/components/CustomJdbcOutputFormat.java
Commit d44465aa389981c1846ea79837ec54dda92cc47c by linhancheng
hotfix: 异常的时候记录SQL语句以区分任务
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/java/com/bcxin/tenant/data/etc/tasks/components/CustomJdbcOutputFormat.java
The file was modified "src/streaming-event-platform/docs/db/\345\275\222\351\233\206\347\232\204\346\211\247\350\241\214\346\227\245\345\277\227.sql"