kylin-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From liy...@apache.org
Subject kylin git commit: KYLIN-2217 fix bug
Date Thu, 24 Nov 2016 23:16:54 GMT
Repository: kylin
Updated Branches:
  refs/heads/KYLIN-2217-2 e4a22531a -> d14de80ee


KYLIN-2217 fix bug


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

Branch: refs/heads/KYLIN-2217-2
Commit: d14de80ee17691f21ab9225bd1f2880ea1b17c04
Parents: e4a2253
Author: Yang Li <liyang@apache.org>
Authored: Fri Nov 25 07:16:45 2016 +0800
Committer: Yang Li <liyang@apache.org>
Committed: Fri Nov 25 07:16:45 2016 +0800

----------------------------------------------------------------------
 .../main/java/org/apache/kylin/engine/mr/DFSFileTable.java    | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kylin/blob/d14de80e/engine-mr/src/main/java/org/apache/kylin/engine/mr/DFSFileTable.java
----------------------------------------------------------------------
diff --git a/engine-mr/src/main/java/org/apache/kylin/engine/mr/DFSFileTable.java b/engine-mr/src/main/java/org/apache/kylin/engine/mr/DFSFileTable.java
index 8c1f6bd..6f337d0 100644
--- a/engine-mr/src/main/java/org/apache/kylin/engine/mr/DFSFileTable.java
+++ b/engine-mr/src/main/java/org/apache/kylin/engine/mr/DFSFileTable.java
@@ -61,12 +61,13 @@ public class DFSFileTable implements ReadableTable {
 
     @Override
     public TableSignature getSignature() throws IOException {
+        Pair<Long, Long> sizeAndLastModified;
         try {
-            Pair<Long, Long> sizeAndLastModified = getSizeAndLastModified(path);
-            return new TableSignature(path, sizeAndLastModified.getFirst(), sizeAndLastModified.getSecond());
+            sizeAndLastModified = getSizeAndLastModified(path);
         } catch (FileNotFoundException ex) {
-            return null;
+            sizeAndLastModified = Pair.newPair(-1L, 0L);
         }
+        return new TableSignature(path, sizeAndLastModified.getFirst(), sizeAndLastModified.getSecond());
     }
 
     @Override


Mime
View raw message