/
>
> central
>
>
>
>
>
> net-cn
>
> central
>
> Human Readable Name for this Mirror.
>
> http://maven.net.cn/content/groups/public/
>
>
>
>
>
> JBossJBPM
>
> central
>
> JBossJBPM Repository
>
&
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
> 在 2021-01-13 13:42:27，"Carmen Free" 写道：
> >hi，
> >
> >图看不见。
> >
> >penguin. 于2021年1月13日周三 下午1:19写道：
> >
> >> 已经在maven的setting文件中配置了好几个镜像了，还是这样。如下图
> >>
> >>
> >>
> >>
> >>
> >>
>
nting.html#prerequisites
>
> 祝好
> 唐云
> ____
> From: Carmen Free
> Sent: Wednesday, January 13, 2021 11:28
> To: user-zh@flink.apache.org
> Subject: Re: rocksdb作为statebackend时，TM节点挂掉了，为何任务不能恢复呢？
>
> Hi 唐老师，
>
> 我又重新尝试了新的场景。
>
> 我将集群
hi，
图看不见。
penguin. 于2021年1月13日周三 下午1:19写道：
> 已经在maven的setting文件中配置了好几个镜像了，还是这样。如下图
>
>
>
>
>
>
d的checkpoint目录配置成了本地目录，checkpoint保存到了本地机器上，所以在failover
> restore的时候，必须得让原task部署回原来的机器才能正常运行。将state backend的checkpoint目录更换为一个DFS目录即可。
>
>
> 祝好
> 唐云
> ____
> From: Carmen Free
> Sent: Tuesday, January 12, 2021 18:14
> To: user-zh@flink.apache.org
限也设置成了777
Yun Tang 于2021年1月12日周二 下午5:46写道：
> Hi
>
> Flink的容错机制是可以保证TM lost时候会尝试重启作业，“为何任务不能恢复”是需要看完整异常栈的，简单描述是无法帮助排查问题的。
>
> 祝好
> 唐云
> ________
> From: Carmen Free
> Sent: Tuesday, January 12, 2021 15:52
> To: user-zh@flink.apache.org
>
hi,
rocksdb作为statebackend时，TM节点挂掉了，为何任务不能恢复呢？
1、环境说明
flink版本：1.10.2
操作系统：centos 7
2、集群说明（当前模拟了2节点）
节点A | 节点B
角色| JM、TM|TM
taskslot | 4 | 4
3、statebackend配置
# rocksdb作为状态后备
state.backend: rocksdb
#
好的，非常感谢。
赵一旦 于2021年1月6日周三 下午1:08写道：
> 这个的话去看看KafkaConnector相关的参数，比较新的版本支持配置解析错误忽略。
>
> Carmen Free 于2021年1月6日周三 上午10:58写道：
>
> > 感谢帮忙解决问题，确实包的路径有问题，换成这个包就解决了这个问题。
> >
> > 紧接着我这边出现了新的异常
> >
> >
> org.apache.flink.shaded.jackson2.com.fasterxml.
处理吗？
赵一旦 于2021年1月5日周二 下午9:18写道：
> 我感觉还是jar的问题。如下尝试下，我懒得去试了。
> 将 org.apache.kafka.common.security.plain.PlainLoginModule 替换为
> org.apache.flink.kafka.shaded.org.apache.kafka.common.securi
> ty.plain.PlainLoginModule
>
> 因为你用的是sql-connector-kafka，这个包把kafka-clients的包shade了。
>
&g
flink sql 消费鉴权的kafka，是怎么消费的呢？在kafka未添加鉴权之前，flink SQL消费kafka是正常的
1、版本说明
flink版本：1.10.2
kafka版本：1.1.0
2、kafka鉴权说明
仅使用了sasl鉴权方式
在kafka客户端有配置 kafka_server-jass.conf、
server.properties、producer.properties、consumer.properties
3、主要配置参数
sasl.mechanism=PLAIN
security.protocol=SASL_PLAINTEXT
10 matches
Mail list logo
