See
<https://ci-beam.apache.org/job/beam_LoadTests_Java_ParDo_Dataflow_V2_Batch_Java17/117/display/redirect?page=changes>
Changes:
[pandiana] BigQueryServicesImpl: reduce number of threads spawned by
[noreply] [BEAM-13204] Fix website bug where code tabs do not appear if the
------------------------------------------
[...truncated 169.87 KB...]
Apr 16, 2022 1:05:21 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:20.254Z: Fusing consumer Step:
115/ParMultiDo(CounterOperation) into Step: 114/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:21 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:20.275Z: Fusing consumer Step:
116/ParMultiDo(CounterOperation) into Step: 115/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:21 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:20.306Z: Fusing consumer Step:
117/ParMultiDo(CounterOperation) into Step: 116/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:21 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:20.328Z: Fusing consumer Step:
118/ParMultiDo(CounterOperation) into Step: 117/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:21 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:20.350Z: Fusing consumer Step:
119/ParMultiDo(CounterOperation) into Step: 118/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:21 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:20.391Z: Fusing consumer Step:
120/ParMultiDo(CounterOperation) into Step: 119/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:21 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:20.413Z: Fusing consumer Step:
121/ParMultiDo(CounterOperation) into Step: 120/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:21 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:20.466Z: Fusing consumer Step:
122/ParMultiDo(CounterOperation) into Step: 121/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:21 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:20.491Z: Fusing consumer Step:
123/ParMultiDo(CounterOperation) into Step: 122/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:21 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:20.523Z: Fusing consumer Step:
124/ParMultiDo(CounterOperation) into Step: 123/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:21 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:20.554Z: Fusing consumer Step:
125/ParMultiDo(CounterOperation) into Step: 124/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:21 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:20.586Z: Fusing consumer Step:
126/ParMultiDo(CounterOperation) into Step: 125/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:21 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:20.618Z: Fusing consumer Step:
127/ParMultiDo(CounterOperation) into Step: 126/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:21 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:20.651Z: Fusing consumer Step:
128/ParMultiDo(CounterOperation) into Step: 127/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:21 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:20.672Z: Fusing consumer Step:
129/ParMultiDo(CounterOperation) into Step: 128/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:21 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:20.703Z: Fusing consumer Step:
130/ParMultiDo(CounterOperation) into Step: 129/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:21 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:20.734Z: Fusing consumer Step:
131/ParMultiDo(CounterOperation) into Step: 130/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:21 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:20.766Z: Fusing consumer Step:
132/ParMultiDo(CounterOperation) into Step: 131/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:21 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:20.799Z: Fusing consumer Step:
133/ParMultiDo(CounterOperation) into Step: 132/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:23 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:20.984Z: Fusing consumer Step:
134/ParMultiDo(CounterOperation) into Step: 133/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:23 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:21.453Z: Fusing consumer Step:
135/ParMultiDo(CounterOperation) into Step: 134/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:23 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:21.489Z: Fusing consumer Step:
136/ParMultiDo(CounterOperation) into Step: 135/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:23 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:21.520Z: Fusing consumer Step:
137/ParMultiDo(CounterOperation) into Step: 136/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:23 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:21.553Z: Fusing consumer Step:
138/ParMultiDo(CounterOperation) into Step: 137/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:23 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:21.584Z: Fusing consumer Step:
139/ParMultiDo(CounterOperation) into Step: 138/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:23 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:21.615Z: Fusing consumer Step:
140/ParMultiDo(CounterOperation) into Step: 139/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:23 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:21.638Z: Fusing consumer Step:
141/ParMultiDo(CounterOperation) into Step: 140/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:23 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:21.663Z: Fusing consumer Step:
142/ParMultiDo(CounterOperation) into Step: 141/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:23 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:21.693Z: Fusing consumer Step:
143/ParMultiDo(CounterOperation) into Step: 142/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:23 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:21.713Z: Fusing consumer Step:
144/ParMultiDo(CounterOperation) into Step: 143/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:23 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:21.735Z: Fusing consumer Step:
145/ParMultiDo(CounterOperation) into Step: 144/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:23 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:21.770Z: Fusing consumer Step:
146/ParMultiDo(CounterOperation) into Step: 145/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:23 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:22.138Z: Fusing consumer Step:
147/ParMultiDo(CounterOperation) into Step: 146/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:23 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:22.357Z: Fusing consumer Step:
148/ParMultiDo(CounterOperation) into Step: 147/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:23 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:22.572Z: Fusing consumer Step:
149/ParMultiDo(CounterOperation) into Step: 148/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:23 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:22.676Z: Fusing consumer Step:
150/ParMultiDo(CounterOperation) into Step: 149/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:23 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:22.890Z: Fusing consumer Step:
151/ParMultiDo(CounterOperation) into Step: 150/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:23 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:22.965Z: Fusing consumer Step:
152/ParMultiDo(CounterOperation) into Step: 151/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:23 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:22.998Z: Fusing consumer Step:
153/ParMultiDo(CounterOperation) into Step: 152/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:23 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:23.046Z: Fusing consumer Step:
154/ParMultiDo(CounterOperation) into Step: 153/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:25 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:23.077Z: Fusing consumer Step:
155/ParMultiDo(CounterOperation) into Step: 154/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:25 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:23.109Z: Fusing consumer Step:
156/ParMultiDo(CounterOperation) into Step: 155/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:25 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:23.142Z: Fusing consumer Step:
157/ParMultiDo(CounterOperation) into Step: 156/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:25 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:23.175Z: Fusing consumer Step:
158/ParMultiDo(CounterOperation) into Step: 157/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:25 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:23.206Z: Fusing consumer Step:
159/ParMultiDo(CounterOperation) into Step: 158/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:25 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:23.229Z: Fusing consumer Step:
160/ParMultiDo(CounterOperation) into Step: 159/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:25 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:23.260Z: Fusing consumer Step:
161/ParMultiDo(CounterOperation) into Step: 160/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:25 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:23.282Z: Fusing consumer Step:
162/ParMultiDo(CounterOperation) into Step: 161/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:25 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:23.304Z: Fusing consumer Step:
163/ParMultiDo(CounterOperation) into Step: 162/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:25 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:23.337Z: Fusing consumer Step:
164/ParMultiDo(CounterOperation) into Step: 163/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:25 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:23.411Z: Fusing consumer Step:
165/ParMultiDo(CounterOperation) into Step: 164/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:25 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:23.464Z: Fusing consumer Step:
166/ParMultiDo(CounterOperation) into Step: 165/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:25 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:23.488Z: Fusing consumer Step:
167/ParMultiDo(CounterOperation) into Step: 166/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:25 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:23.522Z: Fusing consumer Step:
168/ParMultiDo(CounterOperation) into Step: 167/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:25 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:23.545Z: Fusing consumer Step:
169/ParMultiDo(CounterOperation) into Step: 168/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:25 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:23.577Z: Fusing consumer Step:
170/ParMultiDo(CounterOperation) into Step: 169/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:25 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:23.611Z: Fusing consumer Step:
171/ParMultiDo(CounterOperation) into Step: 170/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:25 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:23.761Z: Fusing consumer Step:
172/ParMultiDo(CounterOperation) into Step: 171/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:25 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:23.938Z: Fusing consumer Step:
173/ParMultiDo(CounterOperation) into Step: 172/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:25 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:24.060Z: Fusing consumer Step:
174/ParMultiDo(CounterOperation) into Step: 173/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:25 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:24.169Z: Fusing consumer Step:
175/ParMultiDo(CounterOperation) into Step: 174/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:25 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:24.599Z: Fusing consumer Step:
176/ParMultiDo(CounterOperation) into Step: 175/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:25 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:24.656Z: Fusing consumer Step:
177/ParMultiDo(CounterOperation) into Step: 176/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:25 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:24.971Z: Fusing consumer Step:
178/ParMultiDo(CounterOperation) into Step: 177/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:25 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:25.177Z: Fusing consumer Step:
179/ParMultiDo(CounterOperation) into Step: 178/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:25 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:25.279Z: Fusing consumer Step:
180/ParMultiDo(CounterOperation) into Step: 179/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:27 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:25.458Z: Fusing consumer Step:
181/ParMultiDo(CounterOperation) into Step: 180/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:27 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:25.601Z: Fusing consumer Step:
182/ParMultiDo(CounterOperation) into Step: 181/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:27 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:25.864Z: Fusing consumer Step:
183/ParMultiDo(CounterOperation) into Step: 182/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:27 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:25.915Z: Fusing consumer Step:
184/ParMultiDo(CounterOperation) into Step: 183/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:27 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:25.937Z: Fusing consumer Step:
185/ParMultiDo(CounterOperation) into Step: 184/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:27 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:25.968Z: Fusing consumer Step:
186/ParMultiDo(CounterOperation) into Step: 185/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:27 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:25.989Z: Fusing consumer Step:
187/ParMultiDo(CounterOperation) into Step: 186/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:27 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:26.010Z: Fusing consumer Step:
188/ParMultiDo(CounterOperation) into Step: 187/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:27 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:26.042Z: Fusing consumer Step:
189/ParMultiDo(CounterOperation) into Step: 188/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:27 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:26.074Z: Fusing consumer Step:
190/ParMultiDo(CounterOperation) into Step: 189/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:27 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:26.106Z: Fusing consumer Step:
191/ParMultiDo(CounterOperation) into Step: 190/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:27 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:26.136Z: Fusing consumer Step:
192/ParMultiDo(CounterOperation) into Step: 191/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:27 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:26.168Z: Fusing consumer Step:
193/ParMultiDo(CounterOperation) into Step: 192/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:27 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:26.200Z: Fusing consumer Step:
194/ParMultiDo(CounterOperation) into Step: 193/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:27 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:26.232Z: Fusing consumer Step:
195/ParMultiDo(CounterOperation) into Step: 194/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:27 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:26.264Z: Fusing consumer Step:
196/ParMultiDo(CounterOperation) into Step: 195/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:27 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:26.295Z: Fusing consumer Step:
197/ParMultiDo(CounterOperation) into Step: 196/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:27 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:26.328Z: Fusing consumer Step:
198/ParMultiDo(CounterOperation) into Step: 197/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:27 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:26.359Z: Fusing consumer Step:
199/ParMultiDo(CounterOperation) into Step: 198/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:27 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:26.412Z: Fusing consumer
ParDo(TimeMonitor)2/ParMultiDo(TimeMonitor) into Step:
199/ParMultiDo(CounterOperation)
Apr 16, 2022 1:05:27 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:26.782Z: Executing operation Read input/Impulse+Read
input/ParDo(OutputSingleSource)/ParMultiDo(OutputSingleSource)+Read-input-ParDo-BoundedSourceAsSDFWrapper--ParMultiDo-BoundedSourceAsSDFWrapper-/PairWithRestriction+Read-input-ParDo-BoundedSourceAsSDFWrapper--ParMultiDo-BoundedSourceAsSDFWrapper-/SplitWithSizing
Apr 16, 2022 1:05:27 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:05:26.857Z: Starting 5 ****s in us-central1-b...
Apr 16, 2022 1:06:10 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:06:09.765Z: Autoscaling: Raised the number of ****s to 5
based on the rate of progress in the currently running stage(s).
Apr 16, 2022 1:07:07 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:07:06.763Z: Workers have started successfully.
Apr 16, 2022 1:07:21 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:07:19.510Z: Finished operation Read input/Impulse+Read
input/ParDo(OutputSingleSource)/ParMultiDo(OutputSingleSource)+Read-input-ParDo-BoundedSourceAsSDFWrapper--ParMultiDo-BoundedSourceAsSDFWrapper-/PairWithRestriction+Read-input-ParDo-BoundedSourceAsSDFWrapper--ParMultiDo-BoundedSourceAsSDFWrapper-/SplitWithSizing
Apr 16, 2022 1:07:21 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:07:19.651Z: Executing operation
Read-input-ParDo-BoundedSourceAsSDFWrapper--ParMultiDo-BoundedSourceAsSDFWrapper-/ProcessElementAndRestrictionWithSizing+ParDo(TimeMonitor)/ParMultiDo(TimeMonitor)+ParDo(ByteMonitor)/ParMultiDo(ByteMonitor)+Step:
0/ParMultiDo(CounterOperation)+Step: 1/ParMultiDo(CounterOperation)+Step:
2/ParMultiDo(CounterOperation)+Step: 3/ParMultiDo(CounterOperation)+Step:
4/ParMultiDo(CounterOperation)+Step: 5/ParMultiDo(CounterOperation)+Step:
6/ParMultiDo(CounterOperation)+Step: 7/ParMultiDo(CounterOperation)+Step:
8/ParMultiDo(CounterOperation)+Step: 9/ParMultiDo(CounterOperation)+Step:
10/ParMultiDo(CounterOperation)+Step: 11/ParMultiDo(CounterOperation)+Step:
12/ParMultiDo(CounterOperation)+Step: 13/ParMultiDo(CounterOperation)+Step:
14/ParMultiDo(CounterOperation)+Step: 15/ParMultiDo(CounterOperation)+Step:
16/ParMultiDo(CounterOperation)+Step: 17/ParMultiDo(CounterOperation)+Step:
18/ParMultiDo(CounterOperation)+Step: 19/ParMultiDo(CounterOperation)+Step:
20/ParMultiDo(CounterOperation)+Step: 21/ParMultiDo(CounterOperation)+Step:
22/ParMultiDo(CounterOperation)+Step: 23/ParMultiDo(CounterOperation)+Step:
24/ParMultiDo(CounterOperation)+Step: 25/ParMultiDo(CounterOperation)+Step:
26/ParMultiDo(CounterOperation)+Step: 27/ParMultiDo(CounterOperation)+Step:
28/ParMultiDo(CounterOperation)+Step: 29/ParMultiDo(CounterOperation)+Step:
30/ParMultiDo(CounterOperation)+Step: 31/ParMultiDo(CounterOperation)+Step:
32/ParMultiDo(CounterOperation)+Step: 33/ParMultiDo(CounterOperation)+Step:
34/ParMultiDo(CounterOperation)+Step: 35/ParMultiDo(CounterOperation)+Step:
36/ParMultiDo(CounterOperation)+Step: 37/ParMultiDo(CounterOperation)+Step:
38/ParMultiDo(CounterOperation)+Step: 39/ParMultiDo(CounterOperation)+Step:
40/ParMultiDo(CounterOperation)+Step: 41/ParMultiDo(CounterOperation)+Step:
42/ParMultiDo(CounterOperation)+Step: 43/ParMultiDo(CounterOperation)+Step:
44/ParMultiDo(CounterOperation)+Step: 45/ParMultiDo(CounterOperation)+Step:
46/ParMultiDo(CounterOperation)+Step: 47/ParMultiDo(CounterOperation)+Step:
48/ParMultiDo(CounterOperation)+Step: 49/ParMultiDo(CounterOperation)+Step:
50/ParMultiDo(CounterOperation)+Step: 51/ParMultiDo(CounterOperation)+Step:
52/ParMultiDo(CounterOperation)+Step: 53/ParMultiDo(CounterOperation)+Step:
54/ParMultiDo(CounterOperation)+Step: 55/ParMultiDo(CounterOperation)+Step:
56/ParMultiDo(CounterOperation)+Step: 57/ParMultiDo(CounterOperation)+Step:
58/ParMultiDo(CounterOperation)+Step: 59/ParMultiDo(CounterOperation)+Step:
60/ParMultiDo(CounterOperation)+Step: 61/ParMultiDo(CounterOperation)+Step:
62/ParMultiDo(CounterOperation)+Step: 63/ParMultiDo(CounterOperation)+Step:
64/ParMultiDo(CounterOperation)+Step: 65/ParMultiDo(CounterOperation)+Step:
66/ParMultiDo(CounterOperation)+Step: 67/ParMultiDo(CounterOperation)+Step:
68/ParMultiDo(CounterOperation)+Step: 69/ParMultiDo(CounterOperation)+Step:
70/ParMultiDo(CounterOperation)+Step: 71/ParMultiDo(CounterOperation)+Step:
72/ParMultiDo(CounterOperation)+Step: 73/ParMultiDo(CounterOperation)+Step:
74/ParMultiDo(CounterOperation)+Step: 75/ParMultiDo(CounterOperation)+Step:
76/ParMultiDo(CounterOperation)+Step: 77/ParMultiDo(CounterOperation)+Step:
78/ParMultiDo(CounterOperation)+Step: 79/ParMultiDo(CounterOperation)+Step:
80/ParMultiDo(CounterOperation)+Step: 81/ParMultiDo(CounterOperation)+Step:
82/ParMultiDo(CounterOperation)+Step: 83/ParMultiDo(CounterOperation)+Step:
84/ParMultiDo(CounterOperation)+Step: 85/ParMultiDo(CounterOperation)+Step:
86/ParMultiDo(CounterOperation)+Step: 87/ParMultiDo(CounterOperation)+Step:
88/ParMultiDo(CounterOperation)+Step: 89/ParMultiDo(CounterOperation)+Step:
90/ParMultiDo(CounterOperation)+Step: 91/ParMultiDo(CounterOperation)+Step:
92/ParMultiDo(CounterOperation)+Step: 93/ParMultiDo(CounterOperation)+Step:
94/ParMultiDo(CounterOperation)+Step: 95/ParMultiDo(CounterOperation)+Step:
96/ParMultiDo(CounterOperation)+Step: 97/ParMultiDo(CounterOperation)+Step:
98/ParMultiDo(CounterOperation)+Step: 99/ParMultiDo(CounterOperation)+Step:
100/ParMultiDo(CounterOperation)+Step: 101/ParMultiDo(CounterOperation)+Step:
102/ParMultiDo(CounterOperation)+Step: 103/ParMultiDo(CounterOperation)+Step:
104/ParMultiDo(CounterOperation)+Step: 105/ParMultiDo(CounterOperation)+Step:
106/ParMultiDo(CounterOperation)+Step: 107/ParMultiDo(CounterOperation)+Step:
108/ParMultiDo(CounterOperation)+Step: 109/ParMultiDo(CounterOperation)+Step:
110/ParMultiDo(CounterOperation)+Step: 111/ParMultiDo(CounterOperation)+Step:
112/ParMultiDo(CounterOperation)+Step: 113/ParMultiDo(CounterOperation)+Step:
114/ParMultiDo(CounterOperation)+Step: 115/ParMultiDo(CounterOperation)+Step:
116/ParMultiDo(CounterOperation)+Step: 117/ParMultiDo(CounterOperation)+Step:
118/ParMultiDo(CounterOperation)+Step: 119/ParMultiDo(CounterOperation)+Step:
120/ParMultiDo(CounterOperation)+Step: 121/ParMultiDo(CounterOperation)+Step:
122/ParMultiDo(CounterOperation)+Step: 123/ParMultiDo(CounterOperation)+Step:
124/ParMultiDo(CounterOperation)+Step: 125/ParMultiDo(CounterOperation)+Step:
126/ParMultiDo(CounterOperation)+Step: 127/ParMultiDo(CounterOperation)+Step:
128/ParMultiDo(CounterOperation)+Step: 129/ParMultiDo(CounterOperation)+Step:
130/ParMultiDo(CounterOperation)+Step: 131/ParMultiDo(CounterOperation)+Step:
132/ParMultiDo(CounterOperation)+Step: 133/ParMultiDo(CounterOperation)+Step:
134/ParMultiDo(CounterOperation)+Step: 135/ParMultiDo(CounterOperation)+Step:
136/ParMultiDo(CounterOperation)+Step: 137/ParMultiDo(CounterOperation)+Step:
138/ParMultiDo(CounterOperation)+Step: 139/ParMultiDo(CounterOperation)+Step:
140/ParMultiDo(CounterOperation)+Step: 141/ParMultiDo(CounterOperation)+Step:
142/ParMultiDo(CounterOperation)+Step: 143/ParMultiDo(CounterOperation)+Step:
144/ParMultiDo(CounterOperation)+Step: 145/ParMultiDo(CounterOperation)+Step:
146/ParMultiDo(CounterOperation)+Step: 147/ParMultiDo(CounterOperation)+Step:
148/ParMultiDo(CounterOperation)+Step: 149/ParMultiDo(CounterOperation)+Step:
150/ParMultiDo(CounterOperation)+Step: 151/ParMultiDo(CounterOperation)+Step:
152/ParMultiDo(CounterOperation)+Step: 153/ParMultiDo(CounterOperation)+Step:
154/ParMultiDo(CounterOperation)+Step: 155/ParMultiDo(CounterOperation)+Step:
156/ParMultiDo(CounterOperation)+Step: 157/ParMultiDo(CounterOperation)+Step:
158/ParMultiDo(CounterOperation)+Step: 159/ParMultiDo(CounterOperation)+Step:
160/ParMultiDo(CounterOperation)+Step: 161/ParMultiDo(CounterOperation)+Step:
162/ParMultiDo(CounterOperation)+Step: 163/ParMultiDo(CounterOperation)+Step:
164/ParMultiDo(CounterOperation)+Step: 165/ParMultiDo(CounterOperation)+Step:
166/ParMultiDo(CounterOperation)+Step: 167/ParMultiDo(CounterOperation)+Step:
168/ParMultiDo(CounterOperation)+Step: 169/ParMultiDo(CounterOperation)+Step:
170/ParMultiDo(CounterOperation)+Step: 171/ParMultiDo(CounterOperation)+Step:
172/ParMultiDo(CounterOperation)+Step: 173/ParMultiDo(CounterOperation)+Step:
174/ParMultiDo(CounterOperation)+Step: 175/ParMultiDo(CounterOperation)+Step:
176/ParMultiDo(CounterOperation)+Step: 177/ParMultiDo(CounterOperation)+Step:
178/ParMultiDo(CounterOperation)+Step: 179/ParMultiDo(CounterOperation)+Step:
180/ParMultiDo(CounterOperation)+Step: 181/ParMultiDo(CounterOperation)+Step:
182/ParMultiDo(CounterOperation)+Step: 183/ParMultiDo(CounterOperation)+Step:
184/ParMultiDo(CounterOperation)+Step: 185/ParMultiDo(CounterOperation)+Step:
186/ParMultiDo(CounterOperation)+Step: 187/ParMultiDo(CounterOperation)+Step:
188/ParMultiDo(CounterOperation)+Step: 189/ParMultiDo(CounterOperation)+Step:
190/ParMultiDo(CounterOperation)+Step: 191/ParMultiDo(CounterOperation)+Step:
192/ParMultiDo(CounterOperation)+Step: 193/ParMultiDo(CounterOperation)+Step:
194/ParMultiDo(CounterOperation)+Step: 195/ParMultiDo(CounterOperation)+Step:
196/ParMultiDo(CounterOperation)+Step: 197/ParMultiDo(CounterOperation)+Step:
198/ParMultiDo(CounterOperation)+Step:
199/ParMultiDo(CounterOperation)+ParDo(TimeMonitor)2/ParMultiDo(TimeMonitor)
Apr 16, 2022 1:08:37 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:08:35.823Z: Finished operation
Read-input-ParDo-BoundedSourceAsSDFWrapper--ParMultiDo-BoundedSourceAsSDFWrapper-/ProcessElementAndRestrictionWithSizing+ParDo(TimeMonitor)/ParMultiDo(TimeMonitor)+ParDo(ByteMonitor)/ParMultiDo(ByteMonitor)+Step:
0/ParMultiDo(CounterOperation)+Step: 1/ParMultiDo(CounterOperation)+Step:
2/ParMultiDo(CounterOperation)+Step: 3/ParMultiDo(CounterOperation)+Step:
4/ParMultiDo(CounterOperation)+Step: 5/ParMultiDo(CounterOperation)+Step:
6/ParMultiDo(CounterOperation)+Step: 7/ParMultiDo(CounterOperation)+Step:
8/ParMultiDo(CounterOperation)+Step: 9/ParMultiDo(CounterOperation)+Step:
10/ParMultiDo(CounterOperation)+Step: 11/ParMultiDo(CounterOperation)+Step:
12/ParMultiDo(CounterOperation)+Step: 13/ParMultiDo(CounterOperation)+Step:
14/ParMultiDo(CounterOperation)+Step: 15/ParMultiDo(CounterOperation)+Step:
16/ParMultiDo(CounterOperation)+Step: 17/ParMultiDo(CounterOperation)+Step:
18/ParMultiDo(CounterOperation)+Step: 19/ParMultiDo(CounterOperation)+Step:
20/ParMultiDo(CounterOperation)+Step: 21/ParMultiDo(CounterOperation)+Step:
22/ParMultiDo(CounterOperation)+Step: 23/ParMultiDo(CounterOperation)+Step:
24/ParMultiDo(CounterOperation)+Step: 25/ParMultiDo(CounterOperation)+Step:
26/ParMultiDo(CounterOperation)+Step: 27/ParMultiDo(CounterOperation)+Step:
28/ParMultiDo(CounterOperation)+Step: 29/ParMultiDo(CounterOperation)+Step:
30/ParMultiDo(CounterOperation)+Step: 31/ParMultiDo(CounterOperation)+Step:
32/ParMultiDo(CounterOperation)+Step: 33/ParMultiDo(CounterOperation)+Step:
34/ParMultiDo(CounterOperation)+Step: 35/ParMultiDo(CounterOperation)+Step:
36/ParMultiDo(CounterOperation)+Step: 37/ParMultiDo(CounterOperation)+Step:
38/ParMultiDo(CounterOperation)+Step: 39/ParMultiDo(CounterOperation)+Step:
40/ParMultiDo(CounterOperation)+Step: 41/ParMultiDo(CounterOperation)+Step:
42/ParMultiDo(CounterOperation)+Step: 43/ParMultiDo(CounterOperation)+Step:
44/ParMultiDo(CounterOperation)+Step: 45/ParMultiDo(CounterOperation)+Step:
46/ParMultiDo(CounterOperation)+Step: 47/ParMultiDo(CounterOperation)+Step:
48/ParMultiDo(CounterOperation)+Step: 49/ParMultiDo(CounterOperation)+Step:
50/ParMultiDo(CounterOperation)+Step: 51/ParMultiDo(CounterOperation)+Step:
52/ParMultiDo(CounterOperation)+Step: 53/ParMultiDo(CounterOperation)+Step:
54/ParMultiDo(CounterOperation)+Step: 55/ParMultiDo(CounterOperation)+Step:
56/ParMultiDo(CounterOperation)+Step: 57/ParMultiDo(CounterOperation)+Step:
58/ParMultiDo(CounterOperation)+Step: 59/ParMultiDo(CounterOperation)+Step:
60/ParMultiDo(CounterOperation)+Step: 61/ParMultiDo(CounterOperation)+Step:
62/ParMultiDo(CounterOperation)+Step: 63/ParMultiDo(CounterOperation)+Step:
64/ParMultiDo(CounterOperation)+Step: 65/ParMultiDo(CounterOperation)+Step:
66/ParMultiDo(CounterOperation)+Step: 67/ParMultiDo(CounterOperation)+Step:
68/ParMultiDo(CounterOperation)+Step: 69/ParMultiDo(CounterOperation)+Step:
70/ParMultiDo(CounterOperation)+Step: 71/ParMultiDo(CounterOperation)+Step:
72/ParMultiDo(CounterOperation)+Step: 73/ParMultiDo(CounterOperation)+Step:
74/ParMultiDo(CounterOperation)+Step: 75/ParMultiDo(CounterOperation)+Step:
76/ParMultiDo(CounterOperation)+Step: 77/ParMultiDo(CounterOperation)+Step:
78/ParMultiDo(CounterOperation)+Step: 79/ParMultiDo(CounterOperation)+Step:
80/ParMultiDo(CounterOperation)+Step: 81/ParMultiDo(CounterOperation)+Step:
82/ParMultiDo(CounterOperation)+Step: 83/ParMultiDo(CounterOperation)+Step:
84/ParMultiDo(CounterOperation)+Step: 85/ParMultiDo(CounterOperation)+Step:
86/ParMultiDo(CounterOperation)+Step: 87/ParMultiDo(CounterOperation)+Step:
88/ParMultiDo(CounterOperation)+Step: 89/ParMultiDo(CounterOperation)+Step:
90/ParMultiDo(CounterOperation)+Step: 91/ParMultiDo(CounterOperation)+Step:
92/ParMultiDo(CounterOperation)+Step: 93/ParMultiDo(CounterOperation)+Step:
94/ParMultiDo(CounterOperation)+Step: 95/ParMultiDo(CounterOperation)+Step:
96/ParMultiDo(CounterOperation)+Step: 97/ParMultiDo(CounterOperation)+Step:
98/ParMultiDo(CounterOperation)+Step: 99/ParMultiDo(CounterOperation)+Step:
100/ParMultiDo(CounterOperation)+Step: 101/ParMultiDo(CounterOperation)+Step:
102/ParMultiDo(CounterOperation)+Step: 103/ParMultiDo(CounterOperation)+Step:
104/ParMultiDo(CounterOperation)+Step: 105/ParMultiDo(CounterOperation)+Step:
106/ParMultiDo(CounterOperation)+Step: 107/ParMultiDo(CounterOperation)+Step:
108/ParMultiDo(CounterOperation)+Step: 109/ParMultiDo(CounterOperation)+Step:
110/ParMultiDo(CounterOperation)+Step: 111/ParMultiDo(CounterOperation)+Step:
112/ParMultiDo(CounterOperation)+Step: 113/ParMultiDo(CounterOperation)+Step:
114/ParMultiDo(CounterOperation)+Step: 115/ParMultiDo(CounterOperation)+Step:
116/ParMultiDo(CounterOperation)+Step: 117/ParMultiDo(CounterOperation)+Step:
118/ParMultiDo(CounterOperation)+Step: 119/ParMultiDo(CounterOperation)+Step:
120/ParMultiDo(CounterOperation)+Step: 121/ParMultiDo(CounterOperation)+Step:
122/ParMultiDo(CounterOperation)+Step: 123/ParMultiDo(CounterOperation)+Step:
124/ParMultiDo(CounterOperation)+Step: 125/ParMultiDo(CounterOperation)+Step:
126/ParMultiDo(CounterOperation)+Step: 127/ParMultiDo(CounterOperation)+Step:
128/ParMultiDo(CounterOperation)+Step: 129/ParMultiDo(CounterOperation)+Step:
130/ParMultiDo(CounterOperation)+Step: 131/ParMultiDo(CounterOperation)+Step:
132/ParMultiDo(CounterOperation)+Step: 133/ParMultiDo(CounterOperation)+Step:
134/ParMultiDo(CounterOperation)+Step: 135/ParMultiDo(CounterOperation)+Step:
136/ParMultiDo(CounterOperation)+Step: 137/ParMultiDo(CounterOperation)+Step:
138/ParMultiDo(CounterOperation)+Step: 139/ParMultiDo(CounterOperation)+Step:
140/ParMultiDo(CounterOperation)+Step: 141/ParMultiDo(CounterOperation)+Step:
142/ParMultiDo(CounterOperation)+Step: 143/ParMultiDo(CounterOperation)+Step:
144/ParMultiDo(CounterOperation)+Step: 145/ParMultiDo(CounterOperation)+Step:
146/ParMultiDo(CounterOperation)+Step: 147/ParMultiDo(CounterOperation)+Step:
148/ParMultiDo(CounterOperation)+Step: 149/ParMultiDo(CounterOperation)+Step:
150/ParMultiDo(CounterOperation)+Step: 151/ParMultiDo(CounterOperation)+Step:
152/ParMultiDo(CounterOperation)+Step: 153/ParMultiDo(CounterOperation)+Step:
154/ParMultiDo(CounterOperation)+Step: 155/ParMultiDo(CounterOperation)+Step:
156/ParMultiDo(CounterOperation)+Step: 157/ParMultiDo(CounterOperation)+Step:
158/ParMultiDo(CounterOperation)+Step: 159/ParMultiDo(CounterOperation)+Step:
160/ParMultiDo(CounterOperation)+Step: 161/ParMultiDo(CounterOperation)+Step:
162/ParMultiDo(CounterOperation)+Step: 163/ParMultiDo(CounterOperation)+Step:
164/ParMultiDo(CounterOperation)+Step: 165/ParMultiDo(CounterOperation)+Step:
166/ParMultiDo(CounterOperation)+Step: 167/ParMultiDo(CounterOperation)+Step:
168/ParMultiDo(CounterOperation)+Step: 169/ParMultiDo(CounterOperation)+Step:
170/ParMultiDo(CounterOperation)+Step: 171/ParMultiDo(CounterOperation)+Step:
172/ParMultiDo(CounterOperation)+Step: 173/ParMultiDo(CounterOperation)+Step:
174/ParMultiDo(CounterOperation)+Step: 175/ParMultiDo(CounterOperation)+Step:
176/ParMultiDo(CounterOperation)+Step: 177/ParMultiDo(CounterOperation)+Step:
178/ParMultiDo(CounterOperation)+Step: 179/ParMultiDo(CounterOperation)+Step:
180/ParMultiDo(CounterOperation)+Step: 181/ParMultiDo(CounterOperation)+Step:
182/ParMultiDo(CounterOperation)+Step: 183/ParMultiDo(CounterOperation)+Step:
184/ParMultiDo(CounterOperation)+Step: 185/ParMultiDo(CounterOperation)+Step:
186/ParMultiDo(CounterOperation)+Step: 187/ParMultiDo(CounterOperation)+Step:
188/ParMultiDo(CounterOperation)+Step: 189/ParMultiDo(CounterOperation)+Step:
190/ParMultiDo(CounterOperation)+Step: 191/ParMultiDo(CounterOperation)+Step:
192/ParMultiDo(CounterOperation)+Step: 193/ParMultiDo(CounterOperation)+Step:
194/ParMultiDo(CounterOperation)+Step: 195/ParMultiDo(CounterOperation)+Step:
196/ParMultiDo(CounterOperation)+Step: 197/ParMultiDo(CounterOperation)+Step:
198/ParMultiDo(CounterOperation)+Step:
199/ParMultiDo(CounterOperation)+ParDo(TimeMonitor)2/ParMultiDo(TimeMonitor)
Apr 16, 2022 1:08:37 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:08:36.214Z: Cleaning up.
Apr 16, 2022 1:08:37 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:08:36.308Z: Stopping **** pool...
Apr 16, 2022 1:09:30 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:09:29.761Z: Autoscaling: Resized **** pool from 5 to 0.
Apr 16, 2022 1:09:30 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-04-16T13:09:29.809Z: Worker pool stopped.
Apr 16, 2022 1:09:39 PM org.apache.beam.runners.dataflow.DataflowPipelineJob
logTerminalState
INFO: Job 2022-04-16_06_04_40-2770133919594487072 finished with status DONE.
Load test results for test (ID): 31c07a60-5a89-4a1f-b4c5-c33e44950a24 and
timestamp: 2022-04-16T13:04:33.801000000Z:
Metric: Value:
dataflow_v2_java17_runtime_sec 71.166
dataflow_v2_java17_total_bytes_count 2.0E9
> Task :runners:google-cloud-dataflow-java:cleanUpDockerJavaImages
Untagged: us.gcr.io/apache-beam-testing/java-postcommit-it/java:20220416130357
Untagged:
us.gcr.io/apache-beam-testing/java-postcommit-it/java@sha256:9cc2a06ac544eabd69c614894449e5baa2a0a1aae988b53efb93e924806c80b4
Tag: [us.gcr.io/apache-beam-testing/java-postcommit-it/java:20220416130357]
- referencing digest:
[us.gcr.io/apache-beam-testing/java-postcommit-it/java@sha256:9cc2a06ac544eabd69c614894449e5baa2a0a1aae988b53efb93e924806c80b4]
Deleted [[us.gcr.io/apache-beam-testing/java-postcommit-it/java:20220416130357]
(referencing
[us.gcr.io/apache-beam-testing/java-postcommit-it/java@sha256:9cc2a06ac544eabd69c614894449e5baa2a0a1aae988b53efb93e924806c80b4])].
Removing untagged image
us.gcr.io/apache-beam-testing/java-postcommit-it/java@sha256:9cc2a06ac544eabd69c614894449e5baa2a0a1aae988b53efb93e924806c80b4
Digests:
-
us.gcr.io/apache-beam-testing/java-postcommit-it/java@sha256:9cc2a06ac544eabd69c614894449e5baa2a0a1aae988b53efb93e924806c80b4
ERROR: (gcloud.container.images.delete) Not found: response:
{'docker-distribution-api-version': 'registry/2.0', 'content-type':
'application/json', 'date': 'Sat, 16 Apr 2022 13:09:45 GMT', 'server': 'Docker
Registry', 'cache-control': 'private', 'x-xss-protection': '0',
'x-frame-options': 'SAMEORIGIN', 'transfer-encoding': 'chunked', 'status':
'404', 'content-length': '168', '-content-encoding': 'gzip'}
Failed to compute blob liveness for manifest:
'sha256:9cc2a06ac544eabd69c614894449e5baa2a0a1aae988b53efb93e924806c80b4': None
> Task :runners:google-cloud-dataflow-java:cleanUpDockerJavaImages FAILED
FAILURE: Build failed with an exception.
* Where:
Build file
'<https://ci-beam.apache.org/job/beam_LoadTests_Java_ParDo_Dataflow_V2_Batch_Java17/ws/src/runners/google-cloud-dataflow-java/build.gradle'>
line: 297
* What went wrong:
Execution failed for task
':runners:google-cloud-dataflow-java:cleanUpDockerJavaImages'.
> Process 'command './scripts/cleanup_untagged_gcr_images.sh'' finished with
> non-zero exit value 1
* Try:
> Run with --stacktrace option to get the stack trace.
> Run with --info or --debug option to get more log output.
> Run with --scan to get full insights.
* Get more help at https://help.gradle.org
Deprecated Gradle features were used in this build, making it incompatible with
Gradle 8.0.
You can use '--warning-mode all' to show the individual deprecation warnings
and determine if they come from your own scripts or plugins.
See
https://docs.gradle.org/7.4/userguide/command_line_interface.html#sec:command_line_warnings
Execution optimizations have been disabled for 1 invalid unit(s) of work during
this build to ensure correctness.
Please consult deprecation warnings for more details.
BUILD FAILED in 5m 49s
105 actionable tasks: 8 executed, 97 up-to-date
Publishing build scan...
https://gradle.com/s/4tesr4bub33n2
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
