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.


---

Reply via email to