当我使用storm scheduler时，一个主机可以被安排两次吗？

cwxwcias 于 2021-06-21 发布在 Storm

关注(0)|答案(1)|浏览(265)

例如

topology.newStream("process", new RawDataSpout())
                .parallelismHint(1)
                .shuffle()
                .each(new Fields("frameID"), new RawToRgb(), new Fields("frameIDRawToRgbCompleted"))
                .parallelismHint(1)
                .shuffle()
                .each(new Fields("frameID", "frameIDRawToRgbCompleted"), new StereoInit(), new Fields("frameIDInitCompleted"))
                .parallelismHint(1)
                .setMemoryLoad(6144)
                .shuffle()
                .each(new Fields("frameID", "frameIDRawToRgbCompleted", "frameIDInitCompleted"), new StereoRing(), new Fields("frameIDRingCompleted"))
                .parallelismHint(1)
                .shuffle()
                .each(new Fields("frameID", "frameIDRawToRgbCompleted", "frameIDInitCompleted", "frameIDRingCompleted"), new Rendering(), new Fields("frameIDRenderingCompleted"))
                .parallelismHint(1)
                .setMemoryLoad(6144);

正如上面的代码，一个主机可以同时运行stereoinit和rendering吗？

scheduler apache-storm trident

来源：https://stackoverflow.com/questions/39139050/when-i-use-storm-scheduler-can-one-host-be-scheduled-for-two-times