diff --git a/kubernetes-tests/src/test/java/io/fabric8/kubernetes/client/mock/PodTest.java b/kubernetes-tests/src/test/java/io/fabric8/kubernetes/client/mock/PodTest.java
index fdb97356d45..650489809c4 100644
--- a/kubernetes-tests/src/test/java/io/fabric8/kubernetes/client/mock/PodTest.java
+++ b/kubernetes-tests/src/test/java/io/fabric8/kubernetes/client/mock/PodTest.java
@@ -327,6 +327,7 @@ public void onClose(int code, String reason) {
     execLatch.await(10, TimeUnit.MINUTES);
     assertNotNull(watch);
     assertEquals(expectedOutput, baos.toString());
+    watch.close();
   }
 
 
@@ -375,6 +376,7 @@ public void onClose(KubernetesClientException cause) {
     });
 
     assertTrue(deleteLatch.await(10, TimeUnit.MINUTES));
+    watch.close();
   }