diff --git a/source/node.go b/source/node.go
index 52d7badde..36fc56e7f 100644
--- a/source/node.go
+++ b/source/node.go
@@ -139,8 +139,7 @@ func (ns *nodeSource) Endpoints() ([]*endpoint.Endpoint, error) {
 
 		addrs, err := ns.nodeAddresses(node)
 		if err != nil {
-			log.Error(err)
-			continue
+			return nil, fmt.Errorf("failed to get node address from %s: %s", node.Name, err.Error())
 		}
 
 		ep.Targets = endpoint.Targets(addrs)
diff --git a/source/node_test.go b/source/node_test.go
index 009c15912..1b3a7458e 100644
--- a/source/node_test.go
+++ b/source/node_test.go
@@ -175,7 +175,7 @@ func testNodeSourceEndpoints(t *testing.T) {
 			map[string]string{},
 			map[string]string{},
 			[]*endpoint.Endpoint{},
-			false,
+			true,
 		},
 		{
 			"annotated node without annotation filter returns endpoint",