diff options
| author | Jan Unterbrink <jan.unterbrink@subpath.de> | 2019-09-04 10:02:00 +0200 |
|---|---|---|
| committer | Jan Unterbrink <jan.unterbrink@subpath.de> | 2019-09-04 10:02:00 +0200 |
| commit | 305672b7d3f88b3cd76f9b277fafdfb5a642ba06 (patch) | |
| tree | f7c5b8565da0e2667b036001ccaa9e319cffe87b | |
| parent | Merge pull request #1085 from fisherxu/local-up (diff) | |
| download | kubeedge-305672b7d3f88b3cd76f9b277fafdfb5a642ba06.tar.gz | |
remove unnecesssary error check
| -rw-r--r-- | cloud/pkg/edgecontroller/controller/upstream.go | 4 |
1 files changed, 0 insertions, 4 deletions
diff --git a/cloud/pkg/edgecontroller/controller/upstream.go b/cloud/pkg/edgecontroller/controller/upstream.go index 5a9bb5362..57c3e6d64 100644 --- a/cloud/pkg/edgecontroller/controller/upstream.go +++ b/cloud/pkg/edgecontroller/controller/upstream.go @@ -193,10 +193,6 @@ func (uc *UpstreamController) dispatchMessage(stop chan struct{}) { } klog.Infof("message: %s, resource type is: %s", msg.GetID(), resourceType) operationType := msg.GetOperation() - if err != nil { - klog.Warningf("parse message: %s operation type with error: %s", msg.GetID(), err) - continue - } klog.Infof("message: %s, operation type is: %s", msg.GetID(), operationType) switch resourceType { |