修复taskExecutor失败后，没有正常关闭的问题

core/src/main/java/com/alibaba/datax/core/taskgroup/TaskGroupContainer.java

@@ -187,8 +187,15 @@ public class TaskGroupContainer extends AbstractContainer {
                     }
             	}
             	
-                // 2.发现该taskGroup下taskExecutor的总状态失败则汇报错误
+                // 2.发现该taskGroup下taskExecutor的总状态失败则汇报错误，同时关闭失败的taskExecutor
                 if (failedOrKilled) {
+
+                    taskFailedExecutorMap.forEach((taskId, taskExecutor) -> {
+                        if (!taskExecutor.isShutdown()) {
+                            taskExecutor.shutdown();
+                        }
+                    });
+
                     lastTaskGroupContainerCommunication = reportTaskGroupCommunication(
                             lastTaskGroupContainerCommunication, taskCountInThisTaskGroup);