这不是一个真正的答案。评论太长了,所以我必须创建一个答案....
到目前为止很难说这个问题,这是几乎最新代码的预期输出。
$ ~/.heron/bin/heron submit local ~/.heron/examples/heron-streamlet-examples.jar org.apache.heron.examples.streamlet.WindowedWordCountTopology WindowedWordCountTopology --deploy-deactivated
[2019-02-05 15:09:53 -0800] [INFO]: Using cluster definition in /Users/<user>/.heron/conf/local
Feb 05, 2019 3:09:54 PM org.apache.heron.streamlet.impl.StreamletImpl defaultNameCalculator
INFO: Calculated stage Name as consumer1
[2019-02-05 15:09:54 -0800] [INFO]: Launching topology: 'WindowedWordCountTopology'
[2019-02-05 15:09:55 -0800] [INFO] org.apache.heron.packing.roundrobin.RoundRobinPacking: Initalizing RoundRobinPacking. CPU default: 1.000000, RAM default: ByteAmount{1.0 GB (1073741824 bytes)}, DISK default: ByteAmount{1.0 GB (1073741824 bytes)}, RAM padding: ByteAmount{2.0 GB (2147483648 bytes)}.
[2019-02-05 15:09:55 -0800] [INFO] org.apache.heron.packing.roundrobin.RoundRobinPacking: Pack internal: container CPU hint: 3.000, RAM hint: ByteAmount{-1 bytes}, disk hint: ByteAmount{14.0 GB (15032385536 bytes)}.
[2019-02-05 15:09:55 -0800] [INFO] org.apache.heron.packing.roundrobin.RoundRobinPacking: Pack internal finalized: container#1 CPU: 3.000000, RAM: ByteAmount{4.0 GB (4294967296 bytes)}, disk: ByteAmount{14.0 GB (15032385536 bytes)}.
[2019-02-05 15:09:55 -0800] [INFO] org.apache.heron.packing.roundrobin.RoundRobinPacking: Pack internal finalized: container#2 CPU: 3.000000, RAM: ByteAmount{4.0 GB (4294967296 bytes)}, disk: ByteAmount{14.0 GB (15032385536 bytes)}.
[2019-02-05 15:09:55 -0800] [INFO] org.apache.heron.packing.roundrobin.RoundRobinPacking: Initalizing RoundRobinPacking. CPU default: 1.000000, RAM default: ByteAmount{1.0 GB (1073741824 bytes)}, DISK default: ByteAmount{1.0 GB (1073741824 bytes)}, RAM padding: ByteAmount{2.0 GB (2147483648 bytes)}.
[2019-02-05 15:09:55 -0800] [INFO] org.apache.heron.packing.roundrobin.RoundRobinPacking: Pack internal: container CPU hint: 3.000, RAM hint: ByteAmount{-1 bytes}, disk hint: ByteAmount{14.0 GB (15032385536 bytes)}.
[2019-02-05 15:09:55 -0800] [INFO] org.apache.heron.packing.roundrobin.RoundRobinPacking: Pack internal finalized: container#1 CPU: 3.000000, RAM: ByteAmount{4.0 GB (4294967296 bytes)}, disk: ByteAmount{14.0 GB (15032385536 bytes)}.
[2019-02-05 15:09:55 -0800] [INFO] org.apache.heron.packing.roundrobin.RoundRobinPacking: Pack internal finalized: container#2 CPU: 3.000000, RAM: ByteAmount{4.0 GB (4294967296 bytes)}, disk: ByteAmount{14.0 GB (15032385536 bytes)}.
[2019-02-05 15:09:55 -0800] [INFO]: Successfully launched topology 'WindowedWordCountTopology'
$ ~/.heron/bin/heron activate local WindowedWordCountTopology[2019-02-05 15:10:08 -0800] [INFO]: Using cluster definition in /Users/<user>/.heron/conf/local
[2019-02-05 15:10:09 -0800] [INFO] org.apache.heron.spi.utils.TMasterUtils: Topology command ACTIVATE completed successfully.
[2019-02-05 15:10:09 -0800] [INFO]: Successfully activate topology: WindowedWordCountTopology
对于“本地”,拓扑状态数据存储在 ~/.herondata/repository/state/local// 中。在您的情况下,您可以检查此文件是否已创建并包含正确的信息:~/.herondata/repository/state/local/schedulers/WindowedWordCountTopology