Skip to content

K
k3s
Commit 6669e43f authored by k8s-merge-robot's avatar k8s-merge-robot
Browse files
Options

Merge pull request #22622 from Kaffa-MY/k8s-flocker

Auto commit by PR queue bot
parents f54afa0a a5189d8b
Hide whitespace changes
Inline Side-by-side
Showing with 7 additions and 1 deletion
pkg/volume/flocker/plugin.go
View file @ 6669e43f
...@@ -199,9 +199,15 @@ func (b flockerBuilder) SetUpAt(dir string, fsGroup *int64) error { ...@@ -199,9 +199,15 @@ func (b flockerBuilder) SetUpAt(dir string, fsGroup *int64) error {
if err := b.updateDatasetPrimary(datasetID, primaryUUID); err != nil { if err := b.updateDatasetPrimary(datasetID, primaryUUID); err != nil {
return err return err
} }
newState, err := b.client.GetDatasetState(datasetID)
if err != nil {
return fmt.Errorf("The volume '%s' migrated unsuccessfully.", datasetID)
}
b.flocker.path = newState.Path
} else {
b.flocker.path = s.Path
} }
b.flocker.path = s.Path
volumeutil.SetReady(b.getMetaDir()) volumeutil.SetReady(b.getMetaDir())
return nil return nil
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment