diff --git a/pkg/pmem-device-manager/pmd-ndctl.go b/pkg/pmem-device-manager/pmd-ndctl.go index ed1c0fdcbc..53c3d5bb01 100644 --- a/pkg/pmem-device-manager/pmd-ndctl.go +++ b/pkg/pmem-device-manager/pmd-ndctl.go @@ -70,7 +70,11 @@ func (pmem *pmemNdctl) DeleteDevice(name string, flush bool) error { } func (pmem *pmemNdctl) FlushDeviceData(name string) error { - return fmt.Errorf("Unsupported for pmem devices") + device, err := pmem.GetDevice(name) + if err != nil { + return err + } + return flushDevice(device) } func (pmem *pmemNdctl) GetDevice(name string) (PmemDeviceInfo, error) {