Hi to all,

in my Flink job I wanted to move a folder (containing other folders and
files) to another location.
For example, I wanted to move folder A to folder Y, where my HDFS looks
like:

myRootDir/X/a/aa/aaa/someFile1
myRootDir/X/b/bb/bbb/someFile2
myRootDir/Y

I tried to use rename but it silently fails (rename just returns false) if
the parent directory doesn't exists.
Is there an easy way to do that with the Flink FS apis?
If the rename() is intended to work that way, couldn't be useful a move()
API..?

Best,
Flavio

Reply via email to