Hi All,
I have a route with direct as following :
from("direct:abc").to("hdfs2:xxxxx?splitStrategy=MESSAGE");
I use the route write files in HDFS. I use the producer template to send a
OutputStream to direct:
producerTemplate,sendBody("direct:abc",OutputStream);
Now HDFS producer creates an .opened file first and renames it upon writing the
file.
So,I will only get the callback from direct,once the file is written and
renamed. Is this correct?
Somehow my route has finished but .opene files is still in the HDFS
directory,which in turn is polled by a HDFS consumer who fail to poll the
.opened file.
BR,
Chirag
