executor initialization

[Tomas Barton <ba...@gmail.com>]

Hi,

I have a problem with Mesos executor initialization. A slave receives a
task and is launching an executor, stderr:

WARNING: Logging before InitGoogleLogging() is written to STDERR
I0601 14:54:36.055747 15807 exec.cpp:131] Version: 0.18.2

stdout:

3399 [main] INFO  storm.mesos.MesosSupervisor - Waiting for executor to
initialize...
(just this, nothing more)

it gets stuck at MesosExecutorDriver initialization:

framework executor:

        Semaphore initter = new Semaphore(0);
        _executor = new StormExecutor(initter);
        _driver = new MesosExecutorDriver(_executor);
        _driver.start();
        LOG.info("Waiting for executor to initialize...");
        try {
            initter.acquire();
        } catch (InterruptedException e) {
            throw new RuntimeException(e);
        }
        LOG.info("Executor initialized...");

it won't get over the semaphore, which means that it's waiting for
ExecutorProcess initialization

https://github.com/apache/mesos/blob/master/src/exec/exec.cpp#L694

tcp        0      0 0.0.0.0:5051            0.0.0.0:*               LISTEN

tcp        0      0 0.0.0.0:56363           0.0.0.0:*               LISTEN

tcp        0      0 10.0.0.32:5051          mesos-master:51742
ESTABLISHED
tcp        0      1 10.0.0.32:54868         mesos-master:5051      SYN_SENT

tcp        0      0 10.0.0.32:36554         zookeeper:2181      ESTABLISHED
tcp        0      0 10.0.0.32:42186         mesos-master:5050
 ESTABLISHED

If I understand it correctly, mesos executor has opened port 56363 and is
trying to establish connection with master, right?

However there's no error message about timeout or failed connection. Just
the state of task is TASK_LOST.

Any idea what's wrong?

Thanks,
Tomas