ACCUMULO-3249 Work should be created regardless of open or closed
Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/48f94bd2 Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/48f94bd2 Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/48f94bd2 Branch: refs/heads/master Commit: 48f94bd2905e04b8df0051d57d019684473a3461 Parents: 6a713aa Author: Josh Elser <[email protected]> Authored: Wed Oct 22 15:01:49 2014 -0400 Committer: Josh Elser <[email protected]> Committed: Thu Oct 23 11:18:59 2014 -0400 ---------------------------------------------------------------------- .../java/org/apache/accumulo/master/replication/WorkMaker.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/accumulo/blob/48f94bd2/server/master/src/main/java/org/apache/accumulo/master/replication/WorkMaker.java ---------------------------------------------------------------------- diff --git a/server/master/src/main/java/org/apache/accumulo/master/replication/WorkMaker.java b/server/master/src/main/java/org/apache/accumulo/master/replication/WorkMaker.java index da17bba..0eefca3 100644 --- a/server/master/src/main/java/org/apache/accumulo/master/replication/WorkMaker.java +++ b/server/master/src/main/java/org/apache/accumulo/master/replication/WorkMaker.java @@ -155,7 +155,7 @@ public class WorkMaker { * @return Should a Work entry be created for this status */ protected boolean shouldCreateWork(Status status) { - return status.getClosed() || StatusUtil.isWorkRequired(status); + return StatusUtil.isWorkRequired(status); } protected void addWorkRecord(Text file, Value v, Map<String,String> targets, String sourceTableId) {
