diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/MultithreadedTableMapper.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/MultithreadedTableMapper.java index ca5ef01..0b377ab 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/MultithreadedTableMapper.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/MultithreadedTableMapper.java @@ -166,7 +166,7 @@ public class MultithreadedTableMapper extends TableMapper { @Override public boolean nextKeyValue() throws IOException, InterruptedException { - synchronized (this) { + synchronized (outer) { if (!outer.nextKeyValue()) { return false; } @@ -198,7 +198,7 @@ public class MultithreadedTableMapper extends TableMapper { @Override public void write(K2 key, V2 value) throws IOException, InterruptedException { - synchronized (this) { + synchronized (outer) { outer.write(key, value); } }