@Test(expected = RuntimeException.class)
public void testLoadKeyWithWrongJson() throws Exception {

    elasticsearchServer.getClient().prepareIndex()
            .setIndex(TABLE_META_INDEX)
            .setType(TABLE_META_TYPE)
            .setConsistencyLevel(WriteConsistencyLevel.ALL)
            .setSource("{ \"test\" : \"test\"}")
            .setId(TEST_TABLE)
            .setRefresh(true)
            .execute()
            .actionGet();
    tableMapStore.load(TEST_TABLE);
}