Hi.

>From my presentation on Flink forward you can validate this
•We used EMR on Amazon’s Linux AMI
•We didn't change the default blob server location (/tmp)
•Default a cron job cleaning up in /tmp
•Solution change blob server location with blob.storage.directory

Den tir. 11. sep. 2018 kl. 09.14 skrev miki haiat <miko5...@gmail.com>:

> /tmp/blobStore
> Is it the path  for checkpoints/savepoints  storage ?
>
> On Tue, 11 Sep 2018, 10:01 Raja.Aravapalli, <raja.aravapa...@target.com>
> wrote:
>
>> Hi,
>>
>>
>>
>> My Flink application which reads from Kafka and writes to HDFS is failing
>> repeatedly with below exception:
>>
>>
>>
>> Caused by: java.io.IOException: Server side error: Cannot find required
>> BLOB at /tmp/blobStore-**********
>>
>>
>>
>> Can someone please help me on, what could be the root cause of this
>> issue?  I am not able to trace logs also.
>>
>>
>>
>> Also, FYI, our FLINK cluster(4nodes) is setup on our Hadoop YARN cluster.
>>
>>
>>
>> Thanks a lot.
>>
>>
>>
>>
>>
>> Regards,
>>
>> Raja.
>>
>

Reply via email to