[FLINK-1279] [streaming] Forward partitioning changed to use round-robin method