Skip to content
[Jenkins]Jenkins
log in

Changes

Summary

  1. 公司监管机构变更入离职记录domanid归集 (details)
  2. 企业所属的监管区域 (details)
  3. 调整头信息 (details)
  4. t消息下xxx (details)
  5. 删除日志 (details)
  6. 调整区域信息 (details)
  7. 调整监管区域 (details)
  8. 头部信息 (details)
  9. 调整datasource的获取进程 (details)
  10. 数据库的连接的获取方式 (details)
  11. 调整变量信息 (details)
  12. 调整连接方式 (details)
  13. 调整序列化的属性信息 (details)
  14. 输入元数据日志信息 (details)
  15. 去掉日志 (details)
  16. 调整企业信息: (details)
  17. 添加人员在职状态日志 (details)
  18. 添加跟踪tenant_employees日志 (details)
  19. 添加tenant_employees脚本执行情况日志 (details)
  20. hotfix: 修复分区问题 (details)
  21. tenant_employees添加打印日志 (details)
  22. 调整晋城的功能 (details)
  23. hotfix: 针对备份及非备份采用不同的分区策略 (details)
  24. hotfix: 添加机构类型 (details)
  25. hotfix: 仅同步非监管账户 (details)
  26. 优化问题 (details)
  27. hot:针对分区数量不一致导致的数量问题 (details)
  28. 调整为1并行 (details)
  29. hotfix:调整分区及日志信息 (details)
Commit 42135183969cbeccc94d63aa5e3f27fc30755888 by daiqincheng
公司监管机构变更入离职记录domanid归集
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/preprod/others.json
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/test2/others.json
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/com-prod/others.json
Commit 15a7c77553e6c22cc29cd25004a7ba9c8144967c by linhancheng
企业所属的监管区域
The file was addedsrc/streaming-event-platform/log.file.1
The file was addedsrc/streaming-event-platform/flink-event-udf/src/main/java/com/bcxin/flink/event/udfs/RegionDispatchFunction.java
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/jobs/DbStreamCdcKafkaJob.java
The file was addedsrc/streaming-event-platform/log.file
The file was addedsrc/streaming-event-platform/flink-event-udf/pom.xml
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/JdbcBinLogCaptureApp.java
The file was addedsrc/streaming-event-platform/event-tasks/flink-cdc-kafka-source-task/src/main/java/com/bcxin/flink/cdc/kafka/source/task/compnents/JdbcDbReaderComponent.java
The file was addedsrc/streaming-event-platform/event-tasks/flink-cdc-kafka-source-task/src/main/java/com/bcxin/flink/cdc/kafka/source/task/utils/RecordHeadUtil.java
The file was modified src/streaming-event-platform/pom.xml
Commit c86c14242e06157b2b9ceccedeaf4f3335b0bb5d by linhancheng
调整头信息
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/cdcs/CdcSourceMeta.java
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/utils/RecordHeadUtil.java
Commit 2c1fade3b322d03269e1b865bcbdf1ef1709de60 by linhancheng
t消息下xxx
The file was removedsrc/streaming-event-platform/log.file.1
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/utils/RecordHeadUtil.java
The file was modified src/.gitignore
The file was modified src/streaming-event-platform/log.file
Commit e7193fce2c05dd67534bb3f6bfaa0acf1f82a383 by linhancheng
删除日志
The file was removedsrc/streaming-event-platform/log.file
Commit eb371207d117ce514a50744469e3f6b134497b15 by linhancheng
调整区域信息
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 0005c003dfb36a684f69f8bed02a203ab6b4a550 by linhancheng
调整监管区域
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 a1d5e75dd8eedd9f2dfccaa98ef56e6062720a11 by linhancheng
头部信息
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
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/utils/RecordHeadUtil.java
Commit 02caa4ac712806ddb521a0fb1943c5d6df477b18 by linhancheng
调整datasource的获取进程
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 174b6843d0af520e9da5426e8ab3d8f9a5357fcd by linhancheng
数据库的连接的获取方式
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 382803d8b84f539475baf23a01a3351e0b5fb195 by linhancheng
调整变量信息
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 83b2743d2f9057fa0c08c134e082cd03c62b4e71 by linhancheng
调整连接方式
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 12b24bf609be04b84187bd97b49d78cee0c800be by linhancheng
调整序列化的属性信息
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 f0d6946d46d9cd3271aab39f88cb4329bcb86d49 by linhancheng
输入元数据日志信息
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/utils/RecordHeadUtil.java
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 4081bf0039c54702160408b40ecb3a067825db21 by linhancheng
去掉日志
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 d8417ac20f3038d43bb3350089d8adf5e22c6e4d by linhancheng
调整企业信息:
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/cdcs/CdcSourceMeta.java
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 106e81be69c147709c8c1373819f5fa51678bfbd by daiqincheng
添加人员在职状态日志
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 b5e4b9120f6743c77a102eadfcc11a11065e4052 by daiqincheng
添加跟踪tenant_employees日志
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 419f26a991d1259d8a6d1b13b9226d4c5311c047 by daiqincheng
添加tenant_employees脚本执行情况日志
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 04a8e64bdc569dae11788095af641b55e072a1de by linhancheng
hotfix: 修复分区问题
The file was addedsrc/kafka-connect/kafka-connect/pom.xml
The file was addedsrc/kafka-connect/kafka-connect/src/main/java/com/bcxin/filters/RegionCodeFilter.java
The file was modified src/streaming-event-platform/event-core/src/main/java/com/bcxin/event/core/KafkaConstants.java
Commit 800634ec5b940732948f81fc94be77d56a7adaf8 by daiqincheng
tenant_employees添加打印日志
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 63694f47eed2fbd9c01d350b351a37343b514208 by linhancheng
调整晋城的功能
The file was modified src/kafka-connect/kafka-connect/src/main/java/com/bcxin/filters/RegionCodeFilter.java
Commit 34f447c39cbe480fa570bbc9dfb480a19010aa10 by linhancheng
hotfix: 针对备份及非备份采用不同的分区策略
The file was modified src/streaming-event-platform/flink-streaming-core/src/main/java/com/bcxin/flink/streaming/cores/utils/KafkaUtils.java
The file was modified src/kafka-connect/kafka-connect/src/main/java/com/bcxin/filters/RegionCodeFilter.java
Commit 77384e39f3d11b7f61b9e679eeaad6874493e0f9 by linhancheng
hotfix: 添加机构类型
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
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/utils/RecordHeadUtil.java
The file was addedsrc/streaming-event-platform/event-tasks/flink-cdc-kafka-source-task/src/main/java/com/bcxin/flink/cdc/kafka/source/task/compnents/dtos/OrgInfoDTO.java
Commit 016c78a1eec62dc1b727e496c498683a8c3bacbb by linhancheng
hotfix: 仅同步非监管账户
The file was modified src/kafka-connect/kafka-connect/src/main/java/com/bcxin/filters/RegionCodeFilter.java
Commit 54e77de67fce13d0cbe335765c380c7b08ab23ab by linhancheng
优化问题
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/test2/others.json
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/java/com/bcxin/tenant/data/etc/tasks/DataEtcApp.java
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/test2/shopping-account.json
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/com-prod/salary-manage.json
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
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
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/com-prod/shopping-account.json
Commit 90e26fdde3c8c408adea6b1ae91a1567e6b296c5 by linhancheng
hot:针对分区数量不一致导致的数量问题
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
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 7ef80f881fd6317520fd77ec69cd88bb826cc9f5 by linhancheng
调整为1并行
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 1e3237f8afe79483850ac32fc41778b0806fa9b7 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/DataJobAbstract.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/DataEtcJob.java