Apache Flink 错误 java.lang.ClassNotFoundException答案

【问题标题】：Apache Flink error java.lang.ClassNotFoundExceptionApache Flink 错误 java.lang.ClassNotFoundException
【发布时间】：2018-05-04 07:32:06
【问题描述】：

谁能帮我解决以下错误？我认为版本存在一些问题，但我不知道如何修复它。我正在尝试运行 Apache Flink，我使用 Kafka 主题作为输入尝试运行 Flink 时出现以下错误：

错误：

线程“main”中的异常 java.lang.NoClassDefFoundError: org/apache/flink/util/Preconditions at org.apache.flink.cep.pattern.Pattern.where(Pattern.java:130) at hes.cs63。 CEPMonitor.CEPMonitoring.main(CEPMonitoring.java:55) 引起：java.lang.ClassNotFoundException: org.apache.flink.util.Preconditions at java.net.URLClassLoader.findClass(URLClassLoader.java:381) at java.lang。 ClassLoader.loadClass(ClassLoader.java:424) at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:335) at java.lang.ClassLoader.loadClass(ClassLoader.java:357) ... 2 更多

pom.xml：

<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>

【问题讨论】：

你是如何执行代码的？
来自带有参数的 InteliJ IDEA：'--topic CEP --bootstrap.servers localhost:9092 --group.id SBG --out file:///home/user/'
正如您之前提到的，它可能与冲突的依赖关系有关。是否可以运行以下命令mvn dependency:tree -Dverbose来验证是否有冲突。

标签： java maven apache-kafka apache-flink

【解决方案1】：

您应该将 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。

【讨论】：

【解决方案2】：

你的依赖 flink-cep_2.11 使用 scala 2.11 和 flink 1.3.2，而 flink-streaming-java_2.10 和 flink-connector-kafka-0.9_2.10 使用 scala 2.10 和 flink 1.0.2。

您可以降级 flink-cep 为所有部门获取 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 年初开始使用库。因此，更好的解决方案是将其他两个部门升级到版本 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>

【讨论】：