flink1.15 savepoint 超时报错 java.util.concurrent.TimeoutException

9月前作者：Thomas2143 分类：Toy博客阅读(47) 违法举报

这篇具有很好参考价值的文章主要介绍了flink1.15 savepoint 超时报错 java.util.concurrent.TimeoutException。希望对大家有所帮助。如果存在错误或未考虑完全的地方，请大家不吝赐教，您也可以点击"举报违法"按钮提交疑问。

savepoint命令

flink savepoint e04813d4e7480c526912eb4d32bba510 hdfs://flink/flink/migration/savepoint56650 -Dyarn.application.id=application_1683808492336_1222

flink1.15 savepoint 超时报错 java.util.concurrent.TimeoutException,总结,flink 文章来源地址https://www.toymoban.com/news/detail-725819.html

报错内容

org.apache.flink.util.FlinkException: Triggering a savepoint for the job e04813d4e7480c526912eb4d32bba510 failed.
        at org.apache.flink.client.cli.CliFrontend.triggerSavepoint(CliFrontend.java:777)
        at org.apache.flink.client.cli.CliFrontend.lambda$savepoint$9(CliFrontend.java:754)
        at org.apache.flink.client.cli.CliFrontend.runClusterAction(CliFrontend.java:1002)
        at org.apache.flink.client.cli.CliFrontend.savepoint(CliFrontend.java:751)
        at org.apache.flink.client.cli.CliFrontend.parseAndRun(C

到了这里，关于flink1.15 savepoint 超时报错 java.util.concurrent.TimeoutException的文章就介绍完了。如果您还想了解更多内容，请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章，希望大家以后多多支持TOY模板网！

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：如若内容造成侵权/违法违规/事实不符，请点击违法举报进行投诉反馈，一经查实，立即删除！

分享到：

领支付宝红包赞助服务器费用

flink1.15 维表join guava cache和mysql方面优化

优化前 mysql响应慢,导致算子中数据输出追不上输入,导致显示cpu busy:100% 优化后效果两个图对应两个时刻: - - 图中guava cache命中率是通过guava自带统计,打印出来的. 1 guava缓存数据量上限 = 类中配置的guava缓存数据上线 * task个数(即flink并行度) 缓存越久命中率越高数据越陈旧

2024年01月17日
浏览(36)
【JavaEE】JUC(Java.util.concurrent)常见类

经过前面文章的学习我们大致了解了如何实现多线程编程和解决多线程编程中遇到的线程不安全问题， java.util.concurrent 是我们多线程编程的一个常用包，那么今天我将为大家分享 java.util.concurrent 包下的其他几种常见的类。 ReentrantLock 是可重入互斥锁，跟 synchronized 定位是类似

2024年02月08日
浏览(38)
【JAVAEE】JUC(java.util.concurrent)的常见类

目录 1.Callable接口 1.1简介 1.2代码演示 1.3Runnable与Callable的区别 2.ReentrantLock 2.1ReentrantLock的常用方法 2.2ReentrantLock的代码演示 2.3ReentrantLock和synchronized的区别 3.Semaphore信号量 3.1概念 3.2代码演示 4.CountDownLatch 4.1概念 4.2代码演示 JUC是java.util.concurrent包的简称，JDK1.5之后对多线程的

2024年02月05日
浏览(37)
【Java多线程】面试常考 —— JUC(java.util.concurrent) 的常见类

目录 1、JUC（java.util.concurrent） 1.1、Callable 接口 1.2、ReentrantLock 可重入锁 1.3、Semaphore 信号量 1.4、CountDownLatch 这是java中的一个包，存放着多线程编程中常见的一些类。【Java多线程】Thread类的基本用法-CSDN博客 https://blog.csdn.net/zzzzzhxxx/article/details/136121421?spm=1001.2014.3001.5501 往

2024年04月10日
浏览(82)
已解决java.util.concurrent.ExecutionException异常的正确解决方法，亲测有效！！！

已解决java.util.concurrent.ExecutionException异常的正确解决方法，亲测有效！！！ java.util.concurrent.ExecutionException java.util.concurrent.ExecutionException是Java多线程编程中常见的异常之一，它表示在执行一个Callable或者Runnable任务时，任务抛出了一个异常。下滑查看解决方法具体解决方法可

2024年02月11日
浏览(34)
【JavaEE】JUC（java.util.concurrent）的常见类以及线程安全的集合类

目录 1、JUC（java.util.concurrent）的常见类 1.1、Callable接口的用法（创建线程的一种写法） 1.2、ReentrantLock可重入互斥锁 1.2.1、ReentrantLock和synchronized的区别 1.2.2、如何选择使用哪个锁 1.3、Semaphore信号量 1.4、CountDownLatch 2、线程安全的集合类 2.1、多线程环境使用ArrayList 2.2、

2024年02月07日
浏览(45)
Flink连接Hbase时的kafka报错：java.lang.NoClassDefFoundError: org/apache/kafka/common/utils/ThreadUtils

书接上文【Flink实时数仓】需求一：用户属性维表处理-Flink CDC 连接 MySQL 至 Hbase 实验及报错分析http://t.csdn.cn/bk96r 我隔了一天跑Hbase中的数据，发现kafka报错，但是kafka在这个代码段中并没有使用，原因就是我在今天的其他项目中添加的kafka依赖导致了冲突。注释掉kafka依赖，

2024年02月04日
浏览(49)
Java - JUC(java.util.concurrent)包详解，其下的锁、安全集合类、线程池相关、线程创建相关和线程辅助类、阻塞队列

JUC是java.util.concurrent包的简称，在Java5.0添加，目的就是为了更好的支持高并发任务。让开发者进行多线程编程时减少竞争条件和死锁的问题 java.lang.Thread.State tools（工具类）：又叫信号量三组工具类，包含有 CountDownLatch（闭锁）是一个同步辅助类，在完成一组正在其他线程中

2024年02月05日
浏览(34)
【问题已解决】Unrecognized option: --add-opens=java.base/java.util.concurrent.atomic=ALL-UNNAMED

今天在创建java项目时，运行报错，说无法成功创建java程序。 Unrecognized option: --add-opens=java.base/java.util.concurrent.atomic=ALL-UNNAMED Error: Could not create the Java Virtual Machine. Error: A fatal exception has occurred. Program will exit. 解决办法： 1、使用最新的jdk版本 2、在第三处，选择最新的jdk版本

2024年02月13日
浏览(51)
flink1.18.0 macos sql-client.sh启动报错

2024年01月23日
浏览(40)