Thanks for the reply Fabian, Though here's a small thing I found on the documentation page: https://ci.apache.org/projects/flink/flink-docs-release-0.8/programming_guide.html#transformations
If you look into the Union section, "This operation happens implicitly if more than one data set is used for a specific function input." , I'm not sure what this is supposed to mean. My initial assumption was something like: dFinal = dFinal.union( d1, d2, ... , dN); // passing more than one dataset as function input. But as expected, this does not satisfy the union method signature. And so is that line supposed to mean something else? Or is it a feature not supported by flink 0.8 but works with future releases? Thanks, -- Ritesh Kumar Singh https://riteshtoday.wordpress.com/