Hi colleagues,
I am experiencing problems when trying to write events from a stream to HDFS. I get the following exception:
org.apache.hadoop.ipc.RemoteException(org.apache.hadoop.hdfs.protocol.AlreadyBeingCreatedException): failed to create file /user/biguardian/events/2016-11-28--15/flinkpart-0-0.text for DFSClient_NONMAPREDUCE_1634980080_43 for client 172.21.40.75
because current leaseholder is trying to recreate file.
My Flink version is 1.1.3 and I am running it directly from a JAR (not in YARN) with java -jar.
Do you know the reason of this error?
Kind regards,
Diego
| Free forum by Nabble | Edit this page |