First, thanks for all of your work ! I’m really impressed how well the system works :)
I’m currently using
akka-stream-alpakka-hdfs_2.12:3.0.3 in order to dump a stream.
When the source terminates, I’d like the rotation to happen (in other words, the file in temporary directory should be moved to the correct location in HDFS).
Afaik, the source is correctly closed currently.
Is there an approach to do so?
Thanks in advance for your answers, I hope I’ve sufficiently searched for an answer before posting