You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by 范超 <fa...@mgtv.com> on 2020/08/28 06:01:59 UTC
答复: 从savepoint 启动以后,无法在checkpoint页面看到last restore的相关信息
Hi ���Ƹ磬�յ��������ڲ���һ�¿���
��л��л
-----�ʼ�ԭ��-----
������: Yun Tang [mailto:myasuka@live.com]
����ʱ��: 2020��8��28�� ������ 13:58
�ռ���: user-zh <us...@flink.apache.org>
����: Re: ��savepoint �����Ժ�����checkpointҳ�濴��last restore�������Ϣ
Hi ����
��Ȼ���������ͼ���������������������ˣ����е�optionsӦ�÷���jar���ļ���ַǰ��[1]
1. class name Ӧ���� jar����ַǰ�� [2]
2. savepoint/checkpoint ��ַӦ����jar����ַǰ�� [3]
û����ȷ��checkpoint�ָ���ԭ��Ӧ�������ԭ��
[1] https://ci.apache.org/projects/flink/flink-docs-stable/ops/cli.html#usage
[2] https://ci.apache.org/projects/flink/flink-docs-stable/ops/cli.html#job-submission-examples
[3] https://ci.apache.org/projects/flink/flink-docs-stable/ops/state/checkpoints.html#resuming-from-a-retained-checkpoint
ף��
����
________________________________
From: zilong xiao <ac...@gmail.com>
Sent: Friday, August 28, 2020 11:45
To: user-zh <us...@flink.apache.org>
Subject: Re: ��savepoint �����Ժ�����checkpointҳ�濴��last restore�������Ϣ
ͼ���ˣ���ͼ�����������Ӱ�
���� <fa...@mgtv.com> ��2020��8��28������ ����11:37���
> Hi�� ��Һ�
>
> Flink�汾 1.10.0
>
>
>
> Ŀǰ�����checkpointʹ��rocksdb�ķ�ʽ�洢��hdfs�ϣ���sinkʧ�ܵ�ʱ���ܹ���������һ��checkpoint��ָ���
>
> ��������������������ʹ����������
>
> *bin/flink stop -p ${hdfsSavepointDir} -d $runningJobId -yid
> $yarnAppId*
>
>
>
> ��savepoint�ļ����棬Ȼ����ʹ�ñ����savepoint����������
>
> */bin/flink run -d -m yarn-cluster -p ${parallelism} -yjm ${jm} -ytm
> ${tm} $fullJarPath -s $savePointFullPath �Cc xxx*
>
>
>
> �Ƚ���������ǣ�jm��tm��־����ʾ�ɹ�������������������checkpoint�ָ��ļ�¼����ͼ��ʾ��
>
>
>
> ��֪���Ĵ���֪���Dz��������ﴦ��������ô��
>