See
<https://ci-beam.apache.org/job/beam_PostCommit_Python35/2839/display/redirect?page=changes>
Changes:
[douglas.damon] Add Filter lesson to Go SDK katas
[douglas.damon] Reformat code for readability
[yoshiki.obata] [BEAM-9980] Configure Python versions for direct test suite
tasks via
[douglas.damon] Change license info format in task-info.yaml
[douglas.damon] Update stepik course
[kevinsijo] [BEAM-9920] Enabling artifact staging for xlang transforms
[kevinsijo] documentation(beam/sdks/go): added apache license and function
docstring
[noreply] [BEAM-9547] Implement dataframes top, join, merge. (#12516)
[kevinsijo] fix(beam/sdks/go): correcting changed function name
------------------------------------------
[...truncated 21.88 MB...]
"user_name": "assert_that/Group/GroupByKey"
}
},
{
"kind": "ParallelDo",
"name": "s21",
"properties": {
"display_data": [
{
"key": "fn",
"label": "Transform Function",
"namespace": "apache_beam.transforms.core.CallableWrapperDoFn",
"type": "STRING",
"value": "_merge_tagged_vals_under_key"
},
{
"key": "fn",
"label": "Transform Function",
"namespace": "apache_beam.transforms.core.ParDo",
"shortValue": "CallableWrapperDoFn",
"type": "STRING",
"value": "apache_beam.transforms.core.CallableWrapperDoFn"
}
],
"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_5"
},
{
"@type":
"FastPrimitivesCoder$QlpoOTFBWSZTWYQR6NMAAEDXwH8QgCEJAEBAv279AmAAIABqEqnqGgaABpoyNAGVHpGgMgDQBk0oR6IeoECBiqqU5NY23ndshzT2UPUOGrg42YPi9VyA8lbwwPJgtghxs5Qq1aWwExCDeMa0RHC2QigTCdizz1nx+LuSKcKEhCCPRpg=",
"component_encodings": [],
"pipeline_proto_coder_id":
"ref_Coder_FastPrimitivesCoder_5"
}
],
"is_pair_like": true,
"pipeline_proto_coder_id": "ref_Coder_FastPrimitivesCoder_5"
},
{
"@type": "kind:global_window"
}
],
"is_wrapper": true
},
"output_name": "None",
"user_name":
"assert_that/Group/Map(_merge_tagged_vals_under_key).out"
}
],
"parallel_input": {
"@type": "OutputReference",
"output_name": "out",
"step_name": "s20"
},
"serialized_fn":
"QlpoOTFBWSZTWdmtTFcABBp/zH//////////////////////wSAABABQBHeXbpsW6XYNUUw1NRpT0jEYjJo0DRppoaNDIADTQ2oAMhkAAxGhpkyGg0aAaBpNEyMjU01P0mUymeqaPUAAGgGgAAAABoANDIAAAaYgRGJNCR6gAGgAANADTQAAAA0AAAANAeoBoAEGAAmAAIwAAjAARoxNMATAABMIwjATJiMQMDEhqZEATTVP1PTRkU81R5TQekNqaNDagAAAAAAADQHqAeo9I9TpoT5ic4bZD0IktHY4xTTYNDRbdcngGh7CeqiFTInR1wYLeCsEe98PEIEAdNAgcaJ6kfoWvTU6dRAvxbzgGxqA65byBAxKKwpggR49jEUQAkhKtmG/PK8uZblU1dTxUV8ZYqRX9867UIg3DGmgC7qtTdePR4w60i6tpMI1T/uIlRBSjAzQZpKEBgBR6nzCkEoiBCxEFgKWoTrvkwfcCHQF1BZeKMrAB9k2OuG+BQSSSSuNFXEyZHIhIKTMgmkiZcSRJECBCcQDoBfGUZt3EohBm3rlgtx9AzH09WvymBXF/bOmO0DICe1AQ70FJJdB9ouY1lFijhPqGZgInz5gTK1SjoR0IWPBMEITHEy0hMB1vP5eXoz+4d1aHQLYCUQkScCGIGMcSkqqBfIormlQv5/Bp3FFeMtFdPEnOtZsObXokJBkjqnhkZzS5apBopkS1vsDEGWVCh7USNzypazM8XLvCvl4ogTYAnLqa6OkVXhnOehPejLsI2JBhrtOPFgQpnNHnciimZFen++5F9MpNU7Qu+SnJg8D+OJE21cdEv4RM5BFgoWxlb9HPM7MmWqggsAMo8MiFV7UgheilleQIMkbcAigKYbMWBAweELgCirF+xFAhEFYRsGV8chtgmhuzFd8EVCaSS7QtC+Jw92swklKnxCJvYeXRWUZEJiPVxPjlKaQaV+b4sh2H1fn7PW1ZYEpkQObQCCDSWYNZhlxGGJ6LYNldGqYmgOQwIqFifGM2UNM5TrmWh72gkZhILpYATYYzWiTCzblC2qOOEGrHKvZF2rgsYOxx0qEppEhRCtQ4maWO+sXjRBt4gEiuINOKXECjJa8LCATQOdECv8CbFyxG3f5ejeewlwPplZWBjBoxCu3NaA1i2SZgHCIBQ3EI5xyDdbNn6sGreHGmPNruHcxfssANp1pBwHCYPjIOkaWzFUx2yt7GqUB5iBrdT9WwWOJFwGTD0iiRTVYHZAWCyYvYi5iHEsBAs43AFiqjUqgLyRUGBlDnhIoGJAUUAt/gvgWmti1s3zE0DAp9aRF/ObhAiMb/4UXy3EbmG62U4SRwduBAOGtJIMHcOG4L9iVhbf1b7g1RxDPZWZjm+A/0OTQ5lDZZLvaUp7J1X1nMydl5Cr694WQVuNpq81GtLFduI3sLKX4M1aolOp313qUxKUGoEmXCae5clal2AGIapa5zM5reCmhKTM5GW1KWmqq0yNCLAsWlpSIHZaJVlHMU5qGciflqRBs3J83OHeiGnEdsy0MBA75YQHS52K5HBpNCA3kms3QI2hdGTVgr9ZkGKI/myRtWzqPAWWdUIbdKCq/kA2wZgbtVLThBS8zrFwhBC8WloKkkOTQA4YiqCWgT6PO1EwmsbrZaiRSmW8VsbC+IDAJOMNZ1NSS2GFTtMppZSzN5Ct7iKQtwCI3y+ddz81YO6iIoFc7Y/dWdxyuMKG0QqAZGZDjp/W63J1MH/R1qcP+hqz/aGS+raxurpy/mWAb/F3JFOFCQ2a1MVw=",
"user_name": "assert_that/Group/Map(_merge_tagged_vals_under_key)"
}
},
{
"kind": "ParallelDo",
"name": "s22",
"properties": {
"display_data": [
{
"key": "fn",
"label": "Transform Function",
"namespace": "apache_beam.transforms.core.CallableWrapperDoFn",
"type": "STRING",
"value": "<lambda>"
},
{
"key": "fn",
"label": "Transform Function",
"namespace": "apache_beam.transforms.core.ParDo",
"shortValue": "CallableWrapperDoFn",
"type": "STRING",
"value": "apache_beam.transforms.core.CallableWrapperDoFn"
}
],
"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_5"
},
{
"@type":
"FastPrimitivesCoder$QlpoOTFBWSZTWYQR6NMAAEDXwH8QgCEJAEBAv279AmAAIABqEqnqGgaABpoyNAGVHpGgMgDQBk0oR6IeoECBiqqU5NY23ndshzT2UPUOGrg42YPi9VyA8lbwwPJgtghxs5Qq1aWwExCDeMa0RHC2QigTCdizz1nx+LuSKcKEhCCPRpg=",
"component_encodings": [],
"pipeline_proto_coder_id":
"ref_Coder_FastPrimitivesCoder_5"
}
],
"is_pair_like": true,
"pipeline_proto_coder_id": "ref_Coder_FastPrimitivesCoder_5"
},
{
"@type": "kind:global_window"
}
],
"is_wrapper": true
},
"output_name": "None",
"user_name": "assert_that/Unkey.out"
}
],
"parallel_input": {
"@type": "OutputReference",
"output_name": "None",
"step_name": "s21"
},
"serialized_fn":
"QlpoOTFBWSZTWZZfUfAAAtF/wH///////////////////+ZrwFADNmom9u2uwnhqZFNI9QNGhtR6jTJoaAyaANAAANA0aDTQxNNNMgNBoABolNNM0jJqbU0YmQAAyAAAAAAAAAAABpoyZAaaICRpkU8kyek0xNAGgABoDQAMgAAAAANDIDRBgBMAAACYAEwAAAJgBNDAAAAAAAEqahE8RNPUGjT1DahkAAABoAAAAAAAAAAANo+zvYDJms0gnHIkanWgtQF1IAYUaoZ9WAoCA+jBF/IdD1UIZoZQACUTmFiEwfSPZ/HhN7NYKoX9snvYallBIQkt7s7O0Hu+oTOCwLG193PoCRIuKCq982UYqpJqKAybkSgaSAMjIAMCTEdPboLPXmM7zKeRK6py6AwKw2QhIF9dmxQE4ZX6YYgIu01oKHAiAzRITeJJMEZgIFAIBczHiQD6Zi4jWgFgm1IxQJdJ0zUw+E/YCh3eU5YW1ERPwWvFQm4aoaJsfZTaasGwBCC4y9aFuw9+NzR5MuZkCocwzte14lDi9Tc4UGw8329OhQOGIu/8JBv9deSroabmt6Rhlsx+QwGELEaM0OhZknERB0sZN1uMAJHLMYESVuquW58nwDhn0uOsfSAnGt9N2hZASNNkcgJCsEgn0Bq4yQsS0c8OF3h1YEQgoC7J8Bk3ofUsiTmSkxeVnmt0qhueQCCH1IFjQ6L7EOGlxVeKwlKDJTIqINhAafwyK6LMjpPD55/lCh4YEcBTSl36bDVwwxYl5QIXnzjmhjcx2FDSFAgLgvWDas3gjB00ijNeAgJbMybKgKcze93tT/NgIFbVBYOAGGVNwFJAQQZIKrxFFkaibdrQXoBxFlRm4RZuA28DhKkdQqfpFsVIEOMJHmWRURAk3mO/m8PJfWUCa1DU8V3A8UCAfWEnyoIkGegpKkBhawERSAyKRhASnhDdjBHnRcZFgR8wolIpBCiQVeAKw3xk+EINghMAQDC5hx27WoHscRRczZrjxQQp3VdL/TbzKpuqlRdwf851MWxnq+00oU0RwnLA24zKU6Kl+iq0GZMowg+BiHOZYGV1pMyqtU5udBq79yMiQQmTfyJApgoYXxHzlyAYmPF0XjHuDFR+EqMMkaFFvGDwm8EBtA1NgEYGkY1TDwoIDC1ZFbpzuiIddAyLGKBBGtxFmxIlc4YIdyG0kHpsOmgEiJUkqY/JyWDhvK9cNoex4wfsiE0uH7olG0Kg0L0ZkZhcCwHu7voM3t/a5mIQWkrJlSpbzCnS5jZ/k3u68fnn0LuSKcKEhLL6j4A=",
"user_name": "assert_that/Unkey"
}
},
{
"kind": "ParallelDo",
"name": "s23",
"properties": {
"display_data": [
{
"key": "fn",
"label": "Transform Function",
"namespace": "apache_beam.transforms.core.CallableWrapperDoFn",
"type": "STRING",
"value": "_equal"
},
{
"key": "fn",
"label": "Transform Function",
"namespace": "apache_beam.transforms.core.ParDo",
"shortValue": "CallableWrapperDoFn",
"type": "STRING",
"value": "apache_beam.transforms.core.CallableWrapperDoFn"
}
],
"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_5"
},
{
"@type":
"FastPrimitivesCoder$QlpoOTFBWSZTWYQR6NMAAEDXwH8QgCEJAEBAv279AmAAIABqEqnqGgaABpoyNAGVHpGgMgDQBk0oR6IeoECBiqqU5NY23ndshzT2UPUOGrg42YPi9VyA8lbwwPJgtghxs5Qq1aWwExCDeMa0RHC2QigTCdizz1nx+LuSKcKEhCCPRpg=",
"component_encodings": [],
"pipeline_proto_coder_id":
"ref_Coder_FastPrimitivesCoder_5"
}
],
"is_pair_like": true,
"pipeline_proto_coder_id": "ref_Coder_FastPrimitivesCoder_5"
},
{
"@type": "kind:global_window"
}
],
"is_wrapper": true
},
"output_name": "None",
"user_name": "assert_that/Match.out"
}
],
"parallel_input": {
"@type": "OutputReference",
"output_name": "None",
"step_name": "s22"
},
"serialized_fn":
"QlpoOTFBWSZTWZe9W6kABHR/8v//////////////////////+QAAgIAACAAA0AUXndtWbYtpoDswODUyKep6p5T01R7VMJobUbJNP1Jp6n6ozKDTZQ0NDJtQ2o9T1ANBpoA0HqB5TyJiek/VH6p6hVPTKm2o0Dapnqn6UwgABkBpkyGgBkBkAAAA0GIyAGINNAETaRkRGShsoep+pDQAeoADEB6npAGgAAAAAAGgAADQgwJphNMTE0ZMATAE0GAmmAAmTAAAjBGJiMAmhiGTRglNQRkICYEYqY2UwkZMjI0GgAADQAAGQAeoNGhoD1AZGmiEynHFXnC1KmJBkwoRKjjOucVAys0jL1KCyFRqzqEZESSCUJUFeSvYozW81dxSZvvRzxMwzkwD0N/I83/ieP6HO7mRax419VjNFN5zJygt794cyAwee/4FjoxFDMQTTsfnfADmoOU1WvUrnnf7PFk9xKojlQQOY79SbHnagWL5a0lb/NOiCeaW5KWUdMdDaUtqWmBAybaJPztzIpY2JhhgBuOPvh+DhPQjgRk49UMibl0ONmKLXMshyd3YwdDouwodix70NdTuBU1E4rT92jEljhxVaWYiZmkTYzOcsJ4lko6IyKzbnmc00x5aERnxlCAQg+wg81os7o9LpfpOHXDah1CeuH+UI8i0NLK4sE5AQd3Hve8gAAABkERkRIqkTedsjMDEIEJGDJgJDGGrv5DgXfB2cGNEPKZkCHMAIT0UjqubFqfxN8KNPn2OpUy8HXxLfTelEL/ZYEiUNN/XIINIGKnrpJAIsIjiZrFjEiNYhwjfOeTKokmkI5wuMg5aav3GycXdjcF+wnUbUS2HsvY8MVaSQEmsO+fCAqOEApwO5rj/nW/fKBNA9Qelu6EZvQpGRWsdDVhC7te82rz0LjZBdoXpAxT8fk82nmWM6zv29rOq8mdfZ8mWBildvqAobpp2NHEWDzqXIPoy6+lUZX9p1oIocv8e7J0qNHU1XPtm2PFZpr41uR+1Q61SP1ul6Z+raV9K47lqdBXrJkEFFjEVmah3+VF0HO2KBPnF0DCc4vDsnSvc9zmib+iIsZSCKQxHwldVigW4r3igUUWwZS2t/m4l3lDmvCuMNUXbpiGppEhLgDnq1S7e0WkKWCJd1mhQ6F4L917AF0EB0Hoxts4JDBN28UX1awvBFW/LSy/71p4w+3qMCc9t7GnsaKTRiG4iIlKCPBLK63JmmNsFYSSErFRlNnQOkZzcImqjhjGyQFdGPKRUz2MnMrsA3FNcWZrWeKiZz5YxFMRMSwrItkGc/bJYizaIFT4kygfKbnZUsRB6L9qwaEDt875hU0X5QpkFfG08Df6vo6Yw6fU4+HcsyjGaGsbG2bAUmbPRhCO1AGccVEesLZpdrxM2f8AfpOmnBHbru6hGqJgDA5tIaxhHwLs2bChtMHj+6Fax0iyY55WrpeM9DVUqHh1lcGoE1DleezNxGV6po0Fe5gJFomUXxqb8+94EzQgiqqJhac5zhwOCDuSOTkyCwZQBAjX62ebAF3lXzZiPKhwKK14sYOEXBqLVGZn6iNOi2mtlJfGPoYccVh1aCEBTLSEAYRmydmCnA958Y6IwE94uygzaA6WkFNJFNauWNtIY2CIs3AVLYJWybU1pU1nIVQjUliFACIYPM3NM/ChYSvFBSYumDt2rJuoygNWAmOJ4AlFq8Wicig9MiRJE56kmRABGc4bMaYYb2xKaTjpOcPG3H6dmYm4LKGgKf9UGDPntyjaaifUc4QW9dbdJiNpnaHM87EeWSlbg7aNYkNN0PBE1RwgosLhfk9XazD7FyREQOLA7tFUxXYl+m1HIUkLGoiJJnHEt7YSZ9kyyUjLuul3505dRXc0eYWdpkusX1efMa2XjPwr7SRog0hLq2Qp5FRXW/N2duvlZS9eKbpYWThwYuKIOpFB+JZ2EWahMkWBuFLRN1MBtoSRNJRBAqjMSq5x5mHjrG4IS0BsyABEQxNnD+/+Pm3DlbnAgbEMt0kww3Gpkl6SQZFqHekFZ44rP+LuSKcKEhL3q3Ug=",
"user_name": "assert_that/Match"
}
}
],
"type": "JOB_TYPE_BATCH"
}
apache_beam.runners.dataflow.internal.apiclient: INFO: Create job: <Job
createTime: '2020-08-20T06:21:16.839155Z'
currentStateTime: '1970-01-01T00:00:00Z'
id: '2020-08-19_23_21_15-9942731114296503839'
location: 'us-central1'
name: 'beamapp-jenkins-0820062104-122920'
projectId: 'apache-beam-testing'
stageStates: []
startTime: '2020-08-20T06:21:16.839155Z'
steps: []
tempFiles: []
type: TypeValueValuesEnum(JOB_TYPE_BATCH, 1)>
apache_beam.runners.dataflow.internal.apiclient: INFO: Created job with id:
[2020-08-19_23_21_15-9942731114296503839]
apache_beam.runners.dataflow.internal.apiclient: INFO: Submitted job:
2020-08-19_23_21_15-9942731114296503839
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-19_23_21_15-9942731114296503839?project=apache-beam-testing
--------------------- >> end captured logging << ---------------------
----------------------------------------------------------------------
XML: nosetests-postCommitIT-df-py35.xml
----------------------------------------------------------------------
XML:
<https://ci-beam.apache.org/job/beam_PostCommit_Python35/ws/src/sdks/python/nosetests.xml>
----------------------------------------------------------------------
Ran 66 tests in 3953.763s
FAILED (SKIP=7, errors=1, failures=1)
> Task :sdks:python:test-suites:dataflow:py35:postCommitIT FAILED
FAILURE: Build failed with an exception.
* Where:
Script
'<https://ci-beam.apache.org/job/beam_PostCommit_Python35/ws/src/sdks/python/test-suites/dataflow/common.gradle'>
line: 118
* What went wrong:
Execution failed for task ':sdks:python:test-suites:dataflow:py35: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 8m 40s
153 actionable tasks: 117 executed, 34 from cache, 2 up-to-date
Publishing build scan...
https://gradle.com/s/ucys44z3uokmi
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]