Я хотел отправить данные в сокет, чтобы моя программа Flink могла их прочитать из сокета.
Как указано в этом руководстве https://stackoverflow.com/a/53943644/6640504 Я сделал это с помощью:
cqlsh -e “select * from tableName;” -k mykeyspace Ipaddress 9042 |
nc -lk portNumber
и моя программа Flink считывает данные из сокета без ошибок.
Теперь у меня есть новая проблема: Cassandra отправляет данные на сокет постранично, а программа Flink просто получает одну страницу. Я не знаю, как автоматически отправить другую страницу.
Я отключил «пейджинг» в Cassandra с «пейджингом выключенным»;но он показал мне эту ошибку:
ReadFailure: ошибка сервера: code = 1300 [Реплике не удалось выполнить чтение] message = "Операция не выполнена - получено 0 ответов и 1
failures "info = {'failures': 1, 'receive_responses': 0,> 'required_responses': 1, 'консистентность': 'ONE'}
БудетПожалуйста, помогите мне, как я могу отправить весь результат этого запроса “select * from tableName;” в сокет для использования программой Flink?