Flink Savepoint Config parameter

classic Classic list List threaded Threaded
2 messages Options
Reply | Threaded
Open this post in threaded view
|

Flink Savepoint Config parameter

ant burton
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


Reply | Threaded
Open this post in threaded view
|

Re: Flink Savepoint Config parameter

Aljoscha Krettek
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 <[hidden email]> 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
>
>