Skip to content

Commit

Permalink
Revert "Clusterloader: change the detailed measurement logs to V(2)"
Browse files Browse the repository at this point in the history
This reverts commit bf383bc.
  • Loading branch information
mm4tt committed May 21, 2020
1 parent 6a745dd commit ee795cd
Show file tree
Hide file tree
Showing 6 changed files with 7 additions and 7 deletions.
2 changes: 1 addition & 1 deletion clusterloader2/pkg/measurement/util/phase_latency.go
Original file line number Diff line number Diff line change
Expand Up @@ -119,7 +119,7 @@ func (o *ObjectTransitionTimes) printLatencies(latencies []LatencyData, header s
if index < 0 {
index = 0
}
klog.V(2).Infof("%s: %d %s: %v", o.name, len(latencies)-index, header, latencies[index:])
klog.Infof("%s: %d %s: %v", o.name, len(latencies)-index, header, latencies[index:])
var thresholdString string
if threshold != time.Duration(0) {
thresholdString = fmt.Sprintf("; threshold %v", threshold)
Expand Down
2 changes: 1 addition & 1 deletion clusterloader2/pkg/measurement/util/wait_for_nodes.go
Original file line number Diff line number Diff line change
Expand Up @@ -54,7 +54,7 @@ func WaitForNodes(clientSet clientset.Interface, stopCh <-chan struct{}, options
case <-time.After(options.WaitForNodesInterval):
nodeCount = getNumReadyNodes(ps.List())
if options.EnableLogging {
klog.V(2).Infof("%s: node count (selector = %v): %d", options.CallerName, options.Selector.String(), nodeCount)
klog.Infof("%s: node count (selector = %v): %d", options.CallerName, options.Selector.String(), nodeCount)
}
if options.MinDesiredNodeCount <= nodeCount && nodeCount <= options.MaxDesiredNodeCount {
return nil
Expand Down
4 changes: 2 additions & 2 deletions clusterloader2/pkg/measurement/util/wait_for_pods.go
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,7 @@ import (
"strings"
"time"

v1 "k8s.io/api/core/v1"
"k8s.io/api/core/v1"
clientset "k8s.io/client-go/kubernetes"
"k8s.io/klog"
)
Expand Down Expand Up @@ -89,7 +89,7 @@ func WaitForPods(clientSet clientset.Interface, stopCh <-chan struct{}, options
klog.Errorf("%s: %s: %d pods appeared: %v", options.CallerName, options.Selector.String(), len(addedPods), strings.Join(addedPods, ", "))
}
if options.EnableLogging {
klog.V(2).Infof("%s: %s: %s", options.CallerName, options.Selector.String(), podsStatus.String())
klog.Infof("%s: %s: %s", options.CallerName, options.Selector.String(), podsStatus.String())
}
// We allow inactive pods (e.g. eviction happened).
// We wait until there is a desired number of pods running and all other pods are inactive.
Expand Down
2 changes: 1 addition & 1 deletion clusterloader2/pkg/measurement/util/wait_for_pvcs.go
Original file line number Diff line number Diff line change
Expand Up @@ -76,7 +76,7 @@ func WaitForPVCs(clientSet clientset.Interface, stopCh <-chan struct{}, options
klog.Errorf("%s: %s: %d PVCs appeared: %v", options.CallerName, options.Selector.String(), len(deletedPVCs), strings.Join(deletedPVCs, ", "))
}
if options.EnableLogging {
klog.V(2).Infof("%s: %s: %s", options.CallerName, options.Selector.String(), pvcsStatus.String())
klog.Infof("%s: %s: %s", options.CallerName, options.Selector.String(), pvcsStatus.String())
}
// We wait until there is a desired number of PVCs bound and all other PVCs are pending.
if len(pvcs) == (pvcsStatus.Bound+pvcsStatus.Pending) && pvcsStatus.Bound == options.DesiredPVCCount {
Expand Down
2 changes: 1 addition & 1 deletion clusterloader2/pkg/measurement/util/wait_for_pvs.go
Original file line number Diff line number Diff line change
Expand Up @@ -76,7 +76,7 @@ func WaitForPVs(clientSet clientset.Interface, stopCh <-chan struct{}, options *
klog.Errorf("%s: %s: %d PVs appeared: %v", options.CallerName, options.Selector.String(), len(deletedPVs), strings.Join(deletedPVs, ", "))
}
if options.EnableLogging {
klog.V(2).Infof("%s: %s: %s", options.CallerName, options.Selector.String(), pvStatus.String())
klog.Infof("%s: %s: %s", options.CallerName, options.Selector.String(), pvStatus.String())
}
// We wait until there is a desired number of PVs provisioned and all other PVs are pending.
if len(pvs) == (pvStatus.Bound+pvStatus.Available+pvStatus.Pending) && pvStatus.Bound+pvStatus.Available == options.DesiredPVCount {
Expand Down
2 changes: 1 addition & 1 deletion clusterloader2/pkg/util/cluster.go
Original file line number Diff line number Diff line change
Expand Up @@ -67,7 +67,7 @@ func LogClusterNodes(c clientset.Interface) error {
externalIP = address.Address
}
}
klog.V(2).Infof("Name: %v, clusterIP: %v, externalIP: %v, isSchedulable: %v", nodeList[i].ObjectMeta.Name, internalIP, externalIP, isSchedulable)
klog.Infof("Name: %v, clusterIP: %v, externalIP: %v, isSchedulable: %v", nodeList[i].ObjectMeta.Name, internalIP, externalIP, isSchedulable)
}
return nil
}
Expand Down

0 comments on commit ee795cd

Please sign in to comment.