hadoop - 租约不匹配 LeaseExpiredException

标签 hadoop mapreduce iteration sequencefile

我看过一些关于这个主题的帖子,但我想不出解决我的问题的方法。我正在使用 Hadoop 版本 Hadoop 2.0.0-cdh4.2.0 和 java 版本“1.7.0_09-icedtea”。我正在运行一个程序,该程序利用计数器在一个简单的 mapreduce 示例中控制交互。我还使用序列文件来传输数据。代码很简单:它以数字开头,比如 3。映射器不修改数字,只是简单地传输值; reducer 每次运行时都会将数字减 1。如果数字大于零,则计数器增加。最终,数字必须减少到 0,程序应该在那个点停止。但是,我总是在第一次迭代后(在第二次迭代期间)收到以下错误:

" Running job: job_201304151408_0181
13/05/10 18:55:54 INFO mapred.JobClient:  map 0% reduce 0%
13/05/10 18:56:03 INFO mapred.JobClient:  map 100% reduce 0%
13/05/10 18:56:10 INFO mapred.JobClient:  map 100% reduce 33%

13/05/10 18:56:11 INFO mapred.JobClient: Task Id : attempt_201304151408_0181_r_000002_0, Status : FAILED
org.apache.hadoop.ipc.RemoteException(org.apache.hadoop.hdfs.server.namenode.LeaseExpiredException): Lease mismatch on /user/harsha/iterone/import/data owned by DFSClient_NONMAPREDUCE_-592566041_1 but is accessed by DFSClient_NONMAPREDUCE_-965911637_1"

有人可以帮忙吗?谢谢。

问候...

最佳答案

如果我们试图写入一个不存在的文件,通常会发生 Lease Mismatch。

请检查/user/harsha/iterone/import/data是否在hdfs中。

那是一个文件吗?

关于hadoop - 租约不匹配 LeaseExpiredException,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/16484158/

相关文章:

java - Hadoop - 按前缀聚合

javascript - 为什么这个迭代永远有效

java - ArrayList.remove 在称为 Collection.remove 时会给出不同的结果

python - For 循环迭代,范围从索引 1 重新开始

apache-spark - 具有区分大小写且未插入到配置单元表中的DataFrame

hadoop - 多种自定义可写格式

hadoop - HDFS 表示文件仍处于打开状态,但写入文件的进程已被终止

java - 如何一次导入/导出所有Hbase表?

hadoop - 混淆 hadoop、giraph 和 twister

Hadoop 为 java.nio.ByteBuffer 的键类型抛出 ClassCastException