apache flink cep库问题(集群)

plupiseo  于 2021-06-25  发布在  Flink
关注(0)|答案(1)|浏览(400)

我有一个相当简单的应用程序在eclipse中运行良好。部署到群集时,它会很快失败,原因如下:
java.lang.runtimeexception:无法从类org.ice.drmcl.application中查找main(string[])方法:org/apache/flink/cep/pattern/conditions/iterativecondition
只有在包含模式匹配代码时才会发生,例如:

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

eclipse和cluster都运行flinkv1.3.2

bn31dyow

bn31dyow1#

哦,看-你为什么不看一下手册…:-“注意,flinkcep目前不是二进制发行版的一部分。”
这也许可以解释为什么它找不到你的类,因为它实际上不在那里。摇摇头。

相关问题