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
