我已经克隆了 Flink 训练存储库,并按照从这里构建和部署的说明进行操作,以熟悉 Apache Flink。但是,在构建并导入到 Eclipse IDE 之后,项目中存在错误。在Flink Training Exercises
项目中,我在pomPlugin execution not covered by lifecycle configuration: net.alchim31.maven:scala-maven-plugin:3.1.4:testCompile
中发现了错误。 项目flink-quickstart-java
中也存在错误。 某些依赖项未解决,例如ExecutionEnvironment cannot be resolved
BatchJob
类。
public class BatchJob {
public static void main(String[] args) throws Exception {
// set up the batch execution environment
final ExecutionEnvironment env =
ExecutionEnvironment.getExecutionEnvironment();
我试图清理.m2
文件夹并多次遵守/构建这两个项目,但还没有快乐!一般来说,我总是对 Flink 依赖有问题,在 Java 中编程 Flink 有最佳实践吗?如何解决这些依赖项问题。
我通过选择add-dependencies-for-IDEA
maven配置文件在Eclipse中得到了这个工作。
我将本节添加到我的pom文件中
<plugin>
<groupId>org.codehaus.mojo</groupId>
<artifactId>exec-maven-plugin</artifactId>
<version>1.6.0</version>
<executions>
<execution>
<goals>
<goal>java</goal>
</goals>
</execution>
</executions>
<configuration>
<mainClass>org.apache.flink.flink_quickstart_java.BatchJob</mainClass>
</configuration>
</plugin>
然后创建了一个 Maven Build 运行配置
Goals: org.codehaus.mojo:exec-maven-plugin:java
Profiles: add-dependencies-for-IDEA