开发者社区> 问答> 正文

在写入Tair的Bolt里报错

数据量小时没有问题,只要数据量稍大一点,就会报错:Failed to get Grouper of __master_task_heartbeat when  emit from tairbolt,求指点


Tair操作对象初始化工作在Bolt类的prepare方法里

private TairOperatorImpl tairOperator;
@Override
public void prepare(Map stormConf, TopologyContext context, OutputCollector collector) {
    this.collector = collector;
    this.tairOperator = new TairOperatorImpl(RaceConfig.TairConfigServer, RaceConfig.TairSalveConfigServer,
                RaceConfig.TairGroup, RaceConfig.TairNamespace);
}

展开
收起
闪电云 2016-07-05 21:15:32 4501 0
0 条回答
写回答
取消 提交回答
问答分类:
问答地址:
问答排行榜
最热
最新

相关电子书

更多
阿里云Redis企业版Tair持久存储系列技术解读 立即下载
阿里云Redis企业版Tair持久存储系列产品详解 立即下载
阿里云内存数据库Tair 立即下载