我尝试使用服务器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)
然而,它失败了。我该如何修改?
subscribeTable
函数有一个server
参数,需要将其指定为与xdb(host, port, "admin", "123456")
的连接返回的句柄。跨节点订阅必须指定该参数。