incubator-blur-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From amccu...@apache.org
Subject [3/4] git commit: Fixing logic issue with the processing cluster cache.
Date Mon, 21 Sep 2015 14:43:04 GMT
Fixing logic issue with the processing cluster cache.


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

Branch: refs/heads/master
Commit: b57fd24fef5be2c4ceea471990dcaa4801337af9
Parents: 901543c
Author: Aaron McCurry <amccurry@gmail.com>
Authored: Mon Sep 21 10:41:38 2015 -0400
Committer: Aaron McCurry <amccurry@gmail.com>
Committed: Mon Sep 21 10:41:38 2015 -0400

----------------------------------------------------------------------
 .../java/org/apache/blur/mapreduce/lib/GenericRecordReader.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/b57fd24f/blur-mapred/src/main/java/org/apache/blur/mapreduce/lib/GenericRecordReader.java
----------------------------------------------------------------------
diff --git a/blur-mapred/src/main/java/org/apache/blur/mapreduce/lib/GenericRecordReader.java
b/blur-mapred/src/main/java/org/apache/blur/mapreduce/lib/GenericRecordReader.java
index 680f9f2..ae6e09b 100644
--- a/blur-mapred/src/main/java/org/apache/blur/mapreduce/lib/GenericRecordReader.java
+++ b/blur-mapred/src/main/java/org/apache/blur/mapreduce/lib/GenericRecordReader.java
@@ -194,7 +194,7 @@ public class GenericRecordReader {
       if (localDir.fileLength(name) == fileLength) {
         LOG.info("Cache file length matches [{0}]", name);
         String lastModFile = name + LASTMOD;
-        if (localDir.fileExists(lastModFile) && localDir.fileLength(lastModFile)
!= 8) {
+        if (localDir.fileExists(lastModFile) && localDir.fileLength(lastModFile)
== 8) {
           LOG.info("Cache file last mod file exists [{0}]", name);
           IndexInput input = localDir.openInput(lastModFile, IOContext.DEFAULT);
           long lastMod = input.readLong();


Mime
View raw message