开发者社区 > 云存储 > 正文

结果没有使用本批次数据重试,什么问题?

打扰了,问一下 type SimpleProcessFactory struct { //用户自定义信息,会传递到ProcessFunc和ShutdownFunc中的ChannelContext参数中。 CustomValue interface{}

//Worker记录checkpoint的间隔,CpInterval<=0时会使用DefaultCheckpointInterval。 CpInterval time.Duration

//worker数据处理的同步调用callback,ProcessFunc返回error时worker会用本批数据退避重试ProcessFunc。 ProcessFunc func(channelCtx *ChannelContext, records []*Record) error //worker退出时的同步调用callback。 ShutdownFunc func(channelCtx *ChannelContext)

//日志配置,Logger为nil时会使用DefaultLogConfig初始化logger。 Logger *zap.Logger } worker数据处理的同步调用callback,ProcessFunc返回error时worker会用本批数据退避重试ProcessFunc 已经返回了error ,结果没有使用本批次数据重试,什么问题?

展开
收起
真的很搞笑 2023-04-04 11:41:09 191 0
1 条回答
写回答
取消 提交回答
  • 您好!

    根据您提供的上下文,我无法准确判断结果没有使用本批次数据重试的原因。

    如果您想了解有关结果没有使用本批次数据重试的更多信息,请提供更多上下文或详细说明。

    2024-02-29 17:38:54
    赞同 展开评论 打赏
问答分类:
问答地址:

阿里云存储基于飞天盘古2.0分布式存储系统,产品多种多样,充分满足用户数据存储和迁移上云需求。

相关电子书

更多
低代码开发师(初级)实战教程 立即下载
冬季实战营第三期:MySQL数据库进阶实战 立即下载
阿里巴巴DevOps 最佳实践手册 立即下载