Не удалось получить местоположение планировщика от менеджера состояний Heron Tutorial - PullRequest
Новая
       31

Не удалось получить местоположение планировщика от менеджера состояний Heron Tutorial

0 голосов
/ 02 февраля 2019

Я работаю над учебником по цапле, найденным здесь: https://apache.github.io/incubator-heron/docs/getting-started/'

Я не продвинулся далеко, пока не столкнулся с этой ошибкой: 

$: heron activate local WindowedWordCountTopology

[2019-02-01 15:55:11 +0000] [INFO]: Using cluster definition in /home/<my-user>/.heron/conf/local
[2019-02-01 15:55:11 +0000] [ERROR]: Failed to get scheduler location from state manager
[2019-02-01 15:55:11 +0000] [ERROR]: Failed to activate topology: WindowedWordCountTopology

Я очень новичокГероне.Есть идеи, что может быть причиной этого?

1 Ответ

0 голосов
/ 06 февраля 2019

Это не совсем ответ.Это слишком долго для комментария, поэтому я должен создать ответ ....

Трудно сказать, пока проблема, это ожидаемый результат с почти последним кодом FYI. 

$ ~/.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

Для "local" данные состояния топологии хранятся в ~ / .herondata / repository / state / local //.В вашем случае вы можете проверить, создан ли этот файл и содержит ли он правильную информацию: ~ / .herondata / repository / state / local / schedulers / WindowedWordCountTopology

...