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 目前不是二进制发行版的一部分。

这可以解释为什么它找不到你的类，因为它实际上不存在。摇摇头。