Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-19300 TestMultithreadedTableMapper fails in branch-1.4

This commit is contained in:
tedyu 2017-11-27 11:41:46 -08:00
parent de16690b7a
commit f7f425e53e
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/MultithreadedTableMapper.java
View File

@ -166,7 +166,7 @@ public class MultithreadedTableMapper<K2, V2> extends TableMapper<K2, V2> {
@Override @Override
public boolean nextKeyValue() throws IOException, InterruptedException { public boolean nextKeyValue() throws IOException, InterruptedException {
synchronized (this) { synchronized (outer) {
if (!outer.nextKeyValue()) { if (!outer.nextKeyValue()) {
return false; return false;
} }
@ -198,7 +198,7 @@ public class MultithreadedTableMapper<K2, V2> extends TableMapper<K2, V2> {
@Override @Override
public void write(K2 key, V2 value) throws IOException, public void write(K2 key, V2 value) throws IOException,
InterruptedException { InterruptedException {
synchronized (this) { synchronized (outer) {
outer.write(key, value); outer.write(key, value);
} }
} }