Storm UI

Topology summary

NameIdStatusUptimeNum workersNum executorsNum tasks
VehicleInfoTopologyVehicleInfoTopology-1-1735614733ACTIVE8d 17h 41m 40s2216216

Topology actions

Topology stats

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

Spouts (1d 0h 0m 0s)

IdExecutorsTasksEmittedTransferredComplete latency (ms)AckedFailedLast error
FreightCheckSpout55000.00000
MAJORCAR_QUEUE_SPOUT11404051.667600
STATUS_CHECK_SPOUT11000.00000
SURVEYCONFIGSPOUT11000.00000
VehiclePassInfoSpout55000.00000

Bolts (1d 0h 0m 0s)

IdExecutorsTasksEmittedTransferredCapacity (last 10m)Execute latency (ms)ExecutedProcess latency (ms)AckedFailedLast error
PassCarHandleBolt33000.0000.00000.00000
HighRiskSurveyBolt55000.0000.00000.00000
InterceptCarSurveyBolt55000.0000.00002.000200
CheckPasscardValidateDateBolt33000.00024.00012024.5711400
OverSpeedSurveyBolt55000.0000.00000.00000
AbandonedSurveyBolt55000.0000.00000.00000
InspectSurveyBolt55000.0008.000200.00000
CheckAllowedWayBolt33000.00021.87516022.0002000
PassCardNotifyToWebBolt11000.0000.00000.00000
SysConfigBolt116015000.0008.667601.000600
NotifyToScreenBolt55000.0000.00000.00000
NotifyToWebBolt55000.0000.00000.00000
UnAnnualedSurveyBolt55000.0000.00000.00000
CloneCarSurveyBolt55000.0002.000200.00000
CheckHasPasscardBolt33000.00024.33312025.5001200
SavePasscarInfoBolt55000.00025.18222024.1672400
SendSmsMessageBolt55000.0000.00000.00000
SaveTrafficRestrictionCarInfoBolt55000.0000.00000.00000
GreatCaseSurveyBolt55000.0000.00000.00000
ControlSurveyBolt55000.0003.000200.00000
CheckTrafficRestrictionBolt55000.0000.00000.00000
FlowCalculateBolt33000.0000.00000.00000
SuspectedCarSurveyBolt55000.0003.000200.00000
CheckNeedMonitorCarBolt33000.00024.87516020.8571400
FakeCarSurveyBolt55000.0000.00000.00000
CheckFreightCarBolt55000.00024.08324023.8332400
SaveExpiredPasscardCarInfoBolt33000.0000.00000.00000
NoPassAreaSurveyBolt55000.0001.000200.00000
SaveFreIllegalBolt55000.0000.00000.00000
BusyStatusCalculateBolt11000.0000.00000.00000
UnHandleSurveyBolt55000.0000.00000.00000
NotifyByFreCarBolt11000.0000.00000.00000
SurveyConfigBolt11000.0000.00000.00000
BusyCheckPreHandleBolt33000.0000.00000.00000
NotifyByEmailBolt55000.0000.00000.00000
FlowControlPreHandleBolt33000.0000.00000.00000
CriminalSurveyBolt55000.0000.00000.00000
NotifyToUpperBolt55000.0000.00000.00000
SurveyAlarmHandleBolt55000.0000.00000.00000
YellowLabelBolt11000.0000.00000.00000
SurveyPlanMatchedBolt55000.0000.00000.00000
HitAndRunSurveyBolt55000.0000.00007.000200
TemporaryEventSurveyBolt55000.0000.00000.00000
SaveNoPasscardCarInfoBolt55000.0000.00000.00000
CheckRestrictBolt33000.00023.00014024.6671200
SaveNotAllowdWayCarInfoBolt55000.0000.00000.00000
NotifyByMessageBolt55000.0000.00000.00000
StealedSurveyBolt55000.0005.000200.00000
OtherSurveyBolt55000.0000.00000.00000

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