| Stage Id ▾ | Description | Submitted | Duration | Tasks: Succeeded/Total | Input | Output | Shuffle Read | Shuffle Write |
|---|---|---|---|---|---|---|---|---|
| 25 |
id = b032683b-3bb8-4b00-adb0-dbc962db8a67
runId = d643de75-06e0-44a9-91bb-49bd35306f5c
batch = 740 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) 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:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/01/08 09:45:32 | 0.5 s |
1/1
| ||||
| 24 |
id = b032683b-3bb8-4b00-adb0-dbc962db8a67
runId = d643de75-06e0-44a9-91bb-49bd35306f5c
batch = 740 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) 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:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/01/08 09:45:32 | 0.5 s |
1/1
| ||||
| 23 |
id = b032683b-3bb8-4b00-adb0-dbc962db8a67
runId = d643de75-06e0-44a9-91bb-49bd35306f5c
batch = 739 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) 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:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/01/08 09:45:06 | 0.5 s |
1/1
| ||||
| 22 |
id = b032683b-3bb8-4b00-adb0-dbc962db8a67
runId = d643de75-06e0-44a9-91bb-49bd35306f5c
batch = 739 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) 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:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/01/08 09:45:06 | 0.5 s |
1/1
| ||||
| 21 |
id = b032683b-3bb8-4b00-adb0-dbc962db8a67
runId = d643de75-06e0-44a9-91bb-49bd35306f5c
batch = 738 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) 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:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/01/08 09:36:55 | 0.5 s |
1/1
| ||||
| 20 |
id = b032683b-3bb8-4b00-adb0-dbc962db8a67
runId = d643de75-06e0-44a9-91bb-49bd35306f5c
batch = 738 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) 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:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/01/08 09:36:55 | 0.5 s |
1/1
| ||||
| 19 |
id = b032683b-3bb8-4b00-adb0-dbc962db8a67
runId = d643de75-06e0-44a9-91bb-49bd35306f5c
batch = 737 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) 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:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/01/08 09:32:04 | 0.5 s |
1/1
| ||||
| 18 |
id = b032683b-3bb8-4b00-adb0-dbc962db8a67
runId = d643de75-06e0-44a9-91bb-49bd35306f5c
batch = 737 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) 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:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/01/08 09:32:04 | 0.5 s |
1/1
| ||||
| 17 |
id = b032683b-3bb8-4b00-adb0-dbc962db8a67
runId = d643de75-06e0-44a9-91bb-49bd35306f5c
batch = 736 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) 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:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/01/07 09:09:43 | 0.5 s |
1/1
| ||||
| 16 |
id = b032683b-3bb8-4b00-adb0-dbc962db8a67
runId = d643de75-06e0-44a9-91bb-49bd35306f5c
batch = 736 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) 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:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/01/07 09:09:43 | 0.5 s |
1/1
| ||||
| 15 |
id = b032683b-3bb8-4b00-adb0-dbc962db8a67
runId = d643de75-06e0-44a9-91bb-49bd35306f5c
batch = 735 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) 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:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/01/07 09:08:38 | 0.5 s |
1/1
| ||||
| 14 |
id = b032683b-3bb8-4b00-adb0-dbc962db8a67
runId = d643de75-06e0-44a9-91bb-49bd35306f5c
batch = 735 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) 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:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/01/07 09:08:38 | 0.5 s |
1/1
| ||||
| 13 |
id = b032683b-3bb8-4b00-adb0-dbc962db8a67
runId = d643de75-06e0-44a9-91bb-49bd35306f5c
batch = 734 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) 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:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/01/07 08:18:44 | 0.5 s |
1/1
| ||||
| 12 |
id = b032683b-3bb8-4b00-adb0-dbc962db8a67
runId = d643de75-06e0-44a9-91bb-49bd35306f5c
batch = 734 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) 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:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/01/07 08:18:44 | 0.6 s |
1/1
| ||||
| 11 |
id = b032683b-3bb8-4b00-adb0-dbc962db8a67
runId = d643de75-06e0-44a9-91bb-49bd35306f5c
batch = 733 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) 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:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/01/06 13:25:43 | 0.5 s |
1/1
| ||||
| 10 |
id = b032683b-3bb8-4b00-adb0-dbc962db8a67
runId = d643de75-06e0-44a9-91bb-49bd35306f5c
batch = 733 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) 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:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/01/06 13:25:43 | 0.5 s |
1/1
| ||||
| 9 |
id = b032683b-3bb8-4b00-adb0-dbc962db8a67
runId = d643de75-06e0-44a9-91bb-49bd35306f5c
batch = 732 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) 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:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/01/06 13:17:25 | 0.5 s |
1/1
| ||||
| 8 |
id = b032683b-3bb8-4b00-adb0-dbc962db8a67
runId = d643de75-06e0-44a9-91bb-49bd35306f5c
batch = 732 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) 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:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/01/06 13:17:25 | 0.5 s |
1/1
| ||||
| 7 |
id = b032683b-3bb8-4b00-adb0-dbc962db8a67
runId = d643de75-06e0-44a9-91bb-49bd35306f5c
batch = 731 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) 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:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/01/06 13:12:04 | 0.5 s |
2/2
| ||||
| 6 |
id = b032683b-3bb8-4b00-adb0-dbc962db8a67
runId = d643de75-06e0-44a9-91bb-49bd35306f5c
batch = 731 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) 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:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/01/06 13:12:04 | 0.5 s |
1/1
| ||||
| 5 |
id = b032683b-3bb8-4b00-adb0-dbc962db8a67
runId = d643de75-06e0-44a9-91bb-49bd35306f5c
batch = 730 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) 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:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/01/06 09:57:22 | 0.5 s |
1/1
| ||||
| 4 |
id = b032683b-3bb8-4b00-adb0-dbc962db8a67
runId = d643de75-06e0-44a9-91bb-49bd35306f5c
batch = 730 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) 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:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/01/06 09:57:22 | 0.5 s |
1/1
| ||||
| 3 |
id = b032683b-3bb8-4b00-adb0-dbc962db8a67
runId = d643de75-06e0-44a9-91bb-49bd35306f5c
batch = 729 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) 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:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/01/06 09:57:02 | 0.6 s |
1/1
| ||||
| 2 |
id = b032683b-3bb8-4b00-adb0-dbc962db8a67
runId = d643de75-06e0-44a9-91bb-49bd35306f5c
batch = 729 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) 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:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/01/06 09:57:02 | 0.6 s |
1/1
| ||||
| 1 |
id = b032683b-3bb8-4b00-adb0-dbc962db8a67
runId = d643de75-06e0-44a9-91bb-49bd35306f5c
batch = 728 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) 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:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/01/06 09:56:39 | 0.6 s |
1/1
| ||||
| 0 |
id = b032683b-3bb8-4b00-adb0-dbc962db8a67
runId = d643de75-06e0-44a9-91bb-49bd35306f5c
batch = 728 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) 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:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/01/06 09:56:38 | 1 s |
1/1
|