Hi Dominik,
all job related files (non-HA as well as HA) are removed once the job
reaches a globally terminal state (FINISHED, CANCELLED, FAILED). This is
the case because Flink assumes that the job is done and won't be retried
afterwards. Thus, the documentation in the Flip is not true and
hmm, this indeed looks odd. Looping in Till (cc) who might know more
about this.
On 20.06.2018 16:43, Dominik Wosiński wrote:
Hello,
I'm not sure whether the problem is connected with bad configuration
or it's some inconsistency in the documentation but according to this
Hello,
I'm not sure whether the problem is connected with bad configuration or
it's some inconsistency in the documentation but according to this document:
https://cwiki.apache.org/confluence/display/FLINK/FLIP-19%3A+Improved+BLOB+storage+architecture
. *I*f a job fails, all non-HA files'
