Recreate new TaskInstance Working Directory when exist in worker

[ruanwenjun]

Purpose of the pull request

Recreate the working directory, avoid the exist directory will affect the task instance execution.

TODO: We can put this logic in task plugin, but this will cause all task plugin need to handle this situation.

Brief change log

When we find the task instance working directory exist in worker, we will recreate it.

Verify this pull request

This pull request is code cleanup without any test coverage.

(or)

This pull request is already covered by existing tests, such as (please describe tests).

(or)

This change added tests and can be verified as follows:

(or)

If your pull request contain incompatible change, you should also add it to docs/docs/en/guide/upgrede/incompatible.md

[codecov-commenter]

Codecov Report

Attention: 16 lines in your changes are missing coverage. Please review.

Comparison is base (9212531) 37.80% compared to head (7297e25) 37.82%.

❗ Current head 7297e25 differs from pull request most recent head c8b77bc. Consider uploading reports for the commit c8b77bc to get more accurate results

Files	Patch %	Lines
...server/worker/utils/TaskExecutionContextUtils.java	0.00%	15 Missing ⚠️
...duler/server/worker/runner/WorkerTaskExecutor.java	0.00%	1 Missing ⚠️

Additional details and impacted files

@@             Coverage Diff              @@
##                dev   #15358      +/-   ##
============================================
+ Coverage     37.80%   37.82%   +0.01%     
- Complexity     4680     4681       +1     
============================================
  Files          1304     1304              
  Lines         44934    44937       +3     
  Branches       4811     4812       +1     
============================================
+ Hits          16989    16997       +8     
+ Misses        26095    26088       -7     
- Partials       1850     1852       +2     

☔ View full report in Codecov by Sentry.
📢 Have feedback on the report? Share it here.

[EricGao888]

TODO: We can put this logic in task plugin, but this will cause all task plugin need to handle this situation. What does this TODO mean? Doing it in WorkerTaskExecutor.java seems better than in task plugins.

[ruanwenjun]

TODO: We can put this logic in task plugin, but this will cause all task plugin need to handle this situation. What does this TODO mean? Doing it in WorkerTaskExecutor.java seems better than in task plugins.

Some task instance may store some info in its working, and when we failover or recover(Flink) we may need to read this data.

But right now, we didn't have this kind of task plugin.

[sonarcloud]

Quality Gate passed

The SonarCloud Quality Gate passed, but some issues were introduced.

1 New issue
0 Security Hotspots
0.0% Coverage on New Code
0.0% Duplication on New Code

See analysis details on SonarCloud