Re: docker, error NoResourceAvailableException..

2018-08-15 Thread Esteban Serrano
You can also instead of defining 2 services (taskmanager and taskmanager1), set the scale parameter on taskmanager to the number of desired slots. Something like this: taskmanager: image: "${FLINK_DOCKER_IMAGE:-flink:1.5.2}" scale: 2 expose: - "6121" - "6122" - "8081" On Wed, A

Re: Questions regarding to Flink 1.5.0 REST API change

2018-06-19 Thread Esteban Serrano
For #1, you need to use a PATCH request to "*/jobs/:jobid*" On Tue, Jun 19, 2018 at 11:35 AM Siew Wai Yow wrote: > Hi, > > > Regarding to Flink 1.5.0 REST API breaking change, > >- *The REST API to cancel a job was changed.* >- *The REST API to cancel a job with savepoint was changed.* >

program args size for running jobs

2018-05-22 Thread Esteban Serrano
Hi Flink users Looking for some ideas on alternatives/workaround for running a job which requires a large number of parameters (one of them being a long JSON string). When all params are taken together, the resulting REST API URL puts the size of the URL over the current 4096 bytes limit. Ideally,