Flink 1.11 Пользователь FlinkKafkaConsumer не может распространять водяные знаки, в то время как Flink 1.12 успешно
#java #apache-kafka #apache-flink Вопрос: Я наблюдаю какое - то странное поведение. Я написал несколько процессоров Flink, использующих Flink 1.12, и попытался заставить их работать на Amazon EMR. Однако на данный…