[accumulo] branch 1.7 updated: ACCUMULO-4699 Fixed queued work key in replication (#295)

[mm...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

mmiller pushed a commit to branch 1.7
in repository https://gitbox.apache.org/repos/asf/accumulo.git


The following commit(s) were added to refs/heads/1.7 by this push:
     new 1bf6620  ACCUMULO-4699 Fixed queued work key in replication (#295)
1bf6620 is described below

commit 1bf6620e070146f37772651bf5ae21cf27e40718
Author: Mike Miller <mm...@apache.org>
AuthorDate: Tue Sep 5 10:54:41 2017 -0400

    ACCUMULO-4699 Fixed queued work key in replication (#295)
---
 .../org/apache/accumulo/master/replication/SequentialWorkAssigner.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/server/master/src/main/java/org/apache/accumulo/master/replication/SequentialWorkAssigner.java b/server/master/src/main/java/org/apache/accumulo/master/replication/SequentialWorkAssigner.java
index f24da7e..4d79b02 100644
--- a/server/master/src/main/java/org/apache/accumulo/master/replication/SequentialWorkAssigner.java
+++ b/server/master/src/main/java/org/apache/accumulo/master/replication/SequentialWorkAssigner.java
@@ -104,7 +104,7 @@ public class SequentialWorkAssigner extends DistributedWorkQueueWorkAssigner {
       Map<String,String> replicationForPeer = queuedWorkByPeerName.get(peerName);
       if (null == replicationForPeer) {
         replicationForPeer = new HashMap<>();
-        queuedWorkByPeerName.put(sourceTableId, replicationForPeer);
+        queuedWorkByPeerName.put(peerName, replicationForPeer);
       }
 
       replicationForPeer.put(sourceTableId, work);

-- 
To stop receiving notification emails like this one, please contact
['"commits@accumulo.apache.org" <co...@accumulo.apache.org>'].