test destroy stream when k8s job ends

dist/index.js

@@ -2530,6 +2530,7 @@ class KubernetesTaskRunner {
             };
             try {
                 const resultError = yield new Promise((resolve) => __awaiter(this, void 0, void 0, function* () { return new client_node_1.Log(kubeConfig).log(namespace, podName, containerName, stream, resolve, logOptions); }));
+                stream.destroy();
                 if (resultError) {
                     throw resultError;
                 }

src/model/cloud-runner/k8s/kubernetes-task-runner.ts

@@ -39,6 +39,7 @@ class KubernetesTaskRunner {
       const resultError = await new Promise(async (resolve) =>
         new Log(kubeConfig).log(namespace, podName, containerName, stream, resolve, logOptions),
       );
+      stream.destroy();
       if (resultError) {
         throw resultError;
       }