|
228500
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745801
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745801
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:14:28
|
52 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228501
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745801
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745801
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:14:28
|
43 ms
|
[114250]
|
|
|
228764
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745933
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745933
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:16:42
|
52 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228765
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745933
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745933
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:16:42
|
42 ms
|
[114382]
|
|
|
228824
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745963
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745963
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:17:12
|
52 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228825
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745963
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745963
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:17:12
|
44 ms
|
[114412]
|
|
|
229030
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746066
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746066
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:18:56
|
52 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
229031
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746066
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746066
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:18:56
|
43 ms
|
[114515]
|
|
|
228640
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745871
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745871
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:15:38
|
53 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228641
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745871
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745871
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:15:38
|
44 ms
|
[114320]
|
|
|
228836
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745969
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745969
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:17:19
|
53 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228837
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745969
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745969
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:17:19
|
45 ms
|
[114418]
|
|
|
228886
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745994
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745994
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:17:44
|
53 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228887
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745994
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745994
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:17:44
|
44 ms
|
[114443]
|
|
|
229006
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746054
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746054
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:18:44
|
53 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
229007
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746054
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746054
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:18:44
|
44 ms
|
[114503]
|
|
|
228508
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745805
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745805
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:14:32
|
54 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228509
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745805
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745805
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:14:32
|
44 ms
|
[114254]
|
|
|
228672
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745887
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745887
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:15:56
|
54 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228673
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745887
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745887
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:15:56
|
45 ms
|
[114336]
|
|
|
229274
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746188
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746188
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:20:59
|
54 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
229275
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746188
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746188
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:20:59
|
44 ms
|
[114637]
|
|
|
229318
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746210
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746210
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:21:21
|
54 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
229319
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746210
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746210
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:21:21
|
46 ms
|
[114659]
|
|
|
228338
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745720
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745720
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:13:06
|
55 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228339
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745720
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745720
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:13:06
|
46 ms
|
[114169]
|
|
|
228378
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745740
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745740
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:13:26
|
55 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228379
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745740
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745740
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:13:26
|
45 ms
|
[114189]
|
|
|
228474
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745788
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745788
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:14:14
|
55 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228475
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745788
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745788
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:14:14
|
46 ms
|
[114237]
|
|
|
228536
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745819
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745819
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:14:46
|
55 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228537
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745819
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745819
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:14:46
|
45 ms
|
[114268]
|
|
|
228556
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745829
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745829
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:14:56
|
55 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228557
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745829
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745829
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:14:56
|
46 ms
|
[114278]
|
|
|
228576
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745839
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745839
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:15:06
|
55 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228577
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745839
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745839
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:15:06
|
45 ms
|
[114288]
|
|
|
228780
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745941
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745941
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:16:50
|
55 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228781
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745941
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745941
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:16:50
|
46 ms
|
[114390]
|
|
|
229060
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746081
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746081
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:19:11
|
55 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
229061
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746081
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746081
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:19:11
|
46 ms
|
[114530]
|
|
|
229248
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746175
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746175
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:20:46
|
55 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
229249
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746175
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746175
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:20:46
|
46 ms
|
[114624]
|
|
|
228394
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745748
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745748
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:13:34
|
56 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228395
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745748
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745748
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:13:34
|
47 ms
|
[114197]
|
|
|
228728
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745915
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745915
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:16:24
|
56 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228729
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745915
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745915
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:16:24
|
47 ms
|
[114364]
|
|
|
228798
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745950
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745950
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:16:59
|
56 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228799
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745950
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745950
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:16:59
|
45 ms
|
[114399]
|
|
|
228916
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746009
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746009
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:17:59
|
56 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228917
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746009
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746009
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:17:59
|
47 ms
|
[114458]
|
|
|
229078
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746090
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746090
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:19:20
|
56 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
229079
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746090
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746090
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:19:20
|
47 ms
|
[114539]
|
|
|
229092
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746097
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746097
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:19:27
|
56 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
229093
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746097
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746097
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:19:27
|
47 ms
|
[114546]
|
|
|
229142
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746122
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746122
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:19:52
|
56 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
229143
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746122
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746122
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:19:52
|
47 ms
|
[114571]
|
|
|
229234
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746168
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746168
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:20:38
|
56 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
229235
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746168
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746168
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:20:38
|
43 ms
|
[114617]
|
|
|
228436
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745769
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745769
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:13:55
|
57 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228437
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745769
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745769
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:13:55
|
48 ms
|
[114218]
|
|
|
228582
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745842
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745842
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:15:09
|
57 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228583
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745842
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745842
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:15:09
|
48 ms
|
[114291]
|
|
|
228612
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745857
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745857
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:15:24
|
57 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228613
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745857
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745857
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:15:24
|
47 ms
|
[114306]
|
|
|
228792
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745947
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745947
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:16:56
|
57 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228793
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745947
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745947
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:16:56
|
47 ms
|
[114396]
|
|
|
228862
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745982
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745982
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:17:32
|
57 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228863
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745982
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745982
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:17:32
|
48 ms
|
[114431]
|
|
|
229108
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746105
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746105
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:19:35
|
57 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
229109
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746105
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746105
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:19:35
|
48 ms
|
[114554]
|
|
|
229130
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746116
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746116
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:19:46
|
57 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
229131
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746116
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746116
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:19:46
|
48 ms
|
[114565]
|
|
|
229200
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746151
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746151
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:20:21
|
57 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
229201
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746151
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746151
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:20:21
|
48 ms
|
[114600]
|
|
|
229202
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746152
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746152
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:20:22
|
57 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
229203
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746152
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746152
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:20:22
|
46 ms
|
[114601]
|
|
|
229252
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746177
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746177
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:20:48
|
57 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
229253
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746177
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746177
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:20:48
|
49 ms
|
[114626]
|
|
|
229260
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746181
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746181
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:20:52
|
57 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
229261
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746181
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746181
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:20:52
|
47 ms
|
[114630]
|
|
|
228636
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745869
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745869
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:15:36
|
58 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228637
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745869
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745869
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:15:36
|
49 ms
|
[114318]
|
|
|
228734
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745918
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745918
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:16:27
|
58 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228735
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745918
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745918
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:16:27
|
47 ms
|
[114367]
|
|
|
228748
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745925
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745925
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:16:34
|
58 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228749
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745925
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745925
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:16:34
|
48 ms
|
[114374]
|
|
|
228854
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745978
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745978
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:17:28
|
58 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228855
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745978
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745978
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:17:28
|
48 ms
|
[114427]
|
|
|
228870
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745986
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745986
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:17:36
|
58 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228871
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745986
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745986
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:17:36
|
49 ms
|
[114435]
|
|
|
229010
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746056
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746056
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:18:46
|
58 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
229011
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746056
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746056
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:18:46
|
48 ms
|
[114505]
|
|
|
229148
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746125
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746125
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:19:55
|
58 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
229149
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746125
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746125
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:19:55
|
49 ms
|
[114574]
|
|
|
229220
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746161
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746161
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:20:31
|
58 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
229221
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746161
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746161
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:20:31
|
49 ms
|
[114610]
|
|
|
229304
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746203
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746203
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:21:14
|
58 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
229305
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746203
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746203
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:21:14
|
50 ms
|
[114652]
|
|
|
229324
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746213
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746213
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:21:24
|
58 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
229325
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746213
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746213
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:21:24
|
48 ms
|
[114662]
|
|
|
228354
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745728
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745728
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:13:14
|
59 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228355
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745728
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745728
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:13:14
|
48 ms
|
[114177]
|
|
|
228366
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745734
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745734
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:13:20
|
59 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228367
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745734
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745734
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:13:20
|
49 ms
|
[114183]
|
|
|
228382
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745742
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745742
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:13:28
|
59 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228383
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745742
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745742
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:13:28
|
49 ms
|
[114191]
|
|
|
228450
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745776
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745776
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:14:02
|
59 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228451
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745776
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745776
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:14:02
|
49 ms
|
[114225]
|
|
|
228540
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745821
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745821
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:14:48
|
59 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228541
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745821
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745821
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:14:48
|
50 ms
|
[114270]
|
|
|
228826
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745964
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745964
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:17:13
|
59 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228827
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745964
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745964
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:17:13
|
50 ms
|
[114413]
|
|
|
229036
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746069
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746069
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:18:59
|
59 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
229037
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746069
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746069
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:18:59
|
48 ms
|
[114518]
|
|
|
229066
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746084
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746084
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:19:14
|
59 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
229067
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746084
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746084
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:19:14
|
50 ms
|
[114533]
|
|
|
229094
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746098
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746098
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:19:28
|
59 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
229095
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746098
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746098
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:19:28
|
48 ms
|
[114547]
|
|
|
229190
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746146
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746146
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:20:16
|
59 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
229191
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746146
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746146
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:20:16
|
50 ms
|
[114595]
|
|
|
228386
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745744
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745744
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:13:30
|
60 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228387
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745744
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745744
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:13:30
|
50 ms
|
[114193]
|
|
|
228430
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745766
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745766
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:13:52
|
60 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228431
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745766
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745766
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:13:52
|
50 ms
|
[114215]
|
|
|
228522
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745812
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745812
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:14:39
|
60 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228523
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745812
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745812
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:14:39
|
50 ms
|
[114261]
|
|
|
228642
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745872
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745872
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:15:39
|
60 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228643
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745872
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745872
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:15:39
|
51 ms
|
[114321]
|
|
|
228756
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745929
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745929
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:16:38
|
60 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228757
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745929
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745929
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:16:38
|
50 ms
|
[114378]
|
|
|
228838
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745970
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745970
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:17:20
|
60 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228839
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745970
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745970
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:17:20
|
51 ms
|
[114419]
|
|
|
228850
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745976
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745976
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:17:26
|
60 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228851
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745976
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745976
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:17:26
|
50 ms
|
[114425]
|
|
|
228872
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745987
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745987
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:17:37
|
60 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228873
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745987
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745987
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:17:37
|
51 ms
|
[114436]
|
|
|
228978
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746040
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746040
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:18:30
|
60 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228979
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746040
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746040
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:18:30
|
51 ms
|
[114489]
|
|
|
228994
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746048
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746048
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:18:38
|
60 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228995
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746048
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746048
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:18:38
|
51 ms
|
[114497]
|
|
|
229136
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746119
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746119
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:19:49
|
60 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
229137
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746119
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746119
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:19:49
|
50 ms
|
[114568]
|
|
|
229172
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746137
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746137
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:20:07
|
60 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
229173
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746137
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746137
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:20:07
|
51 ms
|
[114586]
|
|
|
229182
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746142
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746142
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:20:12
|
60 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
229183
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746142
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746142
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:20:12
|
51 ms
|
[114591]
|
|
|
228390
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745746
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745746
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:13:32
|
61 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228391
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745746
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745746
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:13:32
|
52 ms
|
[114195]
|
|
|
228398
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745750
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745750
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:13:36
|
61 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228399
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745750
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745750
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:13:36
|
52 ms
|
[114199]
|
|
|
228424
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745763
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745763
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:13:49
|
61 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228425
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745763
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745763
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:13:49
|
51 ms
|
[114212]
|
|
|
228488
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745795
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745795
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:14:22
|
61 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228489
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745795
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745795
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:14:22
|
52 ms
|
[114244]
|
|
|
228498
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745800
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745800
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:14:27
|
61 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228499
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745800
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745800
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:14:27
|
51 ms
|
[114249]
|
|
|
228514
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745808
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745808
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:14:35
|
61 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228515
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745808
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745808
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:14:35
|
51 ms
|
[114257]
|
|
|
228552
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745827
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745827
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:14:54
|
61 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228553
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745827
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745827
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:14:54
|
51 ms
|
[114276]
|
|
|
228616
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745859
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745859
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:15:26
|
61 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228617
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745859
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745859
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:15:26
|
52 ms
|
[114308]
|
|
|
228698
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745900
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745900
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:16:09
|
61 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228699
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745900
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745900
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:16:09
|
51 ms
|
[114349]
|
|
|
228768
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745935
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745935
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:16:44
|
61 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228769
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745935
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745935
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:16:44
|
52 ms
|
[114384]
|
|
|
228770
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745936
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745936
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:16:45
|
61 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228771
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745936
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745936
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:16:45
|
51 ms
|
[114385]
|
|
|
228776
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745939
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745939
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:16:48
|
61 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228777
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745939
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745939
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:16:48
|
52 ms
|
[114388]
|
|
|
228918
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746010
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746010
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:18:00
|
61 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228919
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746010
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746010
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:18:00
|
50 ms
|
[114459]
|
|
|
228952
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746027
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746027
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:18:17
|
61 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228953
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746027
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746027
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:18:17
|
51 ms
|
[114476]
|
|
|
228982
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746042
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746042
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:18:32
|
61 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228983
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746042
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746042
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:18:32
|
52 ms
|
[114491]
|
|
|
228990
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746046
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746046
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:18:36
|
61 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228991
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746046
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746046
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:18:36
|
52 ms
|
[114495]
|
|
|
229002
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746052
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746052
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:18:42
|
61 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
229003
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746052
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746052
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:18:42
|
51 ms
|
[114501]
|
|
|
229022
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746062
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746062
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:18:52
|
61 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
229023
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746062
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746062
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:18:52
|
51 ms
|
[114511]
|
|
|
229082
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746092
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746092
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:19:22
|
61 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
229083
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746092
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746092
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:19:22
|
51 ms
|
[114541]
|
|
|
229090
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746096
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746096
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:19:26
|
61 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
229091
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746096
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746096
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:19:26
|
52 ms
|
[114545]
|
|
|
229232
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746167
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746167
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:20:37
|
61 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
229233
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746167
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746167
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:20:37
|
52 ms
|
[114616]
|
|
|
229306
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746204
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746204
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:21:15
|
61 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
229307
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746204
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746204
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:21:15
|
52 ms
|
[114653]
|
|
|
229314
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746208
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746208
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:21:19
|
61 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
229315
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746208
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9746208
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:21:19
|
51 ms
|
[114657]
|
|
|
228360
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745731
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745731
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:13:17
|
62 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228361
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745731
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745731
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:13:17
|
52 ms
|
[114180]
|
|
|
228434
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745768
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745768
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:13:54
|
62 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228435
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745768
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745768
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:13:54
|
52 ms
|
[114217]
|
|
|
228460
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745781
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745781
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:14:07
|
62 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228461
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745781
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745781
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:14:07
|
53 ms
|
[114230]
|
|
|
228560
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745831
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745831
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:14:58
|
62 ms
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
228561
|
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745831
+details
TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 0e08ee6f-2501-4b67-8d8a-4af0dbde93d9
batch = 9745831
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220)
com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154)
com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130)
com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/08/13 09:14:58
|
53 ms
|
[114280]
|
|