You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@flink.apache.org by ant burton <ap...@gmail.com> on 2017/09/28 08:54:24 UTC
Flink Savepoint Config parameter
Hey,
When running in EMR and taking a savepoint with
flink cancel -s SAVEPOINT_DIR JOB_ID
results in the following error
Caused by: org.apache.flink.util.ConfigurationException: Config parameter
'Key: 'jobmanager.rpc.address' , default: null (deprecated keys: [])' is
missing (hostname/address of JobManager to connect to).
Am I missing something shouldn't this have been set by the cluster?
Thanks
Re: Flink Savepoint Config parameter
Posted by Aljoscha Krettek <al...@apache.org>.
Hi,
I'm assuming you're running via YARN? I think you need to add the -yid <application id> parameter to your incantation.
Best,
Aljoscha
> On 28. Sep 2017, at 10:54, ant burton <ap...@gmail.com> wrote:
>
> Hey,
>
> When running in EMR and taking a savepoint with
>
> flink cancel -s SAVEPOINT_DIR JOB_ID
>
> results in the following error
>
> Caused by: org.apache.flink.util.ConfigurationException: Config parameter 'Key: 'jobmanager.rpc.address' , default: null (deprecated keys: [])' is missing (hostname/address of JobManager to connect to).
>
> Am I missing something shouldn't this have been set by the cluster?
>
> Thanks
>
>