Fixed the kill test

client/driver/exec.go

@@ -226,6 +226,9 @@ func (h *execHandle) Kill() error {
 	case <-h.doneCh:
 		return nil
 	case <-time.After(h.killTimeout):
+		if h.pluginClient.Exited() {
+			return nil
+		}
 		err := h.executor.Exit()
 		return err
 	}

client/driver/exec_test.go

@@ -265,7 +265,7 @@ func TestExecDriver_Start_Kill_Wait(t *testing.T) {
 		Name: "sleep",
 		Config: map[string]interface{}{
 			"command": "/bin/sleep",
-			"args":    []string{"1"},
+			"args":    []string{"10"},
 		},
 		Resources: basicResources,
 	}

client/driver/plugins/executor.go

@@ -152,18 +152,24 @@ func (e *UniversalExecutor) Exit() error {
 	if e.ctx.ResourceLimits {
 		e.destroyCgroup()
 	}
-	return proc.Kill()
+	if err = proc.Kill(); err != nil {
+		e.logger.Printf("[DEBUG] executor.exit error: %v", err)
+	}
+	return nil
 }
 
 func (e *UniversalExecutor) ShutDown() error {
 	proc, err := os.FindProcess(e.cmd.Process.Pid)
 	if err != nil {
-		return err
+		return fmt.Errorf("executor.shutdown error: %v", err)
 	}
 	if runtime.GOOS == "windows" {
 		return proc.Kill()
 	}
-	return proc.Signal(os.Interrupt)
+	if err = proc.Signal(os.Interrupt); err != nil {
+		return fmt.Errorf("executor.shutdown error: %v", err)
+	}
+	return nil
 }
 
 func (e *UniversalExecutor) configureTaskDir() error {