- Error during shutdown of BlobServer via JVM shutdown hook.
java.lang.NullPointerException
at org.apache.flink.runtime.blob.BlobServer.close(BlobServer.java:300)
at
org.apache.flink.util.ShutdownHookUtil.lambda$addShutdownHook$0(ShutdownHookUtil.java:43)
at java.lang.Thread.run(Thread.java:748
rockey...@163.com
us.janino.SimpleCompiler.cook(SimpleCompiler.java:216)
at org.codehaus.janino.SimpleCompiler.cook(SimpleCompiler.java:207)
at org.codehaus.commons.compiler.Cookable.cook(Cookable.java:80)
at org.codehaus.commons.compiler.Cookable.cook(Cookable.java:75)
at
org.apache.flink.table.runtime.generated.CompileUtils.doCompile(CompileUtils.java:78)
... 15 more
rockey...@163.com
hi,all
flink1.9中关于blink的文档在哪看呀?找了半天找不到 0.0
rockey...@163.com
Have a good day !
hi,Jeff Yang
somnussuy 是我同事,他无法收到您的回复邮件,我在这代替他回复。我们的集群部署模式是 Standalone Cluster 和 HA by
zookeeper,在任务 Could not retrieve the execution result 异常时,日志文件中并没有相关的堆栈信息。
希望得到您的帮助: 1. 如果出现该报错,应该在哪里去排查日志。 2. 出现该报错的可能情况有哪些,目前仅有 flink
集群未启动,一定会复现,其他情况偶然出现,频率在 1/50 左右。
rockey...@163.com
发件人
你好,zhisheng,
我们并没有用到 flink-metrics-prometheus,只是任务执行的时候就会报出 找不到
org/apache/kafka/common/metrics/stats/Rate$1 这个类,不知道是否是flink自己调用到的
rockey...@163.com
发件人: zhisheng
发送时间: 2019-07-25 17:27
收件人: user-zh
主题: Re: flink kafka相关任务执行出错 导致 taskmanager 退出
hi,rockeycui
你是使用了 flink-metrics
谢谢,我们这边排查一下
rockey...@163.com
发件人: athlon...@gmail.com
发送时间: 2019-07-25 17:30
收件人: user-zh
主题: 回复: flink kafka相关任务执行出错 导致 taskmanager 退出
看看classpath里有没有kafka-clients
jar包,这个类是在这个里面的Rate类没有找到如果有那么看看你使用的kafka版本和kafka-clients是否匹配,我遇到类似的问题由于版本不同导致有的类找不到
INFO
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting
down TaskExecutorLocalStateStoresManager.
2019-07-23 10:52:01,580 INFO
org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager
removed spill file directory /tmp/flink-io-3e88d484-6424-4ae6-8eae-1694fa1ed526
rockey...@163.com
INFO
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting
down TaskExecutorLocalStateStoresManager.
2019-07-23 10:52:01,580 INFO
org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager
removed spill file directory /tmp/flink-io-3e88d484-6424-4ae6-8eae-1694fa1ed526
rockey...@163.com