See
<https://ci-beam.apache.org/job/beam_PostCommit_Python36/2851/display/redirect?page=changes>
Changes:
[noreply] [BEAM-10675] Add Python GBK Load Tests for streaming on Dataflow
------------------------------------------
[...truncated 20.48 MB...]
],
"is_wrapper": true
},
"output_name": "out",
"user_name": "Input/Read.out"
}
],
"user_name": "Input/Read"
}
},
{
"kind": "ParallelDo",
"name": "s2",
"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": "str"
}
],
"non_parallel_inputs": {},
"output_info": [
{
"encoding": {
"@type": "kind:windowed_value",
"component_encodings": [
{
"@type":
"StrUtf8Coder$QlpoOTFBWSZTWUUL7GYAABnfwHgQACEAQAgACgC/QvwCYAAgAEiE1B6gbRA9R+qbUKAAaAABzsBennDtsriTt3V+SBhgf2i+oSUiKLItyiLVj4u5IpwoSCKF9jMA",
"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":
"QlpoOTFBWSZTWWtndGAAA1t/4H///////////////////+ZjwQABUAOXvK57tAGQYiap6nqMob0k00MgbJGQyDIAGgMgD1NMhoDJppkD1A9Ro0HqD0hUkYTaCZM2oJpkyMAAEYTCMEwJgAAIwmjTJgRhGIKaGQmkmmgAADQAAAaAaaAAAAAAAAABoNT0kao00AAAGQDQAAADQAANAMQAAMjygABKagIJoaEYExEYkHpPU000AADQAaZAA0HqGgaAeoaZpGEmDlLHDo8I8UzxEhwBhkCMwKSMGhhSBsQqQLAOhCT5AhEAAQHyOAJ6qYD+kMdToweByfC/rI7f3VVSd/z3t2ZkXpfiOc2FzgkKJJBd73Ud9/FYbcCnQkgVn1AM0xtj0KekEFRBJJ4UnlooklUsooQJcoQpYIoX8VzZgv66nePrJH2nsReLLx5MtIZltDOY0LoMJhDL/YzjC6nLX1KITaa0I6bghIU8RCXCJwi2gotlVJAlbTSTBX7EIW2EMaBaFp9bcKG2UBuGWPD7MFWVrsrtMHuAxtXYVjy95SfSW8KdT5SfCo/aP32AZcTENELN3LvjVkjJPQ3YMxtyTK0EhyZ9R41+OgaK6Fu3yHMseyb1zkyGwA9VuoVRZ2HFQgwCcx76GeNby5jrjAsnIM1Kl/CXCQkQG86HApEqZ1zbbpusNlgFuWPk2MNReulA1pNCTHMffmaQiQphEyE4GroLHQr9Z4iAEO0KAGA4hYODwDoMadIjnycXGutxTuSzGLYeDZn26TGnPb3woffm6jZqppcmaQ2WkKsdU63mrOzqcmmL1ESNanywbURFLTgYato0qnXc/aMWCmkq1E9uVaK0U+7sdIhs1s9zyx1ZA6Rc2TFkesN+wZ5wVzqaFGUKA63Lx9Xh/P/Ox9L+Pe697KDY2Bxv6DYM980yxA4GltohoOccp2Yz6ifM+Jk28MOTw3679uAVcNtrcEN5hrJu+dUYt1b2wkkRdujZUNVLuHU+pRKSUeJDNOxOtkXsMayRG0arjkVIzqi8SoC4npD4vzLniTJ6uDJwIJJmZfzquYC90LTbNL6hwop4QwIMTrw2nJR68tqxGyrt5aNgG8EZwhmrRkCMaqbOdr8LtdqTzPydip3JCNHhWhPLgtc2YjqVAWmkFBEApAAgsEDvSCAJUiD7ylMfO8oVNYxQsJhlESCIhYgcN5bmonnzEUyKWg59LyUoQiBS98XwM16welWmHDHNzbtCC+ylmCfIoAbXKnBpxHBuYDUz9bnAh+/To17URujLhB9JYbOPFBX65DkTC4Y+B4TwmCNr6JWYyghjDqtyiO7dsrmJR6dxvNlfw3QrYwq5CBQDVmKORpsCGxc+/4n8auG2Zbps4LxW6zBWLh3C3TZhrxQhrcSk4z5HPkT2rljJmEhrhzYT8jrrT2eTc4O3aYtzZIkAO6B6sfd5nswfxdkuclQq/zNWRDdR00/8XckU4UJBrZ3RgA==",
"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$QlpoOTFBWSZTWYQR6NMAAEDXwH8QgCEJAEBAv279AmAAIABqEqnqGgaABpoyNAGVHpGgMgDQBk0oR6IeoECBiqqU5NY23ndshzT2UPUOGrg42YPi9VyA8lbwwPJgtghxs5Qq1aWwExCDeMa0RHC2QigTCdizz1nx+LuSKcKEhCCPRpg=",
"component_encodings": [
{
"@type":
"FastPrimitivesCoder$QlpoOTFBWSZTWYQR6NMAAEDXwH8QgCEJAEBAv279AmAAIABqEqnqGgaABpoyNAGVHpGgMgDQBk0oR6IeoECBiqqU5NY23ndshzT2UPUOGrg42YPi9VyA8lbwwPJgtghxs5Qq1aWwExCDeMa0RHC2QigTCdizz1nx+LuSKcKEhCCPRpg=",
"component_encodings": [],
"pipeline_proto_coder_id":
"ref_Coder_FastPrimitivesCoder_6"
},
{
"@type":
"FastPrimitivesCoder$QlpoOTFBWSZTWYQR6NMAAEDXwH8QgCEJAEBAv279AmAAIABqEqnqGgaABpoyNAGVHpGgMgDQBk0oR6IeoECBiqqU5NY23ndshzT2UPUOGrg42YPi9VyA8lbwwPJgtghxs5Qq1aWwExCDeMa0RHC2QigTCdizz1nx+LuSKcKEhCCPRpg=",
"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":
"QlpoOTFBWSZTWX+7fwUABDD/4H//////////////////////wkAAUASXu893dxc9ebOjmxu7xFMp6CDKA0aAeo9TTTTIGRoNMmgaGmjQ0AyNDQNBmU0aDR6jCaekDURG0mQ2pNkymh6nqaGmgAA0A0AAAAAAAaAABoAA1NGiYIECJ6Q2kPUBoBoyDQAAAAYh6mQaBhDQBhANMNMkJNPSUZqeptR6hoNGQZBoeoAAAAAAAAADQHqAAGgkUmmQRo0jJT1P1NJ6n6NTanqmgB5QNAAGgA0AAAAMgGhoA0Zxf6SqJ1VZRZ2iidB+UjDDMhx6ou+DMZh0GXxymRKcrSQYaVLXx89mXF09YCW19cEvJGAv5YfoMR6XjOFLEfd0rJ6IOhtJXjKILDSpzU0Zq1ZUtDHCjRj/3ucB+lOI5WsC/fBZhQhCAbGUHYGpMLTyjBnircoZF68vn8VeDfAKRdfV8CUJTqAEyCSQQSSakr9d0s5F+TipyzkIIJkfjMSFGCALkDdRfFVUPguHIdTKO3G9htulpb3VClZMCoyo1zeM0RYh1E9IqFyFcQ6KkpnBGhDdLiqOlXvkSNc68pXSSGdESgzRoXKpeGrPVdjpuEf4Ae0shkzLvHsBTZCO4RqgSRPkCcrKqlAX0HVebgZc6g3xAx99oOK6xI1roKe6UXWCXsoCNBvHdTlMWfLjCOjTqyDEQNLhCG1At/OP8gIbMfkhvSwoAAgia0TckSe+Wmp7T3WW1yUtWvBx64CJxYJaGyYRaFz3oS4A005mao/4myh8rPwQkvPDjrtMyoZQLShq9FGaOkb+bS/9lUWc46L9rk288RQWYIDCODsB8JE6dg3Wx26uHjBtZKtsSqCKU7s6uw2EIxQFMnDiDVZrHKjioncAefjv5tNqSquMJzRU3tpsb7AoMBfVfUlelaEZTg5y5ZEy8zJk2KgVxRxt+Zkea47KVF/68PUz5fryXjkj50u9RIMFZKQEcRXgTwaLtgIuyNAyMTR1eXdSmIp3h4yxDtul4oD7ZixC3jAi+2e5F8Gk4McaWrDSQ3TRXqsrBD/6SwQDUVkIQQCpCxvPHFWutWSiiai9miBCXGgxTFqeZRqxTaMiI0iS6SGGYcGCcstYFe4LA1rZ02RSorqpKEQl3YjmfiaI3LEhGSQATMqH/Z5Re6N6yq74oTWdS9+pmGvDiEBEG29slPOMNzdwW6N+ucM4MFDiZHDoP7IVrXGud+9MKLj+npWSK1LXiyDWBUotwfHlIcObrcIdfbKmyjkhtmE2kKo+0yuZoG1czYsZhNihiQ06DT7JxiT57VDM2WKY2a6oEdskWlJTkFZd3EyxhQ6rIyqEQ5gQUAlDu02MLROJF+y21Q2mw4by7Y5XIyESESJMgDjFsM6Tx6TEKO3LlGWe5c1daD4y2ULamd0ER40zCZoKSLtzg4HZpti0KeRmceRQ1enzop4hU4JtOaR1i8zjOMiqi0xYxhwqcuKyDbzZ23rWJ51WjCS2yZpIJoKutNNg9+pSpek17tyqvMmtbpmbhD5KNHHSmdDERjBUmnKvS7pLKVneL27mBYKm0xdmaN6ovgI15FvFFcCv3XF61ADgOPqhXIrkMnblNSlyYKg4S3Z1jIiePxSRg3SULUzay0PHaUkBhYk+8we9p4uKw2MhmsxmOKozky5KhqKZLZunGWoHHfsfGLhBAMAJkxTHjXnfBfFcT91ZmQLJTwMpUCcW643hEwUIEcDbfpKWERSfehdA8eKIMB8Ui51BAgpOmwEAZNBMLspSiag5xCxBaowBJTa8REsI4WR6XeMcNHB3P929VjJOCxECRRQpDFAQHiIEVClTpra9WTlMAWqhNcfwkXMDRZ3H+LuSKcKEg/3b+Cg=",
"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$QlpoOTFBWSZTWYQR6NMAAEDXwH8QgCEJAEBAv279AmAAIABqEqnqGgaABpoyNAGVHpGgMgDQBk0oR6IeoECBiqqU5NY23ndshzT2UPUOGrg42YPi9VyA8lbwwPJgtghxs5Qq1aWwExCDeMa0RHC2QigTCdizz1nx+LuSKcKEhCCPRpg=",
"component_encodings": [
{
"@type":
"FastPrimitivesCoder$QlpoOTFBWSZTWYQR6NMAAEDXwH8QgCEJAEBAv279AmAAIABqEqnqGgaABpoyNAGVHpGgMgDQBk0oR6IeoECBiqqU5NY23ndshzT2UPUOGrg42YPi9VyA8lbwwPJgtghxs5Qq1aWwExCDeMa0RHC2QigTCdizz1nx+LuSKcKEhCCPRpg=",
"component_encodings": [],
"pipeline_proto_coder_id":
"ref_Coder_FastPrimitivesCoder_6"
},
{
"@type":
"FastPrimitivesCoder$QlpoOTFBWSZTWYQR6NMAAEDXwH8QgCEJAEBAv279AmAAIABqEqnqGgaABpoyNAGVHpGgMgDQBk0oR6IeoECBiqqU5NY23ndshzT2UPUOGrg42YPi9VyA8lbwwPJgtghxs5Qq1aWwExCDeMa0RHC2QigTCdizz1nx+LuSKcKEhCCPRpg=",
"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":
"QlpoOTFBWSZTWVs12QEADJp/////////////////////////////////////////////4A5d9ntD3e9fIV98+d9tX04C+udQDoDp0Or7056e+89tXXVtpwncZMp5NpPUTJohiekxNB6TQAGgDQABoBoA9QDQ9QAAAAAGgANqBtQPUaMmmaR6I9Q8hkMEmT1PSHqNNPJGaZT0amwkMmA0IaSn4qeptT1G1B6jyj1PU2U2pp+qNPKNoZRtI0aHtU8jKeU3qnlPCZRps1T0Yj1J4jU0/U8TIaZNGTTE0SbJqaeUPU9TQ3qeqbKeTKeJPFPUeUGJ6npqe1R6no0yeihFT0KemjQJqn6GExMo2VNgxJplPKexNqp4KeTyCn6aKf6kj1G1MNNJ6TammmRmKek8oHlPKeRGCAGmHpQ8o2pnqEeoYExoAjTTYoPQ0aTaGptMmyUIpoMBDUnqYmmlHpo0TT0RoNGg00eieoHqZNPU2p6ageppppo9QfpTIBpo0fqjT1P1R6jR6mmh6gbap6ajeqaPKAHpNH6p6j1PU9R+qPUPKaeoN6mU9NTNR6EbRP1TQBU2QI1NT0pPyj0IRiabSeKejQ0aeoQyPUZGJhlNPRpqMym0YmQaaI2kz1NEDEfqmnqPQ0ENpD0mNR6mJ6mTNCeRMAQYmmAAmHqhpgJjUEppIQ0TTTTQNBpGjETbUmU8U81MSfpT1PSNkm0xTRhD2qbKeU9Q8p4p6jCPSbSPTU2oGmnpNMJkbU00PKbSNNNNPKDQ8jU09Taj1A9T1DQ0aDE9EHpHqPKZ/FXB5wSnXHH0Ik08MbI4LRWTv4OZWxyJ+dhtuQUhOwoa70A7KYbNVhmZJJmBMDJIZACSZINi/IQAHG8T/ClOjrCGknLs5J6ioHtD16iwaI30DUq6lm0BSCsqft19Owgq8v4IZs5V1i0x8Uixqx9pyGC1+k3OTByPgijTMLeypzcZU2c9eLrcPqrdvb7DjNzt5OVZ0us+TukVOHCrI74m+ZULslb/sgsUrX/TmoVUv52WyS4yZ6SZmvjex4E8zXzya+n8HvCknIkchmP5+bpcHcgDM3qw3OC4P1rtF4rjOhmBADMyEU3OAAwgCmEABKY6loppE/irX7d+6lDYtu4IoMCKeI5yS/qk67p4/ISJ2zMRRTyivvJaEpL/uQKLL9U9hom+Eaj8zRU7mf7eG7loSpdeUzTNYfyJlIPJGrF83IxWNBd4c1oydYiRbpFBhRk9juu7T0K7IcP2BBkvBthixVGIokUDAtWgS5FVFzkxi1Bg3fpYjNzTt3UduVzrZtLtIEO7pNPQwTx4u0ktGz9L6dv6usrdZYU9f7djY23r2toq+FUrUrahdU1S2rX1jBexrWVdXs/gaWDWxbN3Fk5s7Tk/HynVvznd5f4lxg4eBdO0yieXLp2j+ChStXqkk+kXLl9DQrVy9YtXL2DCZ9RwTOCltSBhmt2XZGJ+JbQrCkk3G4zyuq27/OHhq8KcmyasFy05S+na5Ksq0X8dPBcLSSNc4JZYBiWBYA85MwxsUwxnUMRJigmGKKZhjY3HmQAPeJmY4olllllggg3eevhuvcljVOWvOPEFs3FnLLUWSLerxPs7VtABsE4J6FVeWpeGnVka/jtVl10UM6JX7msWRb9IQijFxkJ8Xn9SEaLEjItFASnIN6OZUP2fwgjYS6orwjCq/J0+C1tPEMkv/o+06I6lXFHgjONApQDISNyagKYLMjNQC2LyQMBsgVxrnftiMMlLo2WS4q/NxmsAyxmLs1D02+px4OcOBzVAQstlsexcov8wvpUpjT8LFJGE+FfC19ehAzVz5poqCPw179rdkGMN76nf1PF7zDdPOneT0tvZzJowyXlrR3TOiLHMv5e5GhQNWHdc0YleUnLdXVwGcL78TD4BuX4bzgjqpiVzDIh4XvMwGn+AaRf63GGKK5vHHwcu73Ey0NTq7C46NxtslxCTqD3iTXkt6pokZfqVQeBY7UsQZbyxbujgnJzVBRnsBjcKnGyhr/tYm5Fl29iMfA3rsTx9Zg7X5nO+MTEx7YUs9zxmf4+PI9klQ4Icbm4CKQtG25/Vy8rFIUPIQMyI5DuR0t1alEVG1+3cxFf9kmVt3ypusfKkplDC3b5TMPmr19RbXP/7QYQdX118R7nYSMWLGtWQ+um7iics5JJoqa1MmoLmXzY3mZMrkV1B8je06czy0vZbzf59VS8VUv8W+96jT3WWlmcHg1M39VPp9qesvmy6R7xd9x9ShXu12a9wFNkosbNlxnLmf6M32/43sZWs5lXNUElXSaKXl0j31vPHXuUiau81Mo7zn3/NK7dLP9MPLBVNex9PKPSrZ01OIWLCFnn5GrXKZQ0fPKVtVfJ905QmcU26+da7jkggqL/OhRRRaOkEaAKo18Lftrqs4rmZGNeXvA6yiIcML31z4aOtqZhtpUSOHKhBN/x/sWl1l5nh983gXZ9H6RZDODkY0oziBJkoKeNCjSvuisu/sermdmDI8uIwnGpa0LxlSSJmqdaeARjbDEReSKf0GsssyIWM6mQlbiUKYEjf6AeDqIGrHN9L/Qyj9nta1U8iYxbNs9vNroo99Of9J/UlbWJ3NypvJztFsZMQ5W93ujghoTRktRxeORojHpKlCBIoVSEZo6DSyhvKdTbWMAZlZgGWIs5wYn8ZbQcHQGHHvy559IJprjbHiXplG2R/KYrOOPBN3NXlyn0o7OTI1vSNtkuvZ9LTZp0JSoiER+FTa9EoBcUoRywUmJ0vOMjt/zZ+QxDH42TVpHbuc/eOZTGh3IDbUhVUvWikXqJTC5xHaoP9G5PFlGMOxw6kndvoOwPlDkR3mjWwD6ki/Ey2EWnqsJTqspYFwh1d3HN92qAE7qeRwP6J3p4ORnI6aWoOlB6ZTnYt0Cc7oDsUuNXS3Wqa7dyWHB3cnXfO01jE130b8ncPfI/h2Dt1G3dtQs5ivLgPmUNVr3UOBtH7Kv0nkxH703sFkb97TUUoapbleqXlLvenc/vp3N2sKp1kOyR6hBvFcKf/p2Jq0Gbczqa+WzVTUZXdxBr+W5peQ/lrPLcIXdPm1f2rt2k9zpkxfX3bQG/92HtIGuyXHhSRmMTXQC7XnVXaovP3eftYmvH8+F4rpZNB8hGZVJHIwPSc3so+u55zXprlGkWZ8G7g2dtMDzdHG1HlvDbPzCzWboQNCmM+o6/VQNfWcjyPDh9ldatrWe55PdZ+L/oAzN1PJgAMzJ3xyLn23uIZlaql30y4L3mYruhLF5+t/DJFkH1i3E58WV+x6AAePCWjjl7aYxW3fIA7IdFQmc4aJk2NnNOAiKum7XrpHRY64xg+nECUozhG19S7Z7TSknj/vF8K5I3F7PmzyBAVA346I6h6xviM/uaBdS9VVzJoosFGVjDvA8W1eLssrnZdhlRUXtxdMeqd0jmShrP7OqgH1Nsx8idQlk0P4oHtW1gTcIO5C/JBM3tznMlOgmnsdVRIPqG6yMNptgES5Rd8SV3jbEZ0pSFtiQMBAMQpZGTMwevdJ2xZlAiUr2YskBie29XaOp+NpcLDRFRGtoYOuWvikdfvXtnj+L5dXg8j+UzX2ElhxcPYW2RxZuFNv+d9zRkjueqn5TCy7MwzO7szDNhSRjUupYkWWcnT4+BPIlGcL7C28f8dQN/esMMBnSk3HlgT3aMiLScFERTZWBFJGEfpxx50UCNEhU7TubP4XoXVrpOz3Xs8COjbMB0lvf9zHUAMGqFqYzTIJLgTIBK5JZGA5cBkyEgdpbuFedBJWEm9LfZYnI6fPcHgaXlXUf28YGQTZD8Hewxl1qbVmaIrqtBlO6ajqvGqYHmcnsfRzo1K7rhbPaZTt4cWyCbZtyoaDKeiiqsgC5mNcGTJK402WOeNISxRELPr9b9/4sW/t32nM6e+6WO6sLZb57UamIKCp29q5aDs1rxXn9ro7Olf+RCvhmS5q3y8Q3NBaf03UTH0CN7gZmGaYzNazY5MQAmbzEseVst9ZU7E9NNiozwi+vSpToy8lrRSKMlwpru9B7OEVadNpliT2jiJlcl0yi9YISCBjSYNj7G8/dy76Ga2Haj/GLBYeeiCIh1AB7Oajj9mLT4t6nRJhjlSjUAcVnF8SwADpWI1lbpwBgXjlvi5Y0BzhJaLRTcv1tmc3lQC4tnypvUrbpeU+9lpQ1Nl2+RYzCYo4bhRzALNIr2EzJm4Lt5Jc28zBfEOrqhzA0QTKFIg1od5iuePnstc6H9ksyNR8a9/NiyY9uufMVWnQc1ukfGWqOdtqqagp5BE0en4UuiUkqXZdxbwVlPAMOKKBnE00vccmFZxFpMpNETjwuh39DF0M4pfTp2BFQLEsmpMgiVtwBnYh7t/JBbAmM8xqgnaV6fQ/8wLHjTbNMGc0EdYx2avM0X6nM8Hcv2Aq2rRkENXIrTop1BNtLPlxbeSKxVRWIyIZy6AM8UiPq+ExWrU9vOMhbTod9t4qnX75k7DHP6JOaEYpilKV8Nhhg4iwBnFpFHkkQgQkQmSkeSRKSEcdGWZMkhCEDn9A/PDGxTMMWQhrFDCQdGgOOgt0DBMnz4MVkzEaBmNUhglLRM4zNUTEYt6bA8S9bMViwiDQIZAAbrQU4ZkRAAUyInGKtcO2SJs4MWh6bM0SCMgUJGYrqPnyrHBq9ecS3jE8lmtQFq5WseJzC/zhUOgzN7C9ou0kDQ+DUhcV6lyVmT2kEW5QqUSVBGRzbSDNKwCJTr/U/7uvA9Do/u2+1uKFoyvSyKTAO0LeDJNGdZTaQ0VWSdLHBrJK2YjYCEVWf7GTu53raDUhhWEk2hGJyqxYF3SnCBjZ7aQ1G7txyVQzKr62jo67Xb1Sn44lVVR/4rrhFHEoC8aPBYBMREguBf5cDBMNscQk2t5rKUg2Lp8m00ozfy6bh7u48ebYXg2Dh/1jLLGOeJdcTV1YRzQcr4cFL19hefrsYYQum7xWKrsoLKVjQDgkscI6n7NyZMXE1CFGiLetaxGusJoDCDhCqSDipnJXHwuHffYfgNY7+6GVYzbmptjjy6LWHL67fLrSga9W/Uoh/pFRy6Z4xkIVgZvIRaiMp2EkKXQ29f5urlGerZd4Cy2Y1n+aDP3ElGem9i4uIHdpQEEj0QZM77UXyCcXuiVcZhz1QAPR5Bo2hBCxdvlJTd+Uz1XpdOZjC46bLojEN+cvYk5p9OIjpop0+gQdTodHmt8FGZwli+wPnmu/g0J/XoQggtaHOhpqYQJWGEFnUGXXWKj4+lhEtTw9tC8XBWjW+TXHPueuR4aKiYr+G+S8ilDhUMhLEHER2y1Su9+/U+33kDv0e9p1oGWWGitI8nUPj0bdUk9XRag1AUkXenj0xIkrEyUgSb8bM3+YvlBY6QK36YcXlLG/JNkfIYrgsy/gOxmU2U+U/ToyOzfUop+M4Hvl3aK+wfS5R909HWRZhE1F4tmg1feeVAKYjfc47HfbZ9IiJH61zi7tY1ZpMWeDieviL5cPGuTV3ArLMDHMtmRgVxNymIBlHjN20mwICR98Y5GiAPDN4c6OPeiex07dzaEkpj6DuFTRZpKApirGPiyPjh/Rlyo0lBDjAFI3UY/GfIMNYUR+jVSG46ZoITIqUUdHvDdeRNyE0ABIBcpcZ/mnUNE4NheZHvSZvZr2rqPMjNHwCvn8+hXWfoPeWdKf8+0hvwISkqIsajGhpM7mkD7p0PVvtsQSOFauFAoyJYxfYnSM3CSyLM4QftqBOJnEV+QkoM84SC1/0tMLLvD0RaK2tUZqurNdl8apu5eZat5CS6vpV+CG7WFClSyRyTK7JzVp1xkPcQc4cThEDIBytQ1e2LIoomA9Y1vIGip22qcdhQ1Wwi9yZVHtnC+uK8cxx6ILESS4i3QltLjzMqWbSamd6kkwDuwAz+Khy9ruTbQrn8QyJvajEhgdSNftYU+LjzbpF0o765z4CNzFoGCeovjQ3M77hcppu/B31EXNHE+nfhI+JNb4+lxf3oDx5kl3HWVj4NYzQ4so6Pd4oIL8N5BEjnB7IXJf7+P5meCUb20wx9EjVQHEfdEMkj98dggOjCjKmLpG9o03h5FbIPgvNwzO6InS058PCbrR2xCuzLPnFIpPG7T+MRCCBfWelfWirUE/IbuZKC3WFeKpAtBOU2cbS7aI2XPZO0y1EaaEgnBd9q0cCt2nmJXUql+YbLocIJcv2g058SiPLB9lNAZOAi7JPmIdL4J8f09PFSltXv5RmoJ+V8dFteGIETUD+k4eRryWBsiwtmGwbUNUxwUhRfR7acjxAjyiHzBgcTT3hUkis7Gx9v3u3vm1QnH7ZiZ5F2pjnw+cRIG3c2kXk03paSuQvvO+UZbYoN6R+f1uBySxDCMGM6JHPPQX7robVkfkfQPdkayIlEYUboWH5xLndJMLK2HznUXlNelAniJ+5T5GcQ8WAi4Ye/QNZeaeFOa0sBeA2FPgu8yWfdjCbQ62hy6ySC+0DtRuk/NNR8QKKkPhraGYadUsrP7maXmOblXfRXpM0ZUcEoMUKf6edGX6HjVkU98kwzuFKe66qqeJB5yMKYYRzd5I9dLenaqMnj38q3zrDQC8VGMYRxrXDEbEJ/MAKCikRp8fbSk05f1JAAwvxgEGPtN6qAD2avzcR+H7GWshp3cnYXK1pYc5rn7E2INnnwLcnInb12cWhQoTXerTo7g3ikW0RsQ/mXCJc8023hKt/TgaxlHegMwCYGW1vgFLkU1YN88rsjyEDfyIQ1UU1S8FrCP+SkIE3chjxmgs04ITEJZq7quBEEzJvuyYXqyBnR9NHB5HIJ6ROfxfXBcCGPutstio8DsETXnMjwoMGzukdt159bDpSmaA7Isj6aeY+hwF9Ca7ioeYP94VOekA1EtavoYm4Qn7Y1F0I+FL9rSlMt/1k7YBeFDfKcTv3QwqXdxjgM+ZmO+33jg7hT4FqpYn5OgC4gaJN9DR+QGhwVdtx+7y2gqmRozNvMQaNpc0ORY7Cm6HOguUa/IrawG0WdP8oxMmG7qcLvrv+gOUBTgQISNEo8AatuEn1Fntc2rDzmUz7r2Iemk5z+9pu6Wb92/1+6hob4oPgwLZiTlXU0OwLGwIq+ZcGSpvtZlvlih2B3//i7kinChILZrsgI=",
"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-26T12:15:18.660274Z'
currentStateTime: '1970-01-01T00:00:00Z'
id: '2020-08-26_05_15_17-582754520247347474'
location: 'us-central1'
name: 'beamapp-jenkins-0826121508-612253'
projectId: 'apache-beam-testing'
stageStates: []
startTime: '2020-08-26T12:15:18.660274Z'
steps: []
tempFiles: []
type: TypeValueValuesEnum(JOB_TYPE_BATCH, 1)>
apache_beam.runners.dataflow.internal.apiclient: INFO: Created job with id:
[2020-08-26_05_15_17-582754520247347474]
apache_beam.runners.dataflow.internal.apiclient: INFO: Submitted job:
2020-08-26_05_15_17-582754520247347474
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-26_05_15_17-582754520247347474?project=apache-beam-testing
--------------------- >> end captured logging << ---------------------
----------------------------------------------------------------------
XML: nosetests-postCommitIT-df-py36.xml
----------------------------------------------------------------------
XML:
<https://ci-beam.apache.org/job/beam_PostCommit_Python36/ws/src/sdks/python/nosetests.xml>
----------------------------------------------------------------------
Ran 66 tests in 3884.557s
FAILED (SKIP=7, failures=1)
> Task :sdks:python:test-suites:dataflow:py36:postCommitIT FAILED
FAILURE: Build failed with an exception.
* Where:
Script
'<https://ci-beam.apache.org/job/beam_PostCommit_Python36/ws/src/sdks/python/test-suites/dataflow/common.gradle'>
line: 118
* What went wrong:
Execution failed for task ':sdks:python:test-suites:dataflow:py36: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 1h 7m 36s
167 actionable tasks: 128 executed, 35 from cache, 4 up-to-date
Publishing build scan...
https://gradle.com/s/f727baevqeun6
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]
