at 12:41 PM
To: Harshith Kumar Bolar
Cc: user
Subject: [External] Re: Re: Re: Flink 1.7.2: Task Manager not able to connect
to Job Manager
I forgot to add line numbers to the first link in my previous email:
https://github.com/apache/flink/blob/c6878aca6c5aeee46581b4d6744b31049db9de95
I forgot to add line numbers to the first link in my previous email:
https://github.com/apache/flink/blob/c6878aca6c5aeee46581b4d6744b31049db9de95/flink-dist/src/main/flink-bin/bin/jobmanager.sh#L21-L25
On Fri, Mar 15, 2019 at 8:08 AM Gary Yao wrote:
> Hi Harshith,
>
> In the jobmanager.sh scr
Hi Harshith,
In the jobmanager.sh script, the 2nd argument is assigned to the HOST
variable
[1]. How are you invoking jobmanager.sh? Prior to 1.5, the script expected
an
execution mode (local or cluster) but this is no longer the case [2].
Best,
Gary
[1]
https://github.com/apache/flink/blob/c687
Hi Gary,
An update. I noticed the line “–host cluster” in the program arguments section
of the job manager logs. So, I commented the following section in
jobmanager.sh, the task manager is now able to connect to job manager without
issues.
if [ ! -z $HOST ]; then
args+=("--host")
Hi Gary,
Here are the full job manager and task manager logs. In the job manager logs, I
see it says “starting StandaloneSessionClusterEntrypoint”, whereas in Flink
1.4.2, it used to say “starting JobManager”. Is this correct?
Job manager logs: https://paste.ubuntu.com/p/DCVzsQdpHq/
(https://p
