Guys I have a simple DAG where I simply want to partition the input data. In theory this should not require more then a single Vertex (read splits and write them to individual partitions). IN other words a Vertex with Datasource and DataSink. However, it appears unless I have a vertex sending its output to a OrderedPartitionedKVOutput, partitioner is not being called and the output goes to a single partition.
Any pointers? Cheers Oleg
