Re: Flink Cli 部署问题

2020-07-20 文章 Congxian Qiu
..@gmail.com>; > 发送时间: 2020年7月20日(星期一) 下午2:30 > 收件人: "user-zh" > 主题: Re: Flink Cli 部署问题 > > > > Hi > > 这个调试可以在 IDEA 进行的。 > > 另外你说的通过 web ui 提交没有问题。请问下,是同一个 savepoint 通过 flink run 提交有问题,通过 web ui > 提交没有问题吗?如果是的,能否分享下你的操作过程和命令呢? > > Best, &

?????? Flink Cli ????????

2020-07-20 文章 Z-Z
cli ?? ??jobmanager bin/flink run -d -p 1 -s {savepointuri} /data/test.jar  > webui??http://jobmanager:8081 ; submit new  job??jar??savepoint path > -- ?

Re: Flink Cli 部署问题

2020-07-19 文章 Congxian Qiu
re(RocksDBFullRestoreOperation.java:151) > at > org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackendBuilder.build(RocksDBKeyedStateBackendBuilder.java:279) > > > > > > > > 谢谢回复: > 之前的savepoint都是通过RocksDBStateBackend生成的; > 这个savepoint我通过w

?????? Flink Cli ????????

2020-07-19 文章 Z-Z
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

?????? Flink Cli ????????

2020-07-19 文章 Z-Z
?? ??savepointRocksDBStateBackend savepoint??webui ??IDE??savepoint?? --  -- ??:

Re: Flink Cli 部署问题

2020-07-19 文章 Congxian Qiu
rDynamicMBean(DefaultMBeanServerInterceptor.java:966) > at > com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(DefaultMBeanServerInterceptor.java:900) > at > com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInt

?????? Flink Cli ????????

2020-07-17 文章 Z-Z
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

Re: Flink Cli 部署问题

2020-07-17 文章 Congxian Qiu
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/{

Flink Cli ????????

2020-07-17 文章 Z-Z
restAPI??savepoint(??/jobs/overview ---> /jobs/{jobid}/savepoints ---> /jobs/{jobid}/savepoints/{triggerid})??flinksavepointwebuijar??savepoint?? 202