[minor](progress) do not update progress if job id is not set (#20949)
This commit is contained in:
@ -2216,7 +2216,7 @@ public class Coordinator {
|
||||
}
|
||||
}
|
||||
|
||||
if (params.isSetLoadedRows()) {
|
||||
if (params.isSetLoadedRows() && jobId != -1) {
|
||||
Env.getCurrentEnv().getLoadManager().updateJobProgress(
|
||||
jobId, params.getBackendId(), params.getQueryId(), params.getFragmentInstanceId(),
|
||||
params.getLoadedRows(), params.getLoadedBytes(), params.isDone());
|
||||
|
||||
Reference in New Issue
Block a user