See
<https://ci-beam.apache.org/job/beam_LoadTests_Java_ParDo_Dataflow_V2_Streaming_Java11/431/display/redirect?page=changes>
Changes:
[chamikaramj] Updates old releases to use archive.apache.org
[noreply] Bump google.golang.org/api from 0.93.0 to 0.94.0 in /sdks (#22839)
[noreply] Bump cloud.google.com/go/bigquery from 1.38.0 to 1.39.0 in /sdks
[noreply] Add an integration test for bag state (#22827)
[noreply] Fix a few linting issues (#22842)
[noreply] Add combining state support (#22826)
[noreply] Bump cloud.google.com/go/pubsub from 1.24.0 to 1.25.1 in /sdks
(#22850)
[noreply] Bump google.golang.org/grpc from 1.48.0 to 1.49.0 in /sdks (#22838)
[noreply] [Website] update videos section (#22772)
[noreply] Update Dataflow fnapi_container-version (#22852)
[noreply] Go SDK Katas: Update beam module dependency (#22753)
[noreply] unskip sklearn IT test (#22825)
------------------------------------------
[...truncated 173.17 KB...]
Aug 25, 2022 12:46:28 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:25.998Z: Fusing consumer Step:
105/ParMultiDo(CounterOperation) into Step: 104/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:28 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:26.030Z: Fusing consumer Step:
106/ParMultiDo(CounterOperation) into Step: 105/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:28 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:26.074Z: Fusing consumer Step:
107/ParMultiDo(CounterOperation) into Step: 106/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:28 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:26.121Z: Fusing consumer Step:
108/ParMultiDo(CounterOperation) into Step: 107/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:28 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:26.153Z: Fusing consumer Step:
109/ParMultiDo(CounterOperation) into Step: 108/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:28 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:26.176Z: Fusing consumer Step:
110/ParMultiDo(CounterOperation) into Step: 109/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:28 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:26.208Z: Fusing consumer Step:
111/ParMultiDo(CounterOperation) into Step: 110/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:28 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:26.271Z: Fusing consumer Step:
112/ParMultiDo(CounterOperation) into Step: 111/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:28 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:26.301Z: Fusing consumer Step:
113/ParMultiDo(CounterOperation) into Step: 112/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:28 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:26.333Z: Fusing consumer Step:
114/ParMultiDo(CounterOperation) into Step: 113/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:28 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:26.358Z: Fusing consumer Step:
115/ParMultiDo(CounterOperation) into Step: 114/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:28 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:26.394Z: Fusing consumer Step:
116/ParMultiDo(CounterOperation) into Step: 115/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:28 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:26.429Z: Fusing consumer Step:
117/ParMultiDo(CounterOperation) into Step: 116/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:28 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:26.454Z: Fusing consumer Step:
118/ParMultiDo(CounterOperation) into Step: 117/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:28 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:26.482Z: Fusing consumer Step:
119/ParMultiDo(CounterOperation) into Step: 118/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:28 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:26.515Z: Fusing consumer Step:
120/ParMultiDo(CounterOperation) into Step: 119/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:28 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:26.544Z: Fusing consumer Step:
121/ParMultiDo(CounterOperation) into Step: 120/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:28 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:26.573Z: Fusing consumer Step:
122/ParMultiDo(CounterOperation) into Step: 121/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:28 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:26.599Z: Fusing consumer Step:
123/ParMultiDo(CounterOperation) into Step: 122/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:28 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:26.619Z: Fusing consumer Step:
124/ParMultiDo(CounterOperation) into Step: 123/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:28 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:26.666Z: Fusing consumer Step:
125/ParMultiDo(CounterOperation) into Step: 124/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:28 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:26.700Z: Fusing consumer Step:
126/ParMultiDo(CounterOperation) into Step: 125/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:28 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:26.735Z: Fusing consumer Step:
127/ParMultiDo(CounterOperation) into Step: 126/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:28 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:26.771Z: Fusing consumer Step:
128/ParMultiDo(CounterOperation) into Step: 127/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:28 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:26.804Z: Fusing consumer Step:
129/ParMultiDo(CounterOperation) into Step: 128/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:28 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:26.840Z: Fusing consumer Step:
130/ParMultiDo(CounterOperation) into Step: 129/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:28 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:26.902Z: Fusing consumer Step:
131/ParMultiDo(CounterOperation) into Step: 130/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:28 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:26.933Z: Fusing consumer Step:
132/ParMultiDo(CounterOperation) into Step: 131/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:28 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:26.996Z: Fusing consumer Step:
133/ParMultiDo(CounterOperation) into Step: 132/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:28 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:27.028Z: Fusing consumer Step:
134/ParMultiDo(CounterOperation) into Step: 133/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:28 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:27.078Z: Fusing consumer Step:
135/ParMultiDo(CounterOperation) into Step: 134/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:28 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:27.135Z: Fusing consumer Step:
136/ParMultiDo(CounterOperation) into Step: 135/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:28 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:27.164Z: Fusing consumer Step:
137/ParMultiDo(CounterOperation) into Step: 136/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:28 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:27.194Z: Fusing consumer Step:
138/ParMultiDo(CounterOperation) into Step: 137/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:28 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:27.220Z: Fusing consumer Step:
139/ParMultiDo(CounterOperation) into Step: 138/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:28 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:27.284Z: Fusing consumer Step:
140/ParMultiDo(CounterOperation) into Step: 139/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:28 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:27.315Z: Fusing consumer Step:
141/ParMultiDo(CounterOperation) into Step: 140/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:28 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:27.345Z: Fusing consumer Step:
142/ParMultiDo(CounterOperation) into Step: 141/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:28 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:27.379Z: Fusing consumer Step:
143/ParMultiDo(CounterOperation) into Step: 142/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:28 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:27.414Z: Fusing consumer Step:
144/ParMultiDo(CounterOperation) into Step: 143/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:28 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:27.448Z: Fusing consumer Step:
145/ParMultiDo(CounterOperation) into Step: 144/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:28 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:27.482Z: Fusing consumer Step:
146/ParMultiDo(CounterOperation) into Step: 145/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:28 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:27.506Z: Fusing consumer Step:
147/ParMultiDo(CounterOperation) into Step: 146/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:28 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:27.539Z: Fusing consumer Step:
148/ParMultiDo(CounterOperation) into Step: 147/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:28 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:27.572Z: Fusing consumer Step:
149/ParMultiDo(CounterOperation) into Step: 148/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:28 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:27.597Z: Fusing consumer Step:
150/ParMultiDo(CounterOperation) into Step: 149/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:28 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:27.636Z: Fusing consumer Step:
151/ParMultiDo(CounterOperation) into Step: 150/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:28 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:27.659Z: Fusing consumer Step:
152/ParMultiDo(CounterOperation) into Step: 151/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:28 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:27.688Z: Fusing consumer Step:
153/ParMultiDo(CounterOperation) into Step: 152/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:28 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:27.721Z: Fusing consumer Step:
154/ParMultiDo(CounterOperation) into Step: 153/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:28 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:27.755Z: Fusing consumer Step:
155/ParMultiDo(CounterOperation) into Step: 154/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:28 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:27.802Z: Fusing consumer Step:
156/ParMultiDo(CounterOperation) into Step: 155/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:28 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:27.832Z: Fusing consumer Step:
157/ParMultiDo(CounterOperation) into Step: 156/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:28 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:27.899Z: Fusing consumer Step:
158/ParMultiDo(CounterOperation) into Step: 157/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:28 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:27.932Z: Fusing consumer Step:
159/ParMultiDo(CounterOperation) into Step: 158/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:28 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:28.004Z: Fusing consumer Step:
160/ParMultiDo(CounterOperation) into Step: 159/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:28 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:28.032Z: Fusing consumer Step:
161/ParMultiDo(CounterOperation) into Step: 160/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:28 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:28.082Z: Fusing consumer Step:
162/ParMultiDo(CounterOperation) into Step: 161/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:28 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:28.135Z: Fusing consumer Step:
163/ParMultiDo(CounterOperation) into Step: 162/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:28 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:28.172Z: Fusing consumer Step:
164/ParMultiDo(CounterOperation) into Step: 163/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:28 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:28.215Z: Fusing consumer Step:
165/ParMultiDo(CounterOperation) into Step: 164/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:28 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:28.288Z: Fusing consumer Step:
166/ParMultiDo(CounterOperation) into Step: 165/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:28 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:28.317Z: Fusing consumer Step:
167/ParMultiDo(CounterOperation) into Step: 166/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:28 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:28.350Z: Fusing consumer Step:
168/ParMultiDo(CounterOperation) into Step: 167/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:28 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:28.379Z: Fusing consumer Step:
169/ParMultiDo(CounterOperation) into Step: 168/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:28 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:28.415Z: Fusing consumer Step:
170/ParMultiDo(CounterOperation) into Step: 169/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:28 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:28.452Z: Fusing consumer Step:
171/ParMultiDo(CounterOperation) into Step: 170/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:28 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:28.482Z: Fusing consumer Step:
172/ParMultiDo(CounterOperation) into Step: 171/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:28 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:28.510Z: Fusing consumer Step:
173/ParMultiDo(CounterOperation) into Step: 172/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:28 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:28.545Z: Fusing consumer Step:
174/ParMultiDo(CounterOperation) into Step: 173/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:28 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:28.570Z: Fusing consumer Step:
175/ParMultiDo(CounterOperation) into Step: 174/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:28 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:28.598Z: Fusing consumer Step:
176/ParMultiDo(CounterOperation) into Step: 175/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:28 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:28.640Z: Fusing consumer Step:
177/ParMultiDo(CounterOperation) into Step: 176/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:28 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:28.717Z: Fusing consumer Step:
178/ParMultiDo(CounterOperation) into Step: 177/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:28 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:28.751Z: Fusing consumer Step:
179/ParMultiDo(CounterOperation) into Step: 178/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:31 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:28.783Z: Fusing consumer Step:
180/ParMultiDo(CounterOperation) into Step: 179/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:31 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:28.831Z: Fusing consumer Step:
181/ParMultiDo(CounterOperation) into Step: 180/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:31 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:28.889Z: Fusing consumer Step:
182/ParMultiDo(CounterOperation) into Step: 181/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:31 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:28.916Z: Fusing consumer Step:
183/ParMultiDo(CounterOperation) into Step: 182/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:31 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:28.943Z: Fusing consumer Step:
184/ParMultiDo(CounterOperation) into Step: 183/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:31 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:29.003Z: Fusing consumer Step:
185/ParMultiDo(CounterOperation) into Step: 184/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:31 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:29.028Z: Fusing consumer Step:
186/ParMultiDo(CounterOperation) into Step: 185/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:31 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:29.064Z: Fusing consumer Step:
187/ParMultiDo(CounterOperation) into Step: 186/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:31 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:29.135Z: Fusing consumer Step:
188/ParMultiDo(CounterOperation) into Step: 187/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:31 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:29.167Z: Fusing consumer Step:
189/ParMultiDo(CounterOperation) into Step: 188/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:31 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:29.204Z: Fusing consumer Step:
190/ParMultiDo(CounterOperation) into Step: 189/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:31 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:29.277Z: Fusing consumer Step:
191/ParMultiDo(CounterOperation) into Step: 190/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:31 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:29.304Z: Fusing consumer Step:
192/ParMultiDo(CounterOperation) into Step: 191/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:31 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:29.327Z: Fusing consumer Step:
193/ParMultiDo(CounterOperation) into Step: 192/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:31 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:29.358Z: Fusing consumer Step:
194/ParMultiDo(CounterOperation) into Step: 193/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:31 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:29.391Z: Fusing consumer Step:
195/ParMultiDo(CounterOperation) into Step: 194/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:31 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:29.413Z: Fusing consumer Step:
196/ParMultiDo(CounterOperation) into Step: 195/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:31 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:29.442Z: Fusing consumer Step:
197/ParMultiDo(CounterOperation) into Step: 196/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:31 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:29.475Z: Fusing consumer Step:
198/ParMultiDo(CounterOperation) into Step: 197/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:31 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:29.500Z: Fusing consumer Step:
199/ParMultiDo(CounterOperation) into Step: 198/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:31 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:29.535Z: Fusing consumer
ParDo(TimeMonitor)2/ParMultiDo(TimeMonitor) into Step:
199/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:31 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:29.654Z: Running job using Streaming Engine
Aug 25, 2022 12:46:31 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:29.896Z: Starting 5 ****s in us-central1-a...
Aug 25, 2022 12:47:07 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:47:06.054Z: Autoscaling: Raised the number of ****s to 5 so
that the pipeline can catch up with its backlog and keep up with its input rate.
Aug 25, 2022 12:48:13 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:48:11.232Z: Workers have started successfully.
Aug 25, 2022 12:51:34 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:51:34.219Z: Cleaning up.
Aug 25, 2022 12:51:34 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:51:34.344Z: Stopping **** pool...
Aug 25, 2022 12:51:36 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:51:34.395Z: Stopping **** pool...
The message received from the daemon indicates that the daemon has disappeared.
Build request sent: Build{id=f106b8ec-c287-4ace-b064-fc1afca15eeb,
currentDir=<https://ci-beam.apache.org/job/beam_LoadTests_Java_ParDo_Dataflow_V2_Streaming_Java11/ws/src}>
Attempting to read last messages from the daemon log...
Daemon pid: 2271650
log file: /home/jenkins/.gradle/daemon/7.4/daemon-2271650.out.log
----- Last 20 lines from daemon log file - daemon-2271650.out.log -----
INFO: 2022-08-25T12:46:29.475Z: Fusing consumer Step:
198/ParMultiDo(CounterOperation) into Step: 197/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:31 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:29.500Z: Fusing consumer Step:
199/ParMultiDo(CounterOperation) into Step: 198/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:31 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:29.535Z: Fusing consumer
ParDo(TimeMonitor)2/ParMultiDo(TimeMonitor) into Step:
199/ParMultiDo(CounterOperation)
Aug 25, 2022 12:46:31 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:29.654Z: Running job using Streaming Engine
Aug 25, 2022 12:46:31 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:46:29.896Z: Starting 5 ****s in us-central1-a...
Aug 25, 2022 12:47:07 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:47:06.054Z: Autoscaling: Raised the number of ****s to 5 so
that the pipeline can catch up with its backlog and keep up with its input rate.
Aug 25, 2022 12:48:13 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:48:11.232Z: Workers have started successfully.
Aug 25, 2022 12:51:34 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:51:34.219Z: Cleaning up.
Aug 25, 2022 12:51:34 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:51:34.344Z: Stopping **** pool...
Aug 25, 2022 12:51:36 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-08-25T12:51:34.395Z: Stopping **** pool...
Daemon vm is shutting down... The daemon has exited normally or was terminated
in response to a user interrupt.
----- End of the daemon log -----
FAILURE: Build failed with an exception.
* What went wrong:
Gradle build daemon disappeared unexpectedly (it may have been killed or may
have crashed)
* 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
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]
