Merge "dynamic partition update order is deterministic." am: 47b53c4136
am: 983dd182c7
Change-Id: I6c145d56d8b31da607361d2f7f9808cecbd36d7d
This commit is contained in:
@@ -2226,7 +2226,7 @@ class DynamicPartitionsDifference(object):
|
||||
collections.Counter(e.partition for e in block_diffs).items()
|
||||
if count > 1])
|
||||
|
||||
self._partition_updates = dict()
|
||||
self._partition_updates = collections.OrderedDict()
|
||||
|
||||
for p, block_diff in block_diff_dict.items():
|
||||
self._partition_updates[p] = DynamicPartitionUpdate()
|
||||
@@ -2277,7 +2277,7 @@ class DynamicPartitionsDifference(object):
|
||||
logger.info("Updating dynamic partitions %s",
|
||||
self._partition_updates.keys())
|
||||
|
||||
self._group_updates = dict()
|
||||
self._group_updates = collections.OrderedDict()
|
||||
|
||||
for g in tgt_groups:
|
||||
self._group_updates[g] = DynamicGroupUpdate()
|
||||
|
Reference in New Issue
Block a user