Я пытаюсь создать приложение для потоковой структурированной потоковой передачи с произвольным состоянием, при добавлении groupByKey и mapGroupWithState возникает ошибка после запуска первой задачи.
.groupByKey(_.user_id)
.mapGroupsWithState(GroupStateTimeout.NoTimeout)(sessionState.updateAcrossEvents)
Ошибка: потерянная задача 5.0 в Этап 1.0 (TID 5, узел, исполнитель 1): java .lang.NoClassDefFoundError: Не удалось инициализировать класс com.test.Run $
Run - это основной класс, который содержит метод main.
Может кто-нибудь сказать мне, почему это происходит?
PS: если я пишу напрямую в консоль без groupByKey и mapGroupsWithState, она работает нормально.