flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Aljoscha Krettek <aljos...@apache.org>
Subject Re: Flink Savepoint Config parameter
Date Wed, 11 Oct 2017 15:19:47 GMT
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 <apburton84@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
> 
> 


Mime
View raw message