Почему не работает Flink SocketTextStreamWordCount?

Question

Я создал пример проекта и построил его. Я могу запустить программу WordCount, как и ожидалось. Но когда я запускаю SocketTextWordCount, я не получаю никаких результатов.

• Я отправить данные через нк (LOCALHOST: 9999 с обеих сторон)
• В веб-консоли для беговой работы, я могу видеть, что есть сообщения, посылаемые/получаемые

Но Я никогда не вижу вывод counts.print() в любом месте, даже после убийства nc-сессии.

EDIT - когда я меняю его, чтобы распечатать результаты в текстовый файл, никаких проблем. Таким образом, проблема заключается в том, что counts.print() неправильно записывается в стандартный вывод консоли. Я запускаю пример.

Answer 1

DataStreams печатаются на стандартном этапе процесса TaskManager. При запуске экземпляра Flink (локального или кластера) стандартное из TaskManager направляется в файл .out в каталоге ./log/ корневого каталога Flink. Поэтому вы должны проверить, записана ли запись в эти файлы.

Это поведение отличается от DataSet.print(), где результаты собраны в JobManager, отправлены клиенту и распечатаны клиентом.