栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Java

flink常见错误(重要的已加粗)

Java 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

flink常见错误(重要的已加粗)

  1. Error:scalac: Error: scala.collection.immutable. c o l o n colon coloncolon.tl$1()Lscala/collection/immutable/List;
    (1)scala版本问题,需更改项目scala版本,如下图
    (2)或者加入import org.apache.flink.api.scala._ 解决scala版本冲突
  2. flink-quickstart要求的scala版本,在pom.xml文件中
    在quickstart中
    flink1.15 与 scala2.12.7兼容
    flink1.10与 scala2.11.12兼容
  3. java.lang.ClassNotFoundException: org.apache.flink.api.common.typeinfo.TypeInformation

依赖被排除了(provided从打包文件中排除依赖,flink的运行环境中已经有这个依赖了,idea中运行的时候需要注释掉,或者设置idea为允许,默认排除是因为打包后的文件只有10几k,而不排除有几十M,而flink运行环境中提供了这些以来,而idea没有)
(1)项目允许找到排除的范围

(2)被排除的依赖解除排除

4. Exception in thread “main” org.apache.flink.runtime.client.JobExecutionException: Job execution failed.

(1)socket端口被占用或者没打开
解决方法:先nc -lk 9999打开想连接的端口,再运行代码,或者换端口运行
(2)根本问题是版本问题,早期版本StreamExecutionEnvironment中默认的数据处理时间使用的是处理时间(ProcessingTime),Flink1.14.3的StreamExecutionEnvironment中默认的时间配置从处理时间变为了事件时间。
把时间相关的代码删掉即可解决,如window()
或者设置时间语义
env.setStreamTimeCharacteristic(TimeCharacteristic.ProcessingTime)

  1. 此外quickstart的maven的main方法也要改一下(只影响打包,不影响运行)

  2. maven爆红
    install一下,再刷新一下,或者重进下idea

  3. 发现未知类型不匹配错误,一定要检查导入的包,是否导入错了,如下图所示就是容易出现的错误

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/1020101.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号