Fix generic watches.

Author: brendandburns

util/src/main/java/io/kubernetes/client/util/generic/GenericKubernetesApi.java

@@ -661,9 +661,10 @@ public Watchable<ApiType> watch(String namespace, final ListOptions listOptions)
       throw new IllegalArgumentException("invalid namespace");
     }
     Call call =
-        customObjectsApi.listClusterCustomObjectCall(
+        customObjectsApi.listNamespacedCustomObjectCall(
             this.apiGroup,
             this.apiVersion,
+            namespace,
             this.resourcePlural,
             null,
             listOptions.getContinue(),

util/src/test/java/io/kubernetes/client/util/generic/GenericKubernetesApiTest.java

@@ -19,8 +19,11 @@
 import com.google.gson.Gson;
 import io.kubernetes.client.custom.V1Patch;
 import io.kubernetes.client.openapi.ApiClient;
+import io.kubernetes.client.openapi.ApiException;
 import io.kubernetes.client.openapi.models.*;
 import io.kubernetes.client.util.ClientBuilder;
+import io.kubernetes.client.util.Watchable;
+import io.kubernetes.client.util.generic.options.ListOptions;
 import java.io.IOException;
 import java.net.SocketTimeoutException;
 import java.util.concurrent.TimeUnit;
@@ -163,6 +166,20 @@ public void patchNamespacedJobReturningObject() {
     verify(1, patchRequestedFor(urlPathEqualTo("/apis/batch/v1/namespaces/default/jobs/foo1")));
   }
 
+  @Test
+  public void watchNamespacedJobReturningObject() throws ApiException {
+    V1JobList jobList = new V1JobList().kind("JobList").metadata(new V1ListMeta());
+
+    stubFor(
+        get(urlPathEqualTo("/apis/batch/v1/namespaces/default/jobs"))
+            .willReturn(aResponse().withStatus(200).withBody(new Gson().toJson(jobList))));
+    Watchable<V1Job> jobListWatch = jobClient.watch("default", new ListOptions());
+    verify(
+        1,
+        getRequestedFor(urlPathEqualTo("/apis/batch/v1/namespaces/default/jobs"))
+            .withQueryParam("watch", equalTo("true")));
+  }
+
   @Test
   public void testReadTimeoutShouldThrowException() {
     ApiClient apiClient = new ClientBuilder().setBasePath("http://localhost:" + 8181).build();