Browse code
Fix use of deprecated PodSpec field name
Dan Winship authored on 2016/09/16 09:00:44Showing 2 changed files
| ... | ... |
@@ -130,7 +130,7 @@ func (node *OsdnNode) Start() error {
|
| 130 | 130 |
} |
| 131 | 131 |
|
| 132 | 132 |
func (node *OsdnNode) GetLocalPods(namespace string) ([]kapi.Pod, error) {
|
| 133 |
- fieldSelector := fields.Set{"spec.host": node.hostName}.AsSelector()
|
|
| 133 |
+ fieldSelector := fields.Set{"spec.nodeName": node.hostName}.AsSelector()
|
|
| 134 | 134 |
opts := kapi.ListOptions{
|
| 135 | 135 |
LabelSelector: labels.Everything(), |
| 136 | 136 |
FieldSelector: fieldSelector, |
| ... | ... |
@@ -156,7 +156,7 @@ func getScriptError(output []byte) string {
|
| 156 | 156 |
} |
| 157 | 157 |
|
| 158 | 158 |
func (plugin *OsdnNode) getPod(nodeName, namespace, podName string) (*kapi.Pod, error) {
|
| 159 |
- fieldSelector := fields.Set{"spec.host": nodeName}.AsSelector()
|
|
| 159 |
+ fieldSelector := fields.Set{"spec.nodeName": nodeName}.AsSelector()
|
|
| 160 | 160 |
opts := kapi.ListOptions{
|
| 161 | 161 |
LabelSelector: labels.Everything(), |
| 162 | 162 |
FieldSelector: fieldSelector, |