..@gmail.com>;
> 发送时间: 2020年7月20日(星期一) 下午2:30
> 收件人: "user-zh"
> 主题: Re: Flink Cli 部署问题
>
>
>
> Hi
>
> 这个调试可以在 IDEA 进行的。
>
> 另外你说的通过 web ui 提交没有问题。请问下,是同一个 savepoint 通过 flink run 提交有问题,通过 web ui
> 提交没有问题吗?如果是的,能否分享下你的操作过程和命令呢?
>
> Best,
&
cli ?? ??jobmanager bin/flink run -d -p 1 -s {savepointuri}
/data/test.jar >
webui??http://jobmanager:8081 ; submit new
job??jar??savepoint path >
-- ?
re(RocksDBFullRestoreOperation.java:151)
> at
> org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackendBuilder.build(RocksDBKeyedStateBackendBuilder.java:279)
>
>
>
>
>
>
>
> 谢谢回复:
> 之前的savepoint都是通过RocksDBStateBackend生成的;
> 这个savepoint我通过w
taskmanagercliwebui??
2020-07-20 03:29:25,959 WARN
org.apache.kafka.clients.consumer.ConsumerConfig
- The configuration 'value.serializer' was supplied but
isn't a known config.
2020-07-20 03:29:25,959 INFO
org.apache.ka
??
??savepointRocksDBStateBackend
savepoint??webui ??IDE??savepoint??
-- --
??:
rDynamicMBean(DefaultMBeanServerInterceptor.java:966)
> at
> com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(DefaultMBeanServerInterceptor.java:900)
> at
> com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInt
Flink 1.10.0 ,taskmanager??
2020-07-17 15:06:43,913 ERROR
org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackendBuilder
- Caught unexpected exception.
java.io.EOFException
at java.io.DataInputStream.readFully(DataInputStream.java:197)
at java.io.DataInput
Hi
请问你使用哪个版本的 Flink 呢?能否分享一下 Co-Process (1/1)
(d0309f26a545e74643382ed3f758269b) 这个 tm 的 log 呢?从上面给的日志看,应该是在 083f69d029de
这台机器上。
Best,
Congxian
Z-Z 于2020年7月17日周五 下午6:22写道:
> 大家好,我在部署的时候发现了一个问题,我通过restAPI接口停掉了一个任务并保存了它的savepoint(步骤:/jobs/overview
> ---> /jobs/{jobid}/savepoints --->
> /jobs/{
restAPI??savepoint(??/jobs/overview
---> /jobs/{jobid}/savepoints --->
/jobs/{jobid}/savepoints/{triggerid})??flinksavepointwebuijar??savepoint??
202