diff --git a/kubernetes-client/src/main/java/io/fabric8/kubernetes/client/dsl/internal/WatchConnectionManager.java b/kubernetes-client/src/main/java/io/fabric8/kubernetes/client/dsl/internal/WatchConnectionManager.java index 9b2cd092204..50060e9196f 100644 --- a/kubernetes-client/src/main/java/io/fabric8/kubernetes/client/dsl/internal/WatchConnectionManager.java +++ b/kubernetes-client/src/main/java/io/fabric8/kubernetes/client/dsl/internal/WatchConnectionManager.java @@ -23,7 +23,6 @@ import io.fabric8.kubernetes.client.*; import io.fabric8.kubernetes.client.dsl.base.BaseOperation; import io.fabric8.kubernetes.client.dsl.base.OperationSupport; -import io.fabric8.kubernetes.client.utils.HttpClientUtils; import io.fabric8.kubernetes.client.utils.Utils; import okhttp3.*; import okio.ByteString; @@ -70,7 +69,7 @@ public class WatchConnectionManager baseOperation, final String version, final Watcher watcher, final int reconnectInterval, final int reconnectLimit, long websocketTimeout, int maxIntervalExponent) throws MalformedURLException { this.resourceVersion = new AtomicReference<>(version); // may be a reference to null @@ -81,8 +80,7 @@ public WatchConnectionManager(final OkHttpClient client, final BaseOperation