hbase-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From te...@apache.org
Subject hbase git commit: HBASE-19300 TestMultithreadedTableMapper fails in branch-1.4
Date Mon, 27 Nov 2017 19:41:30 GMT
Repository: hbase
Updated Branches:
  refs/heads/branch-1 de16690b7 -> f7f425e53


HBASE-19300 TestMultithreadedTableMapper fails in branch-1.4


Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/f7f425e5
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/f7f425e5
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/f7f425e5

Branch: refs/heads/branch-1
Commit: f7f425e53ed4b6feb63b88aa6f02f2836607e10c
Parents: de16690
Author: tedyu <yuzhihong@gmail.com>
Authored: Mon Nov 27 11:41:46 2017 -0800
Committer: tedyu <yuzhihong@gmail.com>
Committed: Mon Nov 27 11:41:46 2017 -0800

----------------------------------------------------------------------
 .../apache/hadoop/hbase/mapreduce/MultithreadedTableMapper.java  | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hbase/blob/f7f425e5/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/MultithreadedTableMapper.java
----------------------------------------------------------------------
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<K2, V2> extends TableMapper<K2,
V2> {
 
     @Override
     public boolean nextKeyValue() throws IOException, InterruptedException {
-      synchronized (this) {
+      synchronized (outer) {
         if (!outer.nextKeyValue()) {
           return false;
         }
@@ -198,7 +198,7 @@ public class MultithreadedTableMapper<K2, V2> extends TableMapper<K2,
V2> {
     @Override
     public void write(K2 key, V2 value) throws IOException,
     InterruptedException {
-      synchronized (this) {
+      synchronized (outer) {
         outer.write(key, value);
       }
     }


Mime
View raw message