You are viewing a plain text version of this content. The canonical link for it is here.

Posted to users@zeppelin.apache.org by Michael Guymon <mg...@instructure.com> on 2019/04/25 14:50:25 UTC

flink + zeppelin

Hello,

I am trying to get Flink 1.7 to work with Zeppelin 0.8 from docker
containers. Using docker-compose, the jobmanager, taskmanager, and zeppelin
are all running in their own containers. Zeppelin's Flink integration has
be configured to point at the jobmanager container (same hostname of
jobmanager) for sending Flink requests. When Zeppelin run the Flink
integration, the following error appears in the jobmanager logs:

dropping message [class akka.actor.ActorSelectionMessage] for non-local
recipient [Actor[akka.tcp://flink@172.18.0.5:6123/]] arriving at
[akka.tcp://flink@172.18.0.5:6123] inbound addresses are
[akka.tcp://flink@jobmanager:6123]

This seems like Akka wants the hostname (Jobmanager) for the request but
looks like that is getting translated to the IP when Zeppelin sends it
over.

 Is it possible to get this time of docker setup working?

thanks,
Michael