В настоящее время я работаю над потоковой программой, которая объединяет данные из нескольких сообщений (8), для агрегации требуются все 8 сообщений, поэтому я использую окно счетчика. Все 8 сообщений
Могу ли я как-то получить более подробную информацию о том, что происходит при создании контрольных точек Flink? Время создания FLiNK блокпост отличается от фактора 10. То есть, по крайней мере, что м
Возможно ли запустить версию elasticsearch версии 5.x в Apache Flink 1.2.0? Я не могу обновить свой Flink до 1.3, потому что мне нужна версия 1.2.0 для запуска kafka. тем, что говорится в этой ссылке:
Я использую кластер flink с 9 диспетчерами задач на двух разных физических узлах. Когда я представляю банку Jobmanager (Master) Flink, что именно происходит с банкой. Я имею в виду, распространяется л