Я пытаюсь запустить простую работу в Apache Flink, используя Zeppelin.
Я создал Docker-контейнер с запущенным zeppelin 0.8.0. В этом же контейнере у меня работает apache flink 1.6.1. Когда я запускаю задание, используя интерпретатор flink, который есть у zeppelin по умолчанию, он работает хорошо, и я вижу результат работы. Но когда я делаю это в моем собственном интерпретаторе с flink 1.6.1, работающим в автономном режиме, у меня появляется следующая ошибка:
Конфигурация моего переводчика:
Свойства установлены в flink-conf.yaml
jobmanager.rpc.address: 0.0.0.0
jobmanager.rpc.port: 6134
jobmanager.heap.size: 1024m
taskmanager.heap.size: 1024m
taskmanager.numberOfTaskSlots: 1
parallelism.default: 1
Ошибка, которую я получаю в журнале flink (это означает, что flink получает задание от zeppelin):
2019-01-18 15:30:53,761 WARN
akka.remote.transport.netty.NettyTransport - Remote connection to
[/172.17.0.2:54842] failed with org.apache.flink.shaded.akka.org.jboss.netty.handler.codec.frame.TooLongFrameException: Adjusted frame length exceeds 10485760: 2147549189 - discarded
Я знаю, что в akka по умолчанию установлены размеры кадра 10485760b, но я получаю слишком большое значение 2147549189. Я попытался изменить это свойство akka.framesize: 10485760b в flink-conf.yaml, но я не могу указать этот огромный размер, не имеет для меня особого смысла.