参考 悟迷、松皓

解决什么问题
用什么方法
有什么特点

辣条，返璞的PPT

storage: {  
            provider: 'qiniu',
            bucketname: '你的桶名',
            ACCESS_KEY: 'AK',
            SECRET_KEY: 'SK',
            root: '/image/',
            prefix: 'http://7xp8ho.com1.z0.glb.clouddn.com'
        }

今天要发一个大版本，发现Scheduler调不通线下的机器

排查思路

• 先检查应用启动日志是否正常
• 找msgbroker关键字，看相关jar是否正常加载
• 到日志msgbroker/common-default去观察连接是否正常
• 【如果有必要】去DRM配置页面看客户端是否已链接，再次确认机器ip是否一致
• 到zutil去看消息投递过程

总结

先考虑应用以及相关模块是否正常加载，再通过日志与消息投递排查工具排查链路调用情况

• 一个分布式RPC调用，需要在被调用端记录调用过程中的TraceId以及其他上下文信息

编码要点

• 如果打点的位置在被调用端的主线程，直接用TracerContextUtil拿TraceId即可
• 如果被调用端在被调用过程中起了一个子线程并且需要在子线程中记录TraceId，那么就需要通过在主线程中建一个final对象做一下过渡，将Tracer上下文带入子线程，比如下面代码中的AbstractLogContext。然后在子线程内部去set这个上线文，这样就可以在子线程内部拿到TraceId了

@Override
    public void checkCorrectness(final QueryParameter queryParam, final QueryParameterDTO queryParameter,
            final OlapQueryModel queryModel, final IcubeRouteResultDTO icubeRouteResult, final String queryIcubeSql,
            final List<Map<String, Object>> icubeQueryResult) {
        final AbstractLogContext ctx = AbstractLogContext.get();
        final SoasUserInfo userInfo = UserInfoHolder.getUserInfo();
        // 用异步方式进行检查
        correctThreadPool.submit(new Runnable() {
            @Override
            public void run() {
                try {
                    AbstractLogContext.set(ctx);
                    UserInfoHolder.setUserInfo(userInfo);

                    LogUtil.info(logger, "checkCorrectness start");

                    // 判断前置条件
                    // 1. check DRM 开关
                    if (!AlisisDynamicConfigUtil.isCheckIcubeCorrectness()) {
                        LogUtil.info(logger, "checkCorrectness drm close");
                        return;
                    }

                    // 2. 结果集大小小于limit 并且 小于 MAX_COMPARE_SIZE
                    if (queryParam.getLimit() == null || CollectionUtils.size(icubeQueryResult) >= queryParam
                            .getLimit() || CollectionUtils.size(icubeQueryResult) > MAX_COMPARE_SIZE) {
                        LogUtil.info(logger, "checkCorrectness limit queryLimit={0}, resultSize={1}",
                                queryParam.getLimit(), CollectionUtils.size(icubeQueryResult));
                        return;
                    }

                    // 3. 数据版本 不一致
                    Dataset dataset = queryParam.getDynamicCube().getDataset();
                    DSDTO dsInfo = connectionInfoProcesser.getDSInfo(dataset.getFacTable().getDsId());
                    OdpsTableVO tableByQueryOdps = odpsMetaDataService.getTableByQueryOdps(dsInfo.getConnectUrl(),
                            dsInfo.getProject(), dataset.getFacTable().getName());
                    LogUtil.info(logger, "getTableByQueryOdps: {0}", JSON.toJSONString(tableByQueryOdps));
                    Date icubeTime = icubeRouteResult.getCuboidSelect().getCuboid().getSourceTableCurrentModifiedTime();
                    Date odpsTime = null;
                    if (tableByQueryOdps != null) {
                        odpsTime = tableByQueryOdps.getDataModifyTime();
                    }

                    if (icubeTime == null || odpsTime == null
                            || !icubeTime.equals(odpsTime)) {
                        LogUtil.info(logger, "checkCorrectness data version icubeVersion={0}, odpsVersion={1}",
                                icubeTime, odpsTime);
                        return;
                    }

                    // 判断加速的数据版本是否一致
                    String icubeDsId = icubeRouteResult.getCuboidSelect().getCuboid().getBuildTableModel()
                            .getFactTable()
                            .getDsId();
                    String icubeTableName = icubeRouteResult.getCuboidSelect().getCuboid().getBuildTableModel()
                            .getFactTable()
                            .getTableName();
                    TableConnInfo tableInfo = new TableConnInfo();
                    tableInfo.setDsId(icubeDsId);
                    tableInfo.setTableName(icubeTableName);
                    List<TableConnInfo> tableList = new ArrayList<>();
                    tableList.add(tableInfo);
                    List<TableSpeedupInfo> speedupStatus = speedupManageService.getSpeedupStatus(tableList);
                    if (CollectionUtils.isNotEmpty(speedupStatus)) {
                        TableSpeedupInfo speedupDO = speedupStatus.get(0);
                        if (speedupDO.isSpeedupReady()) {
                            Date speedupVersion = speedupDO.getOdpsDataTime();
                            if (speedupVersion == null || !speedupVersion.equals(odpsTime)) {
                                LogUtil.info(logger,
                                        "checkCorrectness data version speedupVersion={0}, odpsVersion={1}",
                                        speedupVersion, odpsTime);
                                return;
                            }
                        }
                    }

                    // 查询ODPS数据
                    ContextUtil.setQueryFlag(QueryTypeEnum.SQL_GENERATION_ORIGINAL_ONLY.ordinal());
                    queryParameter.setQueryFlag(QueryTypeEnum.SQL_GENERATION_ORIGINAL_ONLY.ordinal());
                    String newQueryId = queryModel.getQueryConfigInfo().getQueryId()
                            + CORRECTNESS_CHECK_QUERY_ID_SUFFIX;
                    queryModel.getQueryConfigInfo().setQueryId(newQueryId);
                    QueryResultModel queryResultModel = queryHandler.queryForRawData(queryModel,
                            queryParameter, false);
                    if (queryResultModel == null) {
                        LogUtil.info(logger, "checkCorrectness query odps result null");
                        return;
                    }
                    List<Map<String, Object>> dataList = queryResultModel.getResultData();

                    // 后置处理
                    QueryUtils.convertDataTypeForOdps(dataList, queryParam, queryResultModel.getResultModel());

                    try {
                        LogUtil.info(logger, "checkCorrectness doCompare");
                        doCompare(dataList, icubeQueryResult);
                        LogUtil.info(logger, "checkCorrectness doCompare success");
                    } catch (IllegalArgumentException e) {
                        LogUtil.error(e, logger, "checkCorrectness faild, icubeSql=#{0}#, odpsSql=#{1}#", queryIcubeSql,
                                queryResultModel.getResultModel().getSqlText());
                        StringBuilder sb = new StringBuilder();
                        sb.append("checkCorrectness faild: ");
                        sb.append("[").append(TracerContextUtil.getTraceId()).append("]");
                        sb.append(e.getMessage()).append("\n");
                        sb.append("用户 ").append(UserInfoHolder.getUserInfo().getUserName());
                        sb.append("工号 ").append(UserInfoHolder.getUserId());
                        sb.append(" @ ").append(EnvUtil.getHostName()).append("\n");
                        sb.append("icubeSql: ").append(queryIcubeSql).append("\n");
                        sb.append("odpsSql: ").append(queryResultModel.getResultModel().getSqlText());
                        exceptionNotifyService.notifyIcube(sb.toString());
                    }
                } catch (Exception e) {
                    LogUtil.error(e, logger, "checkCorrectness error");
                }
            }
        });
    }

root@iZu107n65nyZ:~# apt-get dist-upgrade  
Reading package lists... Done  
Building dependency tree  
Reading state information... Done  
You might want to run 'apt-get -f install' to correct these.  
The following packages have unmet dependencies:  
 libc-bin : Depends: libc6 (< 2.20) but 2.24-12 is installed
 libc-dev-bin : Depends: libc6 (< 2.20) but 2.24-12 is installed
 libc-l10n : Breaks: locales (< 2.21-1) but 2.13+git20120306-12.1 is installed
 libc6 : Breaks: locales (< 2.24) but 2.13+git20120306-12.1 is installed
 libc6-dev : Depends: libc6 (= 2.19-0ubuntu6.6) but 2.24-12 is installed
 nscd : Depends: init-system-helpers (>= 1.18~) but 1.14 is installed

解决方案:

aptitude update

aptitude install libc6-dev  

参考: 传送门 这篇文章里提到aptitude比apt-get聪明，一般能解决这类问题

但是一定要记得快照！！！！！！动内核不快照死路一条

以上错误怀疑是升级nodejs过程中带来的问题

例子

import static org.mockito.Mockito.*;

IcubeCompositeService icubeCompositeService = mock(IcubeCompositeService.class);        doReturn(true).when(icubeCompositeService).addIcubeDefination(any(IcubeDefinitionModel  
                .class));

快速入门

Ghost 使用 Markdown 语法书写内容。简单来说，Markdown 就是一种简化的书写格式！

用 Markdown 语法写作是很容易的。在编辑界面的左侧就是你写作的地方。在你认为需要的时候，可以使用以下这些语法来格式化你的内容。例如下面这个无序列表：

• Item number one
• Item number two
  • A nested item
• A final item

还可以是有序列表：

1. Remember to buy some milk
2. Drink the milk
3. Tweet that I remembered to buy the milk, and drank it

链接

如果要链接其它页面，可以直接把页面的 URL 粘贴过来，例如 http://www.ghostchina.com - 会被自动识别为链接。但是，如果你想自定义链接文本，可以像这样： Ghost 中文网。很简单吧！

图片

插入图片也没问题！前提是你事先知道图片的 URL，然后像下面这样：

如果图片在本地的硬盘里怎么办？也很简单！像下面这样书写就能为图片预留一个位置，然后你可以继续写作，回头再通过拖拽的方式把图片上传到服务器上。

引用

有些时候我们需要引用别人说的话，可以这样：

Wisdomous - it's definitely a word.

代码

或许你是个码农，需要贴一些代码到文章里，可以通过两个引号（Tab 键上面的那个键）加入行内代码 <code>。如果需要加入大段的代码，可以在代码前加 4 个空格缩进，这就是 Markdown 的语法。

.awesome-thing {
    display: block;
    width: 100%;
}

分割线

在任一新行输入 3 个或更多的短横线（减号）就是一条分隔线了。

高级用法

Markdown 还有一个特别用法，就是在你需要的时候可以直接书写 HTML 代码。

只要掌握了上面的这些介绍，你就已经入门了！继续写作吧！