Github user d2r commented on a diff in the pull request: https://github.com/apache/storm/pull/2881#discussion_r227896771 --- Diff: storm-client/src/jvm/org/apache/storm/Config.java --- @@ -1041,6 +1041,19 @@ @isPositiveNumber @NotNull public static final String SUPERVISOR_WORKER_TIMEOUT_SECS = "supervisor.worker.timeout.secs"; + + /** + * A map with blobstore keys mapped to each NUMA Node on the supervisor that will be used + * by scheduler. CPUs, memory and ports available on each NUMA node will be provided. + * Each supervisor will have different map of NUMAs. + * Example: "supervisor.numa.meta": { "numas": [ + * {"node_id": 0, "memory.mb": 122880, "cores": [ 0, 12, 1, 13, 2, 14, 3, 15, 4, 16, 5, 17], + * "ports": [6700, 6701]}, + * {"node_id": 1, "memory.mb": 122880, "cores": [ 6, 18, 7, 19, 8, 20, 9, 21, 10, 22, 11, 23], + * "ports": [6702, 6703]}]} + */ + public static final String SUPERVISOR_NUMA_META = "supervisor.numa.meta"; --- End diff -- We could add `@isType(type = Map.class)` here for some shallow validation.
---