() {   when(this.streamValidationService.isRegistered("time", ApplicationType.source)).thenReturn(true);   when(this.streamValidationService.isRegistered("log", ApplicationType.sink)).thenReturn(true);    final StreamDefinition expectedStreamDefinition = new StreamDefinition(