Spark Jobs (?)

  • User: spark
  • Total Uptime: 1.5 h
  • Scheduling Mode: FIFO
  • Completed Jobs: 178
Event Timeline

Completed Jobs (178)

Page:
Job Id (Job Group) ▾ Description Submitted Duration Stages: Succeeded/Total Tasks (for all stages): Succeeded/Total
177 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 117 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 18:27:32 5 s 1/1
3/3
176 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 117 start at NativeMethodAccessorImpl.java:0 2026/06/17 18:27:32 4 s 1/1
3/3
175 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 116 start at NativeMethodAccessorImpl.java:0 2026/06/17 18:26:32 6 s 1/1
3/3
174 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 116 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 18:26:32 2 s 1/1
3/3
173 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 115 start at NativeMethodAccessorImpl.java:0 2026/06/17 18:25:32 5 s 1/1
3/3
172 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 115 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 18:25:32 2 s 1/1
3/3
171 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 114 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 18:24:32 5 s 1/1
3/3
170 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 114 start at NativeMethodAccessorImpl.java:0 2026/06/17 18:24:32 4 s 1/1
3/3
169 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 113 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 18:23:32 5 s 1/1
3/3
168 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 113 start at NativeMethodAccessorImpl.java:0 2026/06/17 18:23:31 4 s 1/1
3/3
167 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 112 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 18:22:32 5 s 1/1
3/3
166 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 112 start at NativeMethodAccessorImpl.java:0 2026/06/17 18:22:32 3 s 1/1
3/3
165 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 111 start at NativeMethodAccessorImpl.java:0 2026/06/17 18:21:32 5 s 1/1
3/3
164 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 111 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 18:21:31 2 s 1/1
3/3
163 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 110 start at NativeMethodAccessorImpl.java:0 2026/06/17 18:20:32 6 s 1/1
3/3
162 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 110 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 18:20:32 2 s 1/1
3/3
161 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 109 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 18:19:32 5 s 1/1
3/3
160 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 109 start at NativeMethodAccessorImpl.java:0 2026/06/17 18:19:32 4 s 1/1
3/3
159 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 108 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 18:18:32 5 s 1/1
3/3
158 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 108 start at NativeMethodAccessorImpl.java:0 2026/06/17 18:18:32 3 s 1/1
3/3
157 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 107 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 18:17:32 5 s 1/1
3/3
156 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 107 start at NativeMethodAccessorImpl.java:0 2026/06/17 18:17:32 4 s 1/1
3/3
155 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 106 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 18:16:32 5 s 1/1
3/3
154 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 106 start at NativeMethodAccessorImpl.java:0 2026/06/17 18:16:32 3 s 1/1
3/3
153 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 105 start at NativeMethodAccessorImpl.java:0 2026/06/17 18:15:32 6 s 1/1
3/3
152 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 105 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 18:15:32 2 s 1/1
3/3
151 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 104 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 18:14:32 6 s 1/1
3/3
150 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 104 start at NativeMethodAccessorImpl.java:0 2026/06/17 18:14:32 4 s 1/1
3/3
149 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 103 start at NativeMethodAccessorImpl.java:0 2026/06/17 18:13:32 5 s 1/1
3/3
148 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 103 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 18:13:32 2 s 1/1
3/3
147 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 102 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 18:12:32 5 s 1/1
3/3
146 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 102 start at NativeMethodAccessorImpl.java:0 2026/06/17 18:12:32 3 s 1/1
3/3
145 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 101 start at NativeMethodAccessorImpl.java:0 2026/06/17 18:11:32 5 s 1/1
3/3
144 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 101 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 18:11:32 2 s 1/1
3/3
143 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 100 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 18:10:32 6 s 1/1
3/3
142 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 100 start at NativeMethodAccessorImpl.java:0 2026/06/17 18:10:32 4 s 1/1
3/3
141 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 99 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 18:09:32 5 s 1/1
3/3
140 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 99 start at NativeMethodAccessorImpl.java:0 2026/06/17 18:09:32 4 s 1/1
3/3
139 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 98 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 18:08:32 5 s 1/1
3/3
138 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 98 start at NativeMethodAccessorImpl.java:0 2026/06/17 18:08:32 3 s 1/1
3/3
137 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 97 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 18:07:32 5 s 1/1
3/3
136 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 97 start at NativeMethodAccessorImpl.java:0 2026/06/17 18:07:31 3 s 1/1
3/3
135 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 96 start at NativeMethodAccessorImpl.java:0 2026/06/17 18:06:32 5 s 1/1
3/3
134 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 96 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 18:06:32 2 s 1/1
3/3
133 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 95 start at NativeMethodAccessorImpl.java:0 2026/06/17 18:05:32 6 s 1/1
3/3
132 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 95 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 18:05:32 2 s 1/1
3/3
131 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 94 start at NativeMethodAccessorImpl.java:0 2026/06/17 18:04:31 5 s 1/1
3/3
130 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 94 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 18:04:31 2 s 1/1
3/3
129 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 93 start at NativeMethodAccessorImpl.java:0 2026/06/17 18:03:32 5 s 1/1
3/3
128 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 93 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 18:03:32 2 s 1/1
3/3
127 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 92 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 18:02:32 6 s 1/1
3/3
126 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 92 start at NativeMethodAccessorImpl.java:0 2026/06/17 18:02:32 4 s 1/1
3/3
125 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 91 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 18:01:32 5 s 1/1
3/3
124 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 91 start at NativeMethodAccessorImpl.java:0 2026/06/17 18:01:32 4 s 1/1
3/3
123 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 90 start at NativeMethodAccessorImpl.java:0 2026/06/17 18:00:32 6 s 1/1
3/3
122 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 90 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 18:00:32 2 s 1/1
3/3
121 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 89 start at NativeMethodAccessorImpl.java:0 2026/06/17 17:59:32 5 s 1/1
3/3
120 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 89 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:59:32 2 s 1/1
3/3
119 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 88 start at NativeMethodAccessorImpl.java:0 2026/06/17 17:58:32 5 s 1/1
3/3
118 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 88 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:58:31 2 s 1/1
3/3
117 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 87 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:57:31 5 s 1/1
3/3
116 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 87 start at NativeMethodAccessorImpl.java:0 2026/06/17 17:57:31 4 s 1/1
3/3
115 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 86 start at NativeMethodAccessorImpl.java:0 2026/06/17 17:56:32 5 s 1/1
3/3
114 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 86 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:56:32 2 s 1/1
3/3
113 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 85 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:55:32 6 s 1/1
3/3
112 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 85 start at NativeMethodAccessorImpl.java:0 2026/06/17 17:55:32 4 s 1/1
3/3
111 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 84 start at NativeMethodAccessorImpl.java:0 2026/06/17 17:54:32 5 s 1/1
3/3
110 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 84 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:54:32 2 s 1/1
3/3
109 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 83 start at NativeMethodAccessorImpl.java:0 2026/06/17 17:53:32 5 s 1/1
3/3
108 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 83 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:53:31 2 s 1/1
3/3
107 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 82 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:52:32 6 s 1/1
3/3
106 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 82 start at NativeMethodAccessorImpl.java:0 2026/06/17 17:52:32 4 s 1/1
3/3
105 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 81 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:51:32 6 s 1/1
3/3
104 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 81 start at NativeMethodAccessorImpl.java:0 2026/06/17 17:51:32 4 s 1/1
3/3
103 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 80 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:50:32 5 s 1/1
3/3
102 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 80 start at NativeMethodAccessorImpl.java:0 2026/06/17 17:50:32 3 s 1/1
3/3
101 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 79 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:49:32 5 s 1/1
3/3
100 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 79 start at NativeMethodAccessorImpl.java:0 2026/06/17 17:49:32 4 s 1/1
3/3
99 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 78 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:48:32 5 s 1/1
3/3
98 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 78 start at NativeMethodAccessorImpl.java:0 2026/06/17 17:48:32 4 s 1/1
3/3
97 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 77 start at NativeMethodAccessorImpl.java:0 2026/06/17 17:47:32 7 s 1/1
4/4
96 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 77 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:47:32 2 s 1/1
4/4
95 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 76 start at NativeMethodAccessorImpl.java:0 2026/06/17 17:46:32 6 s 1/1
3/3
94 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 76 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:46:32 2 s 1/1
3/3
93 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 75 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:45:32 6 s 1/1
3/3
92 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 75 start at NativeMethodAccessorImpl.java:0 2026/06/17 17:45:32 4 s 1/1
3/3
91 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 74 start at NativeMethodAccessorImpl.java:0 2026/06/17 17:44:32 7 s 1/1
4/4
90 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 74 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:44:32 2 s 1/1
4/4
89 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 73 start at NativeMethodAccessorImpl.java:0 2026/06/17 17:43:32 5 s 1/1
3/3
88 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 73 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:43:32 2 s 1/1
3/3
87 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 72 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:42:32 5 s 1/1
3/3
86 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 72 start at NativeMethodAccessorImpl.java:0 2026/06/17 17:42:32 4 s 1/1
3/3
85 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 71 start at NativeMethodAccessorImpl.java:0 2026/06/17 17:41:32 5 s 1/1
3/3
84 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 71 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:41:32 2 s 1/1
3/3
83 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 70 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:40:32 5 s 1/1
3/3
82 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 70 start at NativeMethodAccessorImpl.java:0 2026/06/17 17:40:32 4 s 1/1
3/3
81 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 69 start at NativeMethodAccessorImpl.java:0 2026/06/17 17:39:32 7 s 1/1
4/4
80 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 69 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:39:32 2 s 1/1
4/4
79 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 68 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:38:32 5 s 1/1
3/3
78 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 68 start at NativeMethodAccessorImpl.java:0 2026/06/17 17:38:32 4 s 1/1
3/3
Page: