Spark Jobs (?)

  • User: spark
  • Total Uptime: 1.4 h
  • Scheduling Mode: FIFO
  • Completed Jobs: 169
Event Timeline

Completed Jobs (169)

Page:
Job Id (Job Group) ▾ Description Submitted Duration Stages: Succeeded/Total Tasks (for all stages): Succeeded/Total
168 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15799 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 16:13:32 5 s 1/1
3/3
167 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15801 start at NativeMethodAccessorImpl.java:0 2026/06/28 16:13:32 3 s 1/1
3/3
166 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15800 start at NativeMethodAccessorImpl.java:0 2026/06/28 16:12:32 5 s 1/1
3/3
165 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15798 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 16:12:32 2 s 1/1
3/3
164 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15799 start at NativeMethodAccessorImpl.java:0 2026/06/28 16:11:32 5 s 1/1
3/3
163 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15797 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 16:11:32 2 s 1/1
3/3
162 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15796 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 16:10:32 5 s 1/1
3/3
161 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15798 start at NativeMethodAccessorImpl.java:0 2026/06/28 16:10:32 4 s 1/1
3/3
160 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15795 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 16:09:32 5 s 1/1
3/3
159 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15797 start at NativeMethodAccessorImpl.java:0 2026/06/28 16:09:32 4 s 1/1
3/3
158 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15796 start at NativeMethodAccessorImpl.java:0 2026/06/28 16:08:32 6 s 1/1
3/3
157 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15794 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 16:08:32 2 s 1/1
3/3
156 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15795 start at NativeMethodAccessorImpl.java:0 2026/06/28 16:07:32 5 s 1/1
3/3
155 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15793 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 16:07:32 2 s 1/1
3/3
154 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15792 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 16:06:32 5 s 1/1
3/3
153 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15794 start at NativeMethodAccessorImpl.java:0 2026/06/28 16:06:31 4 s 1/1
3/3
152 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15793 start at NativeMethodAccessorImpl.java:0 2026/06/28 16:05:32 6 s 1/1
3/3
151 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15791 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 16:05:32 2 s 1/1
3/3
150 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15792 start at NativeMethodAccessorImpl.java:0 2026/06/28 16:04:32 6 s 1/1
3/3
149 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15790 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 16:04:32 2 s 1/1
3/3
148 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15791 start at NativeMethodAccessorImpl.java:0 2026/06/28 16:03:33 5 s 1/1
3/3
147 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15789 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 16:03:32 2 s 1/1
3/3
146 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15788 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 16:02:32 6 s 1/1
3/3
145 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15790 start at NativeMethodAccessorImpl.java:0 2026/06/28 16:02:32 4 s 1/1
3/3
144 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15787 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 16:01:32 6 s 1/1
3/3
143 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15789 start at NativeMethodAccessorImpl.java:0 2026/06/28 16:01:32 4 s 1/1
3/3
142 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15786 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 16:00:32 5 s 1/1
3/3
141 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15788 start at NativeMethodAccessorImpl.java:0 2026/06/28 16:00:32 4 s 1/1
3/3
140 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15785 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 15:59:32 6 s 1/1
3/3
139 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15787 start at NativeMethodAccessorImpl.java:0 2026/06/28 15:59:32 4 s 1/1
3/3
138 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15786 start at NativeMethodAccessorImpl.java:0 2026/06/28 15:58:32 5 s 1/1
3/3
137 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15784 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 15:58:32 2 s 1/1
3/3
136 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15785 start at NativeMethodAccessorImpl.java:0 2026/06/28 15:57:32 5 s 1/1
3/3
135 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15783 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 15:57:32 2 s 1/1
3/3
134 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15784 start at NativeMethodAccessorImpl.java:0 2026/06/28 15:56:32 5 s 1/1
3/3
133 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15782 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 15:56:32 2 s 1/1
3/3
132 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15783 start at NativeMethodAccessorImpl.java:0 2026/06/28 15:55:32 5 s 1/1
3/3
131 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15781 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 15:55:32 2 s 1/1
3/3
130 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15780 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 15:54:32 4 s 1/1
3/3
129 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15782 start at NativeMethodAccessorImpl.java:0 2026/06/28 15:54:32 3 s 1/1
3/3
128 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15779 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 15:53:32 5 s 1/1
3/3
127 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15781 start at NativeMethodAccessorImpl.java:0 2026/06/28 15:53:32 3 s 1/1
3/3
126 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15780 start at NativeMethodAccessorImpl.java:0 2026/06/28 15:52:32 5 s 1/1
3/3
125 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15778 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 15:52:32 2 s 1/1
3/3
124 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15777 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 15:51:32 6 s 1/1
3/3
123 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15779 start at NativeMethodAccessorImpl.java:0 2026/06/28 15:51:32 4 s 1/1
3/3
122 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15776 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 15:50:32 5 s 1/1
3/3
121 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15778 start at NativeMethodAccessorImpl.java:0 2026/06/28 15:50:32 4 s 1/1
3/3
120 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15775 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 15:49:32 6 s 1/1
3/3
119 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15777 start at NativeMethodAccessorImpl.java:0 2026/06/28 15:49:32 4 s 1/1
3/3
118 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15774 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 15:48:32 5 s 1/1
3/3
117 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15776 start at NativeMethodAccessorImpl.java:0 2026/06/28 15:48:32 4 s 1/1
3/3
116 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15773 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 15:47:32 5 s 1/1
3/3
115 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15775 start at NativeMethodAccessorImpl.java:0 2026/06/28 15:47:32 3 s 1/1
3/3
114 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15774 start at NativeMethodAccessorImpl.java:0 2026/06/28 15:46:32 5 s 1/1
3/3
113 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15772 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 15:46:32 2 s 1/1
3/3
112 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15771 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 15:45:32 5 s 1/1
3/3
111 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15773 start at NativeMethodAccessorImpl.java:0 2026/06/28 15:45:32 4 s 1/1
3/3
110 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15772 start at NativeMethodAccessorImpl.java:0 2026/06/28 15:44:32 5 s 1/1
3/3
109 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15770 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 15:44:32 2 s 1/1
3/3
108 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15771 start at NativeMethodAccessorImpl.java:0 2026/06/28 15:43:32 6 s 1/1
3/3
107 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15769 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 15:43:32 3 s 1/1
3/3
106 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15770 start at NativeMethodAccessorImpl.java:0 2026/06/28 15:42:33 5 s 1/1
3/3
105 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15768 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 15:42:32 2 s 1/1
3/3
104 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15769 start at NativeMethodAccessorImpl.java:0 2026/06/28 15:41:32 6 s 1/1
3/3
103 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15767 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 15:41:32 2 s 1/1
3/3
102 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15768 start at NativeMethodAccessorImpl.java:0 2026/06/28 15:40:32 6 s 1/1
3/3
101 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15766 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 15:40:32 2 s 1/1
3/3
100 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15767 start at NativeMethodAccessorImpl.java:0 2026/06/28 15:39:32 5 s 1/1
3/3
99 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15765 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 15:39:32 2 s 1/1
3/3
98 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15766 start at NativeMethodAccessorImpl.java:0 2026/06/28 15:38:32 5 s 1/1
3/3
97 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15764 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 15:38:32 2 s 1/1
3/3
96 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15763 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 15:37:32 5 s 1/1
3/3
95 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15765 start at NativeMethodAccessorImpl.java:0 2026/06/28 15:37:31 3 s 1/1
3/3
94 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15764 start at NativeMethodAccessorImpl.java:0 2026/06/28 15:36:32 5 s 1/1
3/3
93 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15762 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 15:36:32 2 s 1/1
3/3
92 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15763 start at NativeMethodAccessorImpl.java:0 2026/06/28 15:35:32 7 s 1/1
4/4
91 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15761 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 15:35:32 3 s 1/1
4/4
90 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15762 start at NativeMethodAccessorImpl.java:0 2026/06/28 15:34:32 5 s 1/1
3/3
89 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15760 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 15:34:32 2 s 1/1
3/3
88 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15761 start at NativeMethodAccessorImpl.java:0 2026/06/28 15:33:32 6 s 1/1
3/3
87 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15759 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 15:33:32 2 s 1/1
3/3
86 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15758 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 15:32:32 6 s 1/1
3/3
85 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15760 start at NativeMethodAccessorImpl.java:0 2026/06/28 15:32:32 4 s 1/1
3/3
84 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15759 start at NativeMethodAccessorImpl.java:0 2026/06/28 15:31:32 5 s 1/1
3/3
83 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15757 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 15:31:32 2 s 1/1
3/3
82 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15756 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 15:30:32 5 s 1/1
3/3
81 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15758 start at NativeMethodAccessorImpl.java:0 2026/06/28 15:30:32 4 s 1/1
3/3
80 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15757 start at NativeMethodAccessorImpl.java:0 2026/06/28 15:29:32 5 s 1/1
3/3
79 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15755 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 15:29:32 2 s 1/1
3/3
78 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15754 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 15:28:32 6 s 1/1
3/3
77 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15756 start at NativeMethodAccessorImpl.java:0 2026/06/28 15:28:32 4 s 1/1
3/3
76 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15753 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 15:27:32 5 s 1/1
3/3
75 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15755 start at NativeMethodAccessorImpl.java:0 2026/06/28 15:27:32 4 s 1/1
3/3
74 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15752 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 15:26:32 5 s 1/1
3/3
73 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15754 start at NativeMethodAccessorImpl.java:0 2026/06/28 15:26:32 4 s 1/1
3/3
72 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15751 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 15:25:32 5 s 1/1
3/3
71 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15753 start at NativeMethodAccessorImpl.java:0 2026/06/28 15:25:32 3 s 1/1
3/3
70 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15750 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 15:24:32 5 s 1/1
3/3
69 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15752 start at NativeMethodAccessorImpl.java:0 2026/06/28 15:24:32 3 s 1/1
3/3
Page: