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 <[email protected]>
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
['"[email protected]" <[email protected]>'].
