taskConfig,
ARG_BUFFER_CAPACITY,
getDefaultIntegerArgument(taskConfig, DEFAULT_BUFFER_CAPACITY)
);
return new MultiChangeSinkRunnableChangeSourceManager(
taskConfig.getId(),
new ChangeMerger(CONFLICT_RESOLUTION_METHOD_MAP.get(conflictResolutionMethod), bufferCapacity),
taskConfig.getPipeArgs()
);
}