跨服务器订阅流表

请问B机器的本地磁盘数据库订阅A机器的流数据表,我脚本写为:

subscribeTable(tableName="Factor", actionName="FactorToDb", offset=-1, handler=loadTable("dfs://KCB_factor", "table1"), msgAsTable=true, batchSize=50, throttle=1, hash=6, reconnect=true)

没有执行成功:

请先 登录 后评论

1 个回答

saki

subscribeTable有个server参数, 需要指定为 xdb(host,port,"admin","123456")连接返回的句柄,跨节点订阅必须要指定这个参数

请先 登录 后评论