| Pool Name | Minimum Share | Pool Weight | Active Stages | Running Tasks | SchedulingMode |
|---|---|---|---|---|---|
| default | 0 | 1 | 0 | 0 | FAIR |
| Stage Id ▾ | Pool Name | Description | Submitted | Duration | Tasks: Succeeded/Total | Input | Output | Shuffle Read | Shuffle Write |
|---|---|---|---|---|---|---|---|---|---|
| 1062300 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352958 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:17:33 | 91 ms |
4/4
| ||||
| 1062299 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352957 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:17:32 | 35 ms |
4/4
| ||||
| 1062298 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352956 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:17:31 | 40 ms |
4/4
| ||||
| 1062297 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352955 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:17:30 | 57 ms |
4/4
| ||||
| 1062296 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352954 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:17:29 | 37 ms |
4/4
| ||||
| 1062295 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352953 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:17:28 | 42 ms |
4/4
| ||||
| 1062294 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352952 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:17:27 | 36 ms |
4/4
| ||||
| 1062293 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352951 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:17:26 | 46 ms |
4/4
| ||||
| 1062292 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352950 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:17:25 | 49 ms |
4/4
| ||||
| 1062291 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352949 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:17:24 | 41 ms |
4/4
| ||||
| 1062290 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352948 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:17:23 | 41 ms |
4/4
| ||||
| 1062289 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352947 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:17:22 | 31 ms |
4/4
| ||||
| 1062288 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352946 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:17:21 | 57 ms |
4/4
| ||||
| 1062287 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352945 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:17:20 | 42 ms |
4/4
| ||||
| 1062286 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352944 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:17:19 | 35 ms |
4/4
| ||||
| 1062285 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352943 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:17:18 | 46 ms |
4/4
| ||||
| 1062284 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352942 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:17:17 | 40 ms |
4/4
| ||||
| 1062283 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352941 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:17:16 | 0.2 s |
4/4
| ||||
| 1062282 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352940 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:17:15 | 35 ms |
4/4
| ||||
| 1062281 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352939 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:17:14 | 46 ms |
4/4
| ||||
| 1062280 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352938 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:17:13 | 48 ms |
4/4
| ||||
| 1062279 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352937 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:17:12 | 53 ms |
4/4
| ||||
| 1062278 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352936 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:17:11 | 33 ms |
4/4
| ||||
| 1062277 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352935 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:17:10 | 28 ms |
4/4
| ||||
| 1062276 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352934 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:17:09 | 47 ms |
4/4
| ||||
| 1062275 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352933 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:17:08 | 35 ms |
4/4
| ||||
| 1062274 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352932 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:17:07 | 37 ms |
4/4
| ||||
| 1062273 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352931 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:17:06 | 34 ms |
4/4
| ||||
| 1062272 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352930 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:17:05 | 53 ms |
4/4
| ||||
| 1062271 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352929 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:17:04 | 54 ms |
4/4
| ||||
| 1062270 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352928 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:17:03 | 75 ms |
4/4
| ||||
| 1062269 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352927 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:17:02 | 31 ms |
4/4
| ||||
| 1062268 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352926 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:17:01 | 39 ms |
4/4
| ||||
| 1062267 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352925 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:17:00 | 52 ms |
4/4
| ||||
| 1062266 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352924 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:16:59 | 29 ms |
4/4
| ||||
| 1062265 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352923 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:16:58 | 37 ms |
4/4
| ||||
| 1062264 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352922 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:16:57 | 38 ms |
4/4
| ||||
| 1062263 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352921 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:16:56 | 55 ms |
4/4
| ||||
| 1062262 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352920 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:16:55 | 32 ms |
4/4
| ||||
| 1062261 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352919 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:16:54 | 50 ms |
4/4
| ||||
| 1062260 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352918 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:16:53 | 44 ms |
4/4
| ||||
| 1062259 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352917 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:16:52 | 33 ms |
4/4
| ||||
| 1062258 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352916 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:16:51 | 33 ms |
4/4
| ||||
| 1062257 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352915 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:16:50 | 41 ms |
4/4
| ||||
| 1062256 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352914 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:16:49 | 53 ms |
4/4
| ||||
| 1062255 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352913 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:16:48 | 74 ms |
4/4
| ||||
| 1062254 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352912 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:16:47 | 34 ms |
4/4
| ||||
| 1062253 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352911 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:16:46 | 64 ms |
4/4
| ||||
| 1062252 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352910 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:16:45 | 35 ms |
4/4
| ||||
| 1062251 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352909 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:16:44 | 43 ms |
4/4
| ||||
| 1062250 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352908 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:16:43 | 71 ms |
4/4
| ||||
| 1062249 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352907 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:16:42 | 36 ms |
4/4
| ||||
| 1062248 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352906 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:16:41 | 33 ms |
4/4
| ||||
| 1062247 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352905 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:16:40 | 41 ms |
4/4
| ||||
| 1062246 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352904 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:16:39 | 47 ms |
4/4
| ||||
| 1062245 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352903 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:16:38 | 0.1 s |
4/4
| ||||
| 1062244 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352902 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:16:37 | 0.1 s |
4/4
| ||||
| 1062243 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352901 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:16:36 | 38 ms |
4/4
| ||||
| 1062242 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352900 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:16:35 | 36 ms |
4/4
| ||||
| 1062241 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352899 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:16:34 | 41 ms |
4/4
| ||||
| 1062240 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352898 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:16:33 | 84 ms |
4/4
| ||||
| 1062239 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352897 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:16:32 | 55 ms |
4/4
| ||||
| 1062238 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352896 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:16:31 | 40 ms |
4/4
| ||||
| 1062237 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352895 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:16:30 | 43 ms |
4/4
| ||||
| 1062236 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352894 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:16:29 | 34 ms |
4/4
| ||||
| 1062235 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352893 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:16:28 | 36 ms |
4/4
| ||||
| 1062234 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352892 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:16:27 | 53 ms |
4/4
| ||||
| 1062233 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352891 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:16:26 | 30 ms |
4/4
| ||||
| 1062232 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352890 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:16:25 | 54 ms |
4/4
| ||||
| 1062231 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352889 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:16:24 | 49 ms |
4/4
| ||||
| 1062230 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352888 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:16:23 | 44 ms |
4/4
| ||||
| 1062229 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352887 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:16:22 | 34 ms |
4/4
| ||||
| 1062228 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352886 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:16:21 | 35 ms |
4/4
| ||||
| 1062227 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352885 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:16:20 | 47 ms |
4/4
| ||||
| 1062226 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352884 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:16:19 | 40 ms |
4/4
| ||||
| 1062225 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352883 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:16:18 | 58 ms |
4/4
| ||||
| 1062224 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352882 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:16:17 | 0.2 s |
4/4
| ||||
| 1062223 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352881 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:16:16 | 47 ms |
4/4
| ||||
| 1062222 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352880 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:16:15 | 50 ms |
4/4
| ||||
| 1062221 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352879 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:16:14 | 41 ms |
4/4
| ||||
| 1062220 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352878 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:16:13 | 68 ms |
4/4
| ||||
| 1062219 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352877 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:16:12 | 39 ms |
4/4
| ||||
| 1062218 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352876 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:16:11 | 55 ms |
4/4
| ||||
| 1062217 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352875 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:16:10 | 52 ms |
4/4
| ||||
| 1062216 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352874 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:16:09 | 60 ms |
4/4
| ||||
| 1062215 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352873 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:16:08 | 35 ms |
4/4
| ||||
| 1062214 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352872 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:16:07 | 61 ms |
4/4
| ||||
| 1062213 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352871 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:16:06 | 52 ms |
4/4
| ||||
| 1062212 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352870 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:16:05 | 41 ms |
4/4
| ||||
| 1062211 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352869 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:16:04 | 49 ms |
4/4
| ||||
| 1062210 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352868 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:16:03 | 50 ms |
4/4
| ||||
| 1062209 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352867 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:16:02 | 30 ms |
4/4
| ||||
| 1062208 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352866 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:16:01 | 66 ms |
4/4
| ||||
| 1062207 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352865 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:16:00 | 45 ms |
4/4
| ||||
| 1062206 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352864 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:15:59 | 50 ms |
4/4
| ||||
| 1062205 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352863 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:15:58 | 32 ms |
4/4
| ||||
| 1062204 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352862 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:15:57 | 30 ms |
4/4
| ||||
| 1062203 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352861 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:15:56 | 50 ms |
4/4
| ||||
| 1062202 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352860 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:15:55 | 43 ms |
4/4
| ||||
| 1062201 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 403890e5-08ca-4690-9e71-9f7697b5b6cc
batch = 9352859 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/08/08 19:15:54 | 41 ms |
4/4
|