() {   when(this.appRegistryService.appExist("time", ApplicationType.source)).thenReturn(true);   when(this.appRegistryService.appExist("log", ApplicationType.sink)).thenReturn(true);    thrown.expect(InvalidStreamDefinitionException.class);   thrown.expectMessage("Application name '