Flink 仪表板版本 1.3.2 中无法执行 CEP 模式，这是由 ClassNotFoundException 引起的

我写了一个像这样的简单模式

   Pattern<JoinedEvent, ?> pattern = Pattern.<JoinedEvent>begin("start")
            .where(new SimpleCondition<JoinedEvent>() {
     @Override
     public boolean filter(JoinedEvent streamEvent) throws Exception {

            return streamEvent.getRRInterval()>= 10 ;
                        }
             }).within(Time.milliseconds(WindowLength));

并且在 IntellijIdea 中执行得很好。我在仪表板和 IntelliJ-Idea 中都使用 Flink 1.3.2。当我从源代码构建 Flink 时，我看到了很多警告消息，这让我相信迭代条件类尚未包含在 jar 中，因为错误也说ClassNotFoundException。下面是错误

Caused by: java.lang.NoClassDefFoundError: org/apache/flink/cep/pattern/conditions/IterativeCondition
at java.lang.Class.getDeclaredMethods0(Native Method)
at java.lang.Class.privateGetDeclaredMethods(Class.java:2701)
at java.lang.Class.privateGetMethodRecursive(Class.java:3048)
at java.lang.Class.getMethod0(Class.java:3018)
at java.lang.Class.getMethod(Class.java:1784)
at 

org.apache.flink.client.program.PackagedProgram.hasMainMethod(PackagedProgram.java:492)
    ... 38 more
Caused by: java.lang.ClassNotFoundException: org.apache.flink.cep.pattern.conditions.IterativeCondition
    at java.net.URLClassLoader.findClass(URLClassLoader.java:381)
    at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
    at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
    ... 44 more

经过我一整天的努力解决这个问题，终于得到了解决方案。问题非常基本，即 Flink CEP 不是二进制发行版的一部分，因此每当我尝试执行模式时，它都会给我一个错误。

解决方案很简单

如您所见，Flink Binary 没有 cep jar。

所以转到你的 IDE（在我的例子中是 IntelliJ）并复制所需的 jar

转到此位置并将此 jar 复制粘贴到二进制版本中的 lib 文件夹中。

亚拉，问题解决了