And it's possible to add E2E for this case? This seems to only require adding a new case to the current E2E template.

Please fix this in SqlTask

taskExecutionContext.setVarPool(sqlParameters.getVarPool());

Rather than create a common method.

Before adding the common varpool handling, it is best to modify the task plugin's return result to explicitly return the varpool. Otherwise, we are essentially repeatedly modifying a variable, which is prone to causing problems.

Is it about adding varPool replacement in each task (such as SqlTask), rather than handling it uniformly in PhysicalTaskExecutor?

Please fix this in SqlTask

taskExecutionContext.setVarPool(sqlParameters.getVarPool());

Rather than create a common method.
Before adding the common varpool handling, it is best to modify the task plugin's return result to explicitly return the varpool. Otherwise, we are essentially repeatedly modifying a variable, which is prone to causing problems.

Is it about adding varPool replacement in each task (such as SqlTask), rather than handling it uniformly in PhysicalTaskExecutor?

Yes

Quality Gate failed

Failed conditions
0.0% Coverage on New Code (required ≥ 60%)

See analysis details on SonarQube Cloud