Hi Sidhant, the cluster components use tcp to communicate with each other. If you are not using Flink's HA services, then the TaskManager nodes need to be configured with the JobManager's address to connect to them. If you are using HA services, then the service discovery happens through the HA services. One requirement for Flink to work is that the different cluster nodes on which a Flink process is started can communicate with each other.
Cheers, Till On Mon, Aug 24, 2020 at 6:26 PM sidhant gupta <sidhan...@gmail.com> wrote: > ++dev@flink.apache.org > > On Mon, Aug 24, 2020, 7:31 PM sidhant gupta <sidhan...@gmail.com> wrote: > > > Hi User > > > > How jobmanager and task manager communicates with each other ? How to set > > connection between jobmanager and task manager running in different/same > > ec2 instance ? Is it http or tcp ? How the service discovery works ? > > > > Thanks > > Sidhant Gupta > > >
