Flink Автоматически сгенерированные UID были отключены, но UID или ha sh не был назначен оператору Разделение

Question

Используя последнюю версию flink 1.9.1 и установив:

env.getConfig().disableAutoGeneratedUIDs();

Я предоставил uid для всех операторов, которые я использую (фильтр, плоская карта, соединение), но я получаю следующее исключение когда я запускаю:

Исключение в потоке "main" java .lang.IllegalStateException: автоматически сгенерированные UID были отключены, но ни UID, ни ha sh не было назначено оператору Partition

Раздел оператора - это оператор keyBy, который я использую, но я не могу применить к нему функцию «uid»:

В чем проблема? Чего мне не хватает?

Answer 1

Это ошибка - см. FLINK-14910 . Это будет исправлено в 1.9.2 и 1.10.0.

В качестве обходного пути вы можете сделать

keyedStream = foo.keyBy(...)
keyedStream.getTransformation().setUid("blah")

См. http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/How-to-assign-a-UID-to-a-KeyedStream-td32052.html для более подробного обсуждения это.