[Improvement][Master] Add IT case for task timeout alert

Author: shrihari7396

dolphinscheduler-master/src/test/java/org/apache/dolphinscheduler/server/master/integration/WorkflowOperator.java

@@ -67,12 +67,10 @@ public Integer manualTriggerWorkflow(final WorkflowTriggerDTO workflowTriggerDTO
                 .dryRun(workflowTriggerDTO.getDryRun())
                 .taskDependType(workflowTriggerDTO.getTaskDependType())
                 .failureStrategy(workflowTriggerDTO.getFailureStrategy())
-                .warningType(workflowTriggerDTO.getWarningType())
-                .warningGroupId(workflowTriggerDTO.getWarningGroupId())
                 .build();
 
-        final WorkflowManualTriggerResponse manualTriggerWorkflowResponse = workflowInstanceController
-                .manualTriggerWorkflow(workflowManualTriggerRequest);
+        final WorkflowManualTriggerResponse manualTriggerWorkflowResponse =
+                workflowInstanceController.manualTriggerWorkflow(workflowManualTriggerRequest);
         Assertions.assertThat(manualTriggerWorkflowResponse.isSuccess()).isTrue();
 
         return manualTriggerWorkflowResponse.getWorkflowInstanceId();
@@ -116,32 +114,32 @@ public void repeatRunningWorkflowInstance(final Integer workflowInstanceId) {
     }
 
     public void recoverFailureTasks(final Integer workflowInstanceId) {
-        final WorkflowInstanceRecoverFailureTasksRequest recoverFailureTasksRequest = WorkflowInstanceRecoverFailureTasksRequest
-                .builder()
-                .workflowInstanceId(workflowInstanceId)
-                .userId(1)
-                .build();
+        final WorkflowInstanceRecoverFailureTasksRequest recoverFailureTasksRequest =
+                WorkflowInstanceRecoverFailureTasksRequest.builder()
+                        .workflowInstanceId(workflowInstanceId)
+                        .userId(1)
+                        .build();
         workflowInstanceController.triggerFromFailureTasks(recoverFailureTasksRequest);
     }
 
     public WorkflowInstancePauseResponse pauseWorkflowInstance(Integer workflowInstanceId) {
-        final WorkflowInstancePauseRequest workflowInstancePauseRequest = new WorkflowInstancePauseRequest(
-                workflowInstanceId);
+        final WorkflowInstancePauseRequest workflowInstancePauseRequest =
+                new WorkflowInstancePauseRequest(workflowInstanceId);
         return workflowInstanceController.pauseWorkflowInstance(workflowInstancePauseRequest);
     }
 
     public WorkflowInstanceRecoverSuspendTasksResponse recoverSuspendWorkflowInstance(Integer workflowInstanceId) {
-        final WorkflowInstanceRecoverSuspendTasksRequest workflowInstancePauseRequest = WorkflowInstanceRecoverSuspendTasksRequest
-                .builder()
-                .workflowInstanceId(workflowInstanceId)
-                .userId(1)
-                .build();
+        final WorkflowInstanceRecoverSuspendTasksRequest workflowInstancePauseRequest =
+                WorkflowInstanceRecoverSuspendTasksRequest.builder()
+                        .workflowInstanceId(workflowInstanceId)
+                        .userId(1)
+                        .build();
         return workflowInstanceController.triggerFromSuspendTasks(workflowInstancePauseRequest);
     }
 
     public WorkflowInstanceStopResponse stopWorkflowInstance(Integer workflowInstanceId) {
-        final WorkflowInstanceStopRequest workflowInstanceStopRequest = new WorkflowInstanceStopRequest(
-                workflowInstanceId);
+        final WorkflowInstanceStopRequest workflowInstanceStopRequest =
+                new WorkflowInstanceStopRequest(workflowInstanceId);
         return workflowInstanceController.stopWorkflowInstance(workflowInstanceStopRequest);
     }
 
@@ -162,12 +160,6 @@ public static class WorkflowTriggerDTO {
 
         @Builder.Default
         private FailureStrategy failureStrategy = FailureStrategy.CONTINUE;
-
-        @Builder.Default
-        private org.apache.dolphinscheduler.common.enums.WarningType warningType = org.apache.dolphinscheduler.common.enums.WarningType.NONE;
-
-        @Builder.Default
-        private Integer warningGroupId = 0;
     }
 
     @Data