Look for the failure zone label in labels.

Not annotations.  Found this working on #27819.
This commit is contained in:
Matt Liggett 2016-06-22 13:26:58 -07:00
parent 1b3d6d7498
commit c87b613412
2 changed files with 3 additions and 3 deletions

View File

@ -648,7 +648,7 @@ func (kd *KubeDNS) getClusterZone() (string, error) {
// Select a node (arbitrarily the first node) that has `LabelZoneFailureDomain` set. // Select a node (arbitrarily the first node) that has `LabelZoneFailureDomain` set.
for _, nodeItem := range nodeList.Items { for _, nodeItem := range nodeList.Items {
if _, ok := nodeItem.Annotations[unversioned.LabelZoneFailureDomain]; !ok { if _, ok := nodeItem.Labels[unversioned.LabelZoneFailureDomain]; !ok {
continue continue
} }
// Make a copy of the node, don't rely on the loop variable. // Make a copy of the node, don't rely on the loop variable.
@ -663,7 +663,7 @@ func (kd *KubeDNS) getClusterZone() (string, error) {
return "", fmt.Errorf("Could not find any nodes") return "", fmt.Errorf("Could not find any nodes")
} }
zone, ok := node.Annotations[unversioned.LabelZoneFailureDomain] zone, ok := node.Labels[unversioned.LabelZoneFailureDomain]
if !ok || zone == "" { if !ok || zone == "" {
return "", fmt.Errorf("unknown cluster zone") return "", fmt.Errorf("unknown cluster zone")
} }

View File

@ -433,7 +433,7 @@ func newNodes() *kapi.NodeList {
{ {
ObjectMeta: kapi.ObjectMeta{ ObjectMeta: kapi.ObjectMeta{
Name: "testnode-1", Name: "testnode-1",
Annotations: map[string]string{ Labels: map[string]string{
// Note: The zone name here is an arbitrary string and doesn't exactly follow the // Note: The zone name here is an arbitrary string and doesn't exactly follow the
// format used by the cloud providers to name their zones. But that shouldn't matter // format used by the cloud providers to name their zones. But that shouldn't matter
// for these tests here. // for these tests here.