为了熟悉Apache Flink,我已经克隆了Flink Training repo,并遵循了从here构建和部署的说明。但是,在构建并导入到Eclipse IDE之后,项目中会出现错误。在Flink Training Exercises
项目中,我在pom Plugin execution not covered by lifecycle configuration: net.alchim31.maven:scala-maven-plugin:3.1.4:testCompile
中发现了错误。项目flink-quickstart-java
中也有错误。某些依赖项未被解析,例如BatchJob
类中的ExecutionEnvironment cannot be resolved
。
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的最佳实践?我如何解决这些依赖问题。
发布于 2018-05-31 19:03:22
我通过选择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构建运行配置
Goals: org.codehaus.mojo:exec-maven-plugin:java
Profiles: add-dependencies-for-IDEA
https://stackoverflow.com/questions/50608571
复制相似问题