| ID | Description | Submitted | Duration | Jobs |
|---|---|---|---|---|
| 79 |
count at Pipeline.scala:38
org.apache.spark.sql.Dataset.count(Dataset.scala:2429) com.ruckuswireless.rsa.common.Pipeline$class.triggerIndexing(Pipeline.scala:38) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.triggerIndexing(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregateBinnedData(AggregateStage.scala:96) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregateBinnedData(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregate(AggregateStage.scala:31) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregate(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.run(Pipeline.scala:45) com.ruckuswireless.rsa.etl.Pipeline$.run(Pipeline.scala:25) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.runPAAQ(PollAndAggregateQuarthourly.scala:64) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.main(PollAndAggregateQuarthourly.scala:43) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly.main(PollAndAggregateQuarthourly.scala) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.apache.spark.deploy.worker.DriverWrapper$.main(DriverWrapper.scala:58) org.apache.spark.deploy.worker.DriverWrapper.main(DriverWrapper.scala) |
2025/08/22 20:52:04 | 81 ms |
190 |
| 78 |
count at Pipeline.scala:50
org.apache.spark.sql.Dataset.count(Dataset.scala:2429) com.ruckuswireless.rsa.common.Pipeline$class.indexToDruid(Pipeline.scala:50) com.ruckuswireless.rsa.common.Pipeline$class.triggerIndexing(Pipeline.scala:33) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.triggerIndexing(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregateBinnedData(AggregateStage.scala:96) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregateBinnedData(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregate(AggregateStage.scala:31) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregate(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.run(Pipeline.scala:45) com.ruckuswireless.rsa.etl.Pipeline$.run(Pipeline.scala:25) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.runPAAQ(PollAndAggregateQuarthourly.scala:64) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.main(PollAndAggregateQuarthourly.scala:43) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly.main(PollAndAggregateQuarthourly.scala) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.apache.spark.deploy.worker.DriverWrapper$.main(DriverWrapper.scala:58) |
2025/08/22 20:52:03 | 0.8 s |
189 |
| 77 |
count at Pipeline.scala:38
org.apache.spark.sql.Dataset.count(Dataset.scala:2429) com.ruckuswireless.rsa.common.Pipeline$class.triggerIndexing(Pipeline.scala:38) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.triggerIndexing(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregateBinnedData(AggregateStage.scala:90) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregateBinnedData(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregate(AggregateStage.scala:31) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregate(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.run(Pipeline.scala:45) com.ruckuswireless.rsa.etl.Pipeline$.run(Pipeline.scala:25) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.runPAAQ(PollAndAggregateQuarthourly.scala:64) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.main(PollAndAggregateQuarthourly.scala:43) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly.main(PollAndAggregateQuarthourly.scala) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.apache.spark.deploy.worker.DriverWrapper$.main(DriverWrapper.scala:58) org.apache.spark.deploy.worker.DriverWrapper.main(DriverWrapper.scala) |
2025/08/22 20:52:01 | 86 ms |
184 |
| 76 |
count at Pipeline.scala:50
org.apache.spark.sql.Dataset.count(Dataset.scala:2429) com.ruckuswireless.rsa.common.Pipeline$class.indexToDruid(Pipeline.scala:50) com.ruckuswireless.rsa.common.Pipeline$class.triggerIndexing(Pipeline.scala:33) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.triggerIndexing(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregateBinnedData(AggregateStage.scala:90) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregateBinnedData(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregate(AggregateStage.scala:31) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregate(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.run(Pipeline.scala:45) com.ruckuswireless.rsa.etl.Pipeline$.run(Pipeline.scala:25) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.runPAAQ(PollAndAggregateQuarthourly.scala:64) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.main(PollAndAggregateQuarthourly.scala:43) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly.main(PollAndAggregateQuarthourly.scala) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.apache.spark.deploy.worker.DriverWrapper$.main(DriverWrapper.scala:58) |
2025/08/22 20:52:00 | 1 s |
183 |
| 75 |
count at Pipeline.scala:38
org.apache.spark.sql.Dataset.count(Dataset.scala:2429) com.ruckuswireless.rsa.common.Pipeline$class.triggerIndexing(Pipeline.scala:38) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.triggerIndexing(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregateBinnedData(AggregateStage.scala:85) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregateBinnedData(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregate(AggregateStage.scala:31) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregate(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.run(Pipeline.scala:45) com.ruckuswireless.rsa.etl.Pipeline$.run(Pipeline.scala:25) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.runPAAQ(PollAndAggregateQuarthourly.scala:64) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.main(PollAndAggregateQuarthourly.scala:43) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly.main(PollAndAggregateQuarthourly.scala) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.apache.spark.deploy.worker.DriverWrapper$.main(DriverWrapper.scala:58) org.apache.spark.deploy.worker.DriverWrapper.main(DriverWrapper.scala) |
2025/08/22 20:51:57 | 93 ms |
177 |
| 74 |
count at Pipeline.scala:50
org.apache.spark.sql.Dataset.count(Dataset.scala:2429) com.ruckuswireless.rsa.common.Pipeline$class.indexToDruid(Pipeline.scala:50) com.ruckuswireless.rsa.common.Pipeline$class.triggerIndexing(Pipeline.scala:33) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.triggerIndexing(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregateBinnedData(AggregateStage.scala:85) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregateBinnedData(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregate(AggregateStage.scala:31) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregate(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.run(Pipeline.scala:45) com.ruckuswireless.rsa.etl.Pipeline$.run(Pipeline.scala:25) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.runPAAQ(PollAndAggregateQuarthourly.scala:64) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.main(PollAndAggregateQuarthourly.scala:43) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly.main(PollAndAggregateQuarthourly.scala) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.apache.spark.deploy.worker.DriverWrapper$.main(DriverWrapper.scala:58) |
2025/08/22 20:51:56 | 0.7 s |
176 |
| 73 |
count at Pipeline.scala:38
org.apache.spark.sql.Dataset.count(Dataset.scala:2429) com.ruckuswireless.rsa.common.Pipeline$class.triggerIndexing(Pipeline.scala:38) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.triggerIndexing(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregateBinnedData(AggregateStage.scala:81) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregateBinnedData(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregate(AggregateStage.scala:31) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregate(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.run(Pipeline.scala:45) com.ruckuswireless.rsa.etl.Pipeline$.run(Pipeline.scala:25) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.runPAAQ(PollAndAggregateQuarthourly.scala:64) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.main(PollAndAggregateQuarthourly.scala:43) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly.main(PollAndAggregateQuarthourly.scala) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.apache.spark.deploy.worker.DriverWrapper$.main(DriverWrapper.scala:58) org.apache.spark.deploy.worker.DriverWrapper.main(DriverWrapper.scala) |
2025/08/22 20:51:54 | 0.1 s |
171 |
| 72 |
count at Pipeline.scala:50
org.apache.spark.sql.Dataset.count(Dataset.scala:2429) com.ruckuswireless.rsa.common.Pipeline$class.indexToDruid(Pipeline.scala:50) com.ruckuswireless.rsa.common.Pipeline$class.triggerIndexing(Pipeline.scala:33) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.triggerIndexing(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregateBinnedData(AggregateStage.scala:81) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregateBinnedData(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregate(AggregateStage.scala:31) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregate(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.run(Pipeline.scala:45) com.ruckuswireless.rsa.etl.Pipeline$.run(Pipeline.scala:25) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.runPAAQ(PollAndAggregateQuarthourly.scala:64) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.main(PollAndAggregateQuarthourly.scala:43) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly.main(PollAndAggregateQuarthourly.scala) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.apache.spark.deploy.worker.DriverWrapper$.main(DriverWrapper.scala:58) |
2025/08/22 20:51:54 | 0.1 s |
170 |
| 71 |
count at Pipeline.scala:38
org.apache.spark.sql.Dataset.count(Dataset.scala:2429) com.ruckuswireless.rsa.common.Pipeline$class.triggerIndexing(Pipeline.scala:38) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.triggerIndexing(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregateBinnedData(AggregateStage.scala:78) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregateBinnedData(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregate(AggregateStage.scala:31) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregate(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.run(Pipeline.scala:45) com.ruckuswireless.rsa.etl.Pipeline$.run(Pipeline.scala:25) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.runPAAQ(PollAndAggregateQuarthourly.scala:64) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.main(PollAndAggregateQuarthourly.scala:43) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly.main(PollAndAggregateQuarthourly.scala) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.apache.spark.deploy.worker.DriverWrapper$.main(DriverWrapper.scala:58) org.apache.spark.deploy.worker.DriverWrapper.main(DriverWrapper.scala) |
2025/08/22 20:51:54 | 0.1 s |
169 |
| 70 |
count at Pipeline.scala:50
org.apache.spark.sql.Dataset.count(Dataset.scala:2429) com.ruckuswireless.rsa.common.Pipeline$class.indexToDruid(Pipeline.scala:50) com.ruckuswireless.rsa.common.Pipeline$class.triggerIndexing(Pipeline.scala:33) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.triggerIndexing(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregateBinnedData(AggregateStage.scala:78) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregateBinnedData(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregate(AggregateStage.scala:31) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregate(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.run(Pipeline.scala:45) com.ruckuswireless.rsa.etl.Pipeline$.run(Pipeline.scala:25) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.runPAAQ(PollAndAggregateQuarthourly.scala:64) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.main(PollAndAggregateQuarthourly.scala:43) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly.main(PollAndAggregateQuarthourly.scala) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.apache.spark.deploy.worker.DriverWrapper$.main(DriverWrapper.scala:58) |
2025/08/22 20:51:53 | 0.9 s |
168 |
| 69 |
count at ApInventoryAggregator.scala:32
org.apache.spark.sql.Dataset.count(Dataset.scala:2429) com.ruckuswireless.rsa.controllers.aggregators.ApInventoryAggregator$.getData(ApInventoryAggregator.scala:32) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregateBinnedData(AggregateStage.scala:77) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregateBinnedData(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregate(AggregateStage.scala:31) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregate(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.run(Pipeline.scala:45) com.ruckuswireless.rsa.etl.Pipeline$.run(Pipeline.scala:25) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.runPAAQ(PollAndAggregateQuarthourly.scala:64) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.main(PollAndAggregateQuarthourly.scala:43) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly.main(PollAndAggregateQuarthourly.scala) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.apache.spark.deploy.worker.DriverWrapper$.main(DriverWrapper.scala:58) org.apache.spark.deploy.worker.DriverWrapper.main(DriverWrapper.scala) |
2025/08/22 20:51:49 | 2 s |
159 160 161 162 163 |
| 68 |
count at ApInventoryAggregator.scala:31
org.apache.spark.sql.Dataset.count(Dataset.scala:2429) com.ruckuswireless.rsa.controllers.aggregators.ApInventoryAggregator$.getData(ApInventoryAggregator.scala:31) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregateBinnedData(AggregateStage.scala:77) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregateBinnedData(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregate(AggregateStage.scala:31) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregate(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.run(Pipeline.scala:45) com.ruckuswireless.rsa.etl.Pipeline$.run(Pipeline.scala:25) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.runPAAQ(PollAndAggregateQuarthourly.scala:64) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.main(PollAndAggregateQuarthourly.scala:43) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly.main(PollAndAggregateQuarthourly.scala) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.apache.spark.deploy.worker.DriverWrapper$.main(DriverWrapper.scala:58) org.apache.spark.deploy.worker.DriverWrapper.main(DriverWrapper.scala) |
2025/08/22 20:51:48 | 0.7 s |
158 |
| 67 |
count at ApInventoryAggregator.scala:30
org.apache.spark.sql.Dataset.count(Dataset.scala:2429) com.ruckuswireless.rsa.controllers.aggregators.ApInventoryAggregator$.getData(ApInventoryAggregator.scala:30) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregateBinnedData(AggregateStage.scala:77) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregateBinnedData(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregate(AggregateStage.scala:31) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregate(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.run(Pipeline.scala:45) com.ruckuswireless.rsa.etl.Pipeline$.run(Pipeline.scala:25) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.runPAAQ(PollAndAggregateQuarthourly.scala:64) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.main(PollAndAggregateQuarthourly.scala:43) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly.main(PollAndAggregateQuarthourly.scala) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.apache.spark.deploy.worker.DriverWrapper$.main(DriverWrapper.scala:58) org.apache.spark.deploy.worker.DriverWrapper.main(DriverWrapper.scala) |
2025/08/22 20:51:48 | 90 ms |
157 |
| 66 |
count at ApInventoryAggregator.scala:29
org.apache.spark.sql.Dataset.count(Dataset.scala:2429) com.ruckuswireless.rsa.controllers.aggregators.ApInventoryAggregator$.getData(ApInventoryAggregator.scala:29) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregateBinnedData(AggregateStage.scala:77) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregateBinnedData(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregate(AggregateStage.scala:31) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregate(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.run(Pipeline.scala:45) com.ruckuswireless.rsa.etl.Pipeline$.run(Pipeline.scala:25) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.runPAAQ(PollAndAggregateQuarthourly.scala:64) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.main(PollAndAggregateQuarthourly.scala:43) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly.main(PollAndAggregateQuarthourly.scala) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.apache.spark.deploy.worker.DriverWrapper$.main(DriverWrapper.scala:58) org.apache.spark.deploy.worker.DriverWrapper.main(DriverWrapper.scala) |
2025/08/22 20:51:47 | 69 ms |
156 |
| 65 |
count at Pipeline.scala:38
org.apache.spark.sql.Dataset.count(Dataset.scala:2429) com.ruckuswireless.rsa.common.Pipeline$class.triggerIndexing(Pipeline.scala:38) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.triggerIndexing(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregateBinnedData(AggregateStage.scala:74) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregateBinnedData(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregate(AggregateStage.scala:31) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregate(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.run(Pipeline.scala:45) com.ruckuswireless.rsa.etl.Pipeline$.run(Pipeline.scala:25) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.runPAAQ(PollAndAggregateQuarthourly.scala:64) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.main(PollAndAggregateQuarthourly.scala:43) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly.main(PollAndAggregateQuarthourly.scala) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.apache.spark.deploy.worker.DriverWrapper$.main(DriverWrapper.scala:58) org.apache.spark.deploy.worker.DriverWrapper.main(DriverWrapper.scala) |
2025/08/22 20:51:47 | 99 ms |
155 |
| 64 |
count at Pipeline.scala:50
org.apache.spark.sql.Dataset.count(Dataset.scala:2429) com.ruckuswireless.rsa.common.Pipeline$class.indexToDruid(Pipeline.scala:50) com.ruckuswireless.rsa.common.Pipeline$class.triggerIndexing(Pipeline.scala:33) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.triggerIndexing(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregateBinnedData(AggregateStage.scala:74) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregateBinnedData(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregate(AggregateStage.scala:31) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregate(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.run(Pipeline.scala:45) com.ruckuswireless.rsa.etl.Pipeline$.run(Pipeline.scala:25) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.runPAAQ(PollAndAggregateQuarthourly.scala:64) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.main(PollAndAggregateQuarthourly.scala:43) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly.main(PollAndAggregateQuarthourly.scala) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.apache.spark.deploy.worker.DriverWrapper$.main(DriverWrapper.scala:58) |
2025/08/22 20:51:46 | 1 s |
154 |
| 63 |
count at Pipeline.scala:38
org.apache.spark.sql.Dataset.count(Dataset.scala:2429) com.ruckuswireless.rsa.common.Pipeline$class.triggerIndexing(Pipeline.scala:38) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.triggerIndexing(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregateBinnedData(AggregateStage.scala:71) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregateBinnedData(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregate(AggregateStage.scala:31) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregate(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.run(Pipeline.scala:45) com.ruckuswireless.rsa.etl.Pipeline$.run(Pipeline.scala:25) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.runPAAQ(PollAndAggregateQuarthourly.scala:64) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.main(PollAndAggregateQuarthourly.scala:43) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly.main(PollAndAggregateQuarthourly.scala) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.apache.spark.deploy.worker.DriverWrapper$.main(DriverWrapper.scala:58) org.apache.spark.deploy.worker.DriverWrapper.main(DriverWrapper.scala) |
2025/08/22 20:51:43 | 99 ms |
149 |
| 62 |
count at Pipeline.scala:50
org.apache.spark.sql.Dataset.count(Dataset.scala:2429) com.ruckuswireless.rsa.common.Pipeline$class.indexToDruid(Pipeline.scala:50) com.ruckuswireless.rsa.common.Pipeline$class.triggerIndexing(Pipeline.scala:33) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.triggerIndexing(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregateBinnedData(AggregateStage.scala:71) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregateBinnedData(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregate(AggregateStage.scala:31) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregate(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.run(Pipeline.scala:45) com.ruckuswireless.rsa.etl.Pipeline$.run(Pipeline.scala:25) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.runPAAQ(PollAndAggregateQuarthourly.scala:64) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.main(PollAndAggregateQuarthourly.scala:43) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly.main(PollAndAggregateQuarthourly.scala) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.apache.spark.deploy.worker.DriverWrapper$.main(DriverWrapper.scala:58) |
2025/08/22 20:51:41 | 2 s |
148 |
| 61 |
count at AggregateStage.scala:62
org.apache.spark.sql.Dataset.count(Dataset.scala:2429) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregateBinnedData(AggregateStage.scala:62) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregateBinnedData(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregate(AggregateStage.scala:31) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregate(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.run(Pipeline.scala:45) com.ruckuswireless.rsa.etl.Pipeline$.run(Pipeline.scala:25) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.runPAAQ(PollAndAggregateQuarthourly.scala:64) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.main(PollAndAggregateQuarthourly.scala:43) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly.main(PollAndAggregateQuarthourly.scala) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.apache.spark.deploy.worker.DriverWrapper$.main(DriverWrapper.scala:58) org.apache.spark.deploy.worker.DriverWrapper.main(DriverWrapper.scala) |
2025/08/22 20:51:39 | 0.1 s |
143 |
| 60 |
count at AggregateStage.scala:62
org.apache.spark.sql.Dataset.count(Dataset.scala:2429) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregateBinnedData(AggregateStage.scala:62) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregateBinnedData(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregate(AggregateStage.scala:31) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregate(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.run(Pipeline.scala:45) com.ruckuswireless.rsa.etl.Pipeline$.run(Pipeline.scala:25) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.runPAAQ(PollAndAggregateQuarthourly.scala:64) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.main(PollAndAggregateQuarthourly.scala:43) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly.main(PollAndAggregateQuarthourly.scala) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.apache.spark.deploy.worker.DriverWrapper$.main(DriverWrapper.scala:58) org.apache.spark.deploy.worker.DriverWrapper.main(DriverWrapper.scala) |
2025/08/22 20:51:39 | 0.2 s |
142 |
| 59 |
collect at DomainParser.scala:57
org.apache.spark.sql.Dataset.collect(Dataset.scala:2390) com.ruckuswireless.rsa.controllers.parsers.DomainParser$.extract(DomainParser.scala:57) com.ruckuswireless.rsa.controllers.pipelines.stages.ParseStageUtil$.getSwitchHierarchyDF(ParseStage.scala:119) com.ruckuswireless.rsa.controllers.pipelines.stages.ParseStageUtil$.getMetaDFs(ParseStage.scala:59) com.ruckuswireless.rsa.controllers.pipelines.stages.ParseStage$class.parse(ParseStage.scala:22) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.parse(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.run(Pipeline.scala:43) com.ruckuswireless.rsa.etl.Pipeline$.run(Pipeline.scala:25) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.runPAAQ(PollAndAggregateQuarthourly.scala:64) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.main(PollAndAggregateQuarthourly.scala:43) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly.main(PollAndAggregateQuarthourly.scala) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.apache.spark.deploy.worker.DriverWrapper$.main(DriverWrapper.scala:58) org.apache.spark.deploy.worker.DriverWrapper.main(DriverWrapper.scala) |
2025/08/22 20:51:36 | 96 ms |
134 |
| 58 |
collect at DomainParser.scala:57
org.apache.spark.sql.Dataset.collect(Dataset.scala:2390) com.ruckuswireless.rsa.controllers.parsers.DomainParser$.extract(DomainParser.scala:57) com.ruckuswireless.rsa.controllers.pipelines.stages.ParseStageUtil$.getApHierarchyDF(ParseStage.scala:73) com.ruckuswireless.rsa.controllers.pipelines.stages.ParseStageUtil$.getMetaDFs(ParseStage.scala:58) com.ruckuswireless.rsa.controllers.pipelines.stages.ParseStage$class.parse(ParseStage.scala:22) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.parse(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.run(Pipeline.scala:43) com.ruckuswireless.rsa.etl.Pipeline$.run(Pipeline.scala:25) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.runPAAQ(PollAndAggregateQuarthourly.scala:64) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.main(PollAndAggregateQuarthourly.scala:43) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly.main(PollAndAggregateQuarthourly.scala) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.apache.spark.deploy.worker.DriverWrapper$.main(DriverWrapper.scala:58) org.apache.spark.deploy.worker.DriverWrapper.main(DriverWrapper.scala) |
2025/08/22 20:51:35 | 0.2 s |
133 |
| 57 |
count at ADStage.scala:17
org.apache.spark.sql.Dataset.count(Dataset.scala:2429) com.ruckuswireless.rsa.controllers.pipelines.stages.ADStage$class.extractAndSaveADFeatures(ADStage.scala:17) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.extractAndSaveADFeatures(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.run(Pipeline.scala:46) com.ruckuswireless.rsa.etl.Pipeline$.run(Pipeline.scala:24) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.runPAAQ(PollAndAggregateQuarthourly.scala:64) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.main(PollAndAggregateQuarthourly.scala:43) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly.main(PollAndAggregateQuarthourly.scala) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.apache.spark.deploy.worker.DriverWrapper$.main(DriverWrapper.scala:58) org.apache.spark.deploy.worker.DriverWrapper.main(DriverWrapper.scala) |
2025/08/22 20:51:33 | 63 ms |
130 |
| 56 |
count at Pipeline.scala:38
org.apache.spark.sql.Dataset.count(Dataset.scala:2429) com.ruckuswireless.rsa.common.Pipeline$class.triggerIndexing(Pipeline.scala:38) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.triggerIndexing(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregateBinnedData(AggregateStage.scala:129) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregateBinnedData(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregate(AggregateStage.scala:31) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregate(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.run(Pipeline.scala:45) com.ruckuswireless.rsa.etl.Pipeline$.run(Pipeline.scala:24) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.runPAAQ(PollAndAggregateQuarthourly.scala:64) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.main(PollAndAggregateQuarthourly.scala:43) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly.main(PollAndAggregateQuarthourly.scala) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.apache.spark.deploy.worker.DriverWrapper$.main(DriverWrapper.scala:58) org.apache.spark.deploy.worker.DriverWrapper.main(DriverWrapper.scala) |
2025/08/22 20:51:33 | 96 ms |
129 |
| 55 |
count at Pipeline.scala:50
org.apache.spark.sql.Dataset.count(Dataset.scala:2429) com.ruckuswireless.rsa.common.Pipeline$class.indexToDruid(Pipeline.scala:50) com.ruckuswireless.rsa.common.Pipeline$class.triggerIndexing(Pipeline.scala:33) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.triggerIndexing(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregateBinnedData(AggregateStage.scala:129) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregateBinnedData(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregate(AggregateStage.scala:31) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregate(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.run(Pipeline.scala:45) com.ruckuswireless.rsa.etl.Pipeline$.run(Pipeline.scala:24) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.runPAAQ(PollAndAggregateQuarthourly.scala:64) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.main(PollAndAggregateQuarthourly.scala:43) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly.main(PollAndAggregateQuarthourly.scala) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.apache.spark.deploy.worker.DriverWrapper$.main(DriverWrapper.scala:58) |
2025/08/22 20:51:32 | 0.7 s |
128 |
| 54 |
count at WifiCallingAggregator.scala:52
org.apache.spark.sql.Dataset.count(Dataset.scala:2429) com.ruckuswireless.rsa.controllers.aggregators.WifiCallingAggregator$.getData(WifiCallingAggregator.scala:52) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregateBinnedData(AggregateStage.scala:128) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregateBinnedData(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregate(AggregateStage.scala:31) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregate(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.run(Pipeline.scala:45) com.ruckuswireless.rsa.etl.Pipeline$.run(Pipeline.scala:24) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.runPAAQ(PollAndAggregateQuarthourly.scala:64) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.main(PollAndAggregateQuarthourly.scala:43) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly.main(PollAndAggregateQuarthourly.scala) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.apache.spark.deploy.worker.DriverWrapper$.main(DriverWrapper.scala:58) org.apache.spark.deploy.worker.DriverWrapper.main(DriverWrapper.scala) |
2025/08/22 20:51:29 | 2 s |
117 118 119 120 121 122 |
| 53 |
count at WifiCallingAggregator.scala:51
org.apache.spark.sql.Dataset.count(Dataset.scala:2429) com.ruckuswireless.rsa.controllers.aggregators.WifiCallingAggregator$.getData(WifiCallingAggregator.scala:51) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregateBinnedData(AggregateStage.scala:128) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregateBinnedData(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregate(AggregateStage.scala:31) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregate(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.run(Pipeline.scala:45) com.ruckuswireless.rsa.etl.Pipeline$.run(Pipeline.scala:24) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.runPAAQ(PollAndAggregateQuarthourly.scala:64) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.main(PollAndAggregateQuarthourly.scala:43) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly.main(PollAndAggregateQuarthourly.scala) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.apache.spark.deploy.worker.DriverWrapper$.main(DriverWrapper.scala:58) org.apache.spark.deploy.worker.DriverWrapper.main(DriverWrapper.scala) |
2025/08/22 20:51:28 | 0.5 s |
115 116 |
| 52 |
count at WifiCallingAggregator.scala:50
org.apache.spark.sql.Dataset.count(Dataset.scala:2429) com.ruckuswireless.rsa.controllers.aggregators.WifiCallingAggregator$.getData(WifiCallingAggregator.scala:50) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregateBinnedData(AggregateStage.scala:128) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregateBinnedData(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregate(AggregateStage.scala:31) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregate(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.run(Pipeline.scala:45) com.ruckuswireless.rsa.etl.Pipeline$.run(Pipeline.scala:24) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.runPAAQ(PollAndAggregateQuarthourly.scala:64) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.main(PollAndAggregateQuarthourly.scala:43) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly.main(PollAndAggregateQuarthourly.scala) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.apache.spark.deploy.worker.DriverWrapper$.main(DriverWrapper.scala:58) org.apache.spark.deploy.worker.DriverWrapper.main(DriverWrapper.scala) |
2025/08/22 20:51:28 | 0.1 s |
114 |
| 51 |
count at WifiCallingAggregator.scala:49
org.apache.spark.sql.Dataset.count(Dataset.scala:2429) com.ruckuswireless.rsa.controllers.aggregators.WifiCallingAggregator$.getData(WifiCallingAggregator.scala:49) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregateBinnedData(AggregateStage.scala:128) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregateBinnedData(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregate(AggregateStage.scala:31) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregate(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.run(Pipeline.scala:45) com.ruckuswireless.rsa.etl.Pipeline$.run(Pipeline.scala:24) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.runPAAQ(PollAndAggregateQuarthourly.scala:64) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.main(PollAndAggregateQuarthourly.scala:43) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly.main(PollAndAggregateQuarthourly.scala) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.apache.spark.deploy.worker.DriverWrapper$.main(DriverWrapper.scala:58) org.apache.spark.deploy.worker.DriverWrapper.main(DriverWrapper.scala) |
2025/08/22 20:51:27 | 0.4 s |
113 |
| 50 |
count at Pipeline.scala:38
org.apache.spark.sql.Dataset.count(Dataset.scala:2429) com.ruckuswireless.rsa.common.Pipeline$class.triggerIndexing(Pipeline.scala:38) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.triggerIndexing(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregateBinnedData(AggregateStage.scala:125) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregateBinnedData(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregate(AggregateStage.scala:31) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregate(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.run(Pipeline.scala:45) com.ruckuswireless.rsa.etl.Pipeline$.run(Pipeline.scala:24) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.runPAAQ(PollAndAggregateQuarthourly.scala:64) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.main(PollAndAggregateQuarthourly.scala:43) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly.main(PollAndAggregateQuarthourly.scala) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.apache.spark.deploy.worker.DriverWrapper$.main(DriverWrapper.scala:58) org.apache.spark.deploy.worker.DriverWrapper.main(DriverWrapper.scala) |
2025/08/22 20:51:27 | 0.1 s |
112 |
| 49 |
count at Pipeline.scala:89
org.apache.spark.sql.Dataset.count(Dataset.scala:2429) com.ruckuswireless.rsa.common.Pipeline$class.indexToPostgres(Pipeline.scala:89) com.ruckuswireless.rsa.common.Pipeline$class.triggerIndexing(Pipeline.scala:35) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.triggerIndexing(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregateBinnedData(AggregateStage.scala:125) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregateBinnedData(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregate(AggregateStage.scala:31) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregate(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.run(Pipeline.scala:45) com.ruckuswireless.rsa.etl.Pipeline$.run(Pipeline.scala:24) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.runPAAQ(PollAndAggregateQuarthourly.scala:64) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.main(PollAndAggregateQuarthourly.scala:43) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly.main(PollAndAggregateQuarthourly.scala) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.apache.spark.deploy.worker.DriverWrapper$.main(DriverWrapper.scala:58) |
2025/08/22 20:51:27 | 0.2 s |
111 |
| 48 |
count at Pipeline.scala:38
org.apache.spark.sql.Dataset.count(Dataset.scala:2429) com.ruckuswireless.rsa.common.Pipeline$class.triggerIndexing(Pipeline.scala:38) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.triggerIndexing(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregateBinnedData(AggregateStage.scala:119) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregateBinnedData(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregate(AggregateStage.scala:31) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregate(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.run(Pipeline.scala:45) com.ruckuswireless.rsa.etl.Pipeline$.run(Pipeline.scala:24) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.runPAAQ(PollAndAggregateQuarthourly.scala:64) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.main(PollAndAggregateQuarthourly.scala:43) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly.main(PollAndAggregateQuarthourly.scala) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.apache.spark.deploy.worker.DriverWrapper$.main(DriverWrapper.scala:58) org.apache.spark.deploy.worker.DriverWrapper.main(DriverWrapper.scala) |
2025/08/22 20:51:23 | 0.1 s |
105 |
| 47 |
count at Pipeline.scala:50
org.apache.spark.sql.Dataset.count(Dataset.scala:2429) com.ruckuswireless.rsa.common.Pipeline$class.indexToDruid(Pipeline.scala:50) com.ruckuswireless.rsa.common.Pipeline$class.triggerIndexing(Pipeline.scala:33) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.triggerIndexing(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregateBinnedData(AggregateStage.scala:119) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregateBinnedData(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregate(AggregateStage.scala:31) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregate(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.run(Pipeline.scala:45) com.ruckuswireless.rsa.etl.Pipeline$.run(Pipeline.scala:24) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.runPAAQ(PollAndAggregateQuarthourly.scala:64) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.main(PollAndAggregateQuarthourly.scala:43) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly.main(PollAndAggregateQuarthourly.scala) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.apache.spark.deploy.worker.DriverWrapper$.main(DriverWrapper.scala:58) |
2025/08/22 20:51:23 | 0.5 s |
104 |
| 46 |
count at SwitchNetworkAggregator.scala:57
org.apache.spark.sql.Dataset.count(Dataset.scala:2429) com.ruckuswireless.rsa.controllers.aggregators.SwitchNetworkAggregator$.getData(SwitchNetworkAggregator.scala:57) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregateBinnedData(AggregateStage.scala:117) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregateBinnedData(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregate(AggregateStage.scala:31) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregate(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.run(Pipeline.scala:45) com.ruckuswireless.rsa.etl.Pipeline$.run(Pipeline.scala:24) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.runPAAQ(PollAndAggregateQuarthourly.scala:64) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.main(PollAndAggregateQuarthourly.scala:43) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly.main(PollAndAggregateQuarthourly.scala) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.apache.spark.deploy.worker.DriverWrapper$.main(DriverWrapper.scala:58) org.apache.spark.deploy.worker.DriverWrapper.main(DriverWrapper.scala) |
2025/08/22 20:51:21 | 99 ms |
99 |
| 45 |
count at SwitchNetworkAggregator.scala:57
org.apache.spark.sql.Dataset.count(Dataset.scala:2429) com.ruckuswireless.rsa.controllers.aggregators.SwitchNetworkAggregator$.getData(SwitchNetworkAggregator.scala:57) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregateBinnedData(AggregateStage.scala:117) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregateBinnedData(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregate(AggregateStage.scala:31) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregate(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.run(Pipeline.scala:45) com.ruckuswireless.rsa.etl.Pipeline$.run(Pipeline.scala:24) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.runPAAQ(PollAndAggregateQuarthourly.scala:64) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.main(PollAndAggregateQuarthourly.scala:43) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly.main(PollAndAggregateQuarthourly.scala) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.apache.spark.deploy.worker.DriverWrapper$.main(DriverWrapper.scala:58) org.apache.spark.deploy.worker.DriverWrapper.main(DriverWrapper.scala) |
2025/08/22 20:51:20 | 0.3 s |
98 |
| 44 |
count at SwitchNetworkAggregator.scala:56
org.apache.spark.sql.Dataset.count(Dataset.scala:2429) com.ruckuswireless.rsa.controllers.aggregators.SwitchNetworkAggregator$.getData(SwitchNetworkAggregator.scala:56) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregateBinnedData(AggregateStage.scala:117) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregateBinnedData(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregate(AggregateStage.scala:31) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregate(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.run(Pipeline.scala:45) com.ruckuswireless.rsa.etl.Pipeline$.run(Pipeline.scala:24) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.runPAAQ(PollAndAggregateQuarthourly.scala:64) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.main(PollAndAggregateQuarthourly.scala:43) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly.main(PollAndAggregateQuarthourly.scala) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.apache.spark.deploy.worker.DriverWrapper$.main(DriverWrapper.scala:58) org.apache.spark.deploy.worker.DriverWrapper.main(DriverWrapper.scala) |
2025/08/22 20:51:20 | 0.4 s |
97 |
| 43 |
count at SwitchNetworkAggregator.scala:56
org.apache.spark.sql.Dataset.count(Dataset.scala:2429) com.ruckuswireless.rsa.controllers.aggregators.SwitchNetworkAggregator$.getData(SwitchNetworkAggregator.scala:56) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregateBinnedData(AggregateStage.scala:117) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregateBinnedData(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregate(AggregateStage.scala:31) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregate(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.run(Pipeline.scala:45) com.ruckuswireless.rsa.etl.Pipeline$.run(Pipeline.scala:24) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.runPAAQ(PollAndAggregateQuarthourly.scala:64) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.main(PollAndAggregateQuarthourly.scala:43) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly.main(PollAndAggregateQuarthourly.scala) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.apache.spark.deploy.worker.DriverWrapper$.main(DriverWrapper.scala:58) org.apache.spark.deploy.worker.DriverWrapper.main(DriverWrapper.scala) |
2025/08/22 20:51:19 | 0.9 s |
95 96 |
| 42 |
count at SwitchNetworkAggregator.scala:55
org.apache.spark.sql.Dataset.count(Dataset.scala:2429) com.ruckuswireless.rsa.controllers.aggregators.SwitchNetworkAggregator$.getData(SwitchNetworkAggregator.scala:55) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregateBinnedData(AggregateStage.scala:117) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregateBinnedData(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregate(AggregateStage.scala:31) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregate(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.run(Pipeline.scala:45) com.ruckuswireless.rsa.etl.Pipeline$.run(Pipeline.scala:24) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.runPAAQ(PollAndAggregateQuarthourly.scala:64) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.main(PollAndAggregateQuarthourly.scala:43) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly.main(PollAndAggregateQuarthourly.scala) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.apache.spark.deploy.worker.DriverWrapper$.main(DriverWrapper.scala:58) org.apache.spark.deploy.worker.DriverWrapper.main(DriverWrapper.scala) |
2025/08/22 20:51:19 | 35 ms |
94 |
| 41 |
count at SwitchNetworkAggregator.scala:55
org.apache.spark.sql.Dataset.count(Dataset.scala:2429) com.ruckuswireless.rsa.controllers.aggregators.SwitchNetworkAggregator$.getData(SwitchNetworkAggregator.scala:55) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregateBinnedData(AggregateStage.scala:117) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregateBinnedData(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregate(AggregateStage.scala:31) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregate(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.run(Pipeline.scala:45) com.ruckuswireless.rsa.etl.Pipeline$.run(Pipeline.scala:24) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.runPAAQ(PollAndAggregateQuarthourly.scala:64) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.main(PollAndAggregateQuarthourly.scala:43) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly.main(PollAndAggregateQuarthourly.scala) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.apache.spark.deploy.worker.DriverWrapper$.main(DriverWrapper.scala:58) org.apache.spark.deploy.worker.DriverWrapper.main(DriverWrapper.scala) |
2025/08/22 20:51:19 | 0.2 s |
93 |
| 40 |
count at SwitchNetworkAggregator.scala:54
org.apache.spark.sql.Dataset.count(Dataset.scala:2429) com.ruckuswireless.rsa.controllers.aggregators.SwitchNetworkAggregator$.getData(SwitchNetworkAggregator.scala:54) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregateBinnedData(AggregateStage.scala:117) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregateBinnedData(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregate(AggregateStage.scala:31) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregate(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.run(Pipeline.scala:45) com.ruckuswireless.rsa.etl.Pipeline$.run(Pipeline.scala:24) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.runPAAQ(PollAndAggregateQuarthourly.scala:64) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.main(PollAndAggregateQuarthourly.scala:43) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly.main(PollAndAggregateQuarthourly.scala) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.apache.spark.deploy.worker.DriverWrapper$.main(DriverWrapper.scala:58) org.apache.spark.deploy.worker.DriverWrapper.main(DriverWrapper.scala) |
2025/08/22 20:51:18 | 0.4 s |
92 |
| 39 |
count at SwitchNetworkAggregator.scala:54
org.apache.spark.sql.Dataset.count(Dataset.scala:2429) com.ruckuswireless.rsa.controllers.aggregators.SwitchNetworkAggregator$.getData(SwitchNetworkAggregator.scala:54) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregateBinnedData(AggregateStage.scala:117) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregateBinnedData(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregate(AggregateStage.scala:31) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregate(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.run(Pipeline.scala:45) com.ruckuswireless.rsa.etl.Pipeline$.run(Pipeline.scala:24) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.runPAAQ(PollAndAggregateQuarthourly.scala:64) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.main(PollAndAggregateQuarthourly.scala:43) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly.main(PollAndAggregateQuarthourly.scala) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.apache.spark.deploy.worker.DriverWrapper$.main(DriverWrapper.scala:58) org.apache.spark.deploy.worker.DriverWrapper.main(DriverWrapper.scala) |
2025/08/22 20:51:18 | 0.3 s |
91 |
| 38 |
count at SwitchNetworkAggregator.scala:53
org.apache.spark.sql.Dataset.count(Dataset.scala:2429) com.ruckuswireless.rsa.controllers.aggregators.SwitchNetworkAggregator$.getData(SwitchNetworkAggregator.scala:53) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregateBinnedData(AggregateStage.scala:117) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregateBinnedData(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregate(AggregateStage.scala:31) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregate(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.run(Pipeline.scala:45) com.ruckuswireless.rsa.etl.Pipeline$.run(Pipeline.scala:24) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.runPAAQ(PollAndAggregateQuarthourly.scala:64) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.main(PollAndAggregateQuarthourly.scala:43) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly.main(PollAndAggregateQuarthourly.scala) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.apache.spark.deploy.worker.DriverWrapper$.main(DriverWrapper.scala:58) org.apache.spark.deploy.worker.DriverWrapper.main(DriverWrapper.scala) |
2025/08/22 20:51:18 | 76 ms |
90 |
| 37 |
count at SwitchNetworkAggregator.scala:32
org.apache.spark.sql.Dataset.count(Dataset.scala:2429) com.ruckuswireless.rsa.controllers.aggregators.SwitchNetworkAggregator$.getData(SwitchNetworkAggregator.scala:32) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregateBinnedData(AggregateStage.scala:117) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregateBinnedData(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregate(AggregateStage.scala:31) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregate(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.run(Pipeline.scala:45) com.ruckuswireless.rsa.etl.Pipeline$.run(Pipeline.scala:24) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.runPAAQ(PollAndAggregateQuarthourly.scala:64) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.main(PollAndAggregateQuarthourly.scala:43) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly.main(PollAndAggregateQuarthourly.scala) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.apache.spark.deploy.worker.DriverWrapper$.main(DriverWrapper.scala:58) org.apache.spark.deploy.worker.DriverWrapper.main(DriverWrapper.scala) |
2025/08/22 20:51:18 | 25 ms |
89 |
| 36 |
count at AggregateStage.scala:42
org.apache.spark.sql.Dataset.count(Dataset.scala:2429) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.buildPortDelta(AggregateStage.scala:42) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregateBinnedData(AggregateStage.scala:118) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregateBinnedData(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregate(AggregateStage.scala:31) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregate(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.run(Pipeline.scala:45) com.ruckuswireless.rsa.etl.Pipeline$.run(Pipeline.scala:24) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.runPAAQ(PollAndAggregateQuarthourly.scala:64) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.main(PollAndAggregateQuarthourly.scala:43) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly.main(PollAndAggregateQuarthourly.scala) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.apache.spark.deploy.worker.DriverWrapper$.main(DriverWrapper.scala:58) org.apache.spark.deploy.worker.DriverWrapper.main(DriverWrapper.scala) |
2025/08/22 20:51:17 | 0.3 s |
88 |
| 35 |
count at Pipeline.scala:38
org.apache.spark.sql.Dataset.count(Dataset.scala:2429) com.ruckuswireless.rsa.common.Pipeline$class.triggerIndexing(Pipeline.scala:38) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.triggerIndexing(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregateBinnedData(AggregateStage.scala:114) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregateBinnedData(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregate(AggregateStage.scala:31) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregate(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.run(Pipeline.scala:45) com.ruckuswireless.rsa.etl.Pipeline$.run(Pipeline.scala:24) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.runPAAQ(PollAndAggregateQuarthourly.scala:64) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.main(PollAndAggregateQuarthourly.scala:43) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly.main(PollAndAggregateQuarthourly.scala) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.apache.spark.deploy.worker.DriverWrapper$.main(DriverWrapper.scala:58) org.apache.spark.deploy.worker.DriverWrapper.main(DriverWrapper.scala) |
2025/08/22 20:51:17 | 75 ms |
87 |
| 34 |
count at Pipeline.scala:50
org.apache.spark.sql.Dataset.count(Dataset.scala:2429) com.ruckuswireless.rsa.common.Pipeline$class.indexToDruid(Pipeline.scala:50) com.ruckuswireless.rsa.common.Pipeline$class.triggerIndexing(Pipeline.scala:33) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.triggerIndexing(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregateBinnedData(AggregateStage.scala:114) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregateBinnedData(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregate(AggregateStage.scala:31) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregate(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.run(Pipeline.scala:45) com.ruckuswireless.rsa.etl.Pipeline$.run(Pipeline.scala:24) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.runPAAQ(PollAndAggregateQuarthourly.scala:64) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.main(PollAndAggregateQuarthourly.scala:43) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly.main(PollAndAggregateQuarthourly.scala) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.apache.spark.deploy.worker.DriverWrapper$.main(DriverWrapper.scala:58) |
2025/08/22 20:51:16 | 1 s |
86 |
| 33 |
count at SwitchInventoryAggregator.scala:37
org.apache.spark.sql.Dataset.count(Dataset.scala:2429) com.ruckuswireless.rsa.controllers.aggregators.SwitchInventoryAggregator$.getData(SwitchInventoryAggregator.scala:37) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregateBinnedData(AggregateStage.scala:113) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregateBinnedData(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregate(AggregateStage.scala:31) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregate(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.run(Pipeline.scala:45) com.ruckuswireless.rsa.etl.Pipeline$.run(Pipeline.scala:24) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.runPAAQ(PollAndAggregateQuarthourly.scala:64) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.main(PollAndAggregateQuarthourly.scala:43) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly.main(PollAndAggregateQuarthourly.scala) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.apache.spark.deploy.worker.DriverWrapper$.main(DriverWrapper.scala:58) org.apache.spark.deploy.worker.DriverWrapper.main(DriverWrapper.scala) |
2025/08/22 20:51:15 | 63 ms |
85 |
| 32 |
count at SwitchInventoryAggregator.scala:36
org.apache.spark.sql.Dataset.count(Dataset.scala:2429) com.ruckuswireless.rsa.controllers.aggregators.SwitchInventoryAggregator$.getData(SwitchInventoryAggregator.scala:36) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregateBinnedData(AggregateStage.scala:113) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregateBinnedData(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregate(AggregateStage.scala:31) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregate(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.run(Pipeline.scala:45) com.ruckuswireless.rsa.etl.Pipeline$.run(Pipeline.scala:24) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.runPAAQ(PollAndAggregateQuarthourly.scala:64) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.main(PollAndAggregateQuarthourly.scala:43) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly.main(PollAndAggregateQuarthourly.scala) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.apache.spark.deploy.worker.DriverWrapper$.main(DriverWrapper.scala:58) org.apache.spark.deploy.worker.DriverWrapper.main(DriverWrapper.scala) |
2025/08/22 20:51:14 | 0.4 s |
84 |
| 31 |
count at SwitchInventoryAggregator.scala:35
org.apache.spark.sql.Dataset.count(Dataset.scala:2429) com.ruckuswireless.rsa.controllers.aggregators.SwitchInventoryAggregator$.getData(SwitchInventoryAggregator.scala:35) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregateBinnedData(AggregateStage.scala:113) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregateBinnedData(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregate(AggregateStage.scala:31) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregate(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.run(Pipeline.scala:45) com.ruckuswireless.rsa.etl.Pipeline$.run(Pipeline.scala:24) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.runPAAQ(PollAndAggregateQuarthourly.scala:64) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.main(PollAndAggregateQuarthourly.scala:43) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly.main(PollAndAggregateQuarthourly.scala) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.apache.spark.deploy.worker.DriverWrapper$.main(DriverWrapper.scala:58) org.apache.spark.deploy.worker.DriverWrapper.main(DriverWrapper.scala) |
2025/08/22 20:51:14 | 0.7 s |
83 |
| 30 |
count at SwitchInventoryAggregator.scala:34
org.apache.spark.sql.Dataset.count(Dataset.scala:2429) com.ruckuswireless.rsa.controllers.aggregators.SwitchInventoryAggregator$.getData(SwitchInventoryAggregator.scala:34) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregateBinnedData(AggregateStage.scala:113) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregateBinnedData(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregate(AggregateStage.scala:31) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregate(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.run(Pipeline.scala:45) com.ruckuswireless.rsa.etl.Pipeline$.run(Pipeline.scala:24) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.runPAAQ(PollAndAggregateQuarthourly.scala:64) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.main(PollAndAggregateQuarthourly.scala:43) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly.main(PollAndAggregateQuarthourly.scala) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.apache.spark.deploy.worker.DriverWrapper$.main(DriverWrapper.scala:58) org.apache.spark.deploy.worker.DriverWrapper.main(DriverWrapper.scala) |
2025/08/22 20:51:13 | 0.4 s |
82 |
| 29 |
count at Pipeline.scala:38
org.apache.spark.sql.Dataset.count(Dataset.scala:2429) com.ruckuswireless.rsa.common.Pipeline$class.triggerIndexing(Pipeline.scala:38) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.triggerIndexing(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregateBinnedData(AggregateStage.scala:110) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregateBinnedData(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregate(AggregateStage.scala:31) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregate(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.run(Pipeline.scala:45) com.ruckuswireless.rsa.etl.Pipeline$.run(Pipeline.scala:24) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.runPAAQ(PollAndAggregateQuarthourly.scala:64) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.main(PollAndAggregateQuarthourly.scala:43) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly.main(PollAndAggregateQuarthourly.scala) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.apache.spark.deploy.worker.DriverWrapper$.main(DriverWrapper.scala:58) org.apache.spark.deploy.worker.DriverWrapper.main(DriverWrapper.scala) |
2025/08/22 20:51:13 | 82 ms |
81 |
| 28 |
count at Pipeline.scala:50
org.apache.spark.sql.Dataset.count(Dataset.scala:2429) com.ruckuswireless.rsa.common.Pipeline$class.indexToDruid(Pipeline.scala:50) com.ruckuswireless.rsa.common.Pipeline$class.triggerIndexing(Pipeline.scala:33) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.triggerIndexing(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregateBinnedData(AggregateStage.scala:110) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregateBinnedData(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregate(AggregateStage.scala:31) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregate(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.run(Pipeline.scala:45) com.ruckuswireless.rsa.etl.Pipeline$.run(Pipeline.scala:24) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.runPAAQ(PollAndAggregateQuarthourly.scala:64) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.main(PollAndAggregateQuarthourly.scala:43) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly.main(PollAndAggregateQuarthourly.scala) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.apache.spark.deploy.worker.DriverWrapper$.main(DriverWrapper.scala:58) |
2025/08/22 20:51:12 | 0.6 s |
80 |
| 27 |
count at Pipeline.scala:38
org.apache.spark.sql.Dataset.count(Dataset.scala:2429) com.ruckuswireless.rsa.common.Pipeline$class.triggerIndexing(Pipeline.scala:38) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.triggerIndexing(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregateBinnedData(AggregateStage.scala:106) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregateBinnedData(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregate(AggregateStage.scala:31) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregate(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.run(Pipeline.scala:45) com.ruckuswireless.rsa.etl.Pipeline$.run(Pipeline.scala:24) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.runPAAQ(PollAndAggregateQuarthourly.scala:64) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.main(PollAndAggregateQuarthourly.scala:43) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly.main(PollAndAggregateQuarthourly.scala) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.apache.spark.deploy.worker.DriverWrapper$.main(DriverWrapper.scala:58) org.apache.spark.deploy.worker.DriverWrapper.main(DriverWrapper.scala) |
2025/08/22 20:51:10 | 89 ms |
74 |
| 26 |
count at Pipeline.scala:50
org.apache.spark.sql.Dataset.count(Dataset.scala:2429) com.ruckuswireless.rsa.common.Pipeline$class.indexToDruid(Pipeline.scala:50) com.ruckuswireless.rsa.common.Pipeline$class.triggerIndexing(Pipeline.scala:33) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.triggerIndexing(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregateBinnedData(AggregateStage.scala:106) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregateBinnedData(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregate(AggregateStage.scala:31) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregate(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.run(Pipeline.scala:45) com.ruckuswireless.rsa.etl.Pipeline$.run(Pipeline.scala:24) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.runPAAQ(PollAndAggregateQuarthourly.scala:64) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.main(PollAndAggregateQuarthourly.scala:43) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly.main(PollAndAggregateQuarthourly.scala) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.apache.spark.deploy.worker.DriverWrapper$.main(DriverWrapper.scala:58) |
2025/08/22 20:51:09 | 0.8 s |
73 |
| 25 |
count at Pipeline.scala:38
org.apache.spark.sql.Dataset.count(Dataset.scala:2429) com.ruckuswireless.rsa.common.Pipeline$class.triggerIndexing(Pipeline.scala:38) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.triggerIndexing(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregateBinnedData(AggregateStage.scala:101) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregateBinnedData(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregate(AggregateStage.scala:31) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregate(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.run(Pipeline.scala:45) com.ruckuswireless.rsa.etl.Pipeline$.run(Pipeline.scala:24) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.runPAAQ(PollAndAggregateQuarthourly.scala:64) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.main(PollAndAggregateQuarthourly.scala:43) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly.main(PollAndAggregateQuarthourly.scala) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.apache.spark.deploy.worker.DriverWrapper$.main(DriverWrapper.scala:58) org.apache.spark.deploy.worker.DriverWrapper.main(DriverWrapper.scala) |
2025/08/22 20:51:07 | 91 ms |
67 |
| 24 |
count at Pipeline.scala:50
org.apache.spark.sql.Dataset.count(Dataset.scala:2429) com.ruckuswireless.rsa.common.Pipeline$class.indexToDruid(Pipeline.scala:50) com.ruckuswireless.rsa.common.Pipeline$class.triggerIndexing(Pipeline.scala:33) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.triggerIndexing(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregateBinnedData(AggregateStage.scala:101) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregateBinnedData(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregate(AggregateStage.scala:31) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregate(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.run(Pipeline.scala:45) com.ruckuswireless.rsa.etl.Pipeline$.run(Pipeline.scala:24) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.runPAAQ(PollAndAggregateQuarthourly.scala:64) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.main(PollAndAggregateQuarthourly.scala:43) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly.main(PollAndAggregateQuarthourly.scala) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.apache.spark.deploy.worker.DriverWrapper$.main(DriverWrapper.scala:58) |
2025/08/22 20:51:07 | 0.7 s |
66 |
| 23 |
count at Pipeline.scala:38
org.apache.spark.sql.Dataset.count(Dataset.scala:2429) com.ruckuswireless.rsa.common.Pipeline$class.triggerIndexing(Pipeline.scala:38) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.triggerIndexing(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregateBinnedData(AggregateStage.scala:96) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregateBinnedData(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregate(AggregateStage.scala:31) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregate(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.run(Pipeline.scala:45) com.ruckuswireless.rsa.etl.Pipeline$.run(Pipeline.scala:24) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.runPAAQ(PollAndAggregateQuarthourly.scala:64) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.main(PollAndAggregateQuarthourly.scala:43) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly.main(PollAndAggregateQuarthourly.scala) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.apache.spark.deploy.worker.DriverWrapper$.main(DriverWrapper.scala:58) org.apache.spark.deploy.worker.DriverWrapper.main(DriverWrapper.scala) |
2025/08/22 20:51:05 | 0.1 s |
60 |
| 22 |
count at Pipeline.scala:50
org.apache.spark.sql.Dataset.count(Dataset.scala:2429) com.ruckuswireless.rsa.common.Pipeline$class.indexToDruid(Pipeline.scala:50) com.ruckuswireless.rsa.common.Pipeline$class.triggerIndexing(Pipeline.scala:33) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.triggerIndexing(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregateBinnedData(AggregateStage.scala:96) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregateBinnedData(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregate(AggregateStage.scala:31) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregate(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.run(Pipeline.scala:45) com.ruckuswireless.rsa.etl.Pipeline$.run(Pipeline.scala:24) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.runPAAQ(PollAndAggregateQuarthourly.scala:64) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.main(PollAndAggregateQuarthourly.scala:43) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly.main(PollAndAggregateQuarthourly.scala) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.apache.spark.deploy.worker.DriverWrapper$.main(DriverWrapper.scala:58) |
2025/08/22 20:51:04 | 0.7 s |
59 |
| 21 |
count at Pipeline.scala:38
org.apache.spark.sql.Dataset.count(Dataset.scala:2429) com.ruckuswireless.rsa.common.Pipeline$class.triggerIndexing(Pipeline.scala:38) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.triggerIndexing(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregateBinnedData(AggregateStage.scala:90) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregateBinnedData(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregate(AggregateStage.scala:31) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregate(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.run(Pipeline.scala:45) com.ruckuswireless.rsa.etl.Pipeline$.run(Pipeline.scala:24) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.runPAAQ(PollAndAggregateQuarthourly.scala:64) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.main(PollAndAggregateQuarthourly.scala:43) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly.main(PollAndAggregateQuarthourly.scala) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.apache.spark.deploy.worker.DriverWrapper$.main(DriverWrapper.scala:58) org.apache.spark.deploy.worker.DriverWrapper.main(DriverWrapper.scala) |
2025/08/22 20:51:01 | 0.1 s |
54 |
| 20 |
count at Pipeline.scala:50
org.apache.spark.sql.Dataset.count(Dataset.scala:2429) com.ruckuswireless.rsa.common.Pipeline$class.indexToDruid(Pipeline.scala:50) com.ruckuswireless.rsa.common.Pipeline$class.triggerIndexing(Pipeline.scala:33) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.triggerIndexing(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregateBinnedData(AggregateStage.scala:90) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregateBinnedData(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregate(AggregateStage.scala:31) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregate(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.run(Pipeline.scala:45) com.ruckuswireless.rsa.etl.Pipeline$.run(Pipeline.scala:24) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.runPAAQ(PollAndAggregateQuarthourly.scala:64) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.main(PollAndAggregateQuarthourly.scala:43) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly.main(PollAndAggregateQuarthourly.scala) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.apache.spark.deploy.worker.DriverWrapper$.main(DriverWrapper.scala:58) |
2025/08/22 20:51:00 | 1 s |
53 |
| 19 |
count at Pipeline.scala:38
org.apache.spark.sql.Dataset.count(Dataset.scala:2429) com.ruckuswireless.rsa.common.Pipeline$class.triggerIndexing(Pipeline.scala:38) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.triggerIndexing(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregateBinnedData(AggregateStage.scala:85) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregateBinnedData(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregate(AggregateStage.scala:31) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregate(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.run(Pipeline.scala:45) com.ruckuswireless.rsa.etl.Pipeline$.run(Pipeline.scala:24) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.runPAAQ(PollAndAggregateQuarthourly.scala:64) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.main(PollAndAggregateQuarthourly.scala:43) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly.main(PollAndAggregateQuarthourly.scala) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.apache.spark.deploy.worker.DriverWrapper$.main(DriverWrapper.scala:58) org.apache.spark.deploy.worker.DriverWrapper.main(DriverWrapper.scala) |
2025/08/22 20:50:57 | 0.1 s |
47 |
| 18 |
count at Pipeline.scala:50
org.apache.spark.sql.Dataset.count(Dataset.scala:2429) com.ruckuswireless.rsa.common.Pipeline$class.indexToDruid(Pipeline.scala:50) com.ruckuswireless.rsa.common.Pipeline$class.triggerIndexing(Pipeline.scala:33) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.triggerIndexing(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregateBinnedData(AggregateStage.scala:85) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregateBinnedData(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregate(AggregateStage.scala:31) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregate(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.run(Pipeline.scala:45) com.ruckuswireless.rsa.etl.Pipeline$.run(Pipeline.scala:24) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.runPAAQ(PollAndAggregateQuarthourly.scala:64) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.main(PollAndAggregateQuarthourly.scala:43) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly.main(PollAndAggregateQuarthourly.scala) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.apache.spark.deploy.worker.DriverWrapper$.main(DriverWrapper.scala:58) |
2025/08/22 20:50:56 | 0.8 s |
46 |
| 17 |
count at Pipeline.scala:38
org.apache.spark.sql.Dataset.count(Dataset.scala:2429) com.ruckuswireless.rsa.common.Pipeline$class.triggerIndexing(Pipeline.scala:38) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.triggerIndexing(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregateBinnedData(AggregateStage.scala:81) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregateBinnedData(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregate(AggregateStage.scala:31) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregate(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.run(Pipeline.scala:45) com.ruckuswireless.rsa.etl.Pipeline$.run(Pipeline.scala:24) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.runPAAQ(PollAndAggregateQuarthourly.scala:64) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.main(PollAndAggregateQuarthourly.scala:43) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly.main(PollAndAggregateQuarthourly.scala) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.apache.spark.deploy.worker.DriverWrapper$.main(DriverWrapper.scala:58) org.apache.spark.deploy.worker.DriverWrapper.main(DriverWrapper.scala) |
2025/08/22 20:50:54 | 73 ms |
41 |
| 16 |
count at Pipeline.scala:50
org.apache.spark.sql.Dataset.count(Dataset.scala:2429) com.ruckuswireless.rsa.common.Pipeline$class.indexToDruid(Pipeline.scala:50) com.ruckuswireless.rsa.common.Pipeline$class.triggerIndexing(Pipeline.scala:33) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.triggerIndexing(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregateBinnedData(AggregateStage.scala:81) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregateBinnedData(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregate(AggregateStage.scala:31) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregate(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.run(Pipeline.scala:45) com.ruckuswireless.rsa.etl.Pipeline$.run(Pipeline.scala:24) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.runPAAQ(PollAndAggregateQuarthourly.scala:64) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.main(PollAndAggregateQuarthourly.scala:43) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly.main(PollAndAggregateQuarthourly.scala) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.apache.spark.deploy.worker.DriverWrapper$.main(DriverWrapper.scala:58) |
2025/08/22 20:50:54 | 0.1 s |
40 |
| 15 |
count at Pipeline.scala:38
org.apache.spark.sql.Dataset.count(Dataset.scala:2429) com.ruckuswireless.rsa.common.Pipeline$class.triggerIndexing(Pipeline.scala:38) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.triggerIndexing(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregateBinnedData(AggregateStage.scala:78) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregateBinnedData(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregate(AggregateStage.scala:31) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregate(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.run(Pipeline.scala:45) com.ruckuswireless.rsa.etl.Pipeline$.run(Pipeline.scala:24) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.runPAAQ(PollAndAggregateQuarthourly.scala:64) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.main(PollAndAggregateQuarthourly.scala:43) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly.main(PollAndAggregateQuarthourly.scala) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.apache.spark.deploy.worker.DriverWrapper$.main(DriverWrapper.scala:58) org.apache.spark.deploy.worker.DriverWrapper.main(DriverWrapper.scala) |
2025/08/22 20:50:53 | 0.1 s |
39 |
| 14 |
count at Pipeline.scala:50
org.apache.spark.sql.Dataset.count(Dataset.scala:2429) com.ruckuswireless.rsa.common.Pipeline$class.indexToDruid(Pipeline.scala:50) com.ruckuswireless.rsa.common.Pipeline$class.triggerIndexing(Pipeline.scala:33) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.triggerIndexing(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregateBinnedData(AggregateStage.scala:78) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregateBinnedData(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregate(AggregateStage.scala:31) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregate(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.run(Pipeline.scala:45) com.ruckuswireless.rsa.etl.Pipeline$.run(Pipeline.scala:24) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.runPAAQ(PollAndAggregateQuarthourly.scala:64) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.main(PollAndAggregateQuarthourly.scala:43) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly.main(PollAndAggregateQuarthourly.scala) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.apache.spark.deploy.worker.DriverWrapper$.main(DriverWrapper.scala:58) |
2025/08/22 20:50:52 | 0.7 s |
38 |
| 13 |
count at ApInventoryAggregator.scala:32
org.apache.spark.sql.Dataset.count(Dataset.scala:2429) com.ruckuswireless.rsa.controllers.aggregators.ApInventoryAggregator$.getData(ApInventoryAggregator.scala:32) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregateBinnedData(AggregateStage.scala:77) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregateBinnedData(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregate(AggregateStage.scala:31) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregate(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.run(Pipeline.scala:45) com.ruckuswireless.rsa.etl.Pipeline$.run(Pipeline.scala:24) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.runPAAQ(PollAndAggregateQuarthourly.scala:64) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.main(PollAndAggregateQuarthourly.scala:43) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly.main(PollAndAggregateQuarthourly.scala) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.apache.spark.deploy.worker.DriverWrapper$.main(DriverWrapper.scala:58) org.apache.spark.deploy.worker.DriverWrapper.main(DriverWrapper.scala) |
2025/08/22 20:50:49 | 2 s |
29 30 31 32 33 |
| 12 |
count at ApInventoryAggregator.scala:31
org.apache.spark.sql.Dataset.count(Dataset.scala:2429) com.ruckuswireless.rsa.controllers.aggregators.ApInventoryAggregator$.getData(ApInventoryAggregator.scala:31) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregateBinnedData(AggregateStage.scala:77) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregateBinnedData(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregate(AggregateStage.scala:31) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregate(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.run(Pipeline.scala:45) com.ruckuswireless.rsa.etl.Pipeline$.run(Pipeline.scala:24) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.runPAAQ(PollAndAggregateQuarthourly.scala:64) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.main(PollAndAggregateQuarthourly.scala:43) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly.main(PollAndAggregateQuarthourly.scala) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.apache.spark.deploy.worker.DriverWrapper$.main(DriverWrapper.scala:58) org.apache.spark.deploy.worker.DriverWrapper.main(DriverWrapper.scala) |
2025/08/22 20:50:47 | 0.9 s |
28 |
| 11 |
count at ApInventoryAggregator.scala:30
org.apache.spark.sql.Dataset.count(Dataset.scala:2429) com.ruckuswireless.rsa.controllers.aggregators.ApInventoryAggregator$.getData(ApInventoryAggregator.scala:30) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregateBinnedData(AggregateStage.scala:77) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregateBinnedData(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregate(AggregateStage.scala:31) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregate(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.run(Pipeline.scala:45) com.ruckuswireless.rsa.etl.Pipeline$.run(Pipeline.scala:24) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.runPAAQ(PollAndAggregateQuarthourly.scala:64) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.main(PollAndAggregateQuarthourly.scala:43) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly.main(PollAndAggregateQuarthourly.scala) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.apache.spark.deploy.worker.DriverWrapper$.main(DriverWrapper.scala:58) org.apache.spark.deploy.worker.DriverWrapper.main(DriverWrapper.scala) |
2025/08/22 20:50:47 | 94 ms |
27 |
| 10 |
count at ApInventoryAggregator.scala:29
org.apache.spark.sql.Dataset.count(Dataset.scala:2429) com.ruckuswireless.rsa.controllers.aggregators.ApInventoryAggregator$.getData(ApInventoryAggregator.scala:29) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregateBinnedData(AggregateStage.scala:77) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregateBinnedData(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregate(AggregateStage.scala:31) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregate(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.run(Pipeline.scala:45) com.ruckuswireless.rsa.etl.Pipeline$.run(Pipeline.scala:24) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.runPAAQ(PollAndAggregateQuarthourly.scala:64) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.main(PollAndAggregateQuarthourly.scala:43) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly.main(PollAndAggregateQuarthourly.scala) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.apache.spark.deploy.worker.DriverWrapper$.main(DriverWrapper.scala:58) org.apache.spark.deploy.worker.DriverWrapper.main(DriverWrapper.scala) |
2025/08/22 20:50:47 | 0.1 s |
26 |
| 9 |
count at Pipeline.scala:38
org.apache.spark.sql.Dataset.count(Dataset.scala:2429) com.ruckuswireless.rsa.common.Pipeline$class.triggerIndexing(Pipeline.scala:38) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.triggerIndexing(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregateBinnedData(AggregateStage.scala:74) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregateBinnedData(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregate(AggregateStage.scala:31) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregate(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.run(Pipeline.scala:45) com.ruckuswireless.rsa.etl.Pipeline$.run(Pipeline.scala:24) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.runPAAQ(PollAndAggregateQuarthourly.scala:64) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.main(PollAndAggregateQuarthourly.scala:43) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly.main(PollAndAggregateQuarthourly.scala) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.apache.spark.deploy.worker.DriverWrapper$.main(DriverWrapper.scala:58) org.apache.spark.deploy.worker.DriverWrapper.main(DriverWrapper.scala) |
2025/08/22 20:50:46 | 0.2 s |
25 |
| 8 |
count at Pipeline.scala:50
org.apache.spark.sql.Dataset.count(Dataset.scala:2429) com.ruckuswireless.rsa.common.Pipeline$class.indexToDruid(Pipeline.scala:50) com.ruckuswireless.rsa.common.Pipeline$class.triggerIndexing(Pipeline.scala:33) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.triggerIndexing(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregateBinnedData(AggregateStage.scala:74) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregateBinnedData(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregate(AggregateStage.scala:31) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregate(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.run(Pipeline.scala:45) com.ruckuswireless.rsa.etl.Pipeline$.run(Pipeline.scala:24) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.runPAAQ(PollAndAggregateQuarthourly.scala:64) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.main(PollAndAggregateQuarthourly.scala:43) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly.main(PollAndAggregateQuarthourly.scala) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.apache.spark.deploy.worker.DriverWrapper$.main(DriverWrapper.scala:58) |
2025/08/22 20:50:44 | 1 s |
24 |
| 7 |
count at Pipeline.scala:38
org.apache.spark.sql.Dataset.count(Dataset.scala:2429) com.ruckuswireless.rsa.common.Pipeline$class.triggerIndexing(Pipeline.scala:38) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.triggerIndexing(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregateBinnedData(AggregateStage.scala:71) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregateBinnedData(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregate(AggregateStage.scala:31) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregate(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.run(Pipeline.scala:45) com.ruckuswireless.rsa.etl.Pipeline$.run(Pipeline.scala:24) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.runPAAQ(PollAndAggregateQuarthourly.scala:64) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.main(PollAndAggregateQuarthourly.scala:43) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly.main(PollAndAggregateQuarthourly.scala) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.apache.spark.deploy.worker.DriverWrapper$.main(DriverWrapper.scala:58) org.apache.spark.deploy.worker.DriverWrapper.main(DriverWrapper.scala) |
2025/08/22 20:50:41 | 0.2 s |
19 |
| 6 |
count at Pipeline.scala:50
org.apache.spark.sql.Dataset.count(Dataset.scala:2429) com.ruckuswireless.rsa.common.Pipeline$class.indexToDruid(Pipeline.scala:50) com.ruckuswireless.rsa.common.Pipeline$class.triggerIndexing(Pipeline.scala:33) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.triggerIndexing(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.Pipeline$$anonfun$1.apply(Pipeline.scala:45) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregateBinnedData(AggregateStage.scala:71) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregateBinnedData(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregate(AggregateStage.scala:31) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregate(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.run(Pipeline.scala:45) com.ruckuswireless.rsa.etl.Pipeline$.run(Pipeline.scala:24) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.runPAAQ(PollAndAggregateQuarthourly.scala:64) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.main(PollAndAggregateQuarthourly.scala:43) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly.main(PollAndAggregateQuarthourly.scala) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.apache.spark.deploy.worker.DriverWrapper$.main(DriverWrapper.scala:58) |
2025/08/22 20:50:38 | 3 s |
18 |
| 5 |
count at AggregateStage.scala:62
org.apache.spark.sql.Dataset.count(Dataset.scala:2429) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregateBinnedData(AggregateStage.scala:62) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregateBinnedData(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregate(AggregateStage.scala:31) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregate(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.run(Pipeline.scala:45) com.ruckuswireless.rsa.etl.Pipeline$.run(Pipeline.scala:24) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.runPAAQ(PollAndAggregateQuarthourly.scala:64) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.main(PollAndAggregateQuarthourly.scala:43) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly.main(PollAndAggregateQuarthourly.scala) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.apache.spark.deploy.worker.DriverWrapper$.main(DriverWrapper.scala:58) org.apache.spark.deploy.worker.DriverWrapper.main(DriverWrapper.scala) |
2025/08/22 20:50:34 | 0.2 s |
13 |
| 4 |
count at AggregateStage.scala:62
org.apache.spark.sql.Dataset.count(Dataset.scala:2429) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregateBinnedData(AggregateStage.scala:62) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregateBinnedData(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.stages.AggregateStage$class.aggregate(AggregateStage.scala:31) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.aggregate(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.run(Pipeline.scala:45) com.ruckuswireless.rsa.etl.Pipeline$.run(Pipeline.scala:24) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.runPAAQ(PollAndAggregateQuarthourly.scala:64) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.main(PollAndAggregateQuarthourly.scala:43) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly.main(PollAndAggregateQuarthourly.scala) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.apache.spark.deploy.worker.DriverWrapper$.main(DriverWrapper.scala:58) org.apache.spark.deploy.worker.DriverWrapper.main(DriverWrapper.scala) |
2025/08/22 20:50:34 | 0.3 s |
12 |
| 3 |
collect at DomainParser.scala:57
org.apache.spark.sql.Dataset.collect(Dataset.scala:2390) com.ruckuswireless.rsa.controllers.parsers.DomainParser$.extract(DomainParser.scala:57) com.ruckuswireless.rsa.controllers.pipelines.stages.ParseStageUtil$.getSwitchHierarchyDF(ParseStage.scala:119) com.ruckuswireless.rsa.controllers.pipelines.stages.ParseStageUtil$.getMetaDFs(ParseStage.scala:59) com.ruckuswireless.rsa.controllers.pipelines.stages.ParseStage$class.parse(ParseStage.scala:22) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.parse(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.run(Pipeline.scala:43) com.ruckuswireless.rsa.etl.Pipeline$.run(Pipeline.scala:24) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.runPAAQ(PollAndAggregateQuarthourly.scala:64) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.main(PollAndAggregateQuarthourly.scala:43) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly.main(PollAndAggregateQuarthourly.scala) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.apache.spark.deploy.worker.DriverWrapper$.main(DriverWrapper.scala:58) org.apache.spark.deploy.worker.DriverWrapper.main(DriverWrapper.scala) |
2025/08/22 20:50:26 | 0.3 s |
5 |
| 2 |
collect at DomainParser.scala:57
org.apache.spark.sql.Dataset.collect(Dataset.scala:2390) com.ruckuswireless.rsa.controllers.parsers.DomainParser$.extract(DomainParser.scala:57) com.ruckuswireless.rsa.controllers.pipelines.stages.ParseStageUtil$.getApHierarchyDF(ParseStage.scala:73) com.ruckuswireless.rsa.controllers.pipelines.stages.ParseStageUtil$.getMetaDFs(ParseStage.scala:58) com.ruckuswireless.rsa.controllers.pipelines.stages.ParseStage$class.parse(ParseStage.scala:22) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.parse(Pipeline.scala:27) com.ruckuswireless.rsa.controllers.pipelines.Pipeline.run(Pipeline.scala:43) com.ruckuswireless.rsa.etl.Pipeline$.run(Pipeline.scala:24) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.runPAAQ(PollAndAggregateQuarthourly.scala:64) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.main(PollAndAggregateQuarthourly.scala:43) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly.main(PollAndAggregateQuarthourly.scala) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.apache.spark.deploy.worker.DriverWrapper$.main(DriverWrapper.scala:58) org.apache.spark.deploy.worker.DriverWrapper.main(DriverWrapper.scala) |
2025/08/22 20:50:23 | 2 s |
4 |
| 1 |
parquet at ParquetWriter.scala:28
org.apache.spark.sql.DataFrameWriter.parquet(DataFrameWriter.scala:509) com.ruckuswireless.rsa.connectors.ParquetWriter.writeCurrent(ParquetWriter.scala:28) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.pollZDPushQuarthour(PollAndAggregateQuarthourly.scala:126) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.runPAAQ(PollAndAggregateQuarthourly.scala:63) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.main(PollAndAggregateQuarthourly.scala:43) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly.main(PollAndAggregateQuarthourly.scala) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.apache.spark.deploy.worker.DriverWrapper$.main(DriverWrapper.scala:58) org.apache.spark.deploy.worker.DriverWrapper.main(DriverWrapper.scala) |
2025/08/22 20:50:18 | 0.3 s |
1 |
| 0 |
parquet at ParquetWriter.scala:28
org.apache.spark.sql.DataFrameWriter.parquet(DataFrameWriter.scala:509) com.ruckuswireless.rsa.connectors.ParquetWriter.writeCurrent(ParquetWriter.scala:28) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.pollQuarthourData(PollAndAggregateQuarthourly.scala:97) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.runPAAQ(PollAndAggregateQuarthourly.scala:62) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly$.main(PollAndAggregateQuarthourly.scala:43) com.ruckuswireless.rsa.tasks.PollAndAggregateQuarthourly.main(PollAndAggregateQuarthourly.scala) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.apache.spark.deploy.worker.DriverWrapper$.main(DriverWrapper.scala:58) org.apache.spark.deploy.worker.DriverWrapper.main(DriverWrapper.scala) |
2025/08/22 20:50:13 | 5 s |
0 |
