Setting up a Multi-node Flink Cluster

Hello Is there a reference working implementation of a Multi-VM Flink Cluster (NOT on Docker)? e.g., a 1 Master VM + 3 Worker VMs. Not looking for documentation - but a working example with conf files modified. Thanks Z Mang

Flink job submission to Multi-VM Flink Cluster fails!

Hello, I can launch a Flink cluster (version 1.17.x) on my laptop with 1 Job Manager and 3 Task Managers. The cluster starts, jobs can be submitted correctly on the localhost (my laptop). Next I tried to launch this cluster on 4 VMs - 1 Master

????

Re: Flink cannot recognized catalog set by registerCatalog.

nStreamingMode() > .withBuiltInCatalogName("ca1") > .withBuiltInDatabaseName("db1") > .build()); > > > As Dawid said, if I want to store in my custom catalog, I can call > catalog.createTable or using DDL. > > Thanks, > SImon > > On

Re: Flink cannot recognized catalog set by registerCatalog.

Hi Simon, Thanks for reporting the problem. There is some rough edges around catalog API and table environments, and we are improving post 1.9 release. Nevertheless, tableEnv.registerCatalog() is just to put a new catalog in Flink's CatalogManager, It doens't change the default catalog/database a

Re: [ANNOUNCE] Rong Rong becomes a Flink committer

Congratulations, Rong! On Thu, Jul 11, 2019 at 10:59 AM Bowen Li wrote: > Congrats, Rong! > > > On Thu, Jul 11, 2019 at 10:48 AM Oytun Tez wrote: > > > Congratulations Rong! > > > > --- > > Oytun Tez > > > > *M O T A W O R D* > > The World's Fastest Human Translation Platform. > > oy...@motawor

re: How can I submit a flink job to YARN/Cluster from java code?

You can see the detail information at https://ci.apache.org/projects/flink/flink-docs-release-1.3/monitoring/rest_api.html. In this link, it is not said the restful API can not used in yarn cluster. I think it is ok, and you can try. :) z...@zjdex.com ?? 2017-07-28

re: How can I submit a flink job to YARN/Cluster from java code?

cs-release-1.3/monitoring/rest_api.html . z...@zjdex.com ?? 2017-07-28 15:50 user ?? How can I submit a flink job to YARN/Cluster from java code? Hello?? I want to submit a flink job to YARN/Cluster from java code.If this is feasible? Is there anyone tried t