StreamSource and Task updated to support connection level partitioning
merge resolved