重现步骤

[步骤]

dolphinscheduler-worker-cdc-5.dolphinscheduler-worker-cdc-headless.zhcxkj-dolphinscheduler.svc.cluster.local
dolphinscheduler-worker-cdc-5.dolphinscheduler-worker-cdc-headless.zhcxkj-dolphinscheduler.svc.cluster.local
dolphinscheduler-worker-cdc-1.dolphinscheduler-worker-cdc-headless.zhcxkj-dolphinscheduler.svc.cluster.local
dolphinscheduler-worker-cdc-5.dolphinscheduler-worker-cdc-headless.zhcxkj-dolphinscheduler.svc.cluster.local
dolphinscheduler-worker-cdc-5.dolphinscheduler-worker-cdc-headless.zhcxkj-dolphinscheduler.svc.cluster.local
dolphinscheduler-worker-cdc-5.dolphinscheduler-worker-cdc-headless.zhcxkj-dolphinscheduler.svc.cluster.local
dolphinscheduler-worker-cdc-5.dolphinscheduler-worker-cdc-headless.zhcxkj-dolphinscheduler.svc.cluster.local
dolphinscheduler-worker-cdc-5.dolphinscheduler-worker-cdc-headless.zhcxkj-dolphinscheduler.svc.cluster.local
dolphinscheduler-worker-cdc-5.dolphinscheduler-worker-cdc-headless.zhcxkj-dolphinscheduler.svc.cluster.local
dolphinscheduler-worker-cdc-5.dolphinscheduler-worker-cdc-headless.zhcxkj-dolphinscheduler.svc.cluster.local
dolphinscheduler-worker-cdc-5.dolphinscheduler-worker-cdc-headless.zhcxkj-dolphinscheduler.svc.cluster.local
dolphinscheduler-worker-cdc-5.dolphinscheduler-worker-cdc-headless.zhcxkj-dolphinscheduler.svc.cluster.local
dolphinscheduler-worker-cdc-1.dolphinscheduler-worker-cdc-headless.zhcxkj-dolphinscheduler.svc.cluster.local
dolphinscheduler-worker-cdc-5.dolphinscheduler-worker-cdc-headless.zhcxkj-dolphinscheduler.svc.cluster.local
dolphinscheduler-worker-cdc-5.dolphinscheduler-worker-cdc-headless.zhcxkj-dolphinscheduler.svc.cluster.local
dolphinscheduler-worker-cdc-5.dolphinscheduler-worker-cdc-headless.zhcxkj-dolphinscheduler.svc.cluster.local


(@1 int,@2 int)SELECT [ID],[CustomerID],[OrderSourceID],[OrderSourceSKU],[SKU],[SalesNum],[SalesYear],[SalesMonth],[OrderNum],[DaySales],[WareHouseID],[EstimatedSalesNum],getdate() [StarRocksUpdateTime] FROM [rb_report_ordersourceskumonth](nolock) WHERE @1<=[ID] AND [ID]<@2
(@1 int,@2 int)SELECT [ID],[CustomerID],[OrderSourceID],[OrderSourceSKU],[SKU],[SalesNum],[SalesYear],[SalesMonth],[OrderNum],[DaySales],[WareHouseID],[EstimatedSalesNum],getdate() [StarRocksUpdateTime] FROM [rb_report_ordersourceskumonth](nolock) WHERE @1<=[ID] AND [ID]<@2
(@1 int,@2 int)SELECT [ID],[CustomerID],[OrderSourceID],[OrderSourceSKU],[SKU],[SalesNum],[SalesYear],[SalesMonth],[OrderNum],[DaySales],[WareHouseID],[EstimatedSalesNum],getdate() [StarRocksUpdateTime] FROM [rb_report_ordersourceskumonth](nolock) WHERE @1<=[ID] AND [ID]<@2
(@1 int,@2 int)SELECT [ID],[CustomerID],[OrderSourceID],[OrderSourceSKU],[SKU],[SalesNum],[SalesYear],[SalesMonth],[OrderNum],[DaySales],[WareHouseID],[EstimatedSalesNum],getdate() [StarRocksUpdateTime] FROM [rb_report_ordersourceskumonth](nolock) WHERE @1<=[ID] AND [ID]<@2
(@1 int,@2 int)SELECT [ID],[CustomerID],[OrderSourceID],[OrderSourceSKU],[SKU],[SalesNum],[SalesYear],[SalesMonth],[OrderNum],[DaySales],[WareHouseID],[EstimatedSalesNum],getdate() [StarRocksUpdateTime] FROM [rb_report_ordersourceskumonth](nolock) WHERE @1<=[ID] AND [ID]<=@2


select [Id],[CustomerID],[OrderCode],[SKU],[SupplierID],[WarehouseID],[SingleNo],[SingleDetailID],[P_Code],[TrackingNumber],[PackageWeight],[AbnormalLink],[AbnormalType],[AbnormalReasonID],[AbnormalReason],[AbnormalNumber],[AbnormalWarehouseID],[AbnormalPositionID],[HandleMethodID],[ProcedueID],[ConfirmTime],[NodeInProcessing],[OrderStatus],[OvertimeTag],[CompleteTime],[IsCompleteNormal],[IsNeedProcurementResponse],[AbnormalRegisterType],[Remark],[PurchaseAdminID],[MerchandiserAdminID],[PutonAdminID],[PersonDistributePlanID],[AddTime],[AddAdminID],[AddAdminName],[LastUpdateAdminID],[LastUpdateTime],[LastUpdateAdminName],[ProcessAbnormalPerson],[AlibaRefundOrderNo],[AlibaRefundOrderStatus],[RefundAmount],[SyncToSupplierStatus],[SupplierReplyHandleMethodID],[SupplierReplyRemark],getdate() StarRocksUpdateTime,[AbnormalDesc] from rb_procurementabnormal_orderinfo(nolock) where (CustomerId = 1) and  (1937922 <= Id AND Id < 2131714) 


select [Id],[CustomerID],[OrderCode],[SKU],[SupplierID],[WarehouseID],[SingleNo],[SingleDetailID],[P_Code],[TrackingNumber],[PackageWeight],[AbnormalLink],[AbnormalType],[AbnormalReasonID],[AbnormalReason],[AbnormalNumber],[AbnormalWarehouseID],[AbnormalPositionID],[HandleMethodID],[ProcedueID],[ConfirmTime],[NodeInProcessing],[OrderStatus],[OvertimeTag],[CompleteTime],[IsCompleteNormal],[IsNeedProcurementResponse],[AbnormalRegisterType],[Remark],[PurchaseAdminID],[MerchandiserAdminID],[PutonAdminID],[PersonDistributePlanID],[AddTime],[AddAdminID],[AddAdminName],[LastUpdateAdminID],[LastUpdateTime],[LastUpdateAdminName],[ProcessAbnormalPerson],[AlibaRefundOrderNo],[AlibaRefundOrderStatus],[RefundAmount],[SyncToSupplierStatus],[SupplierReplyHandleMethodID],[SupplierReplyRemark],getdate() StarRocksUpdateTime,[AbnormalDesc] from rb_procurementabnormal_orderinfo(nolock) where (CustomerId = 1) and  (775170 <= Id AND Id < 968962) 


select [Id],[CustomerID],[OrderCode],[SKU],[SupplierID],[WarehouseID],[SingleNo],[SingleDetailID],[P_Code],[TrackingNumber],[PackageWeight],[AbnormalLink],[AbnormalType],[AbnormalReasonID],[AbnormalReason],[AbnormalNumber],[AbnormalWarehouseID],[AbnormalPositionID],[HandleMethodID],[ProcedueID],[ConfirmTime],[NodeInProcessing],[OrderStatus],[OvertimeTag],[CompleteTime],[IsCompleteNormal],[IsNeedProcurementResponse],[AbnormalRegisterType],[Remark],[PurchaseAdminID],[MerchandiserAdminID],[PutonAdminID],[PersonDistributePlanID],[AddTime],[AddAdminID],[AddAdminName],[LastUpdateAdminID],[LastUpdateTime],[LastUpdateAdminName],[ProcessAbnormalPerson],[AlibaRefundOrderNo],[AlibaRefundOrderStatus],[RefundAmount],[SyncToSupplierStatus],[SupplierReplyHandleMethodID],[SupplierReplyRemark],getdate() StarRocksUpdateTime,[AbnormalDesc] from rb_procurementabnormal_orderinfo(nolock) where (CustomerId = 1) and  (581378 <= Id AND Id < 775170) 


select [ID],[CustomerID],[OrderSourceID],[ShipmentId],[SellerSKU],[FulfillmentNetworkSKU],[QuantityShipped],[QuantityReceived],[QuantityInCase],[AddTime],[IsOver],getdate() StarRocksUpdateTime from rb_fba_shipmentdetail(nolock) where (CustomerID = 1) and  (13650955 <= ID AND ID < 14701018) 
select [ID],[Country],[CustomerID],[SKU],[BrowseNodeName],[BrowsePathByID],[ParentBrowsePathByID],[IsPlatformShelf],[IsSystemCollect],[IsManualChoose],[IsCompetitiveCollect],[IsDelete],[AddTime],[UpdateTime],[IsRecommend],[IsMain],[DataSource],[IsAI],[IsAC],getdate() StarRocksUpdateTime from e_product_amazon_browsetree (nolock) where (ID > 18000000) and  (20093853 <= ID AND ID < 20617316) 
select [ID],[OrderCode],[CustomerID],[DeliveryCode],[ThirdPartyLogistics],[TrackingNoBOL],[PredFreight],[UpdateTime],getdate() StarRocksUpdateTime from rb_orderinfo_expand (nolock) where (CustomerID = 1) and  (7539329 <= id AND id < 8481745) 
select [ID],[OrderCode],[CustomerID],[DeliveryCode],[ThirdPartyLogistics],[TrackingNoBOL],[PredFreight],[UpdateTime],getdate() StarRocksUpdateTime from rb_orderinfo_expand (nolock) where (CustomerID = 1) and  (10366576 <= id AND id < 11308991) 
select [ID],[OrderCode],[CustomerID],[DeliveryCode],[ThirdPartyLogistics],[TrackingNoBOL],[PredFreight],[UpdateTime],getdate() StarRocksUpdateTime from rb_orderinfo_expand (nolock) where (CustomerID = 1) and  (9424161 <= id AND id < 10366576) 

[结果]


[期望]

降低同步并发量，减少同步数据的范围 9424161 <= id AND id < 10366576 单次都是百万级别的 长时间占用 资源 慢 
历史记录  
  1. 2026-08-07 13:59:12, 由 袁慧斌 创建。
  2. 2026-08-07 14:29:21, 由 李乐同 指派给 吴茵杰。
    修改了 指派给，旧值为 "liletong"，新值为 "wuyinjie"。
  3. 2026-08-07 15:45:01, 由 吴茵杰 解决，方案为 性能问题 。
    修改了 解决方案，旧值为 ""，新值为 "performance"。
    修改了 解决日期，旧值为 ""，新值为 "2026-08-07 15:43:58"。
    修改了 指派给 ，旧值为 "wuyinjie"，新值为 "yuanhuibin"。
    修改了 Bug状态 ，旧值为 "active"，新值为 "resolved"。
    修改了 是否确认，旧值为 "0"，新值为 "1"。
    修改了 解决者 ，旧值为 ""，新值为 "wuyinjie"。
    已调整增量

    rb_procurementabnormal_orderinfo
    rb_fba_shipmentdetail (库存表调整ID范围,CustomerID = 1去掉)
    rb_orderinfo_expand 

  4. 2026-08-10 17:49:11, 由 袁慧斌 编辑。
    修改了 开发责任人，旧值为 ""，新值为 "wuyinjie"。
    修改了 测试责任人，旧值为 ""，新值为 "admin"。
    修改了 解决时效 ，旧值为 "0"，新值为 "1.75"。
    修改了 截止日期 ，旧值为 "0000-00-00"，新值为 "2026-08-07"。
    修改了 重现步骤 ，区别为：
    002- dolphinscheduler-worker-cdc-5.dolphinscheduler-worker-cdc-headless.zhcxkj-dolphinscheduler.svc.cluster.localdolphinscheduler-worker-cdc-5.dolphinscheduler-worker-cdc-headless.zhcxkj-dolphinscheduler.svc.cluster.localdolphinscheduler-worker-cdc-1.dolphinscheduler-worker-cdc-headless.zhcxkj-dolphinscheduler.svc.cluster.localdolphinscheduler-worker-cdc-5.dolphinscheduler-worker-cdc-headless.zhcxkj-dolphinscheduler.svc.cluster.localdolphinscheduler-worker-cdc-5.dolphinscheduler-worker-cdc-headless.zhcxkj-dolphinscheduler.svc.cluster.localdolphinscheduler-worker-cdc-5.dolphinscheduler-worker-cdc-headless.zhcxkj-dolphinscheduler.svc.cluster.localdolphinscheduler-worker-cdc-5.dolphinscheduler-worker-cdc-headless.zhcxkj-dolphinscheduler.svc.cluster.localdolphinscheduler-worker-cdc-5.dolphinscheduler-worker-cdc-headless.zhcxkj-dolphinscheduler.svc.cluster.localdolphinscheduler-worker-cdc-5.dolphinscheduler-worker-cdc-headless.zhcxkj-dolphinscheduler.svc.cluster.localdolphinscheduler-worker-cdc-5.dolphinscheduler-worker-cdc-headless.zhcxkj-dolphinscheduler.svc.cluster.localdolphinscheduler-worker-cdc-5.dolphinscheduler-worker-cdc-headless.zhcxkj-dolphinscheduler.svc.cluster.localdolphinscheduler-worker-cdc-5.dolphinscheduler-worker-cdc-headless.zhcxkj-dolphinscheduler.svc.cluster.localdolphinscheduler-worker-cdc-1.dolphinscheduler-worker-cdc-headless.zhcxkj-dolphinscheduler.svc.cluster.localdolphinscheduler-worker-cdc-5.dolphinscheduler-worker-cdc-headless.zhcxkj-dolphinscheduler.svc.cluster.localdolphinscheduler-worker-cdc-5.dolphinscheduler-worker-cdc-headless.zhcxkj-dolphinscheduler.svc.cluster.localdolphinscheduler-worker-cdc-5.dolphinscheduler-worker-cdc-headless.zhcxkj-dolphinscheduler.svc.cluster.local
    002+ dolphinscheduler-worker-cdc-5.dolphinscheduler-worker-cdc-headless.zhcxkj-dolphinscheduler.svc.cluster.localdolphinscheduler-worker-cdc-5.dolphinscheduler-worker-cdc-headless.zhcxkj-dolphinscheduler.svc.cluster.localdolphinscheduler-worker-cdc-1.dolphinscheduler-worker-cdc-headless.zhcxkj-dolphinscheduler.svc.cluster.localdolphinscheduler-worker-cdc-5.dolphinscheduler-worker-cdc-headless.zhcxkj-dolphinscheduler.svc.cluster.localdolphinscheduler-worker-cdc-5.dolphinscheduler-worker-cdc-headless.zhcxkj-dolphinscheduler.svc.cluster.localdolphinscheduler-worker-cdc-5.dolphinscheduler-worker-cdc-headless.zhcxkj-dolphinscheduler.svc.cluster.localdolphinscheduler-worker-cdc-5.dolphinscheduler-worker-cdc-headless.zhcxkj-dolphinscheduler.svc.cluster.localdolphinscheduler-worker-cdc-5.dolphinscheduler-worker-cdc-headless.zhcxkj-dolphinscheduler.svc.cluster.localdolphinscheduler-worker-cdc-5.dolphinscheduler-worker-cdc-headless.zhcxkj-dolphinscheduler.svc.cluster.localdolphinscheduler-worker-cdc-5.dolphinscheduler-worker-cdc-headless.zhcxkj-dolphinscheduler.svc.cluster.localdolphinscheduler-worker-cdc-5.dolphinscheduler-worker-cdc-headless.zhcxkj-dolphinscheduler.svc.cluster.localdolphinscheduler-worker-cdc-5.dolphinscheduler-worker-cdc-headless.zhcxkj-dolphinscheduler.svc.cluster.localdolphinscheduler-worker-cdc-1.dolphinscheduler-worker-cdc-headless.zhcxkj-dolphinscheduler.svc.cluster.localdolphinscheduler-worker-cdc-5.dolphinscheduler-worker-cdc-headless.zhcxkj-dolphinscheduler.svc.cluster.localdolphinscheduler-worker-cdc-5.dolphinscheduler-worker-cdc-headless.zhcxkj-dolphinscheduler.svc.cluster.localdolphinscheduler-worker-cdc-5.dolphinscheduler-worker-cdc-headless.zhcxkj-dolphinscheduler.svc.cluster.local
    002- <p>dolphinscheduler-worker-cdc-5.dolphinscheduler-worker-cdc-headless.zhcxkj-dolphinscheduler.svc.cluster.local<br />dolphinscheduler-worker-cdc-5.dolphinscheduler-worker-cdc-headless.zhcxkj-dolphinscheduler.svc.cluster.local<br />dolphinscheduler-worker-cdc-1.dolphinscheduler-worker-cdc-headless.zhcxkj-dolphinscheduler.svc.cluster.local<br />dolphinscheduler-worker-cdc-5.dolphinscheduler-worker-cdc-headless.zhcxkj-dolphinscheduler.svc.cluster.local<br />dolphinscheduler-worker-cdc-5.dolphinscheduler-worker-cdc-headless.zhcxkj-dolphinscheduler.svc.cluster.local<br />dolphinscheduler-worker-cdc-5.dolphinscheduler-worker-cdc-headless.zhcxkj-dolphinscheduler.svc.cluster.local<br />dolphinscheduler-worker-cdc-5.dolphinscheduler-worker-cdc-headless.zhcxkj-dolphinscheduler.svc.cluster.local<br />dolphinscheduler-worker-cdc-5.dolphinscheduler-worker-cdc-headless.zhcxkj-dolphinscheduler.svc.cluster.local<br />dolphinscheduler-worker-cdc-5.dolphinscheduler-worker-cdc-headless.zhcxkj-dolphinscheduler.svc.cluster.local<br />dolphinscheduler-worker-cdc-5.dolphinscheduler-worker-cdc-headless.zhcxkj-dolphinscheduler.svc.cluster.local<br />dolphinscheduler-worker-cdc-5.dolphinscheduler-worker-cdc-headless.zhcxkj-dolphinscheduler.svc.cluster.local<br />dolphinscheduler-worker-cdc-5.dolphinscheduler-worker-cdc-headless.zhcxkj-dolphinscheduler.svc.cluster.local<br />dolphinscheduler-worker-cdc-1.dolphinscheduler-worker-cdc-headless.zhcxkj-dolphinscheduler.svc.cluster.local<br />dolphinscheduler-worker-cdc-5.dolphinscheduler-worker-cdc-headless.zhcxkj-dolphinscheduler.svc.cluster.local<br />dolphinscheduler-worker-cdc-5.dolphinscheduler-worker-cdc-headless.zhcxkj-dolphinscheduler.svc.cluster.local<br />dolphinscheduler-worker-cdc-5.dolphinscheduler-worker-cdc-headless.zhcxkj-dolphinscheduler.svc.cluster.local<br /></p>
    002+ <p>dolphinscheduler-worker-cdc-5.dolphinscheduler-worker-cdc-headless.zhcxkj-dolphinscheduler.svc.cluster.local<br />dolphinscheduler-worker-cdc-5.dolphinscheduler-worker-cdc-headless.zhcxkj-dolphinscheduler.svc.cluster.local<br />dolphinscheduler-worker-cdc-1.dolphinscheduler-worker-cdc-headless.zhcxkj-dolphinscheduler.svc.cluster.local<br />dolphinscheduler-worker-cdc-5.dolphinscheduler-worker-cdc-headless.zhcxkj-dolphinscheduler.svc.cluster.local<br />dolphinscheduler-worker-cdc-5.dolphinscheduler-worker-cdc-headless.zhcxkj-dolphinscheduler.svc.cluster.local<br />dolphinscheduler-worker-cdc-5.dolphinscheduler-worker-cdc-headless.zhcxkj-dolphinscheduler.svc.cluster.local<br />dolphinscheduler-worker-cdc-5.dolphinscheduler-worker-cdc-headless.zhcxkj-dolphinscheduler.svc.cluster.local<br />dolphinscheduler-worker-cdc-5.dolphinscheduler-worker-cdc-headless.zhcxkj-dolphinscheduler.svc.cluster.local<br />dolphinscheduler-worker-cdc-5.dolphinscheduler-worker-cdc-headless.zhcxkj-dolphinscheduler.svc.cluster.local<br />dolphinscheduler-worker-cdc-5.dolphinscheduler-worker-cdc-headless.zhcxkj-dolphinscheduler.svc.cluster.local<br />dolphinscheduler-worker-cdc-5.dolphinscheduler-worker-cdc-headless.zhcxkj-dolphinscheduler.svc.cluster.local<br />dolphinscheduler-worker-cdc-5.dolphinscheduler-worker-cdc-headless.zhcxkj-dolphinscheduler.svc.cluster.local<br />dolphinscheduler-worker-cdc-1.dolphinscheduler-worker-cdc-headless.zhcxkj-dolphinscheduler.svc.cluster.local<br />dolphinscheduler-worker-cdc-5.dolphinscheduler-worker-cdc-headless.zhcxkj-dolphinscheduler.svc.cluster.local<br />dolphinscheduler-worker-cdc-5.dolphinscheduler-worker-cdc-headless.zhcxkj-dolphinscheduler.svc.cluster.local<br />dolphinscheduler-worker-cdc-5.dolphinscheduler-worker-cdc-headless.zhcxkj-dolphinscheduler.svc.cluster.local</p>
  5. 2026-08-10 17:49:15, 由 袁慧斌 关闭。
    修改了 Bug状态 ，旧值为 "resolved"，新值为 "closed"。
    修改了 指派给 ，旧值为 "yuanhuibin"，新值为 "closed"。
    修改了 由谁关闭，旧值为 ""，新值为 "yuanhuibin"。
    修改了 关闭日期，旧值为 ""，新值为 "2026-08-10 17:49:15"。
返回
所属项目 技术中心-需求池
所属模块 系统运维   性能优化
所属计划
所属迭代
Bug类型
严重程度 严重
优先级 P1
Bug状态 已关闭
业务部门 技术研发中心
影响功能
开发责任人 吴茵杰
测试责任人 admin
解决时效 1.75
激活次数 0
激活日期
是否确认 是
当前指派 Closed 于 2026-08-10 17:49:15
截止日期 2026-08-07
上线时间 2026-08-07 18:30:00
上线时效 4.51
操作系统
浏览器
关键词
抄送给
所属迭代
相关需求
相关任务
由谁创建 袁慧斌 于 2026-08-07 13:59:11
影响环境 生产环境-线上测试
由谁解决 吴茵杰 于 2026-08-07 15:43:58
解决版本
解决方案 性能问题
由谁关闭 袁慧斌 于 2026-08-10 17:49:15
最后修改 袁慧斌 于 2026-08-10 17:49:15
相关Bug