diff --git metastore/src/java/org/apache/hadoop/hive/metastore/MetaStoreSchemaInfo.java metastore/src/java/org/apache/hadoop/hive/metastore/MetaStoreSchemaInfo.java index 50d03a8..70812f6 100644 --- metastore/src/java/org/apache/hadoop/hive/metastore/MetaStoreSchemaInfo.java +++ metastore/src/java/org/apache/hadoop/hive/metastore/MetaStoreSchemaInfo.java @@ -45,8 +45,10 @@ // Minor version upgrades often don't change schema. So they are equivalent to a version // that has a corresponding schema. eg "0.13.1" is equivalent to "0.13.0" + + // "0.15.0" to "0.14.0" is temporal mapping. if the schema for 0.15.0 is changed, this should be removed. private static final Map EQUIVALENT_VERSIONS = - ImmutableMap.of("0.13.1", "0.13.0"); + ImmutableMap.of("0.13.1", "0.13.0", "0.15.0", "0.14.0"); public MetaStoreSchemaInfo(String hiveHome, HiveConf hiveConf, String dbType) throws HiveMetaException { this.hiveHome = hiveHome; diff --git ql/src/test/results/clientpositive/parallel.q.out ql/src/test/results/clientpositive/parallel.q.out index 5255ccd..f6c0f65 100644 --- ql/src/test/results/clientpositive/parallel.q.out +++ ql/src/test/results/clientpositive/parallel.q.out @@ -161,6 +161,7 @@ POSTHOOK: type: QUERY POSTHOOK: Input: default@src POSTHOOK: Output: default@src_a POSTHOOK: Output: default@src_b +POSTHOOK: Lineage: src_a.key SIMPLE [(src)src.FieldSchema(name:key, type:string, comment:default), ] POSTHOOK: Lineage: src_a.value SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] POSTHOOK: Lineage: src_b.key SIMPLE [(src)src.FieldSchema(name:key, type:string, comment:default), ] POSTHOOK: Lineage: src_b.value SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ]