Apache Flink错误Java . lang . classnotfoundexception

Question

有人能帮我解决以下错误吗？我认为版本有一些问题，但我不知道如何解决。我正在尝试运行Apache Flink，我使用Kafka主题作为输入。我在尝试运行Flink时遇到以下错误：

线程“main”中的异常 java.lang.NoClassDefFoundEror： org/apache/flink/util/Preconditions at org.apache.flink.cep.pattern.pattern.where（Pattern.java：130） 在 hes.cs63.CEPMonitor.CEPMonitoring.main（CEPMonitoring.java：55） 由以下原因引起的： java.lang.ClassNotFoundException.java.java：（启动器.java：335） 在 java.郎.类加载器.load类（类加载器.java：357） ...2更多

<dependencies>
    <dependency>
        <groupId>org.apache.flink</groupId>
        <artifactId>flink-streaming-java_2.10</artifactId>
        <version>1.0.2</version>
    </dependency>
    <dependency>
        <groupId>org.apache.flink</groupId>
        <artifactId>flink-cep_2.11</artifactId>
        <version>1.3.2</version>
    </dependency>
    <dependency>
        <groupId>org.apache.kafka</groupId>
        <artifactId>kafka-clients</artifactId>
        <version>0.9.0.1</version>
    </dependency>
    <dependency>
        <groupId>org.apache.flink</groupId>
        <artifactId>flink-connector-kafka-0.9_2.10</artifactId>
        <version>1.0.2</version>
    </dependency>
    <dependency>
        <groupId>com.google.code.gson</groupId>
        <artifactId>gson</artifactId>
        <version>2.6.2</version>
    </dependency>
</dependencies>

Answer 1

您的依赖项flink-cep_2.11使用scala 2.11和flink 1.3.2，而flink-流-java_2.10和flink-连接器-kafka-0.9_2.10使用scala 2.10和flink 1.0.2。

您可以将flink-cep降级为所有deps的scala 2.10和flink 1.0.2：

<dependency>
    <groupId>org.apache.flink</groupId>
    <artifactId>flink-cep_2.10</artifactId>
    <version>1.0.2</version>
</dependency>

这将在你的pom.xml中给出最小的差异，但你将从2016年初开始使用库。因此，更好的解决方案是将另外两个 deps 升级到版本 1.3.2 和 scala 2.11：

<dependencies>
  <dependency>
    <groupId>org.apache.flink</groupId>
    <artifactId>flink-streaming-java_2.11</artifactId>
    <version>1.3.2</version>
  </dependency>
  <dependency>
    <groupId>org.apache.flink</groupId>
    <artifactId>flink-cep_2.11</artifactId>
    <version>1.3.2</version>
  </dependency>
  <dependency>
    <groupId>org.apache.kafka</groupId>
    <artifactId>kafka-clients</artifactId>
    <version>0.9.0.1</version>
  </dependency>
  <dependency>
    <groupId>org.apache.flink</groupId>
    <artifactId>flink-connector-kafka-0.9_2.11</artifactId>
    <version>1.3.2</version>
  </dependency>
  <dependency>
    <groupId>com.google.code.gson</groupId>
    <artifactId>gson</artifactId>
    <version>2.6.2</version>
  </dependency>
</dependencies>

Answer 2

您应该将flink-streaming-java_2.10和flink-connector-kafka-0.9_2.10依赖项更新到版本1.3.2，以匹配CEP库的版本。并且保持scala版本的一致性——为所有依赖项选择2.10或2.11。

CEP自1.0.2以来有了很大的改进，所以我不建议降级CEP。