如何用netcat将cassandra查询的整个结果发送到socket

1dkrff03  于 2021-06-21  发布在  Flink
关注(0)|答案(0)|浏览(201)

我想把数据发送到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程序使用的套接字?

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题