首先,您可以通过函数getStreamingStat().pubTables 查看发布流表状态,先确认下对应的tableName、actionName是否在返回结果中存在,若存在则说明subscribeTable订阅流表是成功的。
其次,函数getStreamingStat().subWorkers 查看订阅节点的工作线程的状态(注意:只有有消费到订阅表的数据的topic才会出现在函数返回结果中),按tableName、actionName找到对应的topic。
若topic不存在,且你设置的offset=-1,则可以确认下订阅的流表即tableName这张表是否在提交订阅后有新的数据到来;
若topic不存在,但确认过订阅表有数据到来,则可以进一步确认下是否设置了filter参数,而订阅到的数据正好全部被过滤了;
若topic存在,则注意是否有报错信息lastErrMsg,这是很可能是订阅节点处理的过程中报错了。