[FLINK-1110] Fix MapOperator execution and added simple test