IncompleteRead error while streaming to watch some apis

I'm using 6.0.0 with Kubernetes 1.9.
I'm trying using watch API like this.

        w = watch.Watch()
        for event in w.stream(
                self.api_instance_ext_v1Beta1API.
                list_ingress_for_all_namespaces,
                **kwargs):
                 ...

At first loop, it works fine.
However, I got this error from the second loop when there is no change of watching Resources.

  File "/usr/local/lib/python3.6/site-packages/kubernetes/watch/watch.py", line 124, in stream
    for line in iter_resp_lines(resp):
  File "/usr/local/lib/python3.6/site-packages/kubernetes/watch/watch.py", line 45, in iter_resp_lines
    for seg in resp.read_chunked(decode_content=False):
  File "/usr/local/lib/python3.6/site-packages/urllib3/response.py", line 626, in read_chunked
    self._original_response.close()
  File "/usr/local/lib/python3.6/contextlib.py", line 99, in __exit__
    self.gen.throw(type, value, traceback)
  File "/usr/local/lib/python3.6/site-packages/urllib3/response.py", line 320, in _error_catcher
    raise ProtocolError('Connection broken: %r' % e, e)
urllib3.exceptions.ProtocolError: ('Connection broken: IncompleteRead(0 bytes read)', IncompleteRead(0 bytes read))

I think it's because k8s disconnects watch api after 10 minutes.
kubernetes-client intentionally let me handle this?

I had issues with Watch() while using k8 v1.7 and python client 6.0. Later I changed python client to 2.0 and it's working. What I observed is that the client documentation is not updated for the latest version which 6.0.

Now.. I'm doing like this.

from urllib3.exceptions import ProtocolError
...
w = watch.Watch()
try:              
    for event in w.stream(list_resources, **kwargs):
...
except ProtocolError:
    print('skip this error... because kubelet disconnect client after default 10m...')  
...

Is it a known exception? then I will close the issue...

Issues go stale after 90d of inactivity.
Mark the issue as fresh with /remove-lifecycle stale.
Stale issues rot after an additional 30d of inactivity and eventually close.

If this issue is safe to close now please do so with /close.

Send feedback to sig-testing, kubernetes/test-infra and/or fejta.
/lifecycle stale

Stale issues rot after 30d of inactivity.
Mark the issue as fresh with /remove-lifecycle rotten.
Rotten issues close after an additional 30d of inactivity.

If this issue is safe to close now please do so with /close.

Send feedback to sig-testing, kubernetes/test-infra and/or fejta.
/lifecycle rotten

Rotten issues close after 30d of inactivity.
Reopen the issue with /reopen.
Mark the issue as fresh with /remove-lifecycle rotten.

Send feedback to sig-testing, kubernetes/test-infra and/or fejta.
/close

@fejta-bot

@fejta-bot: Closing this issue.

Details

In response to this:

Rotten issues close after 30d of inactivity.
Reopen the issue with /reopen.
Mark the issue as fresh with /remove-lifecycle rotten.

Send feedback to sig-testing, kubernetes/test-infra and/or fejta.
/close

Instructions for interacting with me using PR comments are available here. If you have questions or suggestions related to my behavior, please file an issue against the kubernetes/test-infra repository.

retry logic for ProtocolError during wait_for_completion

Navigation Menu

Repository navigation

IncompleteRead error while streaming to watch some apis #540

Metadata

Assignees

Labels

Type

Projects

Milestone

Relationships

Development

IncompleteRead error while streaming to watch some apis #540

Description

Activity

abushoeb commented on Jun 18, 2018

steveum0105 commented on Jun 19, 2018

fejta-bot commented on Apr 24, 2019

fejta-bot commented on May 24, 2019

fejta-bot commented on Jun 23, 2019

k8s-ci-robot commented on Jun 23, 2019

Metadata

Metadata

Assignees

Labels

Type

Projects

Milestone

Relationships

Development

Issue actions