我想把数据发送到socket,这样我的flink程序就可以从socket读取数据了。
作为本指南https://stackoverflow.com/a/53943644/6640504 我是这样做的:
cqlsh -e “select * from tableName;” -k mykeyspace Ipaddress 9042 |
nc -lk portNumber
我的flink程序从socket读取数据时没有任何错误。
现在我有一个新问题,就是cassandra逐页发送数据到socket,而flink程序只接收一页。我不知道如何自动发送另一页。
我用“paging off”禁用了cassandra中的“paging”;但它告诉我这个错误:
readfailure:来自服务器的错误:code=1300[副本执行read失败]message=“操作失败-收到0个响应和1个
failures“info={'failures':1,'收到的\u响应':0,>'必需的\u响应':1,'一致性':'one'}
你能帮我怎么把这个查询的全部结果发送出去吗 “select * from tableName;”
到flink程序使用的套接字?
暂无答案!
目前还没有任何答案,快来回答吧!