You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by el...@apache.org on 2014/10/23 20:58:25 UTC
[8/9] git commit: ACCUMULO-3249 Work should be created regardless of
open or closed
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 <el...@apache.org>
Authored: Wed Oct 22 15:01:49 2014 -0400
Committer: Josh Elser <el...@apache.org>
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) {