为什么subscribeTable提交之后希望append数据的目标表里并没有数据写入?如何判断subscribeTable成功?

为什么subscribeTable提交之后希望append数据的目标表里并没有数据写入?如何判断subscribeTable成功?我的subscribeTable是通过每天定时任务提交的,之前几天都没有问题为什么今天下游没有写入数据,是subscribeTable失败了吗?

请先 登录 后评论

1 个回答

Yating Xie

首先,您可以通过函数getStreamingStat().pubTables 查看发布流表状态,先确认下对应的tableName、actionName是否在返回结果中存在,若存在则说明subscribeTable订阅流表是成功的。

其次,函数getStreamingStat().subWorkers 查看订阅节点的工作线程的状态(注意:只有有消费到订阅表的数据的topic才会出现在函数返回结果中),按tableName、actionName找到对应的topic。

若topic不存在,且你设置的offset=-1,则可以确认下订阅的流表即tableName这张表是否在提交订阅后有新的数据到来;

若topic不存在,但确认过订阅表有数据到来,则可以进一步确认下是否设置了filter参数,而订阅到的数据正好全部被过滤了;

若topic存在,则注意是否有报错信息lastErrMsg,这是很可能是订阅节点处理的过程中报错了。


请先 登录 后评论