|
783380
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789391
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789391
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:40:12
|
51 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
783381
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789391
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789391
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:40:12
|
42 ms
|
[391690]
|
|
|
782710
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789056
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789056
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:34:33
|
52 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
782711
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789056
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789056
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:34:33
|
44 ms
|
[391355]
|
|
|
783128
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789265
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789265
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:38:05
|
52 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
783129
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789265
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789265
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:38:05
|
42 ms
|
[391564]
|
|
|
783544
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789473
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789473
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:41:34
|
52 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
783545
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789473
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789473
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:41:34
|
44 ms
|
[391772]
|
|
|
783686
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789544
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789544
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:42:45
|
52 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
783687
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789544
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789544
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:42:45
|
43 ms
|
[391843]
|
|
|
783016
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789209
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789209
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:37:06
|
53 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
783017
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789209
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789209
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:37:06
|
44 ms
|
[391508]
|
|
|
783186
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789294
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789294
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:38:34
|
53 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
783187
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789294
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789294
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:38:34
|
45 ms
|
[391593]
|
|
|
782724
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789063
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789063
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:34:40
|
54 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
782725
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789063
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789063
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:34:40
|
45 ms
|
[391362]
|
|
|
783072
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789237
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789237
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:37:37
|
54 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
783073
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789237
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789237
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:37:37
|
42 ms
|
[391536]
|
|
|
783264
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789333
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789333
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:39:13
|
54 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
783265
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789333
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789333
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:39:13
|
44 ms
|
[391632]
|
|
|
783366
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789384
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789384
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:40:05
|
54 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
783367
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789384
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789384
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:40:05
|
45 ms
|
[391683]
|
|
|
783586
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789494
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789494
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:41:55
|
54 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
783587
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789494
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789494
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:41:55
|
46 ms
|
[391793]
|
|
|
782706
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789054
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789054
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:34:31
|
55 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
782707
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789054
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789054
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:34:31
|
45 ms
|
[391353]
|
|
|
783324
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789363
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789363
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:39:44
|
55 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
783325
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789363
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789363
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:39:44
|
46 ms
|
[391662]
|
|
|
782944
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789173
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789173
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:36:30
|
56 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
782945
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789173
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789173
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:36:30
|
46 ms
|
[391472]
|
|
|
782966
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789184
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789184
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:36:41
|
56 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
782967
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789184
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789184
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:36:41
|
48 ms
|
[391483]
|
|
|
783206
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789304
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789304
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:38:44
|
56 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
783207
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789304
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789304
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:38:44
|
47 ms
|
[391603]
|
|
|
782734
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789068
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789068
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:34:45
|
57 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
782735
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789068
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789068
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:34:45
|
48 ms
|
[391367]
|
|
|
782832
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789117
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789117
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:35:34
|
57 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
782833
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789117
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789117
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:35:34
|
48 ms
|
[391416]
|
|
|
783110
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789256
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789256
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:37:56
|
57 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
783111
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789256
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789256
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:37:56
|
48 ms
|
[391555]
|
|
|
783222
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789312
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789312
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:38:52
|
57 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
783223
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789312
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789312
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:38:52
|
49 ms
|
[391611]
|
|
|
783252
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789327
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789327
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:39:07
|
57 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
783253
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789327
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789327
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:39:07
|
48 ms
|
[391626]
|
|
|
783328
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789365
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789365
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:39:46
|
57 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
783329
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789365
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789365
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:39:46
|
49 ms
|
[391664]
|
|
|
783368
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789385
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789385
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:40:06
|
57 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
783369
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789385
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789385
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:40:06
|
48 ms
|
[391684]
|
|
|
783446
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789424
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789424
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:40:45
|
57 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
783447
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789424
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789424
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:40:45
|
48 ms
|
[391723]
|
|
|
783528
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789465
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789465
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:41:26
|
57 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
783529
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789465
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789465
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:41:26
|
49 ms
|
[391764]
|
|
|
783530
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789466
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789466
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:41:27
|
57 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
783531
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789466
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789466
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:41:27
|
47 ms
|
[391765]
|
|
|
783620
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789511
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789511
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:42:12
|
57 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
783621
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789511
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789511
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:42:12
|
48 ms
|
[391810]
|
|
|
783656
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789529
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789529
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:42:30
|
57 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
783657
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789529
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789529
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:42:30
|
48 ms
|
[391828]
|
|
|
783658
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789530
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789530
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:42:31
|
57 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
783659
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789530
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789530
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:42:31
|
48 ms
|
[391829]
|
|
|
782712
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789057
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789057
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:34:34
|
58 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
782713
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789057
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789057
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:34:34
|
49 ms
|
[391356]
|
|
|
782728
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789065
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789065
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:34:42
|
58 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
782729
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789065
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789065
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:34:42
|
49 ms
|
[391364]
|
|
|
782784
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789093
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789093
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:35:10
|
58 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
782785
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789093
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789093
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:35:10
|
49 ms
|
[391392]
|
|
|
782790
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789096
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789096
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:35:13
|
58 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
782791
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789096
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789096
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:35:13
|
48 ms
|
[391395]
|
|
|
782816
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789109
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789109
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:35:26
|
58 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
782817
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789109
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789109
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:35:26
|
49 ms
|
[391408]
|
|
|
782820
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789111
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789111
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:35:28
|
58 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
782821
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789111
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789111
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:35:28
|
49 ms
|
[391410]
|
|
|
782840
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789121
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789121
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:35:38
|
58 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
782841
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789121
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789121
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:35:38
|
49 ms
|
[391420]
|
|
|
782880
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789141
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789141
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:35:58
|
58 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
782881
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789141
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789141
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:35:58
|
48 ms
|
[391440]
|
|
|
782980
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789191
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789191
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:36:48
|
58 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
782981
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789191
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789191
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:36:48
|
49 ms
|
[391490]
|
|
|
783000
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789201
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789201
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:36:58
|
58 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
783001
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789201
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789201
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:36:58
|
49 ms
|
[391500]
|
|
|
783134
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789268
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789268
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:38:08
|
58 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
783135
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789268
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789268
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:38:08
|
49 ms
|
[391567]
|
|
|
783294
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789348
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789348
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:39:29
|
58 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
783295
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789348
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789348
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:39:29
|
50 ms
|
[391647]
|
|
|
783362
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789382
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789382
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:40:03
|
58 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
783363
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789382
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789382
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:40:03
|
49 ms
|
[391681]
|
|
|
783426
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789414
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789414
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:40:35
|
58 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
783427
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789414
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789414
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:40:35
|
50 ms
|
[391713]
|
|
|
783480
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789441
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789441
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:41:02
|
58 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
783481
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789441
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789441
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:41:02
|
49 ms
|
[391740]
|
|
|
783502
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789452
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789452
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:41:13
|
58 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
783503
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789452
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789452
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:41:13
|
50 ms
|
[391751]
|
|
|
783522
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789462
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789462
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:41:23
|
58 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
783523
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789462
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789462
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:41:23
|
49 ms
|
[391761]
|
|
|
783560
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789481
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789481
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:41:42
|
58 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
783561
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789481
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789481
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:41:42
|
49 ms
|
[391780]
|
|
|
783632
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789517
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789517
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:42:18
|
58 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
783633
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789517
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789517
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:42:18
|
48 ms
|
[391816]
|
|
|
782756
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789079
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789079
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:34:56
|
59 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
782757
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789079
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789079
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:34:56
|
49 ms
|
[391378]
|
|
|
782778
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789090
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789090
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:35:07
|
59 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
782779
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789090
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789090
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:35:07
|
51 ms
|
[391389]
|
|
|
782828
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789115
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789115
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:35:32
|
59 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
782829
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789115
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789115
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:35:32
|
51 ms
|
[391414]
|
|
|
782852
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789127
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789127
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:35:44
|
59 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
782853
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789127
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789127
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:35:44
|
50 ms
|
[391426]
|
|
|
782860
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789131
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789131
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:35:48
|
59 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
782861
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789131
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789131
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:35:48
|
50 ms
|
[391430]
|
|
|
782886
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789144
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789144
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:36:01
|
59 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
782887
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789144
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789144
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:36:01
|
50 ms
|
[391443]
|
|
|
782894
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789148
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789148
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:36:05
|
59 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
782895
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789148
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789148
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:36:05
|
50 ms
|
[391447]
|
|
|
782946
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789174
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789174
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:36:31
|
59 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
782947
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789174
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789174
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:36:31
|
50 ms
|
[391473]
|
|
|
782956
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789179
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789179
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:36:36
|
59 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
782957
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789179
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789179
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:36:36
|
50 ms
|
[391478]
|
|
|
782972
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789187
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789187
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:36:44
|
59 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
782973
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789187
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789187
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:36:44
|
51 ms
|
[391486]
|
|
|
783006
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789204
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789204
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:37:01
|
59 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
783007
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789204
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789204
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:37:01
|
50 ms
|
[391503]
|
|
|
783020
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789211
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789211
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:37:08
|
59 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
783021
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789211
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789211
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:37:08
|
50 ms
|
[391510]
|
|
|
783022
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789212
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789212
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:37:09
|
59 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
783023
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789212
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789212
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:37:09
|
50 ms
|
[391511]
|
|
|
783052
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789227
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789227
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:37:27
|
59 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
783053
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789227
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789227
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:37:27
|
50 ms
|
[391526]
|
|
|
783074
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789238
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789238
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:37:38
|
59 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
783075
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789238
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789238
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:37:38
|
50 ms
|
[391537]
|
|
|
783082
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789242
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789242
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:37:42
|
59 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
783083
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789242
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789242
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:37:42
|
49 ms
|
[391541]
|
|
|
783112
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789257
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789257
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:37:57
|
59 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
783113
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789257
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789257
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:37:57
|
50 ms
|
[391556]
|
|
|
783126
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789264
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789264
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:38:04
|
59 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
783127
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789264
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789264
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:38:04
|
50 ms
|
[391563]
|
|
|
783142
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789272
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789272
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:38:12
|
59 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
783143
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789272
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789272
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:38:12
|
50 ms
|
[391571]
|
|
|
783144
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789273
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789273
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:38:13
|
59 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
783145
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789273
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789273
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:38:13
|
50 ms
|
[391572]
|
|
|
783146
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789274
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789274
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:38:14
|
59 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
783147
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789274
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789274
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:38:14
|
50 ms
|
[391573]
|
|
|
783192
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789297
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789297
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:38:37
|
59 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
783193
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789297
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789297
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:38:37
|
50 ms
|
[391596]
|
|
|
783198
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789300
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789300
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:38:40
|
59 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
783199
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789300
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789300
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:38:40
|
50 ms
|
[391599]
|
|
|
783200
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789301
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789301
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:38:41
|
59 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
783201
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789301
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789301
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:38:41
|
50 ms
|
[391600]
|
|
|
783202
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789302
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789302
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:38:42
|
59 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
783203
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789302
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789302
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:38:42
|
49 ms
|
[391601]
|
|
|
783208
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789305
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789305
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:38:45
|
59 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
783209
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789305
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789305
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:38:45
|
48 ms
|
[391604]
|
|
|
783224
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789313
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789313
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:38:53
|
59 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
783225
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789313
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789313
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:38:53
|
50 ms
|
[391612]
|
|
|
783238
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789320
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789320
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:39:00
|
59 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
783239
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789320
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789320
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:39:00
|
50 ms
|
[391619]
|
|
|
783348
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789375
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789375
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:39:56
|
59 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
783349
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789375
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789375
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:39:56
|
50 ms
|
[391674]
|
|
|
783354
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789378
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789378
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:39:59
|
59 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
783355
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789378
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789378
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:39:59
|
50 ms
|
[391677]
|
|
|
783408
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789405
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789405
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:40:26
|
59 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
783409
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789405
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789405
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:40:26
|
50 ms
|
[391704]
|
|
|
783462
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789432
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789432
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:40:53
|
59 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
783463
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789432
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789432
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:40:53
|
50 ms
|
[391731]
|
|
|
783498
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789450
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789450
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:41:11
|
59 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
783499
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789450
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789450
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:41:11
|
50 ms
|
[391749]
|
|
|
783596
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789499
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789499
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:42:00
|
59 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
783597
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789499
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789499
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:42:00
|
50 ms
|
[391798]
|
|
|
783602
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789502
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789502
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:42:03
|
59 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
783603
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789502
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789502
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:42:03
|
51 ms
|
[391801]
|
|
|
783678
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789540
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789540
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:42:41
|
59 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
783679
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789540
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789540
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:42:41
|
50 ms
|
[391839]
|
|
|
783688
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789545
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789545
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:42:46
|
59 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
783689
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789545
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789545
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:42:46
|
51 ms
|
[391844]
|
|
|
782726
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789064
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789064
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:34:41
|
60 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
782727
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789064
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789064
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:34:41
|
51 ms
|
[391363]
|
|
|
782732
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789067
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789067
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:34:44
|
60 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
782733
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789067
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789067
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:34:44
|
50 ms
|
[391366]
|
|
|
782754
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789078
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789078
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:34:55
|
60 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
782755
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789078
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789078
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:34:55
|
51 ms
|
[391377]
|
|
|
782758
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789080
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789080
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:34:57
|
60 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
782759
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789080
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789080
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:34:57
|
51 ms
|
[391379]
|
|
|
782764
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789083
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789083
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:35:00
|
60 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
782765
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789083
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789083
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:35:00
|
51 ms
|
[391382]
|
|
|
782772
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789087
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789087
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:35:04
|
60 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
782773
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789087
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789087
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:35:04
|
51 ms
|
[391386]
|
|
|
782774
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789088
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789088
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:35:05
|
60 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
782775
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789088
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789088
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:35:05
|
50 ms
|
[391387]
|
|
|
782776
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789089
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789089
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:35:06
|
60 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
782777
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789089
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789089
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:35:06
|
51 ms
|
[391388]
|
|
|
782780
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789091
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789091
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:35:08
|
60 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
782781
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789091
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789091
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:35:08
|
51 ms
|
[391390]
|
|
|
782786
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789094
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789094
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:35:11
|
60 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
782787
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789094
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789094
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:35:11
|
49 ms
|
[391393]
|
|
|
782818
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789110
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789110
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:35:27
|
60 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
782819
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789110
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789110
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:35:27
|
51 ms
|
[391409]
|
|
|
782884
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789143
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789143
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:36:00
|
60 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
782885
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789143
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789143
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:36:00
|
51 ms
|
[391442]
|
|
|
782888
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789145
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789145
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:36:02
|
60 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
782889
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789145
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789145
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:36:02
|
50 ms
|
[391444]
|
|
|
782920
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789161
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789161
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:36:18
|
60 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
782921
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789161
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5789161
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/06/24 11:36:18
|
52 ms
|
[391460]
|
|