|
653072
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248437
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248437
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:01:29
|
67 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653073
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248437
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248437
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:01:29
|
58 ms
|
[326536]
|
|
|
653074
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248438
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248438
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:01:30
|
80 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653075
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248438
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248438
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:01:30
|
70 ms
|
[326537]
|
|
|
653076
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248439
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248439
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:01:31
|
0.1 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653077
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248439
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248439
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:01:31
|
95 ms
|
[326538]
|
|
|
653078
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248440
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248440
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:01:32
|
77 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653079
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248440
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248440
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:01:32
|
66 ms
|
[326539]
|
|
|
653080
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248441
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248441
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:01:33
|
65 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653081
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248441
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248441
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:01:33
|
53 ms
|
[326540]
|
|
|
653082
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248442
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248442
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:01:34
|
56 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653083
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248442
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248442
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:01:34
|
47 ms
|
[326541]
|
|
|
653084
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248443
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248443
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:01:35
|
70 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653085
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248443
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248443
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:01:35
|
60 ms
|
[326542]
|
|
|
653086
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248444
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248444
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:01:36
|
72 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653087
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248444
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248444
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:01:36
|
62 ms
|
[326543]
|
|
|
653088
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248445
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248445
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:01:37
|
78 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653089
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248445
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248445
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:01:37
|
67 ms
|
[326544]
|
|
|
653090
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248446
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248446
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:01:38
|
79 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653091
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248446
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248446
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:01:38
|
68 ms
|
[326545]
|
|
|
653092
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248447
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248447
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:01:39
|
53 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653093
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248447
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248447
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:01:39
|
44 ms
|
[326546]
|
|
|
653094
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248448
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248448
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:01:40
|
64 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653095
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248448
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248448
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:01:40
|
52 ms
|
[326547]
|
|
|
653096
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248449
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248449
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:01:41
|
61 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653097
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248449
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248449
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:01:41
|
52 ms
|
[326548]
|
|
|
653098
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248450
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248450
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:01:42
|
72 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653099
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248450
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248450
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:01:42
|
61 ms
|
[326549]
|
|
|
653100
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248451
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248451
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:01:43
|
68 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653101
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248451
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248451
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:01:43
|
55 ms
|
[326550]
|
|
|
653102
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248452
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248452
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:01:44
|
70 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653103
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248452
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248452
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:01:44
|
59 ms
|
[326551]
|
|
|
653104
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248453
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248453
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:01:45
|
99 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653105
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248453
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248453
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:01:45
|
90 ms
|
[326552]
|
|
|
653106
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248454
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248454
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:01:46
|
83 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653107
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248454
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248454
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:01:46
|
73 ms
|
[326553]
|
|
|
653108
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248455
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248455
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:01:47
|
75 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653109
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248455
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248455
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:01:47
|
65 ms
|
[326554]
|
|
|
653110
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248456
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248456
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:01:48
|
75 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653111
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248456
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248456
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:01:48
|
61 ms
|
[326555]
|
|
|
653112
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248457
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248457
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:01:49
|
67 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653113
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248457
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248457
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:01:49
|
58 ms
|
[326556]
|
|
|
653114
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248458
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248458
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:01:50
|
69 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653115
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248458
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248458
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:01:50
|
58 ms
|
[326557]
|
|
|
653116
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248459
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248459
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:01:51
|
82 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653117
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248459
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248459
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:01:51
|
59 ms
|
[326558]
|
|
|
653118
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248460
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248460
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:01:52
|
66 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653119
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248460
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248460
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:01:52
|
57 ms
|
[326559]
|
|
|
653120
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248461
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248461
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:01:53
|
66 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653121
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248461
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248461
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:01:53
|
54 ms
|
[326560]
|
|
|
653122
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248462
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248462
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:01:54
|
67 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653123
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248462
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248462
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:01:54
|
56 ms
|
[326561]
|
|
|
653124
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248463
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248463
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:01:55
|
68 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653125
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248463
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248463
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:01:55
|
58 ms
|
[326562]
|
|
|
653126
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248464
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248464
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:01:56
|
68 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653127
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248464
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248464
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:01:56
|
59 ms
|
[326563]
|
|
|
653128
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248465
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248465
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:01:57
|
59 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653129
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248465
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248465
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:01:57
|
50 ms
|
[326564]
|
|
|
653130
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248466
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248466
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:01:58
|
91 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653131
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248466
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248466
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:01:58
|
79 ms
|
[326565]
|
|
|
653132
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248467
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248467
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:01:59
|
75 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653133
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248467
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248467
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:01:59
|
66 ms
|
[326566]
|
|
|
653134
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248468
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248468
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:00
|
76 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653135
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248468
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248468
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:00
|
66 ms
|
[326567]
|
|
|
653136
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248469
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248469
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:01
|
59 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653137
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248469
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248469
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:01
|
49 ms
|
[326568]
|
|
|
653138
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248470
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248470
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:02
|
57 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653139
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248470
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248470
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:02
|
47 ms
|
[326569]
|
|
|
653140
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248471
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248471
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:03
|
65 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653141
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248471
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248471
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:03
|
55 ms
|
[326570]
|
|
|
653142
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248472
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248472
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:04
|
0.1 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653143
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248472
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248472
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:04
|
0.1 s
|
[326571]
|
|
|
653144
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248473
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248473
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:06
|
71 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653145
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248473
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248473
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:06
|
61 ms
|
[326572]
|
|
|
653146
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248474
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248474
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:07
|
58 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653147
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248474
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248474
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:07
|
49 ms
|
[326573]
|
|
|
653148
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248475
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248475
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:08
|
97 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653149
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248475
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248475
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:08
|
84 ms
|
[326574]
|
|
|
653150
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248476
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248476
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:09
|
74 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653151
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248476
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248476
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:09
|
64 ms
|
[326575]
|
|
|
653152
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248477
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248477
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:10
|
57 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653153
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248477
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248477
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:10
|
48 ms
|
[326576]
|
|
|
653154
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248478
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248478
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:11
|
72 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653155
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248478
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248478
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:11
|
62 ms
|
[326577]
|
|
|
653156
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248479
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248479
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:12
|
98 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653157
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248479
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248479
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:12
|
88 ms
|
[326578]
|
|
|
653158
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248480
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248480
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:13
|
0.1 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653159
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248480
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248480
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:13
|
0.1 s
|
[326579]
|
|
|
653160
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248481
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248481
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:14
|
83 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653161
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248481
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248481
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:14
|
70 ms
|
[326580]
|
|
|
653162
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248482
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248482
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:15
|
80 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653163
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248482
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248482
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:15
|
70 ms
|
[326581]
|
|
|
653164
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248483
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248483
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:16
|
72 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653165
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248483
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248483
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:16
|
62 ms
|
[326582]
|
|
|
653166
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248484
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248484
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:17
|
86 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653167
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248484
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248484
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:17
|
75 ms
|
[326583]
|
|
|
653168
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248485
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248485
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:18
|
81 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653169
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248485
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248485
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:18
|
69 ms
|
[326584]
|
|
|
653170
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248486
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248486
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:19
|
70 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653171
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248486
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248486
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:19
|
61 ms
|
[326585]
|
|
|
653172
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248487
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248487
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:20
|
62 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653173
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248487
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248487
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:20
|
51 ms
|
[326586]
|
|
|
653174
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248488
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248488
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:21
|
73 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653175
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248488
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248488
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:21
|
64 ms
|
[326587]
|
|
|
653176
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248489
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248489
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:22
|
64 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653177
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248489
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248489
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:22
|
55 ms
|
[326588]
|
|
|
653178
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248490
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248490
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:23
|
89 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653179
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248490
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248490
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:23
|
77 ms
|
[326589]
|
|
|
653180
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248491
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248491
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:24
|
68 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653181
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248491
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248491
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:24
|
59 ms
|
[326590]
|
|
|
653182
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248492
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248492
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:25
|
64 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653183
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248492
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248492
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:25
|
53 ms
|
[326591]
|
|
|
653184
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248493
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248493
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:26
|
56 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653185
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248493
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248493
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:26
|
47 ms
|
[326592]
|
|
|
653186
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248494
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248494
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:27
|
91 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653187
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248494
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248494
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:27
|
69 ms
|
[326593]
|
|
|
653188
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248495
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248495
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:28
|
0.1 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653189
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248495
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248495
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:28
|
0.1 s
|
[326594]
|
|
|
653190
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248496
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248496
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:29
|
83 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653191
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248496
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248496
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:29
|
67 ms
|
[326595]
|
|
|
653192
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248497
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248497
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:31
|
83 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653193
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248497
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248497
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:31
|
74 ms
|
[326596]
|
|
|
653194
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248498
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248498
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:32
|
62 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653195
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248498
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248498
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:32
|
52 ms
|
[326597]
|
|
|
653196
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248499
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248499
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:33
|
77 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653197
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248499
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248499
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:33
|
68 ms
|
[326598]
|
|
|
653198
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248500
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248500
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:34
|
86 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653199
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248500
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248500
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:34
|
74 ms
|
[326599]
|
|
|
653200
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248501
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248501
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:35
|
57 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653201
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248501
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248501
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:35
|
48 ms
|
[326600]
|
|
|
653202
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248502
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248502
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:36
|
66 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653203
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248502
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248502
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:36
|
57 ms
|
[326601]
|
|
|
653204
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248503
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248503
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:37
|
64 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653205
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248503
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248503
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:37
|
55 ms
|
[326602]
|
|
|
653206
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248504
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248504
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:38
|
81 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653207
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248504
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248504
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:38
|
69 ms
|
[326603]
|
|
|
653208
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248505
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248505
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:39
|
64 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653209
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248505
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248505
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:39
|
54 ms
|
[326604]
|
|
|
653210
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248506
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248506
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:40
|
61 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653211
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248506
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248506
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:40
|
50 ms
|
[326605]
|
|
|
653212
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248507
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248507
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:41
|
98 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653213
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248507
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248507
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:41
|
75 ms
|
[326606]
|
|
|
653214
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248508
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248508
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:42
|
72 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653215
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248508
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248508
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:42
|
63 ms
|
[326607]
|
|
|
653216
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248509
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248509
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:43
|
88 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653217
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248509
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248509
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:43
|
76 ms
|
[326608]
|
|
|
653218
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248510
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248510
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:44
|
83 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653219
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248510
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248510
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:44
|
72 ms
|
[326609]
|
|
|
653220
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248511
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248511
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:45
|
88 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653221
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248511
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248511
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:45
|
72 ms
|
[326610]
|
|
|
653222
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248512
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248512
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:46
|
75 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653223
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248512
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248512
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:46
|
64 ms
|
[326611]
|
|
|
653224
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248513
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248513
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:47
|
96 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653225
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248513
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248513
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:47
|
71 ms
|
[326612]
|
|
|
653226
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248514
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248514
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:48
|
67 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653227
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248514
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248514
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:48
|
57 ms
|
[326613]
|
|
|
653228
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248515
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248515
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:49
|
73 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653229
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248515
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248515
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:49
|
62 ms
|
[326614]
|
|
|
653230
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248516
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248516
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:50
|
66 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653231
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248516
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248516
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:50
|
53 ms
|
[326615]
|
|
|
653232
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248517
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248517
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:51
|
64 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653233
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248517
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248517
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:51
|
55 ms
|
[326616]
|
|
|
653234
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248518
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248518
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:52
|
62 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653235
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248518
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248518
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:52
|
53 ms
|
[326617]
|
|
|
653236
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248519
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248519
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:53
|
0.1 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653237
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248519
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248519
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:53
|
84 ms
|
[326618]
|
|
|
653238
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248520
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248520
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:55
|
67 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653239
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248520
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248520
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:55
|
57 ms
|
[326619]
|
|
|
653240
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248521
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248521
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:56
|
0.2 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653241
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248521
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248521
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:56
|
0.2 s
|
[326620]
|
|
|
653242
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248522
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248522
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:57
|
76 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653243
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248522
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248522
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:57
|
66 ms
|
[326621]
|
|
|
653244
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248523
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248523
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:58
|
74 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653245
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248523
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248523
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:58
|
61 ms
|
[326622]
|
|
|
653246
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248524
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248524
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:59
|
89 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653247
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248524
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248524
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:02:59
|
78 ms
|
[326623]
|
|
|
653248
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248525
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248525
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:03:00
|
81 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653249
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248525
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248525
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:03:00
|
57 ms
|
[326624]
|
|
|
653250
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248526
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248526
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:03:01
|
60 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653251
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248526
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248526
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:03:01
|
50 ms
|
[326625]
|
|
|
653252
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248527
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248527
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:03:02
|
61 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653253
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248527
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248527
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:03:02
|
51 ms
|
[326626]
|
|
|
653254
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248528
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248528
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:03:03
|
67 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653255
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248528
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248528
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:03:03
|
49 ms
|
[326627]
|
|
|
653256
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248529
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248529
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:03:04
|
66 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653257
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248529
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248529
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:03:04
|
56 ms
|
[326628]
|
|
|
653258
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248530
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248530
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:03:05
|
80 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653259
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248530
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248530
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:03:05
|
71 ms
|
[326629]
|
|
|
653260
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248531
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248531
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:03:06
|
87 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653261
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248531
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248531
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:03:06
|
78 ms
|
[326630]
|
|
|
653262
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248532
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248532
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:03:07
|
89 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653263
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248532
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248532
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:03:07
|
79 ms
|
[326631]
|
|
|
653264
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248533
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248533
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:03:08
|
77 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653265
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248533
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248533
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:03:08
|
68 ms
|
[326632]
|
|
|
653266
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248534
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248534
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:03:09
|
68 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653267
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248534
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248534
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:03:09
|
59 ms
|
[326633]
|
|
|
653268
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248535
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248535
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:03:10
|
90 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653269
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248535
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248535
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:03:10
|
79 ms
|
[326634]
|
|
|
653270
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248536
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248536
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:03:11
|
94 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
653271
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248536
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4248536
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.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:03:11
|
84 ms
|
[326635]
|
|