Storm UI

Topology summary

NameIdStatusUptimeNum workersNum executorsNum tasks
VehicleInfoTopologyVehicleInfoTopology-1-1735614733ACTIVE8d 18h 15m 6s2216216

Topology actions

Topology stats

WindowEmittedTransferredComplete latency (ms)AckedFailed
10m 0s000.00000
3h 0m 0s0052.000200
1d 0h 0m 0s100154051.667600
All time10801404055.7394600

Spouts (All time)

IdExecutorsTasksEmittedTransferredComplete latency (ms)AckedFailedLast error
FreightCheckSpout55000.00000
MAJORCAR_QUEUE_SPOUT1154054055.9094400
STATUS_CHECK_SPOUT11000.00000
SURVEYCONFIGSPOUT110052.000200
VehiclePassInfoSpout55000.00000

Bolts (All time)

IdExecutorsTasksEmittedTransferredCapacity (last 10m)Execute latency (ms)ExecutedProcess latency (ms)AckedFailedLast error
PassCarHandleBolt33000.0000.00000.00000
HighRiskSurveyBolt55000.00040.000402.333600
InterceptCarSurveyBolt55000.0003.000202.000200
CheckPasscardValidateDateBolt33000.00036.492126037.17212800
OverSpeedSurveyBolt55000.0002.5004040.000400
AbandonedSurveyBolt55000.0003.500400.00000
InspectSurveyBolt55000.00027.250802.000400
CheckAllowedWayBolt33000.00037.636132037.07613200
PassCardNotifyToWebBolt11000.0000.00000.00000
SysConfigBolt11540135000.0002.0914401.4554400
NotifyToScreenBolt55000.0000.00000.00000
NotifyToWebBolt55000.0000.00000.00000
UnAnnualedSurveyBolt55000.00037.000405.000400
CloneCarSurveyBolt55000.0002.333602.000400
CheckHasPasscardBolt33000.00037.714126038.12512800
SavePasscarInfoBolt55000.00038.415212036.93421200
SendSmsMessageBolt55000.0000.00000.00000
SaveTrafficRestrictionCarInfoBolt55000.0000.00000.00000
GreatCaseSurveyBolt55000.00033.500403.500400
ControlSurveyBolt55000.0003.0004024.000800
CheckTrafficRestrictionBolt55000.0000.00000.00000
FlowCalculateBolt33000.0000.00000.00000
SuspectedCarSurveyBolt55000.0003.667604.000600
CheckNeedMonitorCarBolt33000.00037.922128037.40612800
FakeCarSurveyBolt55000.0002.000403.000600
CheckFreightCarBolt55000.00036.645214037.39321400
SaveExpiredPasscardCarInfoBolt33000.0000.00000.00000
NoPassAreaSurveyBolt55000.00051.667602.000400
SaveFreIllegalBolt55000.0000.00000.00000
BusyStatusCalculateBolt11000.0000.00000.00000
UnHandleSurveyBolt55000.0003.000201.000200
NotifyByFreCarBolt11000.0000.00000.00000
SurveyConfigBolt11000.0003.000200.00000
BusyCheckPreHandleBolt33000.0000.00000.00000
NotifyByEmailBolt55000.0000.00000.00000
FlowControlPreHandleBolt33000.0000.00000.00000
CriminalSurveyBolt55000.00026.667607.000200
NotifyToUpperBolt55000.0000.00000.00000
SurveyAlarmHandleBolt55000.0000.00000.00000
YellowLabelBolt11000.0004.000200.00000
SurveyPlanMatchedBolt55000.0000.00000.00000
HitAndRunSurveyBolt55000.0003.000404.500400
TemporaryEventSurveyBolt55000.00030.0006036.000400
SaveNoPasscardCarInfoBolt55000.0000.00000.00000
CheckRestrictBolt33000.00036.875128036.22212600
SaveNotAllowdWayCarInfoBolt55000.0000.00000.00000
NotifyByMessageBolt55000.0000.00000.00000
StealedSurveyBolt55000.00024.2508067.000200
OtherSurveyBolt55000.00036.000404.000400

Topology Configuration

KeyValue
storm.idVehicleInfoTopology-1-1735614733
dev.zookeeper.path/tmp/dev-storm-zookeeper
topology.tick.tuple.freq.secs
topology.builtin.metrics.bucket.size.secs60
topology.fall.back.on.java.serializationtrue
topology.max.error.report.per.interval5
zmq.linger.millis5000
topology.skip.missing.kryo.registrationsfalse
storm.messaging.netty.client_worker_threads1
ui.childopts-Xmx768m
storm.zookeeper.session.timeout20000
nimbus.reassigntrue
topology.trident.batch.emit.interval.millis500
prop{"jms.monitorCarQueue.name" "MONITOR_CAR_QUEUE", "TRUNK_ROAD_SPEED3" "35", "TOPOLOGY_0" "com.dahua.itms.ra.topology.VehicleInfoTopology", "PassCarHandleBolt" "3", "HighRiskSurveyBolt" "5", "MODULE_CODE" "901", "TRUNK_ROAD_SPEED4" "25", "jms.freCarQueue.name" "FRE_CAR_QUEUE", "TOPOLOGY_1" "com.dahua.itms.ra.topology.GPSInfoTopology ", "InterceptCarSurveyBolt" "5", "CONGESTIONINDEX_LEVEL1" "1", "FAST_ROAD_VMT" "0.4", "CheckPasscardValidateDateBolt" "3", "TRUNK_ROAD_SPEED5" "15", "SysConfigSpout" "1", "OverSpeedSurveyBolt" "5", "jms.surveyConfigQueue.name" "SURVEY_CONFIG_QUEUE", "jms.congestionindexspeedqueue.name" "CONGESTION_INDEX_SPEED_QUEUE", "CARNUMCOLOR_0" "02", "CONGESTIONINDEX_LEVEL2" "2", "FAST_ROAD" "5", "TrafficRestrictionSwitch" "1", "AbandonedSurveyBolt" "5", "InspectSurveyBolt" "5", "BusyCheckSwitch" "1", "jms.towebqueue.name" "GPS_INFO_QUEUE", "CARNUMCOLOR_1" "01", "CONGESTIONINDEX_LEVEL3" "3", "CheckAllowedWayBolt" "3", "CARNUMCOLOR_2" "23", "CONGESTIONINDEX_LEVEL4" "4", "SysConfigBolt" "1", "NotifyToScreenBolt" "5", "CARNUMCOLOR_3" "06", "CONGESTIONINDEX_LEVEL5" "5", "NotifyToWebBolt" "5", "PassCardChangeBolt" "1", "UnAnnualedSurveyBolt" "5", "CloneCarSurveyBolt" "5", "CongestionIndexSpout" "1", "VehiclePassInfoSpout" "5", "CongestionIndexCalcIndexBolt" "1", "FAST_ROAD_SPEED2" "65", "CheckHasPasscardBolt" "3", "FAST_ROAD_SPEED3" "50", "SavePasscarInfoBolt" "5", "TRUNK_ROAD_VMT" "0.3", "FAST_ROAD_SPEED4" "35", "CONGESTION_INDEX_RECALC_DAY" "30", "CONGESTION_TOPO_WORK_NUMBER" "1", "FAST_ROAD_SPEED5" "20", "SendSmsMessageBolt" "5", "JDBC_URL" "jdbc:oracle:thin:@(DESCRIPTION =(ADDRESS_LIST =(ADDRESS = (PROTOCOL = TCP)(HOST = ${JDBC_SERVER_IP})(PORT = ${JDBC_SERVER_PORT})))(CONNECT_DATA =(SERVICE_NAME = ${JDBC_SERVICE_NAME})) )", "LOCAL_CARNUM_PREFIX" "桂B", "ApplicationID" "zgtxfw", "SaveTrafficRestrictionCarInfoBolt" "5", "TRUNK_ROAD" "6", "GreatCaseSurveyBolt" "5", "JDBC_DRIVER" "oracle.jdbc.driver.OracleDriver", "ControlSurveyBolt" "5", "CheckHasSpecialCardBolt" "5", "FlowCalculateSwitch" "1", "FreightCheckSpout" "5", "CheckTrafficRestrictionBolt" "5", "FlowCalculateBolt" "3", "jms.passcarqueue.name" "PASS_CAR_QUEUE", "SuspectedCarSurveyBolt" "5", "CheckNeedMonitorCarBolt" "3", "BRANCH_ROAD_SPEED2" "35", "jms.surveyInfoQueue.name" "SURVEY_INFO_QUEUE", "FakeCarSurveyBolt" "5", "CheckFreightCarBolt" "5", "SaveExpiredPasscardCarInfoBolt" "3", "SurveySwitch" "1", "NoPassAreaSurveyBolt" "5", "BRANCH_ROAD_SPEED3" "25", "PASSCAR_TOPO_WORK_NUMBER" "2", "jms.screenAlarmQueue.name" "SCREEN_ALARM_QUEUE", "JDBC_USER" "dssc", "SaveFreIllegalBolt" "5", "BRANCH_ROAD_SPEED4" "15", "SaveGPSInfoBolt" "5", "BusyStatusCalculateBolt" "1", "UnHandleSurveyBolt" "5", "SaveTimeForbidenCarInfoBolt" "5", "BRANCH_ROAD_SPEED5" "10", "SurveyConfigBolt" "1", "MQ_USERNAME" "test", "BusyCheckPreHandleBolt" "3", "jms.busystatusqueue.name" "BUSY_STATUS_TO_WEB_QUEUE", "NotifyByEmailBolt" "5", "FlowControlPreHandleBolt" "3", "CriminalSurveyBolt" "5", "DATA_PROVIDER_TYPE" "1", "NotifyToUpperBolt" "5", "MQ_URL" "tcp://127.0.0.1:4455", "SECOND_TRUNK_ROAD_VMT" "0.2", "SECOND_TRUNK_ROAD_SPEED2" "35", "jms.inputqueue.name" "GPS_DATA_QUEUE", "SurveyAlarmHandleBolt" "5", "jms.smsMessageQueue.name" "SMS_MESSAGE_QUEUE", "psisServerPath" "http://10.118.203.152:8080/psis/psisQuery/query.do?psisQueryStr=", "expandId" "6", "YellowLabelBolt" "1", "PassCardSwitch" "1", "SECOND_TRUNK_ROAD_SPEED3" "25", "SurveyConfigSpout" "1", "CongestionIndexSpeedSpout" "1", "jms.congestionindexqueue.name" "CONGESTION_INDEX_QUEUE", "SurveyPlanMatchedBolt" "5", "SECOND_TRUNK_ROAD_SPEED4" "15", "MQ_PASSWORD" "test", "HitAndRunSurveyBolt" "5", "SECOND_TRUNK_ROAD" "7", "LINHAI_GATHER1" "AAA", "IS_LOCAL" "0", "SECOND_TRUNK_ROAD_SPEED5" "10", "CheckTimeForbidenCarBolt" "5", "PlaceGateChangeBolt" "1", "LINHAI_GATHER2" "BBB", "TemporaryEventSurveyBolt" "5", "SaveNoPasscardCarInfoBolt" "5", "CheckRestrictBolt" "3", "JDBC_SERVER_PORT" "1521", "JDBC_SERVICE_NAME" "dssc", "SaveNotAllowdWayCarInfoBolt" "5", "GPSInfoSpout" "5", "GPSINFO_TOPO_WORK_NUMBER" "1", "jms.sysconfigqueue.name" "SEND_TO_REALANALYSE_QUEUE", "SMS_SWITCH" "1", "jms.localcartowebqueue.name" "LOCALCAR_INFO_QUEUE", "BRANCH_ROAD_VMT" "0.1", "StatusCheckSpout" "1", "password" "VGZ8#Bpnaz#V", "jms.emailAlarmQueue.name" "EMAIL_ALARM_QUEUE", "LINHAI_BAYCAR_TIMEOUT" "10", "NotifyByMessageBolt" "5", "CongestionIndexCalcSpeedBolt" "1", "GPSSendToWebBolt" "1", "SMS_WEBSERVICE_ADDRESS" "http://10.118.205.43:9080/OpenMasService", "StealedSurveyBolt" "5", "BRANCH_ROAD" "8", "JDBC_TYPE" "oracle", "MQ_URL2" "tcp://127.0.0.1:4455", "OtherSurveyBolt" "5", "TRUNK_ROAD_SPEED2" "45", "smsContentMenu" "重点车辆管控告警", "JDBC_SERVER_IP" "192.168.3.201", "JDBC_PASSWORD" "Hzjt_1221"}
nimbus.monitor.freq.secs10
logviewer.childopts-Xmx128m
java.library.path/usr/local/lib:/opt/local/lib:/usr/lib
topology.executor.send.buffer.size1024
storm.local.dir../data
storm.messaging.netty.buffer_size5242880
supervisor.worker.start.timeout.secs120
topology.enable.message.timeoutstrue
nimbus.cleanup.inbox.freq.secs600
nimbus.inbox.jar.expiration.secs3600
drpc.worker.threads64
topology.worker.shared.thread.pool.size4
nimbus.host127.0.0.1
storm.messaging.netty.min_wait_ms100
storm.zookeeper.port2181
transactional.zookeeper.port
topology.executor.receive.buffer.size1024
transactional.zookeeper.servers
storm.zookeeper.root/storm
storm.zookeeper.retry.intervalceiling.millis30000
supervisor.enabletrue
storm.messaging.netty.server_worker_threads1
storm.zookeeper.servers["127.0.0.1"]
transactional.zookeeper.root/transactional
topology.acker.executors
topology.kryo.decorators[]
topology.nameVehicleInfoTopology
topology.transfer.buffer.size1024
topology.worker.childopts
drpc.queue.size128
worker.childopts-Xms128m -Xmx768m -XX:PermSize=64m
supervisor.heartbeat.frequency.secs5
topology.error.throttle.interval.secs10
zmq.hwm0
drpc.port3772
supervisor.monitor.frequency.secs3
drpc.childopts-Xmx768m
topology.receiver.buffer.size8
task.heartbeat.frequency.secs3
topology.tasks
storm.messaging.netty.max_retries30
topology.spout.wait.strategybacktype.storm.spout.SleepSpoutWaitStrategy
nimbus.thrift.max_buffer_size1048576
topology.max.spout.pending
storm.zookeeper.retry.interval1000
topology.sleep.spout.wait.strategy.time.ms1
nimbus.topology.validatorbacktype.storm.nimbus.DefaultTopologyValidator
supervisor.slots.ports[6700]
topology.debugfalse
nimbus.task.launch.secs120
nimbus.supervisor.timeout.secs60
topology.kryo.register
topology.message.timeout.secs30
task.refresh.poll.secs10
topology.workers2
supervisor.childopts-Xmx256m
nimbus.thrift.port6627
topology.stats.sample.rate0.05
worker.heartbeat.frequency.secs1
topology.tuple.serializerbacktype.storm.serialization.types.ListDelegateSerializer
topology.disruptor.wait.strategycom.lmax.disruptor.BlockingWaitStrategy
nimbus.task.timeout.secs30
storm.zookeeper.connection.timeout15000
topology.kryo.factorybacktype.storm.serialization.DefaultKryoFactory
drpc.invocations.port3773
logviewer.port8000
zmq.threads1
storm.zookeeper.retry.times5
storm.thrift.transportbacktype.storm.security.auth.SimpleTransportPlugin
topology.state.synchronization.timeout.secs60
supervisor.worker.timeout.secs30
nimbus.file.copy.expiration.secs600
storm.messaging.transportbacktype.storm.messaging.netty.Context
logviewer.appender.nameA1
storm.messaging.netty.max_wait_ms1000
drpc.request.timeout.secs600
storm.local.mode.zmqfalse
ui.port8080
nimbus.childopts-Xmx1024m
storm.cluster.modedistributed
topology.optimizetrue
topology.max.task.parallelism