Re: Flink REST API async?

web frontend and the REST interface). This should solve the problem, but unfortunately it doesn't solve your current problem. Best, Aljoscha On 8. Aug 2017, at 10:26, Francisco Gonzalez Barea <francisco.gonza...@piksel.com<mailto:francisco.gonza...@piksel.com>> wrote: Aha ok… Tha

Re: Problem in Flink 1.3.2 with Mesos task managers offers

-Eron On Tue, Sep 19, 2017 at 8:58 AM, Francisco Gonzalez Barea <francisco.gonza...@piksel.com<mailto:francisco.gonza...@piksel.com>> wrote: Hello guys, We have a flink 1.3.2 session deployed from Marathon json to Mesos with some of the following parameters as enviro

Problem in Flink 1.3.2 with Mesos task managers offers

Hello guys, We have a flink 1.3.2 session deployed from Marathon json to Mesos with some of the following parameters as environment variables: "flink_mesos.initial-tasks": "8", "flink_mesos.resourcemanager.tasks.mem": "4096", And other environment variables including zookeeper, etc. The

Query Rpc address/port remotely?

Hey guys! I´ve got a new question. Having a Flink v1.3.0 running on Mesos, is there any remotely way (rest, or another) to query which is the rpc address and port to connect that Flink via akka? We´ve been taking a look at the rest API but the config endpoint doesn’t seem to provide this

Re: Flink REST API async?

able is used to establish the execution environment that the program obtains from `ExecutionEnvironment.getExecutionEnvironment()`. From the stack trace it appears that two main methods are executing simultaneously and one is corrupting the other. On Mon, Aug 7, 2017 at 8:21 AM, Francisco Go

Flink REST API async?

Hi there! We are doing some POCs submitting jobs remotely to Flink. We tried with Flink CLI and now we´re testing the Rest API. So the point is that when we try to execute a set of requests in an async way (using CompletableFutures) only a couple of them run successfully. For the rest we get

Re: Flink CLI cannot submit job to Flink on Mesos

lease-1.3/setup/jobmanager_high_availability.html#config-file-flink-confyaml> On 1 Aug 2017, at 10:24, Francisco Gonzalez Barea <francisco.gonza...@piksel.com<mailto:francisco.gonza...@piksel.com>> wrote: Hi Stephan, So, do you mean to remove the “-m” param from the flink CLI call? And on

Re: Flink CLI cannot submit job to Flink on Mesos

config used by the CLI. Stephan On Mon, Jul 31, 2017 at 6:27 PM, Francisco Gonzalez Barea <francisco.gonza...@piksel.com<mailto:francisco.gonza...@piksel.com>> wrote: Hi again, On the other hand, we are running the following flink CLI command: ./flink run -d -m ${jobmanager.rpc.addres

Re: Flink CLI cannot submit job to Flink on Mesos

as a fencing token (called leader session id) from the HA store (ZooKeeper). [1] https://ci.apache.org/projects/flink/flink-docs-release-1.3/setup/mesos.html#high-availability Cheers, Till On Thu, Jul 27, 2017 at 6:20 PM, Francisco Gonzalez Barea <francisco.gonza...@piksel.com<mail

Re: Flink CLI cannot submit job to Flink on Mesos

ion id) from the HA store (ZooKeeper). [1] https://ci.apache.org/projects/flink/flink-docs-release-1.3/setup/mesos.html#high-availability Cheers, Till On Thu, Jul 27, 2017 at 6:20 PM, Francisco Gonzalez Barea <francisco.gonza...@piksel.com<mailto:francisco.gonza...@piksel.com>> wrote:

Flink CLI cannot submit job to Flink on Mesos

Hello, We´re having lot of issues while trying to submit a job remotely using the Flink CLI command line tool. We have tried different configurations but in all of them we get errors from AKKA while trying to connect. I will try to summarise the configurations we´ve tried. - Flink 1.3.0