See
<https://ci-beam.apache.org/job/beam_PostCommit_Python38/200/display/redirect?page=changes>
Changes:
[Robin Qiu] Propagate BigQuery streaming insert throttled time to Dataflow
worker in
[Kamil Wasilewski] [BEAM-10524] JSON decoder for ReadFromBigQuery supports
repeatable
[noreply] Merge pull request #12415 from [BEAM-10603] Add the RecordingManager
and
------------------------------------------
[...truncated 20.77 MB...]
"component_encodings": [],
"pipeline_proto_coder_id": "ref_Coder_StrUtf8Coder_9"
},
{
"@type": "kind:global_window"
}
],
"is_wrapper": true
},
"output_name": "None",
"user_name": "To String.out"
}
],
"parallel_input": {
"@type": "OutputReference",
"output_name": "out",
"step_name": "s1"
},
"serialized_fn":
"QlpoOTFBWSZTWc7AtG0AAin/4H//+IvoY4hHb+vcgr///+ZjxQ4BQAL92cObYrduYamU0mnok9JjU9QeoHk2qGnlD1APKG1AAABtQABKmmgEEJvVR6am1APU/VGg0DQBpoZPUAAGgDQaak1T9TU9GiDEMGpkBiDIwNAjE0aADTQBgSmkmip+jJlBPNQwpp6gAepp6noQaGmgAB5R6Q9Q0imyGdfrkOHtycmrV6ZCe1JzQkIB+d58SalhMAhMwPkOlEgEDMANcogZ7HIni0ncfJCQSWea2llR77C1sztwkj+7DRLd1tNq04CKWibBWc8ymUpGpO3XkXkUED0gd/nOokdHeDAQp2zS78J6ynzjV4unG49HlsYxKAFW9TNI+9JA0p4izTdP5+LJCMYiimfnSmJepnTZqBgobHXzfe4CeTESDyb29v7TvPCtPxv3MUeWw3R3Srt4QYy1qg8wQ02WvKk6KxmpX2aFZ9gdLDbXjpRtk5tTSl9AvnC1bcmjki1GoctMjGZhwj+JrAUY+Um57Pa9zJzKcBHDVWVYs1NQo2REkOUogxVWh1v3izyrZmqCBmoZ/dthKFeVvBmcPogIfF7rNWWxdKwswFktwHI4ESc/SLEseXCTaGxglngQJAXYtWxeYgRbucN2wVJNPxPrBBk0sHDXTeNjJV6KS0SQUQZqRkhMcC/K+hB6Ywo80JC4dEKIqIK9eMg6nBwcIoYWfIQTSaFu6xc4azGYoItRUARJro2HoDDe+8/FTgLyKr91m8bDia0gNoIx7VM+7ll3GaIHWn26UXWUtATGmQaqyaBNKyFcKH13dEMPO3tboRDpw6A+wtQgG6YOuM9dihOcGo/kOY3KZdZsXzzER2YPQ18jx36JbYiM4RbZ43gVlwaYz7G0TMma7ozVThuZasBhn3CocLQww+dmMXBKsPRbTby0jXrGMzKMUNROodQgETvEtU+A/ICB15AFPEBhkFJqlIN0sNk7BJAbIRoN5IJQ6LlMMEIoFG33pJkRnc0zuw4q0AcvNqG/rsCa9drX4G1rhKX+4VY1Gqlrrf7eXrfylOGLmLCCPYWSRsZSMURNmyZZFLscuF0UMMXMyxXHY1YonbxdVY5LVmSqN1ATXKtJxtwhR7XtAu5IpwoSGdgWjaA=",
"user_name": "To String"
}
},
{
"kind": "ParallelDo",
"name": "s3",
"properties": {
"display_data": [
{
"key": "fn",
"label": "Transform Function",
"namespace": "apache_beam.transforms.core.ParDo",
"shortValue": "CallableWrapperDoFn",
"type": "STRING",
"value": "apache_beam.transforms.core.CallableWrapperDoFn"
},
{
"key": "fn",
"label": "Transform Function",
"namespace": "apache_beam.transforms.core.CallableWrapperDoFn",
"type": "STRING",
"value": "make_entity"
}
],
"non_parallel_inputs": {},
"output_info": [
{
"encoding": {
"@type": "kind:windowed_value",
"component_encodings": [
{
"@type":
"FastPrimitivesCoder$QlpoOTFBWSZTWSYAoHgAAC334EwIiCAAIQkAQAC/bt0CYAQOACAAahpI0Bppo0GmRtINBqJ6QZAaNDQDyjRqC0RLwD4QPbijFck85Haypu6ovZAReEmQrcsyHc7KzNN4sFkXh7FICbooOXgwoVC0QQeEDWJD5shM4hP8XckU4UJAmAKB4A==",
"component_encodings": [
{
"@type":
"FastPrimitivesCoder$QlpoOTFBWSZTWSYAoHgAAC334EwIiCAAIQkAQAC/bt0CYAQOACAAahpI0Bppo0GmRtINBqJ6QZAaNDQDyjRqC0RLwD4QPbijFck85Haypu6ovZAReEmQrcsyHc7KzNN4sFkXh7FICbooOXgwoVC0QQeEDWJD5shM4hP8XckU4UJAmAKB4A==",
"component_encodings": [],
"pipeline_proto_coder_id":
"ref_Coder_FastPrimitivesCoder_6"
},
{
"@type":
"FastPrimitivesCoder$QlpoOTFBWSZTWSYAoHgAAC334EwIiCAAIQkAQAC/bt0CYAQOACAAahpI0Bppo0GmRtINBqJ6QZAaNDQDyjRqC0RLwD4QPbijFck85Haypu6ovZAReEmQrcsyHc7KzNN4sFkXh7FICbooOXgwoVC0QQeEDWJD5shM4hP8XckU4UJAmAKB4A==",
"component_encodings": [],
"pipeline_proto_coder_id":
"ref_Coder_FastPrimitivesCoder_6"
}
],
"is_pair_like": true,
"pipeline_proto_coder_id": "ref_Coder_FastPrimitivesCoder_6"
},
{
"@type": "kind:global_window"
}
],
"is_wrapper": true
},
"output_name": "None",
"user_name": "To Entity.out"
}
],
"parallel_input": {
"@type": "OutputReference",
"output_name": "None",
"step_name": "s2"
},
"serialized_fn":
"QlpoOTFBWSZTWUhn9p8AAun/8f//fJtNY//lH+vcg7//3+Zrxk4AYAAEAAAA0AP+5YdTrpbu7snWw0QJNqaekaaTU/U1M9SYHpNTIwTNJkMeoNMmmggAPQ0jQwlCjTQmJpoaJPJHijBPU2oNGhoNqNAAA0A9Q0GgA00IRMKnpPFPJHlPUHqHqGgyGajEBkAABoAZDJvVBxoaGhoBoDEDQGQAAaaABoBkAAADCVTyU9DVGnqMIaGmg0AABkAA0AAANA0aAD6EdKAflMXr9oY3Ea5QqtdOlVpx1DmhWO0nK7mTklyiAd50/u1NeixRt+TzNAbdxQ1n+yvdKDPQTqgqwuyCchHKZ7qAFKKQgoIkR4jMQIEe/9fP6QECLOcy4yiTlMyAUqWrTiKhF5L6FVag0fGK8iRkYMrZ8mUNGuhd+Vg0MBjCIQpRXeRefewqjF1GIomdjEUnqorvXTVCmQIuOhwc4qUBVhbTpulyqufq8Ogk0Msjln7lWX8uknH4dK1sjRvoQEKTvrinvzv8ZzK+oSMSEF0/buAjUAA2nY/FbR5tpO2/pwiDXFESn5TfBDavX7lut74KG3XfTGYgmckJ568sqlsQRgwtIdSTJgjIFNe0tm/YBI6Ccyhs+3L6d/f5sGuRlRXPXOhWhSEMSvHP3QoM9trybkm4+QEItq2aAsnNgqBrnvWYgcgiGQnWZDanJZQD4uUvR3KnatEVEExOK5ZmF4eS1wlCWKzBh41qCtGL428Z+xjyY5UCxwq4VJCsEUPdDH4W71HxdDXWxVZq07MwWKNiiLxh1aOOb6qY1OokHhgIXgHySS/3MAu0ziLV3XNWDCLnZXSjtBXCSZ96jIcetL0eswSzEZuptbrAy89RGULtqWYPGlZRDYILAQFlS51rC+sgEFx0I020qiK6ajoG6T4QYk4MOmVOTEatmoUnHIR4jLIGZ+d7YwvEpceuhYr+Av4YLbVqciVytBHwSwxKrFTwO+oYFgRbUrRmW+REw1qSQjwvhEkF1GbCAtF5QUH1eHAjBieiCMFQFNUKUf8lk0bgrr7tvKXCuHBAk7qFUYUBucoVAKk7A9xUpQGk7JKsCEjr1wlg6gdWNIJ4Y7WjSCosjNEwfhcGUlnsiiYLaUEEbEZ94WwDCVGC40kJIPFRbRXrMV5hiDsGWalF8FkaxCR8UhFIhAfeM3GZeNkMQmT2Fbq9/c0tSiAv8IYJ6BS4bEJDOQMUcERvbcnjyQJ38uSxPHOsyEIjPiS9mZxdHoPNe0ag8VGTbNrfNwkKZqXp9VjNSfWsj2p5mueS3kUrkLlWBIjtvZ5eGHY5zKoig1DSCqYIq6GQ4snSZXtcNBxSLeNElCMIkByBuYlCbJEx7IzKpASYFAs3WZzJlEKF/mRRAjMYlqVEixlOtBGeK5rJEXsQBxmAGf7DYMzKN3gsiNcWrL0N16NHTY2yixlKqwVgWlVv0CssRSZaMMbr0CLWdNAa9iVmoz20iJPPLm0Tykj9ut2SnYWpa3aLbSOvZrbXLtMFMkQue7L1JLdiShRFiFSWnIbEvNNB8GZlD0W0F/1+Iu5IpwoSCQz+0+A=",
"user_name": "To Entity"
}
},
{
"kind": "ParallelDo",
"name": "s4",
"properties": {
"display_data": [
{
"key": "fn",
"label": "Transform Function",
"namespace": "apache_beam.transforms.core.ParDo",
"shortValue": "_DatastoreWriteFn",
"type": "STRING",
"value":
"apache_beam.io.gcp.datastore.v1new.datastoreio._DatastoreWriteFn"
},
{
"key": "mutation",
"namespace":
"apache_beam.io.gcp.datastore.v1new.datastoreio._DatastoreWriteFn",
"type": "STRING",
"value": "Write (upsert)"
},
{
"key": "project",
"namespace":
"apache_beam.io.gcp.datastore.v1new.datastoreio._DatastoreWriteFn",
"type": "STRING",
"value": "apache-beam-testing"
}
],
"non_parallel_inputs": {},
"output_info": [
{
"encoding": {
"@type": "kind:windowed_value",
"component_encodings": [
{
"@type":
"FastPrimitivesCoder$QlpoOTFBWSZTWSYAoHgAAC334EwIiCAAIQkAQAC/bt0CYAQOACAAahpI0Bppo0GmRtINBqJ6QZAaNDQDyjRqC0RLwD4QPbijFck85Haypu6ovZAReEmQrcsyHc7KzNN4sFkXh7FICbooOXgwoVC0QQeEDWJD5shM4hP8XckU4UJAmAKB4A==",
"component_encodings": [
{
"@type":
"FastPrimitivesCoder$QlpoOTFBWSZTWSYAoHgAAC334EwIiCAAIQkAQAC/bt0CYAQOACAAahpI0Bppo0GmRtINBqJ6QZAaNDQDyjRqC0RLwD4QPbijFck85Haypu6ovZAReEmQrcsyHc7KzNN4sFkXh7FICbooOXgwoVC0QQeEDWJD5shM4hP8XckU4UJAmAKB4A==",
"component_encodings": [],
"pipeline_proto_coder_id":
"ref_Coder_FastPrimitivesCoder_6"
},
{
"@type":
"FastPrimitivesCoder$QlpoOTFBWSZTWSYAoHgAAC334EwIiCAAIQkAQAC/bt0CYAQOACAAahpI0Bppo0GmRtINBqJ6QZAaNDQDyjRqC0RLwD4QPbijFck85Haypu6ovZAReEmQrcsyHc7KzNN4sFkXh7FICbooOXgwoVC0QQeEDWJD5shM4hP8XckU4UJAmAKB4A==",
"component_encodings": [],
"pipeline_proto_coder_id":
"ref_Coder_FastPrimitivesCoder_6"
}
],
"is_pair_like": true,
"pipeline_proto_coder_id": "ref_Coder_FastPrimitivesCoder_6"
},
{
"@type": "kind:global_window"
}
],
"is_wrapper": true
},
"output_name": "None",
"user_name": "Write to Datastore/Write Batch to Datastore.out"
}
],
"parallel_input": {
"@type": "OutputReference",
"output_name": "None",
"step_name": "s3"
},
"serialized_fn":
"QlpoOTFBWSZTWWaErZMACpx/////////////////////////////////////////////4Awj7js973nc9XNfW4Hu7uQJfRoV7vZwGi121JKy0Iqn5GiAJkGjITTJpqbE9FMjZT0amymYBMmpg0TaJ6j1PU8UYIemk9JgI009AmmBqbJNNPJNlNkm2piTyngnoaaJqep5GJlPamQY1GUbTZAEyhU00EaamaSj/UKfqmeiaj9NSeoeppo9NNJvRNT1PKemU/UT0PTVHqfqnqeUfhFGnlP1J+qPap5oKHonlPFPTZRNp6jU9T2San6UenoKeUPyifqnqHqep5QZpAzU009T1NqMag9QPKP1MJCqek0NDRT01PUZPJqA2p5TTwo9Ro8TUxPCZQ/SjxDEjRpkaejTSNAA0GgADIAAAaA0NNA9QNA0AGjQAaB6gNHqaeoaaMgNRCaYQNIMmpiDT1PSeoPRGjJoGmQHqGgBoGj0mgNA0ABoAAGgZAAA0DQAPU0Bk09QNA0AANAADIAEAAAAAAAAAABMAAAAAAAAAAAmAAAAAAAAAAAAAAAAAAEwEwMSIgABCekwE0maAanoJgEGFPJmgnlJsmU8mmoeU03qmnp6U02Ueo9T0TymnoMUMjynkyjJ4kMT2o0wptRo0BoeoyNPKep6mjQyeoeo9Rsh6U0bWIwNEyALrixOTd+DneWtpR2r1MXmPZcy3qevUKv6VG0y5b0qypYJ0M4xm7b0dkxa0Lw7lfbOq+vOoSyfvWDX5lXiWOWzu/oYFZbxhLHnJ7mcxMJuUNGFo3N1WL894sl5LOofZqrPLrXhfbZiVPo8UilbeKGkHKvdMRrf288z6LQ3ONd2rFdeqUuehYk1JIw0j1ubfKfPztdz7ChT3gABJ3lHAM4kAk9b2Gi6MNt7eiuVVXsz+tZlyhBmVLiAc3j9KkPuar1CZtf38pAk00q0SVkaVPKC60ddcPTYDOquwWy0IxHRxkW1NCNJo9V/wqpwDcEi2u98H+UE2eMPGKu3pPnCMIhdgUKGujh41vIDnjahOllk8FVNu79/XTi2vDoYY7+FM4WOYOXgw7J7Ox6SFQMmiwbDRU3NM5e6u3L11CvD7ibj1sZCso2bl2VDDxRxOhq5yCwyAw7EJVAJkEK/kljAFIEgyKJDsfUt0DpBlSWjQd38l7pe5dLmT8lau+3D5va/7k1E2GRoOpdzyEiSRERAHSQJBHhIEjyUAQLRAkiFEkm4QBp6vASqCOWqtrZ8ucDwJJdQnHSsIYDSgsdcIiunRVCrIaUJmFw5oET7f3LH8We22PRFEsMkxADqtmpqm5RMY0HrHPpALNFJlj6giTCrWct2MAN/N4fWu7o6iTHQrr1l9XaPuH08mLGAD8qLFBowupCmGBMK44mDMKfXPU9IlNkMNJc+uaJV22gPTBYKDw6OrMUr5Xjob8q+WN+1dFgwzh+wszJgiEDo2DpCRRXQjlHG8+UJQfy+ySIAYsqP3R6Ygr99RiWxAKw0wQ/KQgeawF0Unyxwdw9WRcgeVzZ6mSV9hOUjkmmMvTTDr1H2lsdPyebQVMUiP4c893R2bddMFWTMN1+qqqbhWwHRjz34vHew7jfkiP+6kW5sfNnnHqobmm1UGf6lO0Ot6zM+yJOYzm2b46lCglzrjE8kpyZrwb69k/bbDyI3WFXd1OswF4IlEMNHMEw/CT2hQl/CwkjTIEYNOYeDS+Yxshhvd8pp+VurWO/ONLH/Nr6IJBJohd+jGR9fJun3EezkxV8Zw/gOBAQPc/F8ew/DH9XXQObR93bUOn5hD1qLKgpGibwcnI2s3gzV/Yt0G4TGpLNqUSzRT5++otm2y/xF4zUyjdybsyuz6HE6Pt5H2hoQXAMIwMsFkAgikHTQXWsyitNW3s2Qpe6TpoTEc8OawriZrkTWT8G85evnOKZXAGn7FLQh46gvpBG86RjX5rDcL1MnSU/T6232pzTieGKHhIjQE4r3fxT6r4WqB9jlSdpZv/XzXFg0l4hSz/NLuvmH8kOug5Wwre+hpRAcFCi8edLgX0mN0jSGcOWtGeCIeltLQIq+MNmNl/p4GEg7Ffqh3Ka9ptn+uad5iLAd93ipCymPC6V3GK3lygBwaLdi5l0PUYysZK8cIvtnXF8iZtR51C61aRI7cIp6uQFQDCAkfs3nWUYgxw9GMUTNzlyA5r7RkBcEaaHREXfLbzie8DotNgcVEnUG2Hj8wRwG+9T2gm4AQXu+Wvxc01u7hJax6zF9VdHmHhcSkH6oYzK1ns1xl0uVUSPb5xe/RylNr9VuaMK/hMeOXoxZ8QByOiPQi3wqHKf4bnkDNrn0oKvpj5HfsYFs/rXjgJazVmx+Qhw8yzsp5jhyFgPZ3VpbwCzQHQ5DCFedFYDz1wsf5NZjYL9rWFchBWtsUNopqkZZvlLeSu+duN63jLdoU8Ew6KuZLVMym4ityFdpLCCLy2Hi+X7Th3v6b92bx56A4fm8pxPbo9wsVnWHWID6iA7lTlUICxR9VAZJXqyVS0Hp08bgoOkr+6tkYu9ht0BnEMShxs82vRFqhNyda4bTK+zj3j8HbZ69e6vaxUrNS3Z9WqsMKwqsIAASWAAJNRoLo+j+2pcfgeZxH1kF3lxza9hLzkvFdvtc3Fr99H5P6NZi05vdLfEmpiSV+aXXVmYIhabSYsx07MZdr2dRGtQks4jZLTMQ09NAnKKmHAyUB6yfF8KtdUC9QBKXqQIQgG0qog1fQ0BCgck+F7+xrLcnvGg/VDd9Jbek0irjd7pnnaxcmOKvkoSxnE8dqVUnHnzX+Ma1BG7h+LM23zQR7BvD3IPrWXtildBYldl0/wNvspQ8BRMtbVOOt4Ie907ZF48bFN2gsgSQTiqjg9e1rIzfO3PW3ddL9SZl0lSVIUIQkjhoO7z8ru8105BKuRJi0QShX2MOCpXtZdRRCHCTA1ejOIpviC0T29xTHrUeYLFUCki8Q8MBxEfHyezZmzUgAqjVrUpqywIAEGBDQIsY7RGr1+8Mrm7fVbzxN6ztw6yGepTSAHA6goJAJjR6d/YtQCUFVeDYbBaGzxu6sMZpo5JePLybZh5iuAyCO/4PTjj4zYXmGoaiM5RWZKOfKw1pSLiAKiAzxXiGuBdGIelFvzw7k0IZN5B+q6qNTN4cM9abunUAbfw2AqVQmyM05wAkWdX2VKjr+6wgOEAmMRTDmwQJIJgJNbDBDiAAIn0cRge213TePbYeaMTGfMkgPm36dGgFK4vrhBgqT6x75RTRpBgYOwYpCYInAWrEQFJwrxGBsqPBqmnyYwmFYHWv1yC5JuvD+gsAnXf8jm7z1MrUUHLGYI0JAuqUBoVaAonw3jRgNKL+K2DDAUOBrQaMuLeqVHQjmFDYAB9e6gTRhfOn6p6dQ+rsKB31bAAYdAy8OwGIE3Eo4OlEwnJCpwx8Wz9U2QHHtL6cEDAA0WTOAKSb5RA8fwwwRWYntcismuZGREuAVT18nDqwU/xxHsYaJINYhAILOEkQdEjYwgZV2+jvUZkmHOiAAfsvsNa/KKKMDfwXHQT2HMmFwjjbSC1aK73LjXd9Thix7vQNQM0oCBU9YCxDk8p5mBi0Kh4ReomqC+HbaXneBg4xAnZe3vwpcbqq3A9UY7OYNaAAJWVEwByB0oybR0uTAeTy0TdZVvgYAnBYuYIACUDEZk8gaptW72iGULOLoBE/6rT5AvJlT141eQh/jKsZ880WwZBpoCqDgwjQgG/uzoexqK6KI2cIjiQIt1GOz5jxLRCXeZjMY6VRiMbRw4s9tJOwAsrMs6YAHkAIMPEsqMuOhDVTHNhHspM2B0prmLfr/KFzuY748gqsEkUCAGLmFJJCALP0jCPiZaCNIaBCxSoEQEAOfCZIIizDwsOBVZSsyBAMlqBQ9NHVxcJqP0m8bJWJotcnSl5JqCkXsjCstQnndBdT0wpilREWrF9xzxXjImtDoeN83GXztelFB1j6atDHE7LfeK7NhsMJOAa4NRArkg4DHOnXkcCUs3flI93fm2wiBHACCZUABkxTInZ1qoQJ0aRJ7qj5+01HSlrlWTC/TpHWOPnLj4+EvJAJUh9Ha+aiMmQsXKxIqKAmWbeDZKKRNYCfrR2cNxaPmoTseU9gyMjZDwu1V4KWLidga4kBdxxkVk3dlfNmrlURtmfNuRwY9NjM7Ks/DebLf3cSQqGhAYEXN+MwKBmDYI657i4M1qQIy8GWjiSVo/kBOoSc3+7kMEvCgXXcjJ9aPRthCWmjgz6UcHDCDchrApFA4H/gjjGrpMVlW7JxEXicrzn75OR9DuGsPv6P1/1/choo7hH3yn5tqNWxuEJqtkBxbhiJKpfvYDf5NsfNaYo/edQ7WrxfnMB1ypoilq3uI2KM1DsdFp3TkcMgJKgRtXNmVQQxKAxavFpaTeHh2O79BrJAYy2Y/u4svubGDAqlofKjPArJnpdQ+bEbbIaJVOIbb5LNuFwjj0LReEvTXLXCoRXCqjMMLhWIkrssrv7F59KOxtEZ6N2rmBtt1jCehE8FjlEPpLdLu1V1bEVWft+uzOf4EfyJ0bmp+xiXe29bwdT0P6arK71idahU6dkikKMDnC6cGcEVpW7DEQF0KAi9WwenLFoPQAyIXM8d+kqxcpwiihgIGAr3AtqCJ3fx7DSdHzqESGZaKfaE0kI7yVKSIVXHXR1m86Ev8D9DyiH1Fx1fPIXQ0bDWcWw5V1GF/iNagnXZ7DggEnAkjaZpBIi6udJstn1fvMHGgCij/QvSFuYJT2AlakNFRRvSRNT5Ige6RPbdSIWscM7RyuLPUtoHoa2RMqFAImYmxnzo8uPAqD6EiCdOZnRIWmqAoQw7THtFO1U652HcdXM+UbYdIrYMK4vXz/kqJG/9dNsRnQbRPm36xsGSBOBvQiDwaMW1I5wnIXmP7y2/JQIrh1gGVSstZ9arVKmeyjEEgwp8ZZazO0fIdouIuaigMbluHzY4vI+4cRMykCfhGoecODpsfkQFCYZQfKOo+u4g8qKqjTwJJGNLLDBbEyM7RbKZsxUAQvqUR2O1iRTQVyZEQ+KF6IS0QSCYOpGCEMYmgM9ulEqDWtvESoINip7GY5CLbFsjarbfH+MDfq7ClR5WnqHBXOaKkntTB+Qee2Itj0z2lbVXdQfJSJlc9GIAyOfdP1uqdGmfFabX9EBTyOkMriuP3XwhVWPL6bWlLOqN+mLcnJe1zkIFE913RQmYwXeRhKmENCWYatNFZN2qlUiDFaZl9GwqnExEhgHOwo1xx1PrjgIBTZIvQeHMxSKzgW/GL8ljP/yknGaPeUfGRAgErubCwyHz8RSU+ex6fTXhab1piBS3OuGE61nQ55dUaOX5g58SEq41tlhyXVOVNKUVxLKT5vFVmOmSu85adv4NJy61bVl6CFLGyLGOJu0/iU7KeS58CPMmYXqB6DCcK3BIOUxoLWJLGvGfpy1+sbaMFCD7JFdCxSRqXc1GXg6PZNYlAA2OY4alhvXzX1uSZuZwd0jtBAai40VwBSQf89EZPQyneG+6JkTUKyWL0WU2lfe0rJebk/Th+lz8nC1HiWHVtFGssvpN/OO6YMT+DkA6qbGpOBrhJNZerIrBM9VqP1T44KKb9o4NWn4pxwTx76ZfvcmZuKjjW/ckDJrvX1upy/CPPTWSIhvB+9OT8+ePz/Aq+pDLKlGDiZnbfSpf2KjtHlrpv7hgk4s7rdU370qud3HNd8gUaXgNWzxKqTi/B4cajTStY3xsizPFIIathmsW/hohw30py2qu1KPQsums5K3VMSN3qo9dlcpQDDHOzdFE+USj5atRlH9bPpkHvwRhQwioFM2Lmwg7rImBxPFDlTQ0IrsAaMKILMywfiAFDXuNj9P9lSqyPLxD4QEknqBp/J8EmaQt1pmcqr7OvyjnVskiC7bhyGtRB3tUPt5EAUHNEd9/zjwo/seO0tt7SD1+P0HpYhcEmxK1Mo529f0YdtU1ky7NOSYYSs4E7gEVLjh9XnSs+r/Y4WXNGq5IrzSOh+W+TS9rea+nsDzf7b7xJ5KZQCCevZU/bkTIKsb1rYGwNIEg/8DCLwM+aVw09EUWLT5gwKAQTo8Ck4OyfTfMaMWaYDDtyzDUF0jxAbdSRDXO7QkJrkq+4/8XckU4UJBmhK2T",
"user_name": "Write to Datastore/Write Batch to Datastore"
}
}
],
"type": "JOB_TYPE_BATCH"
}
apache_beam.runners.dataflow.internal.apiclient: INFO: Create job: <Job
createTime: '2020-08-25T00:11:25.598705Z'
currentStateTime: '1970-01-01T00:00:00Z'
id: '2020-08-24_17_11_24-17109976075390747382'
location: 'us-central1'
name: 'beamapp-jenkins-0825001116-738530'
projectId: 'apache-beam-testing'
stageStates: []
startTime: '2020-08-25T00:11:25.598705Z'
steps: []
tempFiles: []
type: TypeValueValuesEnum(JOB_TYPE_BATCH, 1)>
apache_beam.runners.dataflow.internal.apiclient: INFO: Created job with id:
[2020-08-24_17_11_24-17109976075390747382]
apache_beam.runners.dataflow.internal.apiclient: INFO: Submitted job:
2020-08-24_17_11_24-17109976075390747382
apache_beam.runners.dataflow.internal.apiclient: INFO: To access the Dataflow
monitoring console, please navigate to
https://console.cloud.google.com/dataflow/jobs/us-central1/2020-08-24_17_11_24-17109976075390747382?project=apache-beam-testing
--------------------- >> end captured logging << ---------------------
----------------------------------------------------------------------
XML: nosetests-postCommitIT-df-py38.xml
----------------------------------------------------------------------
XML:
<https://ci-beam.apache.org/job/beam_PostCommit_Python38/ws/src/sdks/python/nosetests.xml>
----------------------------------------------------------------------
Ran 66 tests in 3306.543s
FAILED (SKIP=7, failures=4)
> Task :sdks:python:test-suites:dataflow:py38:postCommitIT FAILED
FAILURE: Build completed with 4 failures.
1: Task failed with an exception.
-----------
* What went wrong:
Execution failed for task ':release:go-licenses:py:dockerRun'.
> Process 'command 'docker'' finished with non-zero exit value 125
* 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.
==============================================================================
2: Task failed with an exception.
-----------
* Where:
Script
'<https://ci-beam.apache.org/job/beam_PostCommit_Python38/ws/src/sdks/python/test-suites/direct/common.gradle'>
line: 144
* What went wrong:
Execution failed for task
':sdks:python:test-suites:direct:py38:hdfsIntegrationTest'.
> Process 'command '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.
==============================================================================
3: Task failed with an exception.
-----------
* Where:
Script
'<https://ci-beam.apache.org/job/beam_PostCommit_Python38/ws/src/sdks/python/test-suites/direct/common.gradle'>
line: 55
* What went wrong:
Execution failed for task ':sdks:python:test-suites:direct:py38:postCommitIT'.
> Process 'command '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.
==============================================================================
4: Task failed with an exception.
-----------
* Where:
Script
'<https://ci-beam.apache.org/job/beam_PostCommit_Python38/ws/src/sdks/python/test-suites/dataflow/common.gradle'>
line: 118
* What went wrong:
Execution failed for task ':sdks:python:test-suites:dataflow:py38:postCommitIT'.
> Process 'command '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 6.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See
https://docs.gradle.org/5.2.1/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 58m 16s
164 actionable tasks: 125 executed, 35 from cache, 4 up-to-date
Publishing build scan...
https://gradle.com/s/lq74ky2qwurwc
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]
