Мы изменили поток данных sdk (2.5.0) на apache beam sdk (2.12.0) без изменений в коде.
Мы получаем следующее сообщение об ошибке
Expected DoFn to be FunctionSpec with URN urn:beam:dofn:javasdk:0.1, but URN was
Есть ли какие-либо другие настройки, которые необходимо выполнить?
Кажется, что происходит сбой дляэта строка
pipeline.apply(<some code here>).watchForNewFiles(10, Watch.Growth.never()))