Проблема библиотеки CEP в Apache flink (кластер)

Question

У меня довольно простое приложение, хорошо работающее в Eclipse. При развертывании в кластере происходит очень быстрый сбой:

java.lang.RuntimeException: не удалось найти основной метод (String[]) из класса org.ice.drmcl.Application: org/apache/flink/cep/pattern/condition /IterativeCondition

Происходит, только если я включаю код сопоставления с образцом, например, так:

Pattern<TransferMonitor, ?> pattern = Pattern.<TransferMonitor>begin("start")
    .where(new SimpleCondition<TransferMonitor>() {
        // ...
    });

И Eclipse, и Cluster работают под управлением Flink v1.3.2.

Answer 1

О, смотрите - почему бы вам не прочитать руководство....:- "Обратите внимание, что FlinkCEP в настоящее время не является частью бинарного дистрибутива".

Это может объяснить, почему он не может найти ваш класс, поскольку его на самом деле нет. Качает головой.