Many Thanks :)
Best regards/祝好,
Chang Liu 刘畅
> On 14 Dec 2018, at 11:09, Tzu-Li Chen wrote:
>
> Hi Chang,
>
> I think there is a JIRA[1] aimed at harden this case.
>
> In fact Flink create this directory on started and without other warnings,
> we can assume that it has been created. So it
Hi Chang,
I think there is a JIRA[1] aimed at harden this case.
In fact Flink create this directory on started and without other warnings,
we can assume that it has been created. So it might be deleted by
some clean up processes(by Flink or by the fs).
Best,
tison.
[1]
My question is: whatever the Flink user is doing, as long as he/her is doing
all the actions within the Flink-provided ways (Flink CLI or Flink APIs in
code), should not be able to touch this directory, right?
Because this directory is for the JobManager and managed by Flink.
Best regards/祝好,
Hi Chesnay,
What do you mean by "...we can make a small adjustment to the code…"? Do you
mean I, as a flink application developer, can do this in my code, OR, it has to
be a code change in the Flink itself?
And more importantly, I would like to ping point the root cause of this because
I
The directory is automatically created when Flink is started; maybe it
was deleted by some cleanup process?
In any case we can make a small adjustment to the code to create all
required directories when they don't exist.
On 13.12.2018 14:46, Chang Liu wrote:
Dear All,
I did a workaround
Dear All,
I did a workaround and the job submitting is working. I manually created the
directory flink-web-upload under the directory
/tmp/flink-web-ec768ff6-1db1-4afa-885f-b2828bc31127 .
But I don’t think this is the proper solution. Flink should be able to create
such directory
Dear all,
I am trying to submit a job but it got stuck here:
...
2018-12-13 10:43:11,476 INFO
org.apache.flink.configuration.GlobalConfiguration- Loading
configuration property: jobmanager.heap.size, 1024m
2018-12-13 10:43:11,476 INFO
