flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Diego Fustes Villadóniga <dfus...@oesia.com>
Subject Problems with RollingSink
Date Mon, 28 Nov 2016 16:37:41 GMT
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

Mime
View raw message