| Stage Id ▾ | Description | Submitted | Duration | Tasks: Succeeded/Total | Input | Output | Shuffle Read | Shuffle Write |
|---|---|---|---|---|---|---|---|---|
| 64 |
id = b4d9a5a7-9bcc-4f01-85b4-e5c1256e4c56
runId = c10f0d8f-fcf6-4e63-ab5f-ac987135862d
batch = 64 start at EventMessageStream.java:115 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:249) com.touchetv.events.EventMessageStream.main(EventMessageStream.java:115) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1020) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:192) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:215) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1111) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/11/03 12:49:33 | 0.7 s |
1/1
| ||||
| 63 |
id = b4d9a5a7-9bcc-4f01-85b4-e5c1256e4c56
runId = c10f0d8f-fcf6-4e63-ab5f-ac987135862d
batch = 63 start at EventMessageStream.java:115 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:249) com.touchetv.events.EventMessageStream.main(EventMessageStream.java:115) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1020) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:192) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:215) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1111) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/11/03 12:49:33 | 0.7 s |
1/1
| ||||
| 62 |
id = b4d9a5a7-9bcc-4f01-85b4-e5c1256e4c56
runId = c10f0d8f-fcf6-4e63-ab5f-ac987135862d
batch = 62 start at EventMessageStream.java:115 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:249) com.touchetv.events.EventMessageStream.main(EventMessageStream.java:115) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1020) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:192) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:215) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1111) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/11/03 12:49:12 | 1 s |
2/2
| ||||
| 61 |
id = b4d9a5a7-9bcc-4f01-85b4-e5c1256e4c56
runId = c10f0d8f-fcf6-4e63-ab5f-ac987135862d
batch = 61 start at EventMessageStream.java:115 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:249) com.touchetv.events.EventMessageStream.main(EventMessageStream.java:115) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1020) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:192) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:215) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1111) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/11/03 12:48:47 | 1 s |
2/2
| ||||
| 60 |
id = b4d9a5a7-9bcc-4f01-85b4-e5c1256e4c56
runId = c10f0d8f-fcf6-4e63-ab5f-ac987135862d
batch = 60 start at EventMessageStream.java:115 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:249) com.touchetv.events.EventMessageStream.main(EventMessageStream.java:115) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1020) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:192) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:215) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1111) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/11/03 12:48:36 | 1 s |
2/2
| ||||
| 59 |
id = b4d9a5a7-9bcc-4f01-85b4-e5c1256e4c56
runId = c10f0d8f-fcf6-4e63-ab5f-ac987135862d
batch = 59 start at EventMessageStream.java:115 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:249) com.touchetv.events.EventMessageStream.main(EventMessageStream.java:115) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1020) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:192) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:215) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1111) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/11/03 12:48:03 | 0.7 s |
1/1
| ||||
| 58 |
id = b4d9a5a7-9bcc-4f01-85b4-e5c1256e4c56
runId = c10f0d8f-fcf6-4e63-ab5f-ac987135862d
batch = 58 start at EventMessageStream.java:115 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:249) com.touchetv.events.EventMessageStream.main(EventMessageStream.java:115) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1020) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:192) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:215) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1111) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/11/03 12:47:55 | 0.7 s |
1/1
| ||||
| 57 |
id = b4d9a5a7-9bcc-4f01-85b4-e5c1256e4c56
runId = c10f0d8f-fcf6-4e63-ab5f-ac987135862d
batch = 57 start at EventMessageStream.java:115 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:249) com.touchetv.events.EventMessageStream.main(EventMessageStream.java:115) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1020) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:192) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:215) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1111) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/11/03 12:47:48 | 0.7 s |
1/1
| ||||
| 56 |
id = b4d9a5a7-9bcc-4f01-85b4-e5c1256e4c56
runId = c10f0d8f-fcf6-4e63-ab5f-ac987135862d
batch = 56 start at EventMessageStream.java:115 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:249) com.touchetv.events.EventMessageStream.main(EventMessageStream.java:115) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1020) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:192) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:215) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1111) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/11/03 12:47:47 | 0.7 s |
1/1
| ||||
| 55 |
id = b4d9a5a7-9bcc-4f01-85b4-e5c1256e4c56
runId = c10f0d8f-fcf6-4e63-ab5f-ac987135862d
batch = 55 start at EventMessageStream.java:115 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:249) com.touchetv.events.EventMessageStream.main(EventMessageStream.java:115) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1020) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:192) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:215) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1111) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/11/03 12:47:46 | 0.7 s |
1/1
| ||||
| 54 |
id = b4d9a5a7-9bcc-4f01-85b4-e5c1256e4c56
runId = c10f0d8f-fcf6-4e63-ab5f-ac987135862d
batch = 54 start at EventMessageStream.java:115 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:249) com.touchetv.events.EventMessageStream.main(EventMessageStream.java:115) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1020) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:192) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:215) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1111) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/11/03 12:47:40 | 1 s |
2/2
| ||||
| 53 |
id = b4d9a5a7-9bcc-4f01-85b4-e5c1256e4c56
runId = c10f0d8f-fcf6-4e63-ab5f-ac987135862d
batch = 53 start at EventMessageStream.java:115 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:249) com.touchetv.events.EventMessageStream.main(EventMessageStream.java:115) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1020) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:192) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:215) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1111) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/11/03 12:47:39 | 0.7 s |
1/1
| ||||
| 52 |
id = b4d9a5a7-9bcc-4f01-85b4-e5c1256e4c56
runId = c10f0d8f-fcf6-4e63-ab5f-ac987135862d
batch = 52 start at EventMessageStream.java:115 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:249) com.touchetv.events.EventMessageStream.main(EventMessageStream.java:115) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1020) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:192) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:215) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1111) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/11/03 12:47:39 | 0.6 s |
1/1
| ||||
| 51 |
id = b4d9a5a7-9bcc-4f01-85b4-e5c1256e4c56
runId = c10f0d8f-fcf6-4e63-ab5f-ac987135862d
batch = 51 start at EventMessageStream.java:115 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:249) com.touchetv.events.EventMessageStream.main(EventMessageStream.java:115) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1020) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:192) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:215) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1111) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/11/03 12:47:12 | 0.7 s |
1/1
| ||||
| 50 |
id = b4d9a5a7-9bcc-4f01-85b4-e5c1256e4c56
runId = c10f0d8f-fcf6-4e63-ab5f-ac987135862d
batch = 50 start at EventMessageStream.java:115 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:249) com.touchetv.events.EventMessageStream.main(EventMessageStream.java:115) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1020) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:192) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:215) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1111) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/11/03 12:47:10 | 0.7 s |
1/1
| ||||
| 49 |
id = b4d9a5a7-9bcc-4f01-85b4-e5c1256e4c56
runId = c10f0d8f-fcf6-4e63-ab5f-ac987135862d
batch = 49 start at EventMessageStream.java:115 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:249) com.touchetv.events.EventMessageStream.main(EventMessageStream.java:115) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1020) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:192) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:215) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1111) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/11/03 12:47:09 | 0.7 s |
1/1
| ||||
| 48 |
id = b4d9a5a7-9bcc-4f01-85b4-e5c1256e4c56
runId = c10f0d8f-fcf6-4e63-ab5f-ac987135862d
batch = 48 start at EventMessageStream.java:115 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:249) com.touchetv.events.EventMessageStream.main(EventMessageStream.java:115) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1020) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:192) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:215) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1111) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/11/03 12:47:05 | 0.7 s |
1/1
| ||||
| 47 |
id = b4d9a5a7-9bcc-4f01-85b4-e5c1256e4c56
runId = c10f0d8f-fcf6-4e63-ab5f-ac987135862d
batch = 47 start at EventMessageStream.java:115 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:249) com.touchetv.events.EventMessageStream.main(EventMessageStream.java:115) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1020) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:192) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:215) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1111) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/11/03 12:47:04 | 0.6 s |
1/1
| ||||
| 46 |
id = b4d9a5a7-9bcc-4f01-85b4-e5c1256e4c56
runId = c10f0d8f-fcf6-4e63-ab5f-ac987135862d
batch = 46 start at EventMessageStream.java:115 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:249) com.touchetv.events.EventMessageStream.main(EventMessageStream.java:115) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1020) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:192) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:215) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1111) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/11/03 12:47:01 | 1 s |
2/2
| ||||
| 45 |
id = b4d9a5a7-9bcc-4f01-85b4-e5c1256e4c56
runId = c10f0d8f-fcf6-4e63-ab5f-ac987135862d
batch = 45 start at EventMessageStream.java:115 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:249) com.touchetv.events.EventMessageStream.main(EventMessageStream.java:115) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1020) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:192) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:215) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1111) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/11/03 12:46:55 | 2 s |
3/3
| ||||
| 44 |
id = b4d9a5a7-9bcc-4f01-85b4-e5c1256e4c56
runId = c10f0d8f-fcf6-4e63-ab5f-ac987135862d
batch = 44 start at EventMessageStream.java:115 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:249) com.touchetv.events.EventMessageStream.main(EventMessageStream.java:115) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1020) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:192) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:215) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1111) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/11/03 12:46:52 | 3 s |
4/4
| ||||
| 43 |
id = b4d9a5a7-9bcc-4f01-85b4-e5c1256e4c56
runId = c10f0d8f-fcf6-4e63-ab5f-ac987135862d
batch = 43 start at EventMessageStream.java:115 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:249) com.touchetv.events.EventMessageStream.main(EventMessageStream.java:115) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1020) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:192) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:215) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1111) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/11/03 12:46:51 | 0.6 s |
1/1
| ||||
| 42 |
id = b4d9a5a7-9bcc-4f01-85b4-e5c1256e4c56
runId = c10f0d8f-fcf6-4e63-ab5f-ac987135862d
batch = 42 start at EventMessageStream.java:115 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:249) com.touchetv.events.EventMessageStream.main(EventMessageStream.java:115) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1020) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:192) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:215) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1111) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/11/03 12:46:50 | 1 s |
2/2
| ||||
| 41 |
id = b4d9a5a7-9bcc-4f01-85b4-e5c1256e4c56
runId = c10f0d8f-fcf6-4e63-ab5f-ac987135862d
batch = 41 start at EventMessageStream.java:115 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:249) com.touchetv.events.EventMessageStream.main(EventMessageStream.java:115) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1020) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:192) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:215) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1111) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/11/03 12:46:49 | 0.6 s |
1/1
| ||||
| 40 |
id = b4d9a5a7-9bcc-4f01-85b4-e5c1256e4c56
runId = c10f0d8f-fcf6-4e63-ab5f-ac987135862d
batch = 40 start at EventMessageStream.java:115 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:249) com.touchetv.events.EventMessageStream.main(EventMessageStream.java:115) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1020) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:192) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:215) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1111) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/11/03 12:46:45 | 1 s |
2/2
| ||||
| 39 |
id = b4d9a5a7-9bcc-4f01-85b4-e5c1256e4c56
runId = c10f0d8f-fcf6-4e63-ab5f-ac987135862d
batch = 39 start at EventMessageStream.java:115 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:249) com.touchetv.events.EventMessageStream.main(EventMessageStream.java:115) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1020) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:192) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:215) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1111) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/11/03 12:46:44 | 0.7 s |
1/1
| ||||
| 38 |
id = b4d9a5a7-9bcc-4f01-85b4-e5c1256e4c56
runId = c10f0d8f-fcf6-4e63-ab5f-ac987135862d
batch = 38 start at EventMessageStream.java:115 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:249) com.touchetv.events.EventMessageStream.main(EventMessageStream.java:115) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1020) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:192) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:215) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1111) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/11/03 12:46:42 | 0.7 s |
1/1
| ||||
| 37 |
id = b4d9a5a7-9bcc-4f01-85b4-e5c1256e4c56
runId = c10f0d8f-fcf6-4e63-ab5f-ac987135862d
batch = 37 start at EventMessageStream.java:115 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:249) com.touchetv.events.EventMessageStream.main(EventMessageStream.java:115) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1020) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:192) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:215) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1111) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/11/03 12:46:36 | 1 s |
2/2
| ||||
| 36 |
id = b4d9a5a7-9bcc-4f01-85b4-e5c1256e4c56
runId = c10f0d8f-fcf6-4e63-ab5f-ac987135862d
batch = 36 start at EventMessageStream.java:115 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:249) com.touchetv.events.EventMessageStream.main(EventMessageStream.java:115) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1020) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:192) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:215) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1111) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/11/03 12:46:36 | 0.7 s |
1/1
| ||||
| 35 |
id = b4d9a5a7-9bcc-4f01-85b4-e5c1256e4c56
runId = c10f0d8f-fcf6-4e63-ab5f-ac987135862d
batch = 35 start at EventMessageStream.java:115 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:249) com.touchetv.events.EventMessageStream.main(EventMessageStream.java:115) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1020) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:192) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:215) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1111) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/11/03 12:46:34 | 1 s |
2/2
| ||||
| 34 |
id = b4d9a5a7-9bcc-4f01-85b4-e5c1256e4c56
runId = c10f0d8f-fcf6-4e63-ab5f-ac987135862d
batch = 34 start at EventMessageStream.java:115 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:249) com.touchetv.events.EventMessageStream.main(EventMessageStream.java:115) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1020) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:192) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:215) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1111) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/11/03 12:46:33 | 0.6 s |
1/1
| ||||
| 33 |
id = b4d9a5a7-9bcc-4f01-85b4-e5c1256e4c56
runId = c10f0d8f-fcf6-4e63-ab5f-ac987135862d
batch = 33 start at EventMessageStream.java:115 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:249) com.touchetv.events.EventMessageStream.main(EventMessageStream.java:115) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1020) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:192) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:215) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1111) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/11/03 12:46:31 | 2 s |
3/3
| ||||
| 32 |
id = b4d9a5a7-9bcc-4f01-85b4-e5c1256e4c56
runId = c10f0d8f-fcf6-4e63-ab5f-ac987135862d
batch = 32 start at EventMessageStream.java:115 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:249) com.touchetv.events.EventMessageStream.main(EventMessageStream.java:115) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1020) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:192) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:215) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1111) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/11/03 12:46:29 | 1 s |
2/2
| ||||
| 31 |
id = b4d9a5a7-9bcc-4f01-85b4-e5c1256e4c56
runId = c10f0d8f-fcf6-4e63-ab5f-ac987135862d
batch = 31 start at EventMessageStream.java:115 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:249) com.touchetv.events.EventMessageStream.main(EventMessageStream.java:115) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1020) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:192) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:215) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1111) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/11/03 12:46:29 | 0.6 s |
1/1
| ||||
| 30 |
id = b4d9a5a7-9bcc-4f01-85b4-e5c1256e4c56
runId = c10f0d8f-fcf6-4e63-ab5f-ac987135862d
batch = 30 start at EventMessageStream.java:115 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:249) com.touchetv.events.EventMessageStream.main(EventMessageStream.java:115) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1020) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:192) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:215) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1111) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/11/03 12:46:28 | 0.6 s |
1/1
| ||||
| 29 |
id = b4d9a5a7-9bcc-4f01-85b4-e5c1256e4c56
runId = c10f0d8f-fcf6-4e63-ab5f-ac987135862d
batch = 29 start at EventMessageStream.java:115 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:249) com.touchetv.events.EventMessageStream.main(EventMessageStream.java:115) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1020) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:192) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:215) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1111) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/11/03 12:46:26 | 0.7 s |
1/1
| ||||
| 28 |
id = b4d9a5a7-9bcc-4f01-85b4-e5c1256e4c56
runId = c10f0d8f-fcf6-4e63-ab5f-ac987135862d
batch = 28 start at EventMessageStream.java:115 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:249) com.touchetv.events.EventMessageStream.main(EventMessageStream.java:115) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1020) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:192) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:215) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1111) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/11/03 12:46:22 | 0.7 s |
1/1
| ||||
| 27 |
id = b4d9a5a7-9bcc-4f01-85b4-e5c1256e4c56
runId = c10f0d8f-fcf6-4e63-ab5f-ac987135862d
batch = 27 start at EventMessageStream.java:115 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:249) com.touchetv.events.EventMessageStream.main(EventMessageStream.java:115) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1020) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:192) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:215) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1111) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/11/03 12:46:09 | 0.7 s |
1/1
| ||||
| 26 |
id = b4d9a5a7-9bcc-4f01-85b4-e5c1256e4c56
runId = c10f0d8f-fcf6-4e63-ab5f-ac987135862d
batch = 26 start at EventMessageStream.java:115 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:249) com.touchetv.events.EventMessageStream.main(EventMessageStream.java:115) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1020) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:192) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:215) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1111) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/11/03 12:46:05 | 0.7 s |
1/1
| ||||
| 25 |
id = b4d9a5a7-9bcc-4f01-85b4-e5c1256e4c56
runId = c10f0d8f-fcf6-4e63-ab5f-ac987135862d
batch = 25 start at EventMessageStream.java:115 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:249) com.touchetv.events.EventMessageStream.main(EventMessageStream.java:115) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1020) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:192) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:215) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1111) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/11/03 12:46:04 | 0.7 s |
1/1
| ||||
| 24 |
id = b4d9a5a7-9bcc-4f01-85b4-e5c1256e4c56
runId = c10f0d8f-fcf6-4e63-ab5f-ac987135862d
batch = 24 start at EventMessageStream.java:115 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:249) com.touchetv.events.EventMessageStream.main(EventMessageStream.java:115) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1020) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:192) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:215) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1111) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/11/03 12:45:33 | 0.7 s |
1/1
| ||||
| 23 |
id = b4d9a5a7-9bcc-4f01-85b4-e5c1256e4c56
runId = c10f0d8f-fcf6-4e63-ab5f-ac987135862d
batch = 23 start at EventMessageStream.java:115 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:249) com.touchetv.events.EventMessageStream.main(EventMessageStream.java:115) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1020) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:192) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:215) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1111) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/11/03 12:45:30 | 0.6 s |
1/1
| ||||
| 22 |
id = b4d9a5a7-9bcc-4f01-85b4-e5c1256e4c56
runId = c10f0d8f-fcf6-4e63-ab5f-ac987135862d
batch = 22 start at EventMessageStream.java:115 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:249) com.touchetv.events.EventMessageStream.main(EventMessageStream.java:115) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1020) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:192) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:215) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1111) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/11/03 12:45:08 | 3 s |
3/3
| ||||
| 21 |
id = b4d9a5a7-9bcc-4f01-85b4-e5c1256e4c56
runId = c10f0d8f-fcf6-4e63-ab5f-ac987135862d
batch = 21 start at EventMessageStream.java:115 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:249) com.touchetv.events.EventMessageStream.main(EventMessageStream.java:115) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1020) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:192) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:215) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1111) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/11/03 12:45:07 | 1 s |
1/1
| ||||
| 20 |
id = b4d9a5a7-9bcc-4f01-85b4-e5c1256e4c56
runId = c10f0d8f-fcf6-4e63-ab5f-ac987135862d
batch = 20 start at EventMessageStream.java:115 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:249) com.touchetv.events.EventMessageStream.main(EventMessageStream.java:115) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1020) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:192) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:215) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1111) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/11/03 12:45:04 | 0.9 s |
1/1
| ||||
| 19 |
id = b4d9a5a7-9bcc-4f01-85b4-e5c1256e4c56
runId = c10f0d8f-fcf6-4e63-ab5f-ac987135862d
batch = 19 start at EventMessageStream.java:115 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:249) com.touchetv.events.EventMessageStream.main(EventMessageStream.java:115) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1020) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:192) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:215) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1111) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/11/03 12:44:59 | 1.0 s |
1/1
| ||||
| 18 |
id = b4d9a5a7-9bcc-4f01-85b4-e5c1256e4c56
runId = c10f0d8f-fcf6-4e63-ab5f-ac987135862d
batch = 18 start at EventMessageStream.java:115 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:249) com.touchetv.events.EventMessageStream.main(EventMessageStream.java:115) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1020) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:192) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:215) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1111) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/10/30 09:25:30 | 1 s |
1/1
| ||||
| 17 |
id = b4d9a5a7-9bcc-4f01-85b4-e5c1256e4c56
runId = c10f0d8f-fcf6-4e63-ab5f-ac987135862d
batch = 17 start at EventMessageStream.java:115 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:249) com.touchetv.events.EventMessageStream.main(EventMessageStream.java:115) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1020) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:192) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:215) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1111) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/10/30 09:11:55 | 0.7 s |
1/1
| ||||
| 16 |
id = b4d9a5a7-9bcc-4f01-85b4-e5c1256e4c56
runId = c10f0d8f-fcf6-4e63-ab5f-ac987135862d
batch = 16 start at EventMessageStream.java:115 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:249) com.touchetv.events.EventMessageStream.main(EventMessageStream.java:115) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1020) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:192) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:215) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1111) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/10/30 09:11:06 | 0.7 s |
1/1
| ||||
| 15 |
id = b4d9a5a7-9bcc-4f01-85b4-e5c1256e4c56
runId = c10f0d8f-fcf6-4e63-ab5f-ac987135862d
batch = 15 start at EventMessageStream.java:115 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:249) com.touchetv.events.EventMessageStream.main(EventMessageStream.java:115) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1020) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:192) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:215) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1111) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/10/30 09:10:56 | 2 s |
3/3
| ||||
| 14 |
id = b4d9a5a7-9bcc-4f01-85b4-e5c1256e4c56
runId = c10f0d8f-fcf6-4e63-ab5f-ac987135862d
batch = 14 start at EventMessageStream.java:115 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:249) com.touchetv.events.EventMessageStream.main(EventMessageStream.java:115) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1020) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:192) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:215) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1111) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/10/30 09:10:45 | 0.7 s |
1/1
| ||||
| 13 |
id = b4d9a5a7-9bcc-4f01-85b4-e5c1256e4c56
runId = c10f0d8f-fcf6-4e63-ab5f-ac987135862d
batch = 13 start at EventMessageStream.java:115 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:249) com.touchetv.events.EventMessageStream.main(EventMessageStream.java:115) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1020) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:192) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:215) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1111) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/10/30 09:10:42 | 0.6 s |
1/1
| ||||
| 12 |
id = b4d9a5a7-9bcc-4f01-85b4-e5c1256e4c56
runId = c10f0d8f-fcf6-4e63-ab5f-ac987135862d
batch = 12 start at EventMessageStream.java:115 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:249) com.touchetv.events.EventMessageStream.main(EventMessageStream.java:115) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1020) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:192) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:215) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1111) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/10/30 09:10:39 | 3 s |
4/4
| ||||
| 11 |
id = b4d9a5a7-9bcc-4f01-85b4-e5c1256e4c56
runId = c10f0d8f-fcf6-4e63-ab5f-ac987135862d
batch = 11 start at EventMessageStream.java:115 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:249) com.touchetv.events.EventMessageStream.main(EventMessageStream.java:115) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1020) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:192) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:215) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1111) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/10/30 09:10:38 | 0.6 s |
1/1
| ||||
| 10 |
id = b4d9a5a7-9bcc-4f01-85b4-e5c1256e4c56
runId = c10f0d8f-fcf6-4e63-ab5f-ac987135862d
batch = 10 start at EventMessageStream.java:115 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:249) com.touchetv.events.EventMessageStream.main(EventMessageStream.java:115) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1020) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:192) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:215) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1111) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/10/30 09:07:48 | 0.7 s |
1/1
| ||||
| 9 |
id = b4d9a5a7-9bcc-4f01-85b4-e5c1256e4c56
runId = c10f0d8f-fcf6-4e63-ab5f-ac987135862d
batch = 9 start at EventMessageStream.java:115 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:249) com.touchetv.events.EventMessageStream.main(EventMessageStream.java:115) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1020) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:192) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:215) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1111) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/10/30 09:07:19 | 0.6 s |
1/1
| ||||
| 8 |
id = b4d9a5a7-9bcc-4f01-85b4-e5c1256e4c56
runId = c10f0d8f-fcf6-4e63-ab5f-ac987135862d
batch = 8 start at EventMessageStream.java:115 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:249) com.touchetv.events.EventMessageStream.main(EventMessageStream.java:115) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1020) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:192) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:215) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1111) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/10/30 09:07:17 | 0.6 s |
1/1
| ||||
| 7 |
id = b4d9a5a7-9bcc-4f01-85b4-e5c1256e4c56
runId = c10f0d8f-fcf6-4e63-ab5f-ac987135862d
batch = 7 start at EventMessageStream.java:115 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:249) com.touchetv.events.EventMessageStream.main(EventMessageStream.java:115) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1020) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:192) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:215) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1111) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/10/30 09:07:14 | 0.6 s |
1/1
| ||||
| 6 |
id = b4d9a5a7-9bcc-4f01-85b4-e5c1256e4c56
runId = c10f0d8f-fcf6-4e63-ab5f-ac987135862d
batch = 6 start at EventMessageStream.java:115 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:249) com.touchetv.events.EventMessageStream.main(EventMessageStream.java:115) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1020) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:192) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:215) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1111) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/10/30 09:07:01 | 2 s |
2/2
| ||||
| 5 |
id = b4d9a5a7-9bcc-4f01-85b4-e5c1256e4c56
runId = c10f0d8f-fcf6-4e63-ab5f-ac987135862d
batch = 5 start at EventMessageStream.java:115 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:249) com.touchetv.events.EventMessageStream.main(EventMessageStream.java:115) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1020) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:192) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:215) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1111) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/10/30 09:06:59 | 2 s |
2/2
| ||||
| 4 |
id = b4d9a5a7-9bcc-4f01-85b4-e5c1256e4c56
runId = c10f0d8f-fcf6-4e63-ab5f-ac987135862d
batch = 4 start at EventMessageStream.java:115 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:249) com.touchetv.events.EventMessageStream.main(EventMessageStream.java:115) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1020) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:192) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:215) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1111) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/10/30 09:06:56 | 1 s |
1/1
| ||||
| 3 |
id = b4d9a5a7-9bcc-4f01-85b4-e5c1256e4c56
runId = c10f0d8f-fcf6-4e63-ab5f-ac987135862d
batch = 3 start at EventMessageStream.java:115 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:249) com.touchetv.events.EventMessageStream.main(EventMessageStream.java:115) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1020) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:192) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:215) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1111) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/10/30 09:06:55 | 1 s |
1/1
| ||||
| 2 |
id = b4d9a5a7-9bcc-4f01-85b4-e5c1256e4c56
runId = c10f0d8f-fcf6-4e63-ab5f-ac987135862d
batch = 2 start at EventMessageStream.java:115 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:249) com.touchetv.events.EventMessageStream.main(EventMessageStream.java:115) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1020) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:192) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:215) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1111) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/10/30 09:06:52 | 0.8 s |
1/1
| ||||
| 1 |
id = b4d9a5a7-9bcc-4f01-85b4-e5c1256e4c56
runId = c10f0d8f-fcf6-4e63-ab5f-ac987135862d
batch = 1 start at EventMessageStream.java:115 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:249) com.touchetv.events.EventMessageStream.main(EventMessageStream.java:115) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1020) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:192) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:215) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1111) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/10/30 09:06:48 | 1 s |
1/1
| ||||
| 0 |
id = b4d9a5a7-9bcc-4f01-85b4-e5c1256e4c56
runId = c10f0d8f-fcf6-4e63-ab5f-ac987135862d
batch = 0 start at EventMessageStream.java:115 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:249) com.touchetv.events.EventMessageStream.main(EventMessageStream.java:115) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1020) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:192) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:215) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1111) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/10/26 15:35:37 | 18 s |
6/6
|