if (source == null) {
throw new IllegalArgumentException(String.format("No Plugin of type '%s' named '%s' was found",
Constants.Source.PLUGINTYPE, sourceConfig.getName()));
}
PluginProperties sinkProperties = getPluginProperties(sinkConfig);
<BUG>PipelineConfigurable sink = configurer.usePlugin(Constants.Sink.PLUGINTYPE, sinkConfig.getName(), sinkPluginId,
sinkProperties);
if (sink == null) {</BUG>
throw new IllegalArgumentException(String.format("No Plugin of type '%s' named '%s' was found",
Constants.Sink.PLUGINTYPE, sinkConfig.getName()));

if (source == null) {
throw new IllegalArgumentException(String.format("No Plugin of type '%s' named '%s' was found",
Constants.Source.PLUGINTYPE, sourceConfig.getName()));
}
PluginProperties sinkProperties = getPluginProperties(sinkConfig);
PipelineConfigurable sink = configurer.usePlugin(Constants.Sink.PLUGINTYPE, sinkConfig.getName(),
sinkPluginId, sinkProperties);
if (sink == null) {
throw new IllegalArgumentException(String.format("No Plugin of type '%s' named '%s' was found",
Constants.Sink.PLUGINTYPE, sinkConfig.getName()));
