Apache flink CEP 库问题（集群）

Question

我有一个相当简单的应用程序在 Eclipse 中运行良好。当部署到集群时，它会很快失败：

java.lang.RuntimeException: 无法查找 main(String[]) 来自 org.ice.drmcl.Application 类的方法： org/apache/flink/cep/pattern/conditions/IterativeCondition

仅当我包含模式匹配代码时才会发生，例如像这样：

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

Eclipse 和 Cluster 都在运行 Flink v1.3.2

Answer 1

哦，看 - 你为什么不阅读手册......： - “请注意，FlinkCEP 目前不是二进制发行版的一部分。”

这也许可以解释为什么它实际上不存在您的课程。摇头。