See
<https://ci-beam.apache.org/job/beam_PostCommit_Python38/173/display/redirect?page=changes>
Changes:
[heejong] [BEAM-10679] improving XLang KafkaIO streaming test
[heejong] fix formatting
[heejong] fix incorrect coder issue
[heejong] use Create
[noreply] [BEAM-9919] Added an External Transform API to Go SDK (#12445)
------------------------------------------
[...truncated 21.55 MB...]
"user_name": "assert_that/Group/GroupByKey"
}
},
{
"kind": "ParallelDo",
"name": "s23",
"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": "_merge_tagged_vals_under_key"
}
],
"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_3"
},
{
"@type":
"FastPrimitivesCoder$QlpoOTFBWSZTWSYAoHgAAC334EwIiCAAIQkAQAC/bt0CYAQOACAAahpI0Bppo0GmRtINBqJ6QZAaNDQDyjRqC0RLwD4QPbijFck85Haypu6ovZAReEmQrcsyHc7KzNN4sFkXh7FICbooOXgwoVC0QQeEDWJD5shM4hP8XckU4UJAmAKB4A==",
"component_encodings": [],
"pipeline_proto_coder_id":
"ref_Coder_FastPrimitivesCoder_3"
}
],
"is_pair_like": true,
"pipeline_proto_coder_id": "ref_Coder_FastPrimitivesCoder_3"
},
{
"@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": "s22"
},
"serialized_fn":
"QlpoOTFBWSZTWRTQctsAAu3//X///S/SY8xFXe/9jr////ZvxQ4BYAAgAAQABABQA68KoAAowaTUmaTKep5Q0yeo0aHinqPUGmagAyAANAAAGnqADQqnkRkyTNPVP0UwJpkaMNIwACYjTJgAAmjEwQyYDgAAGgaGhoaZABoAANANDQAAMgAA4AABoGhoaGmQAaAADQDQ0AADIAAGIhDUZEYKejU2jKTynobVPU2jSZMjTQ9RkGmQDGkeieE1GnqFkDQZSpGANfa7RT5zZC3lJ9qprBzVAzPZ9xr8N0T5LQBFtLmez2vh/G/SKh1HrFEBL0s/u8gorUTEtXkwPEREeSDl2/7xNmiBHIQxaGMQEAKkTNDzIARQESiGREArsIwqiDQonbHuTBhqhAZV8KHxlE+sw+k4eGA5W9Cf+AEghT/JiXgUWKPCfGYFxA8Ejg8Rv78ReCFI9PsQWEV7mxYTsxjUmNUSwn6rasjyHdJJVKQFDeIzCIDUUlKsKKNB5eikYwh+w5IecwPSg4cDz+sGlwQLgstbgxem/HP1XnDQhXsmywyZK4Q7PNkEIKmfuqh2dFRvV2JtAxLebbx9itTSuEgwtdTXddz0/twgHaoGTex4hym4AZm7SJ3gB5PKvL5m/Q78sFrm3XsMBEVw4BA/Bh2TEgWy3cjtdO0bdQkBUzEBnq2XPIMTDHLd6+xKE1lNu1OTt1FcMAKItW4uWHTOsdbNh0EDGIBePTAMzChZIzcfdFraqkOUGjbjRGGkwpZxaMhEYYje5jknlp56nv2lFa359IZLSw05CXGUPb9QRh+t7YygQhQRCO+e722DJMvC/XQHHxMcpAv1h9s5weLNllpARDhayMMfMFtLfzgy2zx5HPWnYdejSBnHvZAdI6Z7GzsDXbMVVisOHadU0um1aOOYnGRoAZMGcMD4iiBugK7VIWYDIwEoq6TOJMWgogVpF2YGLEuSnQC3gyMONdju3ALTWxn1C5QM4oZIm7rmsmGFchpA8FeqBfuapwEDn8BcRDWwgGEpCQ0V6mwe0aN4Whk1VvVE7dkbpWM8WzhhMXiJj2wJFfTn722IiqlMmwG82owDnrFg47ei2+LGaSe9yGZsETWLCiFYMWvIRnFo5+CtzZcN+hxVa1Q/V0VCjUAzg0AcGaqNtJKMAL54GvC4BQM+zdEkd3ueYoKzW3EOJxLNPcrxFX3rynTG7sjCLwjK+pnBmiPDQ1JQyHRRmoibIIRZlSKUaEB73voGIkCrJNhjNOssqk8p8oXDOdCQnTSykJBF0GXKgRdRoC8KIMbzEOqLbJB5tzp1BELaYRToQ5mIFaJHP0ej1H3TraJCGt1uzinwldqq0jonPoXQnZnKcJ1Ku5MWOwtIP11U9iHQHXYlHsyEEcAoKtYo6TSlx3Eks6gQSJYzkQgIBFMgikl5RhiBghTEgdSsaBhp4EBBIMsAwqjzTwiCmyWPZqjlzF3JFOFCQFNBy2w=",
"user_name": "assert_that/Group/Map(_merge_tagged_vals_under_key)"
}
},
{
"kind": "ParallelDo",
"name": "s24",
"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": "<lambda>"
}
],
"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_3"
},
{
"@type":
"FastPrimitivesCoder$QlpoOTFBWSZTWSYAoHgAAC334EwIiCAAIQkAQAC/bt0CYAQOACAAahpI0Bppo0GmRtINBqJ6QZAaNDQDyjRqC0RLwD4QPbijFck85Haypu6ovZAReEmQrcsyHc7KzNN4sFkXh7FICbooOXgwoVC0QQeEDWJD5shM4hP8XckU4UJAmAKB4A==",
"component_encodings": [],
"pipeline_proto_coder_id":
"ref_Coder_FastPrimitivesCoder_3"
}
],
"is_pair_like": true,
"pipeline_proto_coder_id": "ref_Coder_FastPrimitivesCoder_3"
},
{
"@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": "s23"
},
"serialized_fn":
"QlpoOTFBWSZTWXEBOHIAAfp/6H3/fGtIY4pFjevcgr//3+ZrxA4ABABAAr3WXRpqcg1MlPQk9NR6BoQ0zRGJgJphDRgIaNGamJgBqZJieoamQTTT0hpiMmjQ00AGgAAAA0DEip5GpoGQA0GjIyBkZAA0ZAwIGGoEoQSZPU00J6npDUabUY1ME0yZGRp6QaNNDyI00aD1TbCszN3NlPQbX75iYOft2YPSSjH+7a3EkFONmBJSICZiBCmAUsIBkhHrqQjoTmpIm6JXuwVn4ckVSto/UgO6osOFOk4x5agTFXEVfNx493VWGc24535pDVPrDojXAYxpD4dgPoIXgakF0vJUG8mYBKEIZZ7YvxBsTDY/GkSwwI5OEugB63c83IdafbXfwiDLrVjyoKWUDCnmjjemAQ18PBo9lwQtU3DIHs5suXnd8COCi2ijih/WPNq/jgAgPCy3ajEjFQoYANaWlq9RUtt0gUM8SIZZxPEQELI3yKjSMXh0NwCweLeEJ0dFfxP1PfbtcgR14eq+pM0CY1IkSdpXWXAV8K1R0Qcb9JbR3RYExDzJxb7IypOuwuHpZLAL1wxlgYbH3Qe4XCqPr7BcTxt7eB2qmbTcmtRzjC2BQ6gIIhCXJnnmJlx0OHNYYSRyF8798sRLGkGENkg2UW7A9uAgUEYLUFEEINBCSooPZCIK5QXcGVH5lx0lHDI1vAOFCiCj0u+IkGKvOWvTc1Ap0zQA+FGCQgKrGacmVYGANnYBcSd4KqomyBw9oFKlrOWHNIWkk19kcbBkn4L5AOsiZB5bJCgsi87SWd7PxKSvEzHQ1A4QVAKr6wDVcMDhI6Mg1ioeA5Q8Bor54YSrvWMIfOPE2ZaW4xROhdsClMK9FBSWL7DaCGG1GoEUQuBChu6JGlk6ZD3vRZGJX0D0oQKsjCiHOhpPSDpDQJ6AWqz05DrgYgD6jwHExCx58+jRwZ0SnSY5MRTnFmBSSfiB676wF2SNWMI42S3mh2OlcWioaF6nM0SzWXnNEbnMLBQmhjotiFOmDGuUCNQjLH/f4u5IpwoSDiAnDkA=",
"user_name": "assert_that/Unkey"
}
},
{
"kind": "ParallelDo",
"name": "s25",
"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": "_equal"
}
],
"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_3"
},
{
"@type":
"FastPrimitivesCoder$QlpoOTFBWSZTWSYAoHgAAC334EwIiCAAIQkAQAC/bt0CYAQOACAAahpI0Bppo0GmRtINBqJ6QZAaNDQDyjRqC0RLwD4QPbijFck85Haypu6ovZAReEmQrcsyHc7KzNN4sFkXh7FICbooOXgwoVC0QQeEDWJD5shM4hP8XckU4UJAmAKB4A==",
"component_encodings": [],
"pipeline_proto_coder_id":
"ref_Coder_FastPrimitivesCoder_3"
}
],
"is_pair_like": true,
"pipeline_proto_coder_id": "ref_Coder_FastPrimitivesCoder_3"
},
{
"@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": "s24"
},
"serialized_fn":
"QlpoOTFBWSZTWf3+qlAAAx3//v///8vWd61XP//c5r////Z/9Q4B8IAAAQABARAEAFAEJvNTW67aQjrz2DQhT0qeyYqeKeapp6mxIzU2hNHoT1AemkxPUPSaaZANMyh6mnqejKNNAeoaA0KMU9BHpDJpoptJ5NMU00MnqGjTRkAANAAAABoZAAyDVMTJhUejUHqGTQGgA0D1BoaAAAAAAAAAABoNNRKNHqZAA0ZA0DQaNMQ00BkYg0NGgBoaMgaAAAAlCE0gm0RpkwU9TTTymgZPU0AMmgAAAyAA0GgPSNAANMIWUk0XOyC1xqN6o7kYWO6pgcgwBu/tc4PsDPHbOAq/DYlwGZ/kTsWhimpWNLHNWGOc9iwZNO/FN/0OCen0OIGL/L9S3QFMDzb5ETRwN7hYoy0hnvsGhECwppCmz2kSshtBKCJ+U95zkIQg6Sz22nypKoRoy5SCzRkR0YrKiRgkyhsoRcIzSI5hcZ7KOaRUIAqRFRlBVQio+q0LuYrVx6JJZvDXvMhonyLA+SWtMBPx1wiGc4yHJ6SDvGRMkV9KSNq7eNFDenVcqKpjtQtkB2rIw4U9ZpjyWBNKWdjpGXX7SXbUxdD+tTrbGFbrwSnk1pMbHmOdufkLsuUnjeKh5DBhFHZaj6lsyInCoC4SMXgUFHcvAIQAeEd+pytj3y8D9uPGzIzq9vCgy92G/Maqg8IpLqMV1oDuyM7afi2QsGQR0KZEIJmthKGfAdEZAMEQiBe3KBCFmVd6GIdWKYFAQEQeEMAywOxuWrXWV7RKbKd4fM4+S5FUxI9keYCpXvEgFIbPhfyqJiTiRJ2s5wDnz77kwjyFlYoezXaxz3tnLDATboqyOchsOsHANVjSq+hG2qLA2C+VLOAC4PFxQPcpPR8VEjImSs9Q1JJMk06U5Hx5wFASJDk/A2VKJUQPlCSthgQDhu/qSqeRTJnXmyRxFCZJBOyQDVfDIYytiQlT5AEAEDOCWnwkI0T+nkH7zKvaAHJemmG3JYBrlqFQIbZ42aqQtagt+tAdw9IHW0w3HBt6FOsGLmrKAm/yskCUWBvZ4bqBNYHTonFllsn8E7qS4VmjH/nEIlLJiGiGHgYKuZFnkdWAmMDr1gUhGGrOsBxm4gwhF0QWgysMDA9kJQVyKCpwXq5QbRW5nYoYmjMZeQOFChBUsQSreKQUYW0l1hYcildCaJVA1wbQQVqAoV7MYmCxTuXjiFqXYfmUGw7R2hQDNdTn4xFriLCoEp9HomPdty68JwoLNOc5wruBRGKxVa2yOMA4zM61TfkWhMGgQJ9Bo7GCmMYaLX1pyiwDAQJXEdDQtykVin2sr7TT3o2g7LhcjqKuhgfrktQMjNL8yZYFIukpoiXlNTOOkwoNRJxUBLFIZjQsyvDQ8Q1Ab1SBwe5YEYTXbhjz3CBz17QnPVYhNmBrod6mZksGo1HAY6dEg2oHyBnIFUGF06QeUlS69hl/2Yt/iPZy6gbFtmQ7O02m+R24mU3KK8Cs4CDVqKSF5gwgpZ0K1piEAX1VQMsfpdkNiCY5QkEojJCKLRspCUXRKiFghDeKDBWQL0vmikSoKIPln+n24I/AtAQt7h1fPlLgYLZctkshimaMYGIUOurWHTSTNOOHgI3DNKMJYcWVFbmtVYTdG/FCTUjlhhPSmuP8plPHBMb8CSzLYmSutXmqouKFp6a2tjbBIpyw2kKIaEeFBqWyE0PNk8lzFur8Cmlzdf/i7kinChIfv9VKAA==",
"user_name": "assert_that/Match"
}
}
],
"type": "JOB_TYPE_BATCH"
}
apache_beam.runners.dataflow.internal.apiclient: INFO: Create job: <Job
createTime: '2020-08-18T06:23:03.990057Z'
currentStateTime: '1970-01-01T00:00:00Z'
id: '2020-08-17_23_23_02-2307310129497404330'
location: 'us-central1'
name: 'beamapp-jenkins-0818061634-551982'
projectId: 'apache-beam-testing'
stageStates: []
startTime: '2020-08-18T06:23:03.990057Z'
steps: []
tempFiles: []
type: TypeValueValuesEnum(JOB_TYPE_BATCH, 1)>
apache_beam.runners.dataflow.internal.apiclient: INFO: Created job with id:
[2020-08-17_23_23_02-2307310129497404330]
apache_beam.runners.dataflow.internal.apiclient: INFO: Submitted job:
2020-08-17_23_23_02-2307310129497404330
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-17_23_23_02-2307310129497404330?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 3403.801s
FAILED (SKIP=7, errors=1, failures=1)
> Task :sdks:python:test-suites:dataflow:py38:postCommitIT FAILED
FAILURE: Build 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 59m 12s
154 actionable tasks: 118 executed, 34 from cache, 2 up-to-date
Publishing build scan...
https://gradle.com/s/qbvxrq73fvbdq
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]
