|
228338
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745720
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745720
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/13 09:13:06
|
55 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228339
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745720
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745720
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/13 09:13:06
|
46 ms
|
[114169]
|
|
|
228340
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745721
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745721
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/13 09:13:07
|
80 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228341
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745721
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745721
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/13 09:13:07
|
70 ms
|
[114170]
|
|
|
228342
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745722
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745722
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/13 09:13:08
|
74 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228343
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745722
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745722
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/13 09:13:08
|
65 ms
|
[114171]
|
|
|
228344
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745723
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745723
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/13 09:13:09
|
76 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228345
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745723
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745723
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/13 09:13:09
|
67 ms
|
[114172]
|
|
|
228346
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745724
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745724
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/13 09:13:10
|
87 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228347
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745724
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745724
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/13 09:13:10
|
78 ms
|
[114173]
|
|
|
228348
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745725
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745725
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/13 09:13:11
|
69 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228349
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745725
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745725
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/13 09:13:11
|
60 ms
|
[114174]
|
|
|
228350
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745726
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745726
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/13 09:13:12
|
77 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228351
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745726
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745726
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/13 09:13:12
|
68 ms
|
[114175]
|
|
|
228352
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745727
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745727
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/13 09:13:13
|
0.1 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228353
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745727
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745727
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/13 09:13:13
|
97 ms
|
[114176]
|
|
|
228354
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745728
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745728
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/13 09:13:14
|
59 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228355
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745728
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745728
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/13 09:13:14
|
48 ms
|
[114177]
|
|
|
228356
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745729
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745729
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/13 09:13:15
|
84 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228357
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745729
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745729
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/13 09:13:15
|
74 ms
|
[114178]
|
|
|
228358
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745730
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745730
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/13 09:13:16
|
66 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228359
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745730
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745730
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/13 09:13:16
|
56 ms
|
[114179]
|
|
|
228360
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745731
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745731
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/13 09:13:17
|
62 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228361
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745731
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745731
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/13 09:13:17
|
52 ms
|
[114180]
|
|
|
228362
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745732
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745732
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/13 09:13:18
|
77 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228363
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745732
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745732
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/13 09:13:18
|
67 ms
|
[114181]
|
|
|
228364
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745733
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745733
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/13 09:13:19
|
82 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228365
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745733
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745733
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/13 09:13:19
|
73 ms
|
[114182]
|
|
|
228366
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745734
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745734
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/13 09:13:20
|
59 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228367
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745734
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745734
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/13 09:13:20
|
49 ms
|
[114183]
|
|
|
228368
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745735
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745735
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/13 09:13:21
|
76 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228369
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745735
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745735
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/13 09:13:21
|
67 ms
|
[114184]
|
|
|
228370
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745736
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745736
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/13 09:13:22
|
65 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228371
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745736
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745736
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/13 09:13:22
|
56 ms
|
[114185]
|
|
|
228372
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745737
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745737
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/13 09:13:23
|
94 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228373
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745737
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745737
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/13 09:13:23
|
84 ms
|
[114186]
|
|
|
228374
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745738
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745738
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/13 09:13:24
|
75 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228375
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745738
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745738
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/13 09:13:24
|
66 ms
|
[114187]
|
|
|
228376
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745739
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745739
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/13 09:13:25
|
69 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228377
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745739
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745739
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/13 09:13:25
|
60 ms
|
[114188]
|
|
|
228378
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745740
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745740
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/13 09:13:26
|
55 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228379
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745740
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745740
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/13 09:13:26
|
45 ms
|
[114189]
|
|
|
228380
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745741
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745741
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/13 09:13:27
|
0.1 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228381
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745741
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745741
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/13 09:13:27
|
87 ms
|
[114190]
|
|
|
228382
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745742
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745742
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/13 09:13:28
|
59 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228383
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745742
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745742
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/13 09:13:28
|
49 ms
|
[114191]
|
|
|
228384
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745743
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745743
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/13 09:13:29
|
70 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228385
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745743
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745743
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/13 09:13:29
|
60 ms
|
[114192]
|
|
|
228386
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745744
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745744
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/13 09:13:30
|
60 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228387
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745744
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745744
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/13 09:13:30
|
50 ms
|
[114193]
|
|
|
228388
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745745
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745745
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/13 09:13:31
|
67 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228389
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745745
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745745
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/13 09:13:31
|
54 ms
|
[114194]
|
|
|
228390
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745746
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745746
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/13 09:13:32
|
61 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228391
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745746
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745746
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/13 09:13:32
|
52 ms
|
[114195]
|
|
|
228392
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745747
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745747
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/13 09:13:33
|
88 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228393
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745747
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745747
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/13 09:13:33
|
79 ms
|
[114196]
|
|
|
228394
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745748
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745748
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/13 09:13:34
|
56 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228395
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745748
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745748
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/13 09:13:34
|
47 ms
|
[114197]
|
|
|
228396
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745749
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745749
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/13 09:13:35
|
92 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228397
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745749
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745749
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/13 09:13:35
|
83 ms
|
[114198]
|
|
|
228398
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745750
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745750
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/13 09:13:36
|
61 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228399
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745750
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745750
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/13 09:13:36
|
52 ms
|
[114199]
|
|
|
228400
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745751
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745751
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/13 09:13:37
|
72 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228401
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745751
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745751
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/13 09:13:37
|
62 ms
|
[114200]
|
|
|
228402
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745752
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745752
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/13 09:13:38
|
66 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228403
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745752
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745752
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/13 09:13:38
|
58 ms
|
[114201]
|
|
|
228404
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745753
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745753
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/13 09:13:39
|
80 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228405
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745753
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745753
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/13 09:13:39
|
71 ms
|
[114202]
|
|
|
228406
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745754
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745754
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/13 09:13:40
|
0.1 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228407
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745754
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745754
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/13 09:13:40
|
92 ms
|
[114203]
|
|
|
228408
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745755
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745755
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/13 09:13:41
|
82 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228409
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745755
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745755
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/13 09:13:41
|
73 ms
|
[114204]
|
|
|
228410
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745756
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745756
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/13 09:13:42
|
66 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228411
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745756
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745756
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/13 09:13:42
|
57 ms
|
[114205]
|
|
|
228412
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745757
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745757
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/13 09:13:43
|
97 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228413
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745757
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745757
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/13 09:13:43
|
87 ms
|
[114206]
|
|
|
228414
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745758
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745758
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/13 09:13:44
|
77 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228415
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745758
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745758
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/13 09:13:44
|
68 ms
|
[114207]
|
|
|
228416
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745759
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745759
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/13 09:13:45
|
70 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228417
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745759
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745759
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/13 09:13:45
|
61 ms
|
[114208]
|
|
|
228418
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745760
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745760
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/13 09:13:46
|
65 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228419
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745760
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745760
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/13 09:13:46
|
46 ms
|
[114209]
|
|
|
228420
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745761
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745761
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/13 09:13:47
|
0.1 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228421
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745761
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745761
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/13 09:13:47
|
0.1 s
|
[114210]
|
|
|
228422
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745762
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745762
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/13 09:13:48
|
0.1 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228423
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745762
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745762
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/13 09:13:48
|
0.1 s
|
[114211]
|
|
|
228424
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745763
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745763
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/13 09:13:49
|
61 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228425
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745763
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745763
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/13 09:13:49
|
51 ms
|
[114212]
|
|
|
228426
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745764
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745764
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/13 09:13:50
|
83 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228427
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745764
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745764
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/13 09:13:50
|
74 ms
|
[114213]
|
|
|
228428
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745765
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745765
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/13 09:13:51
|
84 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228429
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745765
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745765
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/13 09:13:51
|
76 ms
|
[114214]
|
|
|
228430
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745766
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745766
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/13 09:13:52
|
60 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228431
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745766
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745766
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/13 09:13:52
|
50 ms
|
[114215]
|
|
|
228432
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745767
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745767
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/13 09:13:53
|
75 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228433
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745767
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745767
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/13 09:13:53
|
66 ms
|
[114216]
|
|
|
228434
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745768
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745768
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/13 09:13:54
|
62 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228435
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745768
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745768
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/13 09:13:54
|
52 ms
|
[114217]
|
|
|
228436
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745769
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745769
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/13 09:13:55
|
57 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228437
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745769
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745769
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/13 09:13:55
|
48 ms
|
[114218]
|
|
|
228438
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745770
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745770
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/13 09:13:56
|
67 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228439
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745770
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745770
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/13 09:13:56
|
56 ms
|
[114219]
|
|
|
228440
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745771
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745771
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/13 09:13:57
|
73 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228441
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745771
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745771
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/13 09:13:57
|
62 ms
|
[114220]
|
|
|
228442
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745772
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745772
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/13 09:13:58
|
74 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228443
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745772
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745772
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/13 09:13:58
|
64 ms
|
[114221]
|
|
|
228444
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745773
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745773
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/13 09:13:59
|
74 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228445
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745773
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745773
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/13 09:13:59
|
65 ms
|
[114222]
|
|
|
228446
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745774
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745774
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/13 09:14:00
|
83 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228447
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745774
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745774
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/13 09:14:00
|
73 ms
|
[114223]
|
|
|
228448
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745775
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745775
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/13 09:14:01
|
73 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228449
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745775
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745775
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/13 09:14:01
|
63 ms
|
[114224]
|
|
|
228450
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745776
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745776
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/13 09:14:02
|
59 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228451
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745776
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745776
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/13 09:14:02
|
49 ms
|
[114225]
|
|
|
228452
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745777
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745777
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/13 09:14:03
|
77 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228453
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745777
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745777
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/13 09:14:03
|
68 ms
|
[114226]
|
|
|
228454
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745778
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745778
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/13 09:14:04
|
74 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228455
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745778
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745778
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/13 09:14:04
|
65 ms
|
[114227]
|
|
|
228456
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745779
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745779
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/13 09:14:05
|
96 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228457
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745779
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745779
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/13 09:14:05
|
87 ms
|
[114228]
|
|
|
228458
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745780
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745780
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/13 09:14:06
|
89 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228459
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745780
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745780
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/13 09:14:06
|
79 ms
|
[114229]
|
|
|
228460
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745781
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745781
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/13 09:14:07
|
62 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228461
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745781
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745781
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/13 09:14:07
|
53 ms
|
[114230]
|
|
|
228462
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745782
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745782
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/13 09:14:08
|
64 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228463
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745782
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745782
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/13 09:14:08
|
54 ms
|
[114231]
|
|
|
228464
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745783
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745783
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/13 09:14:09
|
63 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228465
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745783
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745783
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/13 09:14:09
|
54 ms
|
[114232]
|
|
|
228466
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745784
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745784
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/13 09:14:10
|
64 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228467
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745784
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745784
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/13 09:14:10
|
54 ms
|
[114233]
|
|
|
228468
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745785
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745785
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/13 09:14:11
|
0.2 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228469
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745785
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745785
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/13 09:14:11
|
0.2 s
|
[114234]
|
|
|
228470
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745786
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745786
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/13 09:14:12
|
84 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228471
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745786
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745786
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/13 09:14:12
|
70 ms
|
[114235]
|
|
|
228472
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745787
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745787
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/13 09:14:13
|
69 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228473
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745787
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745787
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/13 09:14:13
|
58 ms
|
[114236]
|
|
|
228474
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745788
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745788
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/13 09:14:14
|
55 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228475
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745788
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745788
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/13 09:14:14
|
46 ms
|
[114237]
|
|
|
228476
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745789
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745789
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/13 09:14:15
|
89 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228477
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745789
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745789
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/13 09:14:15
|
79 ms
|
[114238]
|
|
|
228478
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745790
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745790
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/13 09:14:16
|
82 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228479
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745790
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745790
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/13 09:14:16
|
73 ms
|
[114239]
|
|
|
228480
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745791
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745791
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/13 09:14:17
|
72 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228481
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745791
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745791
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/13 09:14:17
|
60 ms
|
[114240]
|
|
|
228482
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745792
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745792
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/13 09:14:18
|
87 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228483
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745792
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745792
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/13 09:14:18
|
77 ms
|
[114241]
|
|
|
228484
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745793
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745793
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/13 09:14:20
|
86 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228485
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745793
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745793
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/13 09:14:20
|
78 ms
|
[114242]
|
|
|
228486
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745794
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745794
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/13 09:14:21
|
74 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228487
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745794
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745794
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/13 09:14:21
|
65 ms
|
[114243]
|
|
|
228488
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745795
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745795
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/13 09:14:22
|
61 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228489
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745795
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745795
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/13 09:14:22
|
52 ms
|
[114244]
|
|
|
228490
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745796
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745796
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/13 09:14:23
|
0.1 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228491
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745796
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745796
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/13 09:14:23
|
96 ms
|
[114245]
|
|
|
228492
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745797
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745797
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/13 09:14:24
|
69 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228493
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745797
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745797
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/13 09:14:24
|
58 ms
|
[114246]
|
|
|
228494
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745798
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745798
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/13 09:14:25
|
86 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228495
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745798
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745798
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/13 09:14:25
|
75 ms
|
[114247]
|
|
|
228496
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745799
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745799
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/13 09:14:26
|
67 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228497
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745799
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745799
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/13 09:14:26
|
59 ms
|
[114248]
|
|
|
228498
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745800
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745800
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/13 09:14:27
|
61 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228499
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745800
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745800
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/13 09:14:27
|
51 ms
|
[114249]
|
|
|
228500
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745801
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745801
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/13 09:14:28
|
52 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228501
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745801
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745801
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/13 09:14:28
|
43 ms
|
[114250]
|
|
|
228502
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745802
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745802
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/13 09:14:29
|
63 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228503
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745802
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745802
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/13 09:14:29
|
54 ms
|
[114251]
|
|
|
228504
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745803
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745803
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/13 09:14:30
|
0.1 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228505
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745803
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745803
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/13 09:14:30
|
0.1 s
|
[114252]
|
|
|
228506
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745804
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745804
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/13 09:14:31
|
78 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228507
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745804
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745804
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/13 09:14:31
|
66 ms
|
[114253]
|
|
|
228508
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745805
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745805
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/13 09:14:32
|
54 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228509
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745805
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745805
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/13 09:14:32
|
44 ms
|
[114254]
|
|
|
228510
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745806
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745806
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/13 09:14:33
|
97 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228511
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745806
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745806
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/13 09:14:33
|
86 ms
|
[114255]
|
|
|
228512
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745807
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745807
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/13 09:14:34
|
71 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228513
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745807
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745807
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/13 09:14:34
|
62 ms
|
[114256]
|
|
|
228514
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745808
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745808
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/13 09:14:35
|
61 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228515
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745808
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745808
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/13 09:14:35
|
51 ms
|
[114257]
|
|
|
228516
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745809
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745809
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/13 09:14:36
|
71 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228517
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745809
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745809
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/13 09:14:36
|
62 ms
|
[114258]
|
|
|
228518
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745810
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745810
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/13 09:14:37
|
65 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228519
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745810
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745810
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/13 09:14:37
|
56 ms
|
[114259]
|
|
|
228520
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745811
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745811
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/13 09:14:38
|
71 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228521
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745811
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745811
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/13 09:14:38
|
61 ms
|
[114260]
|
|
|
228522
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745812
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745812
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/13 09:14:39
|
60 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228523
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745812
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745812
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/13 09:14:39
|
50 ms
|
[114261]
|
|
|
228524
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745813
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745813
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/13 09:14:40
|
72 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228525
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745813
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745813
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/13 09:14:40
|
62 ms
|
[114262]
|
|
|
228526
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745814
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745814
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/13 09:14:41
|
71 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228527
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745814
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745814
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/13 09:14:41
|
60 ms
|
[114263]
|
|
|
228528
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745815
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745815
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/13 09:14:42
|
81 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228529
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745815
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745815
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/13 09:14:42
|
71 ms
|
[114264]
|
|
|
228530
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745816
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745816
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/13 09:14:43
|
0.1 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228531
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745816
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745816
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/13 09:14:43
|
95 ms
|
[114265]
|
|
|
228532
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745817
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745817
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/13 09:14:44
|
66 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228533
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745817
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745817
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/13 09:14:44
|
57 ms
|
[114266]
|
|
|
228534
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745818
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745818
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/13 09:14:45
|
72 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228535
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745818
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745818
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/13 09:14:45
|
63 ms
|
[114267]
|
|
|
228536
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745819
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745819
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/13 09:14:46
|
55 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228537
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745819
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745819
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/13 09:14:46
|
45 ms
|
[114268]
|
|