zoukankan      html  css  js  c++  java
  • Flink- 本地运行报错(Cannot find compatible factory for specified execution.target (=local))

    本地运行报错信息

    Exception in thread "main" java.lang.NullPointerException: Cannot find compatible factory for specified execution.target (=local)
    	at org.apache.flink.util.Preconditions.checkNotNull(Preconditions.java:104)
    	at org.apache.flink.api.java.ExecutionEnvironment.executeAsync(ExecutionEnvironment.java:937)
    	at org.apache.flink.api.java.ExecutionEnvironment.execute(ExecutionEnvironment.java:860)
    	at org.apache.flink.api.java.ExecutionEnvironment.execute(ExecutionEnvironment.java:844)
    	at org.apache.flink.api.java.DataSet.collect(DataSet.java:413)
    	at org.apache.flink.api.java.DataSet.print(DataSet.java:1652)
    	at org.apache.flink.api.scala.DataSet.print(DataSet.scala:1864)
    	at com.rz.flinkdemo.wc.WordCount$.main(WordCount.scala:22)
    	at com.rz.flinkdemo.wc.WordCount.main(WordCount.scala)
    

    原因:pom文件没有添flink流处理依赖

    解决方法: pom文件添flink流处理依赖

    <dependencies>
            <dependency>
                <groupId>org.apache.flink</groupId>
                <artifactId>flink-scala_2.12</artifactId>
                <version>1.10.1</version>
            </dependency>
            <dependency>
                <groupId>org.apache.flink</groupId>
                <artifactId>flink-streaming-scala_2.12</artifactId>
                <version>1.10.1</version>
                <!--<scope>provided</scope>-->
            </dependency>
        </dependencies>
    

      

  • 相关阅读:
    软件开发中的程序员和产品经理
    Linux下自动备份MySQL
    使用FeignClient,消费方使用方法,和一些坑
    FeignClient 使用
    关于sql查询,按时间段查询
    aquery验证
    Ajax
    弹框
    来源于网络 感觉很好就收藏;了
    org.springframework.dao.EmptyResultDataAccessException: Incorrect result size: expected 1, actual 0
  • 原文地址:https://www.cnblogs.com/RzCong/p/13619104.html
Copyright © 2011-2022 走看看