|
@@ -372,7 +372,8 @@ public class SqlTask extends AbstractTaskExecutor {
|
|
|
// is the timeout set
|
|
|
boolean timeoutFlag = taskExecutionContext.getTaskTimeoutStrategy() == TaskTimeoutStrategy.FAILED
|
|
|
|| taskExecutionContext.getTaskTimeoutStrategy() == TaskTimeoutStrategy.WARNFAILED;
|
|
|
- try (PreparedStatement stmt = connection.prepareStatement(sqlBinds.getSql())) {
|
|
|
+ try {
|
|
|
+ PreparedStatement stmt = connection.prepareStatement(sqlBinds.getSql());
|
|
|
if (timeoutFlag) {
|
|
|
stmt.setQueryTimeout(taskExecutionContext.getTaskTimeout());
|
|
|
}
|