diff --git a/waggle-dance-core/src/test/java/com/hotels/bdp/waggledance/mapping/service/impl/YamlFederatedMetaStoreStorageTest.java b/waggle-dance-core/src/test/java/com/hotels/bdp/waggledance/mapping/service/impl/YamlFederatedMetaStoreStorageTest.java index 1882de25..a39434a8 100644 --- a/waggle-dance-core/src/test/java/com/hotels/bdp/waggledance/mapping/service/impl/YamlFederatedMetaStoreStorageTest.java +++ b/waggle-dance-core/src/test/java/com/hotels/bdp/waggledance/mapping/service/impl/YamlFederatedMetaStoreStorageTest.java @@ -216,7 +216,7 @@ public void saveFederationWriteFederations() throws Exception { storage.insert(newFederatedInstance); storage.saveFederation(); List lines = Files.readAllLines(file.toPath(), StandardCharsets.UTF_8); - assertThat(lines.size(), is(26)); + assertThat(lines.size(), is(25)); assertThat(lines.get(0), is("primary-meta-store:")); assertThat(lines.get(1), is(" access-control-type: READ_ONLY")); assertThat(lines.get(2), is(" database-prefix: ''")); @@ -227,22 +227,21 @@ public void saveFederationWriteFederations() throws Exception { assertThat(lines.get(7), is("- access-control-type: READ_ONLY")); assertThat(lines.get(8), is(" configuration-properties:")); assertThat(lines.get(9), is(" hive.metastore.kerberos.principal: hive/_HOST@REALM")); - assertThat(lines.get(10), is(" database-name-mapping: {}")); - assertThat(lines.get(11), is(" database-prefix: hcom_2_")); - assertThat(lines.get(12), is(" hive-metastore-filter-hook: filter.hook.class")); - assertThat(lines.get(13), is(" latency: 0")); - assertThat(lines.get(14), is(" mapped-databases:")); - assertThat(lines.get(15), is(" - db1")); - assertThat(lines.get(16), is(" - db2")); - assertThat(lines.get(17), is(" mapped-tables:")); - assertThat(lines.get(18), is(" - database: db1")); - assertThat(lines.get(19), is(" mapped-tables:")); - assertThat(lines.get(20), is(" - tbl1")); - assertThat(lines.get(21), is(" - database: db2")); - assertThat(lines.get(22), is(" mapped-tables:")); - assertThat(lines.get(23), is(" - tbl2")); - assertThat(lines.get(24), is(" name: hcom_2")); - assertThat(lines.get(25), is(" remote-meta-store-uris: thrift://localhost:29083")); + assertThat(lines.get(10), is(" database-prefix: hcom_2_")); + assertThat(lines.get(11), is(" hive-metastore-filter-hook: filter.hook.class")); + assertThat(lines.get(12), is(" latency: 0")); + assertThat(lines.get(13), is(" mapped-databases:")); + assertThat(lines.get(14), is(" - db1")); + assertThat(lines.get(15), is(" - db2")); + assertThat(lines.get(16), is(" mapped-tables:")); + assertThat(lines.get(17), is(" - database: db1")); + assertThat(lines.get(18), is(" mapped-tables:")); + assertThat(lines.get(19), is(" - tbl1")); + assertThat(lines.get(20), is(" - database: db2")); + assertThat(lines.get(21), is(" mapped-tables:")); + assertThat(lines.get(22), is(" - tbl2")); + assertThat(lines.get(23), is(" name: hcom_2")); + assertThat(lines.get(24), is(" remote-meta-store-uris: thrift://localhost:29083")); } @Test @@ -301,7 +300,7 @@ public void savePrimaryWriteFederations() throws Exception { storage.insert(newFederatedInstance("hcom_2", "thrift://localhost:29083")); storage.saveFederation(); List lines = Files.readAllLines(file.toPath(), StandardCharsets.UTF_8); - assertThat(lines.size(), is(25)); + assertThat(lines.size(), is(24)); assertThat(lines.get(0), is("primary-meta-store:")); assertThat(lines.get(1), is(" access-control-type: READ_ONLY")); assertThat(lines.get(2), is(" configuration-properties:")); @@ -322,11 +321,10 @@ public void savePrimaryWriteFederations() throws Exception { assertThat(lines.get(17), is(" remote-meta-store-uris: thrift://localhost:19083")); assertThat(lines.get(18), is("federated-meta-stores:")); assertThat(lines.get(19), is("- access-control-type: READ_ONLY")); - assertThat(lines.get(20), is(" database-name-mapping: {}")); - assertThat(lines.get(21), is(" database-prefix: hcom_2_")); - assertThat(lines.get(22), is(" latency: 0")); - assertThat(lines.get(23), is(" name: hcom_2")); - assertThat(lines.get(24), is(" remote-meta-store-uris: thrift://localhost:29083")); + assertThat(lines.get(20), is(" database-prefix: hcom_2_")); + assertThat(lines.get(21), is(" latency: 0")); + assertThat(lines.get(22), is(" name: hcom_2")); + assertThat(lines.get(23), is(" remote-meta-store-uris: thrift://localhost:29083")); } private PrimaryMetaStore newPrimaryInstance(String name, String remoteMetaStoreUris) {