0

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

   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
4

2 回答 2

1

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

解决方法很简单

在此处输入图像描述

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

所以去你的IDE，在我的例子中是IntelliJ并复制所需的jar

在此处输入图像描述

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

亚拉，问题解决了

于 2017-10-29T05:55:22.993 回答
0

如果你不想手动添加依赖或者你有一个maven或者sbt项目，你可以简单的在.pom文件或者对应的sbt文件中添加依赖，然后添加下面的依赖。

根据您的项目需要更改 flink 版本。

<!-- https://mvnrepository.com/artifact/org.apache.flink/flink-cep_2.11 -->
<dependency>
  <groupId>org.apache.flink</groupId>
  <artifactId>flink-cep_2.11</artifactId>
  <version>1.3.2</version>
</dependency>


// https://mvnrepository.com/artifact/org.apache.flink/flink-cep_2.11
libraryDependencies += "org.apache.flink" % "flink-cep_2.11" % "1.3.2"
于 2017-10-30T09:51:51.960 回答