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
ino.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 !
你好，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是否匹配,我遇到类似的问题由于版本不同导致有的类找不到
.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
.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
