Skip to content

Changes

Summary

  1. 添加数据库 (details)
  2. 修复重复问题 (details)
  3. 修复配置信息 (details)
  4. 添加薪酬管理文件 (details)
  5. 嘻嘻嘻 (details)
  6. 新增合同管理归集 (details)
  7. 调整连接信息serverTimezone => connectionTimeZone (details)
  8. 修改serverTimeZone到ConnectTimeZone后修复变量问题 (details)
  9. 调整连接timezone (details)
  10. 仅设置测试环境每次,读取的时候读取最新 (details)
  11. 1 (details)
  12. proc_sync_attendance_REALITY_update_by_tenant_user_credentials参数错误 (details)
  13. 硬件归集提交 (details)
  14. 修改配置 (details)
  15. 修改配置 (details)
  16. 修改硬件的sql (details)
  17. 调整私网IP (details)
  18. 调整为私网IP (details)
  19. 公司监管机构变更入离职记录domanid归集 (details)
  20. 测试环境采用内网IP地址 (details)
  21. 归集用户模型 (details)
  22. 增加跨区字段归集到公司表 (details)
  23. 重启 (details)
  24. 调整企业信息: (details)
  25. xxxxxxxx (details)
  26. 重置:不要冲最新的位置获取 (details)
  27. 测试环境重启先取30分钟前数据 (details)
  28. hotfix: 调整参数信息 (details)
  29. 晋城从业单位和驻勤项目消息归集到数据库 (details)
  30. 修改启动命令 (details)
  31. 修复合并代码 (details)
  32. 启动jc flink (details)
  33. 调整晋城的参数信息 (details)
  34. 调整配置信息 (details)
  35. 原始晋城的flink配置 (details)
  36. 调整参数 (details)
  37. 初始化晋城信息 (details)
  38. 嘻嘻嘻 (details)
  39. 电子围栏产生站内信 (details)
  40. 电子围栏产生站内信 (details)
  41. 嘻嘻嘻 (details)
  42. 嘻嘻嘻 (details)
  43. 修改监管变更入离职记录问题 (details)
  44. 去掉商城相关 (details)
  45. 调整晋城的数据归集 (details)
  46. 线索上报告知监管归属的民警 (details)
  47. 添加日志 (details)
  48. 调整晋城的部署方式 (details)
  49. 调整消息格式 (details)
  50. xxxxxxx (details)
  51. 消息内容 (details)
  52. 调整新版本日志 (details)
  53. 调整消息内容 (details)
  54. 调整企业归集信息 (details)
  55. 调整参数 (details)
  56. 调整消息内容 (details)
  57. 调整人员信息 (details)
  58. 签到数据同步至巡防任务的表 (details)
  59. 消息触发 (details)
  60. 同步赚取积分 (details)
  61. 调整反馈积分信息 (details)
  62. 巡防任务功能 (details)
  63. 赚取积分问题 (details)
  64. 调整日志 (details)
  65. 去掉日志 (details)
  66. 调整checkpoint (details)
  67. hotfix:调整日志 (details)
  68. hotfix: 参数问题 (details)
  69. 手动开启事务功能 (details)
  70. 提交重试操作 (details)
  71. hotfix: 数据丢失的问题 (details)
  72. 调整输出日志信息 (details)
  73. hotfix: 去除区域信息的日志 (details)
  74. hotfix: 调整重试机制及异常处理方式 (details)
  75. hotfix: 数据跟踪 (details)
  76. 预警数据节点 (details)
  77. 针对错误的情况,记录日志信息 (details)
  78. 调整输出日志 (details)
  79. 调整跟踪日志 (details)
  80. 企业严格模式 (details)
  81. 嘻嘻嘻 (details)
  82. 调整执行脚本的逻辑 (details)
  83. 调整执行方法 (details)
  84. 调整重试逻辑 (details)
  85. 调整日志逻辑 (details)
  86. 调整缓存信息 (details)
  87. 调整信息 (details)
  88. 调整重试逻辑 (details)
  89. hotfix: 修复提交不生效问题 (details)
  90. hotfix:调整cdc (details)
  91. 重试验证数据库情况 (details)
  92. hotfix: 添加记录重试日志步骤 (details)
  93. 调整归集日志结构 (details)
  94. hotfix: 调整批处理数量 (details)
  95. hotfix: 调优批处理 (details)
  96. hotfix: 异常的时候记录SQL语句以区分任务 (details)
  97. hotfix: 批量处理问题 (details)
  98. 调整归集商城功能 (details)
  99. 添加累计未持证归集 (details)
  100. 添加累计未持证归集 (details)
  101. 添加签章状态归集 (details)
  102. 添加签章状态归集 (details)
  103. 累计未持证存储过程添加公司类型判断 (details)
  104. 累计未持证存储过程添加公司类型判断 (details)
  105. 证书详情同步签章证书表操作脚本修改 (details)
  106. 脚本增加库名 (details)
  107. 修改证书详情同步签章证书表操作查询脚本 (details)
  108. 修改脚本联立 (details)
  109. 添加输出序列化的日志 (details)
  110. 监听体检虚拟订单 (details)
  111. 体检虚拟订单监听 (details)
  112. hotfix: 调整jobname (details)
Commit c902a900b59749fa698596cf6d03892f5f7c2939 by subingcheng
添加数据库
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/test2/shopping-account.json
Commit d46b6c7fba7e2bd83420cd5e8a80b74a127811bd by linhancheng
修复重复问题
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/test2/shopping-account.json
Commit 39e7bcabed1bc5ec9c953d960df99f7a937259a6 by linhancheng
修复配置信息
The file was addedsrc/streaming-event-platform/log.file.5
The file was modified src/streaming-event-platform/log.file
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 addedsrc/streaming-event-platform/log.file.6
Commit 93426019ff89be2959cac0a41621f68d75aeed05 by subingcheng
添加薪酬管理文件
The file was addedsrc/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/test2/salary-manage.json
Commit 8a81e21043d647da59fdcf9af146c0e7b51cd717 by linhancheng
嘻嘻嘻
The file was addedsrc/streaming-event-platform/docs/flink-standalone/env/log4j.properties
Commit 202d6f2f0991112e422ec916ee84a3ba4c31751b by subingcheng
新增合同管理归集
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/test2/shopping-account.json
Commit 84b91dde102c015dbf02ec2dc1fef6c7549ad6c4 by linhancheng
调整连接信息serverTimezone => connectionTimeZone
The file was modified src/streaming-event-platform/docs/tableTask-Conf/com-prod/company/flinkjob.sql
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/local/user-credential-details.json
The file was modified src/streaming-event-platform/event-tasks/flink-streaming-table-task/src/main/java/com/bcxin/flink/streaming/table/tasks/components/JdbcSourceDefinitionUtils.java
The file was modified "src/streaming-event-platform/docs/tableTask-Conf/db/TableTask-\344\274\201\344\270\232-\351\251\273\345\213\244-\351\251\273\345\213\244\344\272\272\345\221\230-\344\272\272\345\221\230.sql"
The file was modified src/streaming-event-platform/docs/flink-standalone/sql-client/project/kafka-companyinfocollect-employee
The file was modified src/streaming-event-platform/event-tasks/flink-streaming-table-task/src/main/resources/jdbcs/task-te.properties
The file was modified src/streaming-event-platform/docs/tableTask-Conf/JdbcMetaConf.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/local/user.json
The file was modified src/streaming-event-platform/event-jobs/event-job-domain/src/main/java/com/bcxin/event/job/domain/commands/UpdateJdbcDefinitionCommand.java
The file was modified src/streaming-event-platform/event-jobs/event-job-domain/src/main/java/com/bcxin/event/job/domain/services/impls/JdbcDefinitionServiceImpl.java
The file was modified src/streaming-event-platform/docs/scripts/preprod/flink-job.sql
The file was modified src/streaming-event-platform/event-jobs/event-job-domain/src/main/java/com/bcxin/event/job/domain/commands/CreateJdbcDefinitionCommand.java
The file was modified src/streaming-event-platform/event-tasks/flink-streaming-computing-task/src/main/resources/jdbcs/task-com-prod.properties
The file was modified "src/streaming-event-platform/docs/tableTask-Conf/com-prod/employees/TableTaskConf_\345\256\236\346\227\266\345\275\222\351\233\206\344\272\272\345\221\230\344\277\241\346\201\257.json"
The file was modified src/streaming-event-platform/event-tasks/flink-cdc-dispatch-task/src/main/java/com/bcxin/flink/cdc/dispatch/task/jobs/Binlog2DispatchCdcJob.java
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/com-prod/others.json
The file was modified src/streaming-event-platform/flink-event-job-web-api/src/main/java/com/bcxin/flink/event/job/web/apis/controllers/requests/JdbcDefinitionRequest.java
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/test2/removed/shopping-product.json
The file was modified src/streaming-event-platform/flink-event-job-web-api/src/main/resources/application.yml
The file was modified src/streaming-event-platform/event-jobs/event-job-domain/src/main/java/com/bcxin/event/job/domain/entities/JdbcDefinitionEntity.java
The file was modified src/streaming-event-platform/log.file.1
The file was modified src/streaming-event-platform/event-tasks/flink-streaming-computing-task/src/main/resources/jdbcs/task-dev.properties
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-table-task/src/main/resources/configs/preprod/db.properties
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-table-task/src/main/resources/configs/test2/db.properties
The file was modified src/streaming-event-platform/event-tasks/flink-data-webhook-task/src/main/resources/jdbcs/task-com-prod.properties
The file was modified src/streaming-event-platform/event-tasks/flink-streaming-computing-task/src/main/resources/job_kafka_2_jdbc_kms-team-proc.json
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/flink-cdc-kafka-source-task/src/main/resources/jdbcs/task-dev.properties
The file was modified src/streaming-event-platform/flink-event-job-web-api/src/main/java/com/bcxin/flink/event/job/web/apis/controllers/responses/JdbcResponse.java
The file was modified src/streaming-event-platform/event-tasks/flink-cdc-kafka-source-task/src/main/resources/jdbcs/task-test2.properties
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/docs/tableTask-Conf/TableTaskConf_\345\256\236\346\227\266\345\275\222\351\233\206\344\274\201\344\270\232-\351\251\273\345\213\244-\351\251\273\345\213\244\344\272\272\345\221\230-\344\272\272\345\221\230\344\277\241\346\201\257.json"
The file was modified "src/streaming-event-platform/docs/tableTask-Conf/com-prod/station-person-count/TableTaskConf_\345\256\236\346\227\266\345\275\222\351\233\206\344\274\201\344\270\232-\351\251\273\345\213\244-\351\251\273\345\213\244\344\272\272\345\221\230-\344\272\272\345\221\230\344\277\241\346\201\257.json"
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/preprod/shopping-account.json
The file was modified src/streaming-event-platform/event-tasks/flink-streaming-computing-task/src/main/resources/job_kafka_2_jdbc_kms-team.json
The file was modified src/streaming-event-platform/docs/tableTask-Conf/com-prod/station-person-count/MetaConf.json
The file was modified src/streaming-event-platform/docs/tableTask-Conf/com-prod/station-person-count/flinkjob.sql
The file was modified "src/streaming-event-platform/docs/tableTask-Conf/com-prod/company/TableTaskConf_\345\256\236\346\227\266\345\275\222\351\233\206\344\274\201\344\270\232\344\277\241\346\201\257.json"
The file was modified "src/streaming-event-platform/docs/scripts/\345\220\214\346\227\266\346\266\210\350\264\271\345\244\232\350\241\250\347\232\204\344\273\273\345\212\241\345\217\202\346\225\260"
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/preprod/removed/employees.json
The file was modified "src/streaming-event-platform/docs/scripts/\351\251\273\345\213\244\344\277\241\346\201\257\344\273\273\345\212\241\345\217\202\346\225\260"
The file was modified src/streaming-event-platform/docs/tableTask-Conf/com-prod/station-person-deprecated/MetaConf.json
The file was modified "src/streaming-event-platform/docs/\345\217\202\346\225\260"
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/com-prod/removed/user-credential-details.json
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/preprod/removed/shopping-product.json
The file was modified src/streaming-event-platform/event-tasks/flink-streaming-table-task/src/main/resources/jdbcs/task-com-prod.properties
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/local/employees.json
The file was modified src/streaming-event-platform/event-tasks/flink-data-webhook-task/src/main/resources/jdbcs/task-te.properties
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/preprod/removed/user-credential-details.json
The file was modified src/streaming-event-platform/event-tasks/flink-cdc-kafka-source-task/src/main/resources/datasource-default.properties
The file was modified src/streaming-event-platform/docs/tableTask-Conf/com-prod/company/MetaConf.json
The file was modified src/streaming-event-platform/log.file.3
The file was modified "src/streaming-event-platform/docs/tableTask-Conf/com-prod/TableTaskConf_\345\256\236\346\227\266\345\275\222\351\233\206\344\274\201\344\270\232-\351\251\273\345\213\244-\351\251\273\345\213\244\344\272\272\345\221\230-\344\272\272\345\221\230\344\277\241\346\201\257.json"
The file was modified src/streaming-event-platform/event-tasks/flink-cdc-dispatch-task/src/main/resources/jdbcs/task-com-prod.properties
The file was modified src/streaming-event-platform/docs/tableTask-Conf/com-prod/MetaConf.json
The file was modified src/streaming-event-platform/event-tasks/flink-cdc-kafka-source-task/src/main/resources/datasource-obpm2.properties
The file was modified src/streaming-event-platform/event-tasks/flink-streaming-computing-task/src/main/resources/jdbcs/task-te.properties
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/test2/user.json
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/com-prod/removed/employees.json
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/preprod/salary-manage.json
The file was modified src/streaming-event-platform/event-core/src/main/java/com/bcxin/event/core/definitions/JdbcDefinition.java
The file was modified "src/streaming-event-platform/docs/tableTask-Conf/com-prod/station-person-deprecated/TableTaskConf_\345\256\236\346\227\266\345\275\222\351\233\206\344\274\201\344\270\232-\351\251\273\345\213\244-\351\251\273\345\213\244\344\272\272\345\221\230-\344\272\272\345\221\230\344\277\241\346\201\257.json"
The file was modified src/streaming-event-platform/event-core/src/main/java/com/bcxin/event/core/JdbcParameterDTO.java
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/com-prod/shopping-account.json
The file was modified src/streaming-event-platform/event-tasks/flink-cdc-kafka-source-task/src/main/resources/jdbcs/task-com-prod.properties
The file was modified src/streaming-event-platform/docs/tableTask-Conf/com-prod/employees/flinkjob.sql
The file was modified src/streaming-event-platform/docs/flink-standalone/sql-client/kafka-user-credential-sink-dwd-user-info
The file was modified src/streaming-event-platform/docs/db/flink-jobs.sql
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/com-prod/user.json
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/com-prod/removed/shopping-product.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/resources/configs/test2/removed/user-credential-details.json
The file was modified src/streaming-event-platform/docs/cdc/flink-jobs.sql
The file was modified src/streaming-event-platform/event-tasks/flink-streaming-computing-task/src/main/resources/job_kafka_2_jdbc_tenant_users.json
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/preprod/removed/company.json
The file was modified src/streaming-event-platform/event-core/src/main/java/com/bcxin/event/core/definitions/JdbcConnectorDefinition.java
The file was modified src/streaming-event-platform/event-tasks/flink-streaming-computing-task/src/main/java/com/bcxin/flink/streaming/computing/task/StreamingJobApp.java
The file was modified src/streaming-event-platform/event-tasks/flink-cdc-kafka-source-task/src/main/resources/jdbcs/task-preprod.properties
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/DbStreamCdcJobAbstract.java
The file was modified src/streaming-event-platform/docs/cdc/com-prod/flink-jobs.sql
The file was modified src/streaming-event-platform/flink-event-job-web-api/src/main/java/com/bcxin/flink/event/job/web/apis/controllers/SourceSinkController.java
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/test2/removed/company.json
The file was modified src/streaming-event-platform/event-tasks/flink-cdc-dispatch-task/src/main/java/com/bcxin/flink/cdc/dispatch/task/proerpties/CdcDatabaseSourceProperty.java
The file was modified src/streaming-event-platform/docs/scripts/flinkJob.db.sql
The file was modified src/streaming-event-platform/event-tasks/flink-streaming-computing-task/src/main/resources/job_kafka_2_jdbc.json
The file was modified src/streaming-event-platform/docs/scripts/com-prod/flinkJob.db.sql
The file was modified src/streaming-event-platform/docs/tableTask-Conf/MetaConf.json
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/preprod/user.json
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/test2/removed/employees.json
The file was modified src/streaming-event-platform/event-tasks/flink-streaming-computing-task/src/main/resources/job-02.json
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-table-task/src/main/resources/configs/com-prod/db.properties
The file was modified src/streaming-event-platform/event-tasks/flink-cdc-dispatch-task/src/main/resources/jdbcs/task-te.properties
The file was modified src/streaming-event-platform/docs/flink-standalone/env/log4j.properties
The file was modified src/streaming-event-platform/docs/tableTask-Conf/com-prod/employees/MetaConf.json
The file was modified src/streaming-event-platform/flink-streaming-core/src/main/java/com/bcxin/flink/streaming/cores/JdbcJobExecutorUtil.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/proerpties/CdcDatabaseSourceProperty.java
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/com-prod/removed/company.json
The file was modified src/streaming-event-platform/event-tasks/flink-streaming-computing-task/src/main/resources/job.json
The file was modified src/streaming-event-platform/docs/tableTask-Conf/com-prod/station-person-deprecated/flinkjob.sql
Commit 421c7a63c5f248bcbd115ab5b6e8a3cf3b383de8 by linhancheng
修改serverTimeZone到ConnectTimeZone后修复变量问题
The file was modified src/streaming-event-platform/event-core/src/main/java/com/bcxin/event/core/JdbcParameterDTO.java
The file was modified src/streaming-event-platform/event-jobs/event-job-domain/src/main/java/com/bcxin/event/job/domain/services/impls/JdbcDefinitionServiceImpl.java
The file was modified src/streaming-event-platform/event-tasks/flink-streaming-computing-task/src/main/java/com/bcxin/flink/streaming/computing/task/StreamingJobApp.java
The file was modified src/streaming-event-platform/event-core/src/main/java/com/bcxin/event/core/definitions/JdbcDefinition.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/DbStreamCdcJobAbstract.java
The file was modified src/streaming-event-platform/flink-event-job-web-api/src/main/java/com/bcxin/flink/event/job/web/apis/controllers/SourceSinkController.java
The file was modified src/streaming-event-platform/event-tasks/flink-cdc-dispatch-task/src/main/java/com/bcxin/flink/cdc/dispatch/task/jobs/Binlog2DispatchCdcJob.java
The file was modified src/streaming-event-platform/event-jobs/event-job-domain/src/main/java/com/bcxin/event/job/domain/entities/JdbcDefinitionEntity.java
Commit fee6ab28fcd8cd89b360181334609538e22b85f5 by linhancheng
调整连接timezone
The file was removedsrc/streaming-event-platform/log.file
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/DbStreamCdcJobAbstract.java
Commit ae671c7134d34d832db99fade018f80a9b573555 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/StartupOptionUtil.java
Commit ae636a2e583847f5c8d1c7e0cb94231bfd2f54e8 by subingcheng
1
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/test2/shopping-account.json
Commit 05b0e538cce61e34ccca610756b0e0930b3ac49e by daiqincheng
proc_sync_attendance_REALITY_update_by_tenant_user_credentials参数错误
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/preprod/user.json
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/test2/user.json
Commit ecc64576e3fe201dccbfcd366d5a08cd6cd68fff by 1442819348
硬件归集提交
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/test2/shopping-account.json
Commit 730c15f5f906466345fec7845610e859b89284b7 by 1442819348
修改配置
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/test2/shopping-account.json
Commit d6ce86de2aa84f5c2774798f9b61d042c7e1210c by 1442819348
修改配置
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/test2/shopping-account.json
Commit eaedda54658224408e8e21fbfe67e9d717e34edc by 1442819348
修改硬件的sql
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/test2/shopping-account.json
Commit 81e0c5099970befbb41c8abdf72b066bbc7c33d6 by linhancheng
调整私网IP
The file was modified src/streaming-event-platform/log.file
The file was modified src/streaming-event-platform/event-tasks/flink-cdc-kafka-source-task/src/main/resources/jdbcs/task-test2.properties
Commit 13b6eb8f4c5a6579818f610828694565a753461e by linhancheng
调整为私网IP
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/test2/removed/user-credential-details.json
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/test2/removed/company.json
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/test2/others.json
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/test2/removed/shopping-product.json
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/test2/user.json
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/test2/salary-manage.json
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/test2/removed/employees.json
Commit dc083d7f3769afa58b2c201bfd0963ea1ec57813 by daiqincheng
公司监管机构变更入离职记录domanid归集
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/com-prod/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/preprod/others.json
Commit c82a2b59108b0db9dd1257d6d1673cd31c5369e5 by linhancheng
测试环境采用内网IP地址
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-table-task/src/main/resources/configs/test2/db.properties
Commit a4eca23c895ba2e0febe37d7f970a4d98a0d6e60 by linhancheng
归集用户模型
The file was added"src/streaming-event-platform/docs/20250107/\347\224\250\346\210\267\346\250\241\345\236\213.md"
The file was addedsrc/streaming-event-platform/docs/20250107/README
The file was addedsrc/streaming-event-platform/docs/20250107/flinksql.sql
Commit d5e1f0e31db8ee06600d5e66f4972c3dc0ecea08 by 1442819348
增加跨区字段归集到公司表
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/test2/others.json
Commit 474ae6bd1a231f431f1e91891f53cbf843b57023 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/jobs/DbStreamCdcJobAbstract.java
Commit d915430b0dcfd6a7e257a8a9f1db413112864ed1 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/cdcs/CdcSourceMeta.java
Commit b8033d26c5a96211cff6d759f8c740a13da119e9 by linhancheng
xxxxxxxx
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 0386178e4536df2aa8172136ec1f9d176a0e7765 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/jobs/DbStreamCdcJobAbstract.java
Commit 0df9d3defe6292cfcd25ab95f96a46e4d4f49817 by linhancheng
测试环境重启先取30分钟前数据
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/DbStreamCdcJobAbstract.java
Commit 90427e0a16deefb582f15306baee3bdbfd70b9fe 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/jobs/DbStreamCdcJobAbstract.java
The file was modified src/streaming-event-platform/event-tasks/flink-cdc-kafka-source-task/src/main/resources/jdbcs/task-dev.properties
Commit cd01fdc0b18f9ac44f5f37e21f8b0be8a84a1d0d 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/properties/DataEtcConfigProperty.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/java/com/bcxin/tenant/data/etc/tasks/jobs/DataJobAbstract.java
The file was addedsrc/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/com-prod/jc-info-sync.json
The file was addedsrc/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/test2/jc-info-sync.json
Commit 23ccf3f0617b9f38f5f27b288f9afc5eda2693d0 by daiqincheng
修改启动命令
The file was modified src/streaming-event-platform/docs/flink-standalone/env/tests/start-flink-jobs.sh
The file was modified src/streaming-event-platform/docs/flink-standalone/env/com-prod/start-flink-jobs.sh
Commit 33d1082e08b552041af543b97a648b46f0c3fa2d 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 1128a342094339b6d4275e9780f13e1da9661c77 by linhancheng
启动jc flink
The file was addedsrc/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/jc-prod/jc-start-flink-jobs.sh
The file was addedsrc/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/jc-prod/flink-point.properties
The file was removedsrc/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/com-prod/jc-info-sync.json
The file was addedsrc/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/jc-prod/jc-info-sync.json
Commit 94f1e2b074c621ceb640548a4a51007156b247ad by linhancheng
调整晋城的参数信息
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/jc-prod/jc-start-flink-jobs.sh
The file was addedsrc/streaming-event-platform/event-tasks/flink-cdc-kafka-source-task/src/main/resources/jdbcs/task-jc-prod.properties
Commit 306591e9b178196ea71d8d30a576c067b6619bf9 by linhancheng
调整配置信息
The file was addedsrc/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/jc-prod/others.json
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/jc-prod/jc-start-flink-jobs.sh
The file was addedsrc/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/jc-prod/user.json
Commit 6ce728cbfc12fff3a6873306e66829e82d48e6d9 by linhancheng
原始晋城的flink配置
The file was addedsrc/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/jc-prod/flink-conf.yaml
Commit 7bdc12c4a2cbda0eeb101ad48c5be0997a7632e8 by linhancheng
调整参数
The file was modified src/streaming-event-platform/event-tasks/flink-cdc-kafka-source-task/src/main/resources/jdbcs/task-jc-prod.properties
Commit 944e65f71cae838b6538b87fa31f1df27474197c by linhancheng
初始化晋城信息
The file was addedsrc/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/jc-prod/init-kafka.sh
Commit 6f792946e6d9d54e4e14a1f98396375a898b4083 by linhancheng
嘻嘻嘻
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/jc-prod/init-kafka.sh
Commit 1ef31651a1273664217db558a746afd2365ed891 by linhancheng
电子围栏产生站内信
The file was addedsrc/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/jc-prod/message.json
The file was addedsrc/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/test2/start-flink-jobs.sh
The file was addedsrc/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/test2/message.json
Commit 86c326afea8d7aea15729f4906417b74daf2a776 by linhancheng
电子围栏产生站内信
The file was addedsrc/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/test2/start-flink-jobs.sh
The file was addedsrc/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/test2/message.json
The file was addedsrc/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/jc-prod/message.json
Commit 90198cf65af6a37d5b26bc5499823c0835665f97 by linhancheng
嘻嘻嘻
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/test2/message.json
Commit c888e62ec934b2725b1755baeebeaeac3db55c37 by linhancheng
嘻嘻嘻
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/test2/message.json
Commit d528156be57c0ee4634a9860f8a5a96b96633c93 by daiqincheng
修改监管变更入离职记录问题
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/jc-prod/others.json
Commit 58cf906fb0870fdc2fae2e8d301a1734857ad22a by daiqincheng
去掉商城相关
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/jc-prod/user.json
Commit e8e44221bf4afbcf10356c116e87446750c83da2 by linhancheng
调整晋城的数据归集
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/jc-prod/others.json
Commit b71294b989eefe40cb95b4f20c63701c597a1714 by linhancheng
线索上报告知监管归属的民警
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/test2/message.json
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/jc-prod/message.json
Commit c3a8735f8862a6dd3ec78200af86c162382b9e49 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
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 369945f410f22dc85f861a0b23c62b42273c8abf by linhancheng
调整晋城的部署方式
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/jc-prod/jc-start-flink-jobs.sh
Commit 5ca9ac4edc7226792f086552ed7697cfd123b67b by linhancheng
调整消息格式
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/jc-prod/message.json
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/test2/message.json
Commit bb42d6d9f2b333539c57e6248636484ba3e843e4 by linhancheng
xxxxxxx
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/jc-prod/user.json
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 2419808365fa6916645bf9d16ddf7bccb42950d7 by linhancheng
消息内容
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/test2/message.json
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/jc-prod/message.json
Commit 0a17913f7772443c8b7c4dbb09c08247eacefca2 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
Commit e43edba8bdc2addda6109b648bfe5d349f3128ab by linhancheng
调整消息内容
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/jc-prod/message.json
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/test2/message.json
Commit d1d010930b6e6450fdbc1245915e216612278d74 by linhancheng
调整企业归集信息
The file was addedsrc/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/jc-prod/companyinfo.json
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/jc-prod/user.json
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/jc-prod/jc-start-flink-jobs.sh
Commit e8d76b1574fee4ec07ae53f46771e9f3bde94725 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/flink-streaming-core/src/main/java/com/bcxin/flink/streaming/cores/utils/KafkaUtils.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 d96f0219eb8157bb404db8f88ada48ec9ca199bd by linhancheng
调整消息内容
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/jc-prod/user.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
Commit 482bd27eefd83990fc5ec8e87981264684215737 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/DataJobAbstract.java
Commit 669854d97d212459b7b84c1d67cb807ac0fc48a6 by linhancheng
签到数据同步至巡防任务的表
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/test2/message.json
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/jc-prod/message.json
Commit add297166db57de8c3cdfffe885027a4738cda9f by linhancheng
消息触发
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/test2/message.json
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/jc-prod/message.json
Commit ac93a5d61adbd829de17bd01e972595091d66e88 by linhancheng
同步赚取积分
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/jc-prod/message.json
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/test2/message.json
Commit 6f40ff453f9ba3deb8087b3b3b21b0dcf52e4690 by linhancheng
调整反馈积分信息
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/test2/message.json
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/jc-prod/message.json
Commit 5745823f165284665cf7cc60d4d5e4a7b99bda15 by linhancheng
巡防任务功能
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/test2/message.json
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/jc-prod/message.json
Commit 478a37003c13d30ae633e4b9a1e3cb51440bf453 by linhancheng
赚取积分问题
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/jc-prod/message.json
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/test2/message.json
Commit 4d013ef07ccc6d253c55541876faca2f6f9ac4c3 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/components/BinlogRawValue.java
Commit 58e7acf5d49391a3bebbe019599df309fe47141e 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/DataJobAbstract.java
Commit 206f738981144ab8a4caa4a8d4f82f63e2952685 by linhancheng
调整checkpoint
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 0b1d49efbdb42b8616e2ef285f645066ed877f13 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/components/CustomJdbcOutputFormat.java
Commit 104ff73241ad2b1e4f92eae90da7ac40ce280a52 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
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 753be8ab102bd9e377eecb6803acab8aa9e727b3 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
Commit 7f6f167201375df63e9fe48d2b2942a33a451173 by linhancheng
提交重试操作
The file was addedsrc/streaming-event-platform/event-core/src/main/java/com/bcxin/event/core/exceptions/RetryEventException.java
The file was added"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"
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 addedsrc/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
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/java/com/bcxin/tenant/data/etc/tasks/components/BinlogRawValue.java
Commit 5d660147bbf3683e35aadd7980de8688815f750c 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 2d57f75bcc7ebbf79123df27be193ff8072dabe0 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
Commit 34f417416f188358f6ec7a9fe6aba13492917066 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
Commit 1b1eb51e383abcb78509e4b79941d86a3be5480a by linhancheng
hotfix: 调整重试机制及异常处理方式
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 1c3d20f006de292c51af04020aff291e038068ad 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 082536d41ade417973bca9fd9f2542e4e10d4a63 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
Commit cbe81ce5584d1ff75276af474ef85039d28d1b66 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 e19716ddcd90bddbe32129fc5502758b7d28cdc3 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
Commit 5c9911f633e2f1734477bd8fdc47fc184ccb0876 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
Commit 09da6e642289d4d694545d147bca3c51a9525bae 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/DataSourceUtil.java
Commit d7efe99071967b4bb386d3dfbdc1d4d3dc9db671 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/components/DataSourceUtil.java
Commit 43a897d09198b260aec396372e033732618a8934 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/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/components/CustomJdbcOutputFormat.java
The file was addedsrc/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/java/com/bcxin/tenant/data/etc/tasks/components/impls/CustomJdbcAcceptPreparedStatementParameterImpl.java
The file was addedsrc/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/java/com/bcxin/tenant/data/etc/tasks/components/CustomJdbcOutputFormatParameterWrapper.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/CustomJdbcAcceptPreparedStatementParameter.java
Commit 8e84dd73ebf19724aa114ec2a501f756828ffab6 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
Commit b4c500f34b2e943dcc754ac3cdb85145bed6cec5 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
The file was addedsrc/streaming-event-platform/event-core/src/main/java/com/bcxin/event/core/exceptions/AffectedEventException.java
The file was modified src/streaming-event-platform/event-core/src/main/java/com/bcxin/event/core/utils/RetryUtil.java
Commit d4e814a33c4c2543ad0774a6c6f54e03696a9e1f 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
Commit 5191facb99e844014dfb96b7996a6c3948f0da8f 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 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-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-core/src/main/java/com/bcxin/event/core/utils/RetryUtil.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/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/components/CustomJdbcOutputFormat.java
Commit 8fee16d39d897a44ebc57f853b5786d10b2e2c61 by linhancheng
hotfix: 添加记录重试日志步骤
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 c9e1ec56f8c55d341b84c56b32278d1f166cf222 by linhancheng
调整归集日志结构
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"
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 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"
Commit d0ee1aa488f4bdc337bb0d959e7573b8a5deec8c 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 1755b512d849274a8d00bfc7a46df8b96b273d66 by linhancheng
调整归集商城功能
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/com-prod/shopping-account.json
Commit 397e37591fe1135a9a5c4fcf54ba88fae6b96668 by daiqincheng
添加累计未持证归集
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/test2/user.json
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/com-prod/user.json
Commit ce8d2d482e122cbe277d870fcf8e84aa4e82521a by daiqincheng
添加累计未持证归集
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/com-prod/user.json
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/test2/user.json
Commit e8be449c6c0e38d11ddfd0eae5bb4099c07b1cf9 by daiqincheng
添加签章状态归集
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/com-prod/user.json
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/test2/user.json
Commit b30a1e09e5ad4c024a286a820467ef0ed6a817b3 by daiqincheng
添加签章状态归集
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/com-prod/user.json
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/test2/user.json
Commit d6815dd58781a7555fa12dc43560fee3b0d6023c by daiqincheng
累计未持证存储过程添加公司类型判断
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/com-prod/user.json
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/test2/user.json
Commit e77d584856bb3664b6b4bae0a0358e77ec4d327c by daiqincheng
累计未持证存储过程添加公司类型判断
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/test2/user.json
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/com-prod/user.json
Commit 2692b9362b6718943a1c8b7c849b538abb58203d by zhongxuefeng
证书详情同步签章证书表操作脚本修改
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/com-prod/user.json
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/test2/user.json
Commit 2ade6000656f155ada44f952f5e5dc91732178bf by zhongxuefeng
脚本增加库名
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/test2/user.json
Commit 07516228edac5b14fe4ccf18b8770fdb2099a670 by zhongxuefeng
修改证书详情同步签章证书表操作查询脚本
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/com-prod/user.json
Commit 0b255968a0243ee7aa646d1e29b47357847f6d80 by zhongxuefeng
修改脚本联立
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/test2/user.json
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-task/src/main/resources/configs/com-prod/user.json
Commit 012b46d3eae1793c4a479d020a56e685e8cd3353 by linhancheng
添加输出序列化的日志
The file was modified src/streaming-event-platform/event-core/src/main/java/com/bcxin/event/core/JsonProviderImpl.java
Commit 653f826d3766c2943d941500d0c803a502d941ad by 1442819348
监听体检虚拟订单
The file was addedsrc/streaming-event-platform/event-tasks/tenant-data-etc-table-task/src/main/resources/configs/test2/shopping-order-webhook-checkup.json
Commit d79577ae2da45b41ada407c1337069095a981ea5 by 1442819348
体检虚拟订单监听
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-table-task/src/main/resources/configs/test2/shopping-order-webhook-checkup.json
Commit 8c9a496ce5a87f4d782da8062f5853cf51d83f90 by linhancheng
hotfix: 调整jobname
The file was modified src/streaming-event-platform/event-tasks/tenant-data-etc-table-task/src/main/java/com/bcxin/tenant/data/etc/table/tasks/EtcTableApp.java