|
653756
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248779
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248779
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:07:24
|
64 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653757
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248779
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248779
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:07:24
|
54 ms
|
[326878]
|
|
|
653758
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248780
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248780
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:07:25
|
61 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653759
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248780
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248780
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:07:25
|
51 ms
|
[326879]
|
|
|
653760
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248781
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248781
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:07:26
|
68 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653761
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248781
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248781
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:07:26
|
57 ms
|
[326880]
|
|
|
653762
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248782
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248782
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:07:27
|
59 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653763
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248782
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248782
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:07:27
|
48 ms
|
[326881]
|
|
|
653764
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248783
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248783
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:07:28
|
91 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653765
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248783
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248783
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:07:28
|
75 ms
|
[326882]
|
|
|
653766
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248784
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248784
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:07:29
|
72 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653767
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248784
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248784
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:07:29
|
61 ms
|
[326883]
|
|
|
653768
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248785
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248785
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:07:30
|
68 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653769
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248785
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248785
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:07:30
|
58 ms
|
[326884]
|
|
|
653770
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248786
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248786
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:07:31
|
70 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653771
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248786
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248786
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:07:31
|
60 ms
|
[326885]
|
|
|
653772
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248787
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248787
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:07:32
|
58 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653773
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248787
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248787
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:07:32
|
49 ms
|
[326886]
|
|
|
653774
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248788
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248788
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:07:33
|
85 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653775
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248788
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248788
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:07:33
|
75 ms
|
[326887]
|
|
|
653776
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248789
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248789
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:07:34
|
70 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653777
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248789
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248789
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:07:34
|
58 ms
|
[326888]
|
|
|
653778
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248790
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248790
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:07:35
|
67 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653779
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248790
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248790
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:07:35
|
58 ms
|
[326889]
|
|
|
653780
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248791
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248791
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:07:36
|
77 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653781
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248791
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248791
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:07:36
|
68 ms
|
[326890]
|
|
|
653782
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248792
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248792
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:07:37
|
63 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653783
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248792
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248792
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:07:37
|
53 ms
|
[326891]
|
|
|
653784
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248793
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248793
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:07:38
|
69 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653785
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248793
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248793
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:07:38
|
60 ms
|
[326892]
|
|
|
653786
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248794
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248794
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:07:39
|
59 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653787
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248794
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248794
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:07:39
|
50 ms
|
[326893]
|
|
|
653788
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248795
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248795
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:07:40
|
64 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653789
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248795
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248795
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:07:40
|
54 ms
|
[326894]
|
|
|
653790
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248796
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248796
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:07:41
|
98 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653791
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248796
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248796
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:07:41
|
86 ms
|
[326895]
|
|
|
653792
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248797
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248797
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:07:42
|
73 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653793
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248797
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248797
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:07:42
|
64 ms
|
[326896]
|
|
|
653794
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248798
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248798
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:07:43
|
0.1 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653795
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248798
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248798
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:07:43
|
97 ms
|
[326897]
|
|
|
653796
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248799
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248799
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:07:44
|
66 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653797
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248799
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248799
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:07:44
|
57 ms
|
[326898]
|
|
|
653798
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248800
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248800
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:07:45
|
68 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653799
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248800
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248800
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:07:45
|
58 ms
|
[326899]
|
|
|
653800
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248801
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248801
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:07:46
|
66 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653801
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248801
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248801
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:07:46
|
56 ms
|
[326900]
|
|
|
653802
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248802
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248802
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:07:47
|
84 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653803
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248802
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248802
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:07:47
|
74 ms
|
[326901]
|
|
|
653804
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248803
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248803
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:07:48
|
84 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653805
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248803
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248803
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:07:48
|
74 ms
|
[326902]
|
|
|
653806
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248804
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248804
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:07:49
|
68 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653807
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248804
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248804
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:07:49
|
58 ms
|
[326903]
|
|
|
653808
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248805
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248805
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:07:50
|
73 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653809
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248805
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248805
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:07:50
|
64 ms
|
[326904]
|
|
|
653810
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248806
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248806
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:07:51
|
71 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653811
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248806
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248806
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:07:51
|
59 ms
|
[326905]
|
|
|
653812
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248807
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248807
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:07:52
|
58 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653813
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248807
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248807
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:07:52
|
47 ms
|
[326906]
|
|
|
653814
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248808
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248808
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:07:53
|
80 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653815
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248808
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248808
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:07:53
|
70 ms
|
[326907]
|
|
|
653816
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248809
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248809
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:07:54
|
83 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653817
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248809
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248809
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:07:54
|
74 ms
|
[326908]
|
|
|
653818
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248810
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248810
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:07:55
|
55 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653819
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248810
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248810
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:07:55
|
44 ms
|
[326909]
|
|
|
653820
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248811
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248811
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:07:56
|
74 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653821
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248811
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248811
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:07:56
|
65 ms
|
[326910]
|
|
|
653822
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248812
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248812
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:07:57
|
55 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653823
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248812
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248812
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:07:57
|
46 ms
|
[326911]
|
|
|
653824
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248813
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248813
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:07:58
|
68 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653825
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248813
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248813
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:07:58
|
58 ms
|
[326912]
|
|
|
653826
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248814
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248814
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:07:59
|
83 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653827
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248814
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248814
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:07:59
|
72 ms
|
[326913]
|
|
|
653828
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248815
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248815
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:00
|
87 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653829
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248815
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248815
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:00
|
77 ms
|
[326914]
|
|
|
653830
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248816
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248816
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:01
|
60 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653831
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248816
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248816
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:01
|
50 ms
|
[326915]
|
|
|
653832
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248817
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248817
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:02
|
59 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653833
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248817
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248817
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:02
|
48 ms
|
[326916]
|
|
|
653834
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248818
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248818
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:03
|
85 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653835
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248818
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248818
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:03
|
76 ms
|
[326917]
|
|
|
653836
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248819
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248819
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:04
|
62 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653837
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248819
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248819
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:04
|
52 ms
|
[326918]
|
|
|
653838
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248820
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248820
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:05
|
56 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653839
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248820
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248820
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:05
|
45 ms
|
[326919]
|
|
|
653840
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248821
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248821
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:06
|
88 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653841
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248821
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248821
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:06
|
78 ms
|
[326920]
|
|
|
653842
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248822
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248822
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:07
|
70 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653843
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248822
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248822
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:07
|
60 ms
|
[326921]
|
|
|
653844
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248823
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248823
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:08
|
82 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653845
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248823
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248823
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:08
|
72 ms
|
[326922]
|
|
|
653846
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248824
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248824
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:09
|
75 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653847
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248824
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248824
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:09
|
65 ms
|
[326923]
|
|
|
653848
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248825
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248825
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:10
|
68 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653849
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248825
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248825
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:10
|
58 ms
|
[326924]
|
|
|
653850
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248826
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248826
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:11
|
60 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653851
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248826
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248826
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:11
|
51 ms
|
[326925]
|
|
|
653852
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248827
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248827
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:12
|
79 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653853
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248827
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248827
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:12
|
69 ms
|
[326926]
|
|
|
653854
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248828
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248828
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:13
|
80 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653855
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248828
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248828
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:13
|
70 ms
|
[326927]
|
|
|
653856
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248829
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248829
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:14
|
0.1 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653857
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248829
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248829
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:14
|
0.1 s
|
[326928]
|
|
|
653858
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248830
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248830
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:15
|
80 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653859
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248830
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248830
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:15
|
70 ms
|
[326929]
|
|
|
653860
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248831
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248831
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:16
|
69 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653861
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248831
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248831
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:16
|
58 ms
|
[326930]
|
|
|
653862
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248832
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248832
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:17
|
95 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653863
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248832
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248832
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:17
|
66 ms
|
[326931]
|
|
|
653864
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248833
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248833
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:18
|
69 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653865
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248833
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248833
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:18
|
59 ms
|
[326932]
|
|
|
653866
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248834
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248834
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:19
|
61 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653867
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248834
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248834
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:19
|
52 ms
|
[326933]
|
|
|
653868
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248835
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248835
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:20
|
59 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653869
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248835
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248835
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:20
|
49 ms
|
[326934]
|
|
|
653870
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248836
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248836
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:21
|
0.1 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653871
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248836
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248836
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:21
|
0.1 s
|
[326935]
|
|
|
653872
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248837
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248837
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:22
|
69 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653873
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248837
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248837
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:22
|
58 ms
|
[326936]
|
|
|
653874
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248838
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248838
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:23
|
79 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653875
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248838
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248838
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:23
|
68 ms
|
[326937]
|
|
|
653876
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248839
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248839
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:24
|
63 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653877
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248839
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248839
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:24
|
53 ms
|
[326938]
|
|
|
653878
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248840
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248840
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:25
|
58 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653879
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248840
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248840
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:25
|
47 ms
|
[326939]
|
|
|
653880
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248841
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248841
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:26
|
53 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653881
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248841
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248841
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:26
|
43 ms
|
[326940]
|
|
|
653882
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248842
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248842
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:27
|
68 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653883
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248842
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248842
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:27
|
59 ms
|
[326941]
|
|
|
653884
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248843
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248843
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:28
|
92 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653885
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248843
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248843
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:28
|
83 ms
|
[326942]
|
|
|
653886
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248844
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248844
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:29
|
91 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653887
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248844
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248844
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:29
|
81 ms
|
[326943]
|
|
|
653888
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248845
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248845
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:31
|
66 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653889
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248845
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248845
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:31
|
56 ms
|
[326944]
|
|
|
653890
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248846
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248846
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:32
|
65 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653891
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248846
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248846
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:32
|
56 ms
|
[326945]
|
|
|
653892
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248847
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248847
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:33
|
92 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653893
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248847
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248847
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:33
|
80 ms
|
[326946]
|
|
|
653894
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248848
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248848
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:34
|
62 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653895
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248848
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248848
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:34
|
53 ms
|
[326947]
|
|
|
653896
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248849
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248849
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:36
|
64 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653897
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248849
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248849
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:36
|
54 ms
|
[326948]
|
|
|
653898
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248850
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248850
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:37
|
80 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653899
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248850
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248850
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:37
|
70 ms
|
[326949]
|
|
|
653900
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248851
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248851
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:38
|
91 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653901
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248851
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248851
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:38
|
74 ms
|
[326950]
|
|
|
653902
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248852
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248852
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:39
|
69 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653903
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248852
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248852
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:39
|
60 ms
|
[326951]
|
|
|
653904
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248853
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248853
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:40
|
61 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653905
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248853
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248853
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:40
|
50 ms
|
[326952]
|
|
|
653906
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248854
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248854
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:41
|
54 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653907
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248854
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248854
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:41
|
44 ms
|
[326953]
|
|
|
653908
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248855
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248855
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:42
|
73 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653909
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248855
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248855
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:42
|
64 ms
|
[326954]
|
|
|
653910
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248856
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248856
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:43
|
82 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653911
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248856
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248856
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:43
|
72 ms
|
[326955]
|
|
|
653912
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248857
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248857
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:44
|
0.1 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653913
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248857
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248857
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:44
|
0.1 s
|
[326956]
|
|
|
653914
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248858
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248858
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:45
|
63 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653915
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248858
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248858
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:45
|
53 ms
|
[326957]
|
|
|
653916
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248859
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248859
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:46
|
69 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653917
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248859
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248859
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:46
|
59 ms
|
[326958]
|
|
|
653918
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248860
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248860
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:47
|
76 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653919
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248860
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248860
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:47
|
66 ms
|
[326959]
|
|
|
653920
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248861
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248861
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:48
|
81 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653921
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248861
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248861
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:48
|
72 ms
|
[326960]
|
|
|
653922
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248862
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248862
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:49
|
65 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653923
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248862
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248862
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:49
|
56 ms
|
[326961]
|
|
|
653924
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248863
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248863
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:50
|
0.1 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653925
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248863
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248863
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:50
|
0.1 s
|
[326962]
|
|
|
653926
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248864
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248864
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:51
|
0.1 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653927
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248864
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248864
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:51
|
0.1 s
|
[326963]
|
|
|
653928
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248865
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248865
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:52
|
83 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653929
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248865
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248865
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:52
|
74 ms
|
[326964]
|
|
|
653930
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248866
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248866
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:53
|
65 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653931
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248866
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248866
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:53
|
55 ms
|
[326965]
|
|
|
653932
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248867
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248867
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:54
|
62 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653933
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248867
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248867
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:54
|
52 ms
|
[326966]
|
|
|
653934
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248868
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248868
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:55
|
61 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653935
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248868
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248868
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:55
|
51 ms
|
[326967]
|
|
|
653936
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248869
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248869
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:56
|
58 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653937
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248869
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248869
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:56
|
48 ms
|
[326968]
|
|
|
653938
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248870
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248870
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:57
|
0.1 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653939
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248870
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248870
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:57
|
94 ms
|
[326969]
|
|
|
653940
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248871
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248871
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:58
|
73 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653941
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248871
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248871
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:58
|
59 ms
|
[326970]
|
|
|
653942
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248872
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248872
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:59
|
97 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653943
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248872
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248872
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:08:59
|
88 ms
|
[326971]
|
|
|
653944
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248873
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248873
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:09:00
|
77 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653945
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248873
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248873
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:09:00
|
66 ms
|
[326972]
|
|
|
653946
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248874
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248874
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:09:01
|
76 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653947
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248874
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248874
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:09:01
|
66 ms
|
[326973]
|
|
|
653948
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248875
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248875
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:09:02
|
73 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653949
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248875
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248875
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:09:02
|
57 ms
|
[326974]
|
|
|
653950
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248876
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248876
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:09:03
|
0.1 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653951
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248876
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248876
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:09:03
|
0.1 s
|
[326975]
|
|
|
653952
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248877
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248877
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:09:04
|
75 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653953
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248877
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248877
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:09:04
|
64 ms
|
[326976]
|
|
|
653954
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248878
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248878
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:09:05
|
55 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653955
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248878
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248878
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/05/09 20:09:05
|
45 ms
|
[326977]
|
|