Skip to content

Commit cd0aaac

Browse files
committed
Skip to call metadata store API if no data available
Signed-off-by: Alan Zhang <shuai.xyz@gmail.com>
1 parent d0daae4 commit cd0aaac

1 file changed

Lines changed: 12 additions & 5 deletions

File tree

samza-core/src/main/java/org/apache/samza/container/grouper/task/TaskAssignmentManager.java

Lines changed: 12 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -142,11 +142,18 @@ public void writeTaskContainerMappings(Map<String, Map<String, TaskMode>> mappin
142142
}
143143
}
144144
}
145-
146-
taskContainerMappingMetadataStore.deleteAll(taskContainerMappingsToBeDeleted);
147-
taskModeMappingMetadataStore.deleteAll(taskModeMappingsToBeDeleted);
148-
taskContainerMappingMetadataStore.putAll(taskContainerMappingsToBeStored);
149-
taskModeMappingMetadataStore.putAll(taskModeMappingsToBeStored);
145+
if (!taskContainerMappingsToBeDeleted.isEmpty()) {
146+
taskContainerMappingMetadataStore.deleteAll(taskContainerMappingsToBeDeleted);
147+
}
148+
if (!taskModeMappingsToBeDeleted.isEmpty()) {
149+
taskModeMappingMetadataStore.deleteAll(taskModeMappingsToBeDeleted);
150+
}
151+
if (!taskContainerMappingsToBeStored.isEmpty()) {
152+
taskContainerMappingMetadataStore.putAll(taskContainerMappingsToBeStored);
153+
}
154+
if (!taskModeMappingsToBeStored.isEmpty()) {
155+
taskModeMappingMetadataStore.putAll(taskModeMappingsToBeStored);
156+
}
150157
}
151158

152159
/**

0 commit comments

Comments
 (0)