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常见错误(重要的已加粗)的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/332864

相关文章

JVM 常见异常及内存诊断

栈内存溢出 栈内存大小设置:-Xss size 默认除了window以外的所有操作系统默认情况大小为 1MB,window 的默认大小依赖于虚拟机内存。 栈帧过多导致栈内存溢出 下述示例代码,由于递归深度没有限制且没有设置出口,每次方法的调用都会产生一个栈帧导致了创建的栈帧过多,而导致内存溢出(StackOverflowError)。 示例代码: 运行结果: 栈帧过大导致栈内存

模拟实现vector中的常见接口

insert void insert(iterator pos, const T& x){if (_finish == _endofstorage){int n = pos - _start;size_t newcapacity = capacity() == 0 ? 2 : capacity() * 2;reserve(newcapacity);pos = _start + n;//防止迭代

【经验交流】修复系统事件查看器启动不能时出现的4201错误

方法1,取得『%SystemRoot%\LogFiles』文件夹和『%SystemRoot%\System32\wbem』文件夹的权限(包括这两个文件夹的所有子文件夹的权限),简单点说,就是使你当前的帐户拥有这两个文件夹以及它们的子文件夹的绝对控制权限。这是最简单的方法,不少老外说,这样一弄,倒是解决了问题。不过对我的系统,没用; 方法2,以不带网络的安全模式启动,运行命令行,输入“ne

【Kubernetes】常见面试题汇总(三)

目录 9.简述 Kubernetes 的缺点或当前的不足之处? 10.简述 Kubernetes 相关基础概念? 9.简述 Kubernetes 的缺点或当前的不足之处? Kubernetes 当前存在的缺点(不足)如下: ① 安装过程和配置相对困难复杂; ② 管理服务相对繁琐; ③ 运行和编译需要很多时间; ④ 它比其他替代品更昂贵; ⑤ 对于简单的应用程序来说,可能不

【附答案】C/C++ 最常见50道面试题

文章目录 面试题 1:深入探讨变量的声明与定义的区别面试题 2:编写比较“零值”的`if`语句面试题 3:深入理解`sizeof`与`strlen`的差异面试题 4:解析C与C++中`static`关键字的不同用途面试题 5:比较C语言的`malloc`与C++的`new`面试题 6:实现一个“标准”的`MIN`宏面试题 7:指针是否可以是`volatile`面试题 8:探讨`a`和`&a`

Flink任务重启策略

概述 Flink支持不同的重启策略,以在故障发生时控制作业如何重启集群在启动时会伴随一个默认的重启策略,在没有定义具体重启策略时会使用该默认策略。如果在工作提交时指定了一个重启策略,该策略会覆盖集群的默认策略默认的重启策略可以通过 Flink 的配置文件 flink-conf.yaml 指定。配置参数 restart-strategy 定义了哪个策略被使用。常用的重启策略: 固定间隔 (Fixe

常见的服务器

常见的Web服务器 1、Tomcat:Tomcat和Java结合得最好,是Oracle官方推荐的JSP服务器。Tomcat是开源的Web服务器,经过长时间的发展,性能、稳定性等方面都非常优秀。 2、Jetty:另一个优秀的Web服务器。Jetty有个更大的优点是,Jetty可作为一个嵌入式服务器,即:如果在应用中加入Jetty的JAR文件,应用可在代码中对外提供Web服务。 3、Resin:

SQL2005 性能监视器计数器错误解决方法

【系统环境】 windows 2003 +sql2005 【问题状况】 用户在不正当删除SQL2005后会造成SQL2005 性能监视器计数器错误,如下图 【解决办法】 1、在 “开始” --> “运行”中输入 regedit,开启注册表编辑器,定位到 [HKEY_LOCAL_MACHINE\SOFTWARE\Microsoft\Windows NT\CurrentVer

【Kubernetes】常见面试题汇总(一)

目录 1.简述 etcd 及其特点? 2.简述 etcd 适应的场景? 3.简述什么是Kubernetes? 4.简述 Kubernetes和 Docker的关系? 1.简述 etcd 及其特点? (1)etcd 是Core0s 团队发起的开源项目,是一个管理配置信息和服务发现(service discovery)的项目,它的目标是构建一个高可用的分布式键值(keyvalue)数据

Cmake之3.0版本重要特性及用法实例(十三)

简介: CSDN博客专家、《Android系统多媒体进阶实战》一书作者 新书发布:《Android系统多媒体进阶实战》🚀 优质专栏: Audio工程师进阶系列【原创干货持续更新中……】🚀 优质专栏: 多媒体系统工程师系列【原创干货持续更新中……】🚀 优质视频课程:AAOS车载系统+AOSP14系统攻城狮入门视频实战课 🚀 人生格言: 人生从来没有捷径,只有行动才是治疗恐惧