Watcher stuck forever in a case of network disconnect

[NikPaushkin]

What happened (please include outputs or screenshots):
If the network to Kubernetes API disconnects, watcher just gets stuck forever with no exception.

What you expected to happen:
Watcher should raise an exception in a case of any network issues.

How to reproduce it (as minimally and precisely as possible):

1. Run watcher for any object list with some timeout (60 seconds, for example)
2. Turn off network adapter on your laptop
3. Wait for 60 seconds (timeout) and watcher still does not return the control: thread just stuck

Anything else we need to know?:

Environment:

• Kubernetes version (kubectl version): 1.17.0
• OS (e.g., MacOS 10.13.6): Windows 10
• Python version (python --version): 3.7
• Python client version (pip list | grep kubernetes): 11.0.0

[roycaihw]

This seems to be related to #868

[NikPaushkin]

This seems to be related to #868

@roycaihw well, it can be fixed like that, if we don't want to fix stream itself

[roycaihw]

cc @alanjcastonguay

[ellieayla]

Yeah, this is one of the failure modes that prompted #868. But I still don't have a method to fix it, other than simply setting a client-side timeout. Did you have one set in this test? Can you paste a minimal example that reproduces the problem in your test?

[NikPaushkin]

@alanjcastonguay It works like that always for me. The minimal code is trivial

from kubernetes import client, watch
from datetime import datetime

watcher = watch.Watch()
func = client.CoreV1Api(client.ApiClient(client.Configuration())).list_namespaced_pod
kwargs = dict()
kwargs['timeout_seconds'] = 60
try:
    while True:
        for event in watcher.stream(func, **kwargs):
            watcher_last_time_alive = datetime.now()
            print(watcher_last_time_alive)
except Exception as e:
    logging.error("API request failed", extra={
        "API": "Kubernetes",
        "method": func,
        "kwargsGiven": kwargs,
        "error": str(e)
    })

[Cweiping]

This problem can be repeated in the case of unstable network environment. The more unstable the network, the more likely it is to have problems

[ellieayla]

kwargs['timeout_seconds'] = 60 is a polite request to the server, asking it to cleanly close the connection after 60 seconds. If you have a network outage, this does nothing. You can set this number much higher, maybe to 3600 seconds (1h).

kwargs['_request_timeout'] = 60 is a client-side timeout, configuring your local socket. If you have a network outage dropping all packets with no RST/FIN, this is how long your client waits before realizing & dropping the connection. You can keep this number low, maybe 60 seconds.

[NikPaushkin]

@alanjcastonguay Thank you for clarification! When I add _request_timeout, it really raises exception. But it does that not after _request_timeout time, though: I got an exception each 5 seconds (seems like some default timeout of urllib3. But that's still much better behaviour.

[ellieayla]

The value is provided to a urllib3.Timeout at

python/kubernetes/client/rest.py

Lines 141 to 147 in 02ef5be

	if _request_timeout:
	if isinstance(_request_timeout, (int, ) if six.PY3 else (int, long)): # noqa: E501,F821
	timeout = urllib3.Timeout(total=_request_timeout)
	elif (isinstance(_request_timeout, tuple) and
	len(_request_timeout) == 2):
	timeout = urllib3.Timeout(
	connect=_request_timeout[0], read=_request_timeout[1])

. Dunno where 5 might be coming from.

[NikPaushkin]

@alanjcastonguay Yep, my bad, forgot to remove my reconnect 5 seconds sleep

[ellieayla]

/remove-kind bug
/triage support

Ok to close this?

[NikPaushkin]

@alanjcastonguay After adding _request_timeout I got a timeout error every _request_timeout seconds, regardless of network connection state

HTTPSConnectionPool(host='10.233.0.1', port=443): Read timed out.

It got all the events and then dies with that error after _request_timeout.

My kwargs is

{"_request_timeout": 90, "timeout_seconds": 3600}