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

2023-11-02 19:40

本文主要是介绍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. 发现未知类型不匹配错误,一定要检查导入的包,是否导入错了,如下图所示就是容易出现的错误
    import org.apache.flink.table.runtime.operators.window.TimeWindow

  4. 方法爆红,特别是集成第三方组件
    手敲把方法所有内容写完再刷新,延迟有时候很大,且idea在集成第三方组件maven时非常不智能

这篇关于flink常见错误(重要的已加粗)的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!


原文地址:https://blog.csdn.net/XWxDSJ/article/details/125873263
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.chinasem.cn/article/332864

相关文章

Redis高性能Key-Value存储与缓存利器常见解决方案

《Redis高性能Key-Value存储与缓存利器常见解决方案》Redis是高性能内存Key-Value存储系统,支持丰富数据类型与持久化方案(RDB/AOF),本文给大家介绍Redis高性能Key-... 目录Redis:高性能Key-Value存储与缓存利器什么是Redis?为什么选择Redis?Red

深度解析Java @Serial 注解及常见错误案例

《深度解析Java@Serial注解及常见错误案例》Java14引入@Serial注解,用于编译时校验序列化成员,替代传统方式解决运行时错误,适用于Serializable类的方法/字段,需注意签... 目录Java @Serial 注解深度解析1. 注解本质2. 核心作用(1) 主要用途(2) 适用位置3

Debian 13升级后网络转发等功能异常怎么办? 并非错误而是管理机制变更

《Debian13升级后网络转发等功能异常怎么办?并非错误而是管理机制变更》很多朋友反馈,更新到Debian13后网络转发等功能异常,这并非BUG而是Debian13Trixie调整... 日前 Debian 13 Trixie 发布后已经有众多网友升级到新版本,只不过升级后发现某些功能存在异常,例如网络转

SpringBoot3匹配Mybatis3的错误与解决方案

《SpringBoot3匹配Mybatis3的错误与解决方案》文章指出SpringBoot3与MyBatis3兼容性问题,因未更新MyBatis-Plus依赖至SpringBoot3专用坐标,导致类冲... 目录SpringBoot3匹配MyBATis3的错误与解决mybatis在SpringBoot3如果

MySQL ORDER BY 语句常见用法、示例详解

《MySQLORDERBY语句常见用法、示例详解》ORDERBY是结构化查询语言(SQL)中的关键字,隶属于SELECT语句的子句结构,用于对查询结果集按指定列进行排序,本文给大家介绍MySQL... 目录mysql ORDER BY 语句详细说明1.基本语法2.排序方向详解3.多列排序4.常见用法示例5.

nginx配置错误日志的实现步骤

《nginx配置错误日志的实现步骤》配置nginx代理过程中,如果出现错误,需要看日志,可以把nginx日志配置出来,以便快速定位日志问题,下面就来介绍一下nginx配置错误日志的实现步骤,感兴趣的可... 目录前言nginx配置错误日志总结前言在配置nginx代理过程中,如果出现错误,需要看日志,可以把

MySQL 索引简介及常见的索引类型有哪些

《MySQL索引简介及常见的索引类型有哪些》MySQL索引是加速数据检索的特殊结构,用于存储列值与位置信息,常见的索引类型包括:主键索引、唯一索引、普通索引、复合索引、全文索引和空间索引等,本文介绍... 目录什么是 mysql 的索引?常见的索引类型有哪些?总结性回答详细解释1. MySQL 索引的概念2

Olingo分析和实践之ODataImpl详细分析(重要方法详解)

《Olingo分析和实践之ODataImpl详细分析(重要方法详解)》ODataImpl.java是ApacheOlingoOData框架的核心工厂类,负责创建序列化器、反序列化器和处理器等组件,... 目录概述主要职责类结构与继承关系核心功能分析1. 序列化器管理2. 反序列化器管理3. 处理器管理重要方

Python错误AttributeError: 'NoneType' object has no attribute问题的彻底解决方法

《Python错误AttributeError:NoneTypeobjecthasnoattribute问题的彻底解决方法》在Python项目开发和调试过程中,经常会碰到这样一个异常信息... 目录问题背景与概述错误解读:AttributeError: 'NoneType' object has no at

MySQL深分页进行性能优化的常见方法

《MySQL深分页进行性能优化的常见方法》在Web应用中,分页查询是数据库操作中的常见需求,然而,在面对大型数据集时,深分页(deeppagination)却成为了性能优化的一个挑战,在本文中,我们将... 目录引言:深分页,真的只是“翻页慢”那么简单吗?一、背景介绍二、深分页的性能问题三、业务场景分析四、