Re: How to run multiple InputFormat on multiple nodes

2019-07-16 Thread Zhu Zhu
Hi Han, from your description, looks that the 3 source nodes you created are running in the same shared slot, thus in the same node. So far DataSet API does not support customizing slot sharing group. So we may not enforce the sources to be in different shared groups to avoid that. But I think the

How to run multiple InputFormat on multiple nodes

2019-07-16 Thread HAN QIU
Dears, I have installed the Flink standalone cluster with 3 nodes, and I want to select some data from database. For high performance, I split the one sql to many, and I want these many sqls can run on the 3 nodes distributed.But actually these sqls are runing on the same node. Here is my codes