赞
踩
在运行Flink基本的词频统计代码时遇到如下错误
解决方法:
缺少 flink-client jar
在pom.xml文件里引入即可
在<properties>标签下加入自己flink的版本(已配置完请忽略)
<properties>
<!--Flink 版本-->
<flink.version>1.13.0</flink.version>
</properties>
在<dependencies>标签下加入子标签<dependency>,并加入flink-clients
<dependencies> <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-clients_2.11</artifactId> <version>${flink.version}</version> </dependency> </dependencies>
之后刷新maven工程
重新运行词频统计代码就能出结果了
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。