diff --git a/pkg/migrate/migrate.go b/pkg/migrate/migrate.go index 8c07823..4c1373a 100644 --- a/pkg/migrate/migrate.go +++ b/pkg/migrate/migrate.go @@ -33,6 +33,8 @@ const desiredReclaimAnnotation = baseAnnotation + "-reclaim" // but that would require adding the k8s import overrides to our go.mod const IsDefaultStorageClassAnnotation = "storageclass.kubernetes.io/is-default-class" +const pvMigrateContainerName = "pvmigrate" + // Cli uses CLI options to run Migrate func Cli() { var sourceSCName string @@ -240,7 +242,8 @@ func copyOnePVC(ctx context.Context, w *log.Logger, clientset k8sclient.Interfac } podLogsReq := clientset.CoreV1().Pods(ns).GetLogs(createdPod.Name, &corev1.PodLogOptions{ - Follow: true, + Container: pvMigrateContainerName, + Follow: true, }) podLogs, err := podLogsReq.Stream(ctx) if err != nil { @@ -330,7 +333,7 @@ func createMigrationPod(ctx context.Context, clientset k8sclient.Interface, ns s }, Containers: []corev1.Container{ { - Name: "pvmigrate-" + sourcePvcName, + Name: pvMigrateContainerName, Image: rsyncImage, Command: []string{ "rsync", diff --git a/pkg/migrate/migrate_test.go b/pkg/migrate/migrate_test.go index f3a64b3..622815d 100644 --- a/pkg/migrate/migrate_test.go +++ b/pkg/migrate/migrate_test.go @@ -715,7 +715,7 @@ func Test_createMigrationPod(t *testing.T) { }, Containers: []corev1.Container{ { - Name: "pvmigrate-sourcepvc", + Name: "pvmigrate", Image: "imagename", Command: []string{ "rsync",