@@ -312,8 +312,8 @@ func getNormalizedVersion(kubeVersion, gkeVersion string) (string, error) {
312
312
313
313
}
314
314
315
- func getKubeClusterVersion () (string , error ) {
316
- out , err := exec .Command (" kubectl" , "version" , "-o=json" ).CombinedOutput ()
315
+ func getKubeClusterVersion (k8sDir string ) (string , error ) {
316
+ out , err := exec .Command (filepath . Join ( k8sDir , "cluster" , " kubectl.sh" ) , "version" , "-o=json" ).CombinedOutput ()
317
317
if err != nil {
318
318
return "" , fmt .Errorf ("failed to obtain cluster version, error: %v" , err )
319
319
}
@@ -325,14 +325,14 @@ func getKubeClusterVersion() (string, error) {
325
325
var v version
326
326
err = json .Unmarshal (out , & v )
327
327
if err != nil {
328
- return "" , fmt .Errorf ("Failed to parse kubectl version output, error: %v" , err )
328
+ return "" , fmt .Errorf ("Failed to parse kubectl version output, error: %v: %s " , err , out )
329
329
}
330
330
331
331
return v .ServerVersion .GitVersion , nil
332
332
}
333
333
334
- func mustGetKubeClusterVersion () string {
335
- ver , err := getKubeClusterVersion ()
334
+ func mustGetKubeClusterVersion (k8sDir string ) string {
335
+ ver , err := getKubeClusterVersion (k8sDir )
336
336
if err != nil {
337
337
klog .Fatalf ("Error: %v" , err )
338
338
}
0 commit comments