You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by bi...@apache.org on 2017/01/17 05:38:45 UTC

kylin git commit: minor, fix findFristTable fact table filter in DataModelDesc

Repository: kylin
Updated Branches:
  refs/heads/master 576d2dd35 -> f18267043


minor, fix findFristTable fact table filter in DataModelDesc


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

Branch: refs/heads/master
Commit: f18267043df55c2e8a6a378e126a4fafa302f3c8
Parents: 576d2dd
Author: Billy Liu <bi...@apache.org>
Authored: Tue Jan 17 13:38:39 2017 +0800
Committer: Billy Liu <bi...@apache.org>
Committed: Tue Jan 17 13:38:39 2017 +0800

----------------------------------------------------------------------
 .../java/org/apache/kylin/metadata/model/DataModelDesc.java   | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kylin/blob/f1826704/core-metadata/src/main/java/org/apache/kylin/metadata/model/DataModelDesc.java
----------------------------------------------------------------------
diff --git a/core-metadata/src/main/java/org/apache/kylin/metadata/model/DataModelDesc.java b/core-metadata/src/main/java/org/apache/kylin/metadata/model/DataModelDesc.java
index 571b196..cc599a4 100644
--- a/core-metadata/src/main/java/org/apache/kylin/metadata/model/DataModelDesc.java
+++ b/core-metadata/src/main/java/org/apache/kylin/metadata/model/DataModelDesc.java
@@ -273,11 +273,16 @@ public class DataModelDesc extends RootPersistentEntity {
         if (rootFactTableRef.getTableIdentity().equals(tableIdentity))
             return rootFactTableRef;
 
+        for (TableRef fact : factTableRefs) {
+            if (fact.getTableIdentity().equals(tableIdentity))
+                return fact;
+        }
+
         for (TableRef lookup : lookupTableRefs) {
             if (lookup.getTableIdentity().equals(tableIdentity))
                 return lookup;
         }
-        throw new IllegalArgumentException("Table not found by " + tableIdentity);
+        throw new IllegalArgumentException("Table not found by " + tableIdentity + " in model " + name);
     }
 
     public void init(KylinConfig config, Map<String, TableDesc> tables) {