diff --git a/scale-demo/aggregator/aggregator.go b/scale-demo/aggregator/aggregator.go
index 161708819b..b8a6fbc7b8 100644
--- a/scale-demo/aggregator/aggregator.go
+++ b/scale-demo/aggregator/aggregator.go
@@ -101,7 +101,17 @@ func loadData() {
 		fmt.Printf("Error creating client: %v", err)
 		return
 	}
-	pods, err := c.Pods("default").List(labels.Everything(), fields.Everything())
+	var labelSelector labels.Selector
+	if *selector != "" {
+		labelSelector, err = labels.Parse(*selector)
+		if err != nil {
+			fmt.Printf("Parse label selector err: %v", err)
+			return
+		}
+	} else {
+		labelSelector = labels.Everything()
+	}
+	pods, err := c.Pods("default").List(labelSelector, fields.Everything())
 	if err != nil {
 		fmt.Printf("Error getting pods: %v", err)
 		return