栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 前沿技术 > 大数据 > 大数据系统

TransmittableThreadLocal错误排查

TransmittableThreadLocal错误排查

一  问题背景

   数据写入丢失

二 疑点以及日志分析

(1)关键日志分析:

收到了相关的kafka消息,并且打印了日志,针对该kafka消息,处理并提交了。

针对链路的处理,是通过handler链处理的,查看nodeStore的链,发现写入只用了0ms,这个可能性不大,说明可能没有执行数据库操作。

21/10/18 17:46:40,563[DEBUG][bgp-ls-node-process-batch-commit]- Handler list with handler:NodeStoreServiceImpl@4f3a94ae cost:0ms.

三 代码走查分析

(1)因为NodeStore底层调用的是BatchStore,但是日志中显示,BatchStore是并没有开启批量模式.

public boolean addData(Object object) throws TopologyException {
    if (autoCommit.get().isAutoCommit()) {
        logger.debug("autoCommit is true, disable batch store. {}", object);
        return save(object);
    } else {
        put(object);
        if (stage.get().size() > batchStoreThreadhold) {
            batchCommit();
        }
    }
    return false;
}

(2)继续分析下重系统启动到kafka处理流程:

                           

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/729209.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号