Fixed 'Cannot postpone partition processing' problem and added partition owner check to Map and MultiMap KeyValueSource implementations