| Stage Id ▾ | Description | Submitted | Duration | Tasks: Succeeded/Total | Input | Output | Shuffle Read | Shuffle Write |
|---|---|---|---|---|---|---|---|---|
| 129 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18420 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) | 2025/12/12 12:45:41 | 0.5 s |
1/1
| ||||
| 128 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18420 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) | 2025/12/12 12:45:41 | 0.5 s |
1/1
| ||||
| 127 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18419 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) | 2025/12/12 12:45:11 | 0.5 s |
1/1
| ||||
| 126 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18419 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) | 2025/12/12 12:45:11 | 0.5 s |
1/1
| ||||
| 125 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18418 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) | 2025/12/12 12:44:29 | 0.5 s |
1/1
| ||||
| 124 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18418 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) | 2025/12/12 12:44:29 | 0.5 s |
1/1
| ||||
| 123 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18417 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) | 2025/12/12 12:42:25 | 0.5 s |
1/1
| ||||
| 122 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18417 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) | 2025/12/12 12:42:25 | 0.5 s |
1/1
| ||||
| 121 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18416 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) | 2025/12/12 12:41:52 | 0.5 s |
1/1
| ||||
| 120 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18416 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) | 2025/12/12 12:41:52 | 0.5 s |
1/1
| ||||
| 119 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18415 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) | 2025/12/12 12:40:52 | 0.5 s |
1/1
| ||||
| 118 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18415 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) | 2025/12/12 12:40:52 | 0.5 s |
1/1
| ||||
| 117 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18414 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) | 2025/12/12 12:40:41 | 0.5 s |
1/1
| ||||
| 116 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18414 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) | 2025/12/12 12:40:41 | 0.5 s |
1/1
| ||||
| 115 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18413 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) | 2025/12/12 12:40:34 | 0.5 s |
1/1
| ||||
| 114 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18413 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) | 2025/12/12 12:40:34 | 0.5 s |
1/1
| ||||
| 113 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18412 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) | 2025/12/12 12:40:10 | 0.5 s |
1/1
| ||||
| 112 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18412 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) | 2025/12/12 12:40:10 | 0.5 s |
1/1
| ||||
| 111 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18411 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) | 2025/12/12 12:38:47 | 0.5 s |
1/1
| ||||
| 110 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18411 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) | 2025/12/12 12:38:47 | 0.5 s |
1/1
| ||||
| 109 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18410 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) | 2025/12/12 12:38:14 | 0.5 s |
1/1
| ||||
| 108 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18410 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) | 2025/12/12 12:38:14 | 0.5 s |
1/1
| ||||
| 107 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18409 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) | 2025/12/10 18:30:26 | 0.5 s |
3/3
| ||||
| 106 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18409 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) | 2025/12/10 18:30:26 | 0.5 s |
1/1
| ||||
| 105 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18408 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) | 2025/12/10 11:44:11 | 0.5 s |
1/1
| ||||
| 104 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18408 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) | 2025/12/10 11:44:11 | 0.5 s |
1/1
| ||||
| 103 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18407 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) | 2025/12/10 11:43:11 | 0.5 s |
1/1
| ||||
| 102 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18407 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) | 2025/12/10 11:43:11 | 0.5 s |
1/1
| ||||
| 101 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18406 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) | 2025/12/09 12:07:33 | 0.5 s |
3/3
| ||||
| 100 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18406 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) | 2025/12/09 12:07:33 | 0.5 s |
1/1
| ||||
| 99 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18405 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) | 2025/12/09 12:06:57 | 0.5 s |
1/1
| ||||
| 98 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18405 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) | 2025/12/09 12:06:57 | 0.5 s |
1/1
| ||||
| 97 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18404 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) | 2025/12/09 12:03:58 | 0.5 s |
3/3
| ||||
| 96 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18404 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) | 2025/12/09 12:03:58 | 0.5 s |
1/1
| ||||
| 95 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18403 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) | 2025/12/09 12:02:48 | 0.5 s |
3/3
| ||||
| 94 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18403 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) | 2025/12/09 12:02:48 | 0.5 s |
1/1
| ||||
| 93 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18402 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) | 2025/12/09 12:01:11 | 0.5 s |
3/3
| ||||
| 92 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18402 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) | 2025/12/09 12:01:11 | 0.5 s |
1/1
| ||||
| 91 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18401 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) | 2025/12/09 12:00:26 | 0.5 s |
3/3
| ||||
| 90 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18401 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) | 2025/12/09 12:00:26 | 0.5 s |
1/1
| ||||
| 89 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18400 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) | 2025/12/09 11:58:06 | 0.5 s |
3/3
| ||||
| 88 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18400 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) | 2025/12/09 11:58:06 | 0.5 s |
1/1
| ||||
| 87 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18399 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) | 2025/12/09 11:56:23 | 0.5 s |
3/3
| ||||
| 86 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18399 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) | 2025/12/09 11:56:23 | 0.5 s |
1/1
| ||||
| 85 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18398 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) | 2025/12/09 11:54:29 | 0.5 s |
3/3
| ||||
| 84 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18398 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) | 2025/12/09 11:54:29 | 0.5 s |
1/1
| ||||
| 83 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18397 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) | 2025/12/09 11:51:49 | 0.5 s |
1/1
| ||||
| 82 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18397 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) | 2025/12/09 11:51:49 | 0.5 s |
1/1
| ||||
| 81 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18396 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) | 2025/12/08 21:13:44 | 11 ms |
2/2
| ||||
| 80 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18396 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) | 2025/12/08 21:13:44 | 0.5 s |
1/1
| ||||
| 79 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18395 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) | 2025/12/08 21:13:43 | 0.5 s |
2/2
| ||||
| 78 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18395 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) | 2025/12/08 21:13:43 | 0.4 s |
1/1
| ||||
| 77 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18394 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) | 2025/12/08 21:13:39 | 0.5 s |
2/2
| ||||
| 76 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18394 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) | 2025/12/08 21:13:39 | 0.5 s |
1/1
| ||||
| 75 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18393 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) | 2025/12/08 21:13:37 | 8 ms |
2/2
| ||||
| 74 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18393 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) | 2025/12/08 21:13:37 | 0.5 s |
1/1
| ||||
| 73 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18392 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) | 2025/12/08 21:13:36 | 0.5 s |
2/2
| ||||
| 72 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18392 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) | 2025/12/08 21:13:36 | 0.3 s |
1/1
| ||||
| 71 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18391 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) | 2025/12/08 21:13:31 | 0.5 s |
1/1
| ||||
| 70 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18391 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) | 2025/12/08 21:13:31 | 0.5 s |
1/1
| ||||
| 69 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18390 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) | 2025/12/08 19:52:13 | 0.5 s |
1/1
| ||||
| 68 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18390 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) | 2025/12/08 19:52:13 | 0.5 s |
1/1
| ||||
| 67 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18389 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) | 2025/12/08 19:51:37 | 0.5 s |
1/1
| ||||
| 66 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18389 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) | 2025/12/08 19:51:37 | 0.5 s |
1/1
| ||||
| 65 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18388 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) | 2025/12/08 17:06:55 | 0.5 s |
2/2
| ||||
| 64 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18388 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) | 2025/12/08 17:06:55 | 0.5 s |
1/1
| ||||
| 63 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18387 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) | 2025/12/08 17:06:36 | 0.5 s |
1/1
| ||||
| 62 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18387 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) | 2025/12/08 17:06:36 | 0.5 s |
1/1
| ||||
| 61 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18386 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) | 2025/12/08 17:04:03 | 0.5 s |
1/1
| ||||
| 60 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18386 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) | 2025/12/08 17:04:03 | 0.5 s |
1/1
| ||||
| 59 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18385 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) | 2025/12/08 16:59:59 | 0.5 s |
1/1
| ||||
| 58 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18385 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) | 2025/12/08 16:59:59 | 0.5 s |
1/1
| ||||
| 57 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18384 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) | 2025/12/04 10:11:12 | 0.5 s |
1/1
| ||||
| 56 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18384 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) | 2025/12/04 10:11:12 | 0.5 s |
1/1
| ||||
| 55 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18383 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) | 2025/12/04 10:10:59 | 0.5 s |
1/1
| ||||
| 54 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18383 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) | 2025/12/04 10:10:59 | 0.5 s |
1/1
| ||||
| 53 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18382 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) | 2025/12/04 10:10:39 | 0.5 s |
1/1
| ||||
| 52 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18382 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) | 2025/12/04 10:10:39 | 0.5 s |
1/1
| ||||
| 51 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18381 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) | 2025/12/04 10:10:27 | 0.5 s |
1/1
| ||||
| 50 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18381 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) | 2025/12/04 10:10:27 | 0.5 s |
1/1
| ||||
| 49 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18380 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) | 2025/12/04 10:10:10 | 0.5 s |
1/1
| ||||
| 48 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18380 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) | 2025/12/04 10:10:10 | 0.5 s |
1/1
| ||||
| 47 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18379 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) | 2025/12/04 09:13:03 | 0.5 s |
1/1
| ||||
| 46 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18379 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) | 2025/12/04 09:13:03 | 0.5 s |
1/1
| ||||
| 45 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18378 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) | 2025/12/04 01:02:24 | 0.5 s |
1/1
| ||||
| 44 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18378 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) | 2025/12/04 01:02:24 | 0.5 s |
1/1
| ||||
| 43 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18377 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) | 2025/12/04 01:01:53 | 0.5 s |
1/1
| ||||
| 42 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18377 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) | 2025/12/04 01:01:53 | 0.5 s |
1/1
| ||||
| 41 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18376 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) | 2025/12/03 15:34:57 | 0.5 s |
1/1
| ||||
| 40 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18376 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) | 2025/12/03 15:34:57 | 0.5 s |
1/1
| ||||
| 39 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18375 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) | 2025/12/03 11:40:37 | 0.5 s |
1/1
| ||||
| 38 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18375 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) | 2025/12/03 11:40:37 | 0.5 s |
1/1
| ||||
| 37 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18374 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) | 2025/12/03 11:26:47 | 0.5 s |
1/1
| ||||
| 36 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18374 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) | 2025/12/03 11:26:47 | 0.5 s |
1/1
| ||||
| 35 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18373 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) | 2025/12/03 09:42:30 | 0.5 s |
1/1
| ||||
| 34 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18373 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) | 2025/12/03 09:42:30 | 0.5 s |
1/1
| ||||
| 33 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18372 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) | 2025/12/02 15:14:41 | 0.5 s |
1/1
| ||||
| 32 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18372 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) | 2025/12/02 15:14:41 | 0.5 s |
1/1
| ||||
| 31 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18371 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) | 2025/12/02 10:27:50 | 0.5 s |
1/1
| ||||
| 30 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 9dea1f76-9518-4dce-ab99-3bdb11dea9a7
batch = 18371 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) | 2025/12/02 10:27:50 | 0.5 s |
1/1
|