See
<https://ci-beam.apache.org/job/beam_LoadTests_Go_ParDo_Flink_Batch/791/display/redirect?page=changes>
Changes:
[relax] Fix inconsistent cache bug
[noreply] update cloudpickle version (#25142)
[noreply] [ToB][Frontend] Gradle tasks for ToB frontend (#24919)
[noreply] Remove databaseRole from metadata DB requests in
[noreply] Update typehint code to allow primitive composite types in python 3.9+
[noreply] Fix intruction -> instruction typo
[chamikaramj] Increase default expansion service timeout
[noreply] Further increase transient expansion service timeout (#25176)
[noreply] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager in /sdks (#25182)
[noreply] Adds the SampleDataRequest/Response (#25065)
------------------------------------------
[...truncated 247.61 KB...]
spec: <
urn: "beam:transform:pardo:v1"
payload:
"\n\202\002\n\031beam:go:transform:dofn:v1\032\344\001ChliZWFtOmdvOnRyYW5zZm9ybTpkb2ZuOnYxEowBCkUSHwgYEhsIGkoXbWFpbi5jb3VudGVyT3BlcmF0aW9uRm4aInsiT3BlcmF0aW9ucyI6MTAwLCJOdW1Db3VudGVycyI6MX0SHggBEhoKBAgZQAsSCAoGCBQSAggIEggKBggUEgIICBocChoKBAgZQAsSCAoGCBQSAggIEggKBggUEgIICCIFUGFyRG8="
>
inputs: <
key: "i0"
value: "n4"
>
outputs: <
key: "i0"
value: "n5"
>
environment_id: "go"
>
>
transforms: <
key: "s1"
value: <
unique_name: "synthetic.Source"
subtransforms: "e1"
subtransforms: "e2"
subtransforms: "e3"
outputs: <
key: "n3"
value: "n3"
>
environment_id: "go"
>
>
pcollections: <
key: "n1"
value: <
unique_name: "n1"
coder_id: "c0"
is_bounded: BOUNDED
windowing_strategy_id: "w0"
>
>
pcollections: <
key: "n2"
value: <
unique_name: "n2"
coder_id: "c3"
is_bounded: BOUNDED
windowing_strategy_id: "w0"
>
>
pcollections: <
key: "n3"
value: <
unique_name: "n3"
coder_id: "c1"
is_bounded: BOUNDED
windowing_strategy_id: "w0"
>
>
pcollections: <
key: "n4"
value: <
unique_name: "n4"
coder_id: "c1"
is_bounded: BOUNDED
windowing_strategy_id: "w0"
>
>
pcollections: <
key: "n5"
value: <
unique_name: "n5"
coder_id: "c1"
is_bounded: BOUNDED
windowing_strategy_id: "w0"
>
>
windowing_strategies: <
key: "w0"
value: <
window_fn: <
urn: "beam:window_fn:global_windows:v1"
>
merge_status: NON_MERGING
window_coder_id: "c2"
trigger: <
default: <
>
>
accumulation_mode: DISCARDING
output_time: END_OF_WINDOW
closing_behavior: EMIT_IF_NONEMPTY
on_time_behavior: FIRE_IF_NONEMPTY
environment_id: "go"
>
>
coders: <
key: "c0"
value: <
spec: <
urn: "beam:coder:bytes:v1"
>
>
>
coders: <
key: "c1"
value: <
spec: <
urn: "beam:coder:kv:v1"
>
component_coder_ids: "c0"
component_coder_ids: "c0"
>
>
coders: <
key: "c2"
value: <
spec: <
urn: "beam:coder:global_window:v1"
>
>
>
coders: <
key: "c3"
value: <
spec: <
urn: "beam:coder:row:v1"
payload:
"\n\021\n\013num_records\032\002\020\004\n\024\n\016initial_splits\032\002\020\004\n\016\n\010key_size\032\002\020\004\n\020\n\nvalue_size\032\002\020\004\n\022\n\014num_hot_keys\032\002\020\004\n\026\n\020hot_key_fraction\032\002\020\006\022$f691cccd-3963-4ed9-9f25-d9fdfd07b30d"
>
>
>
coders: <
key: "c4"
value: <
spec: <
urn: "beam:go:coder:custom:v1"
payload:
"ChdvZmZzZXRyYW5nZS5SZXN0cmljdGlvbhJTCBpKT2dpdGh1Yi5jb20vYXBhY2hlL2JlYW0vc2Rrcy92Mi9nby9wa2cvYmVhbS9pby9ydHJhY2tlcnMvb2Zmc2V0cmFuZ2UuUmVzdHJpY3Rpb24atAEKS2dpdGh1Yi5jb20vYXBhY2hlL2JlYW0vc2Rrcy92Mi9nby9wa2cvYmVhbS9pby9ydHJhY2tlcnMvb2Zmc2V0cmFuZ2UucmVzdEVuYxJlCBYiUwgaSk9naXRodWIuY29tL2FwYWNoZS9iZWFtL3Nka3MvdjIvZ28vcGtnL2JlYW0vaW8vcnRyYWNrZXJzL29mZnNldHJhbmdlLlJlc3RyaWN0aW9uKgYIFBICCAgqBAgZQAEitAEKS2dpdGh1Yi5jb20vYXBhY2hlL2JlYW0vc2Rrcy92Mi9nby9wa2cvYmVhbS9pby9ydHJhY2tlcnMvb2Zmc2V0cmFuZ2UucmVzdERlYxJlCBYiBggUEgIICCpTCBpKT2dpdGh1Yi5jb20vYXBhY2hlL2JlYW0vc2Rrcy92Mi9nby9wa2cvYmVhbS9pby9ydHJhY2tlcnMvb2Zmc2V0cmFuZ2UuUmVzdHJpY3Rpb24qBAgZQAE="
>
>
>
coders: <
key: "c5"
value: <
spec: <
urn: "beam:coder:length_prefix:v1"
>
component_coder_ids: "c4"
>
>
coders: <
key: "c6"
value: <
spec: <
urn: "beam:coder:bool:v1"
>
>
>
coders: <
key: "c7"
value: <
spec: <
urn: "beam:coder:kv:v1"
>
component_coder_ids: "c5"
component_coder_ids: "c6"
>
>
environments: <
key: "go"
value: <
urn: "beam:env:docker:v1"
payload: "\n6gcr.io/apache-beam-testing/beam-sdk/beam_go_sdk:latest"
capabilities: "beam:protocol:progress_reporting:v1"
capabilities: "beam:protocol:multi_core_bundle_processing:v1"
capabilities: "beam:transform:sdf_truncate_sized_restrictions:v1"
capabilities: "beam:protocol:****_status:v1"
capabilities: "beam:protocol:monitoring_info_short_ids:v1"
capabilities: "beam:version:sdk_base:go:apache/beam_go_sdk:2.46.0.dev"
capabilities: "beam:coder:bytes:v1"
capabilities: "beam:coder:bool:v1"
capabilities: "beam:coder:varint:v1"
capabilities: "beam:coder:double:v1"
capabilities: "beam:coder:string_utf8:v1"
capabilities: "beam:coder:length_prefix:v1"
capabilities: "beam:coder:kv:v1"
capabilities: "beam:coder:iterable:v1"
capabilities: "beam:coder:state_backed_iterable:v1"
capabilities: "beam:coder:windowed_value:v1"
capabilities: "beam:coder:global_window:v1"
capabilities: "beam:coder:interval_window:v1"
capabilities: "beam:coder:row:v1"
capabilities: "beam:coder:nullable:v1"
dependencies: <
type_urn: "beam:artifact:type:file:v1"
role_urn: "beam:artifact:role:go_****_binary:v1"
>
>
>
>
root_transform_ids: "s1"
root_transform_ids: "e4"
root_transform_ids: "e5"
requirements: "beam:requirement:pardo:splittable_dofn:v1"
2023/01/26 11:36:46 Using specified **** binary: 'linux_amd64/pardo'
2023/01/26 11:36:47 Prepared job with id:
load-tests-go-flink-batch-pardo-4-0126100245_dc0dbb19-8c34-48fb-b137-bb4b08e29fe5
and staging token:
load-tests-go-flink-batch-pardo-4-0126100245_dc0dbb19-8c34-48fb-b137-bb4b08e29fe5
2023/01/26 11:36:49 Staged binary artifact with token:
2023/01/26 11:36:49 Submitted job:
load0tests0go0flink0batch0pardo0400126100245-root-0126113649-6f3ec888_2625ba6d-e76e-4895-878f-ef6fb26fe099
2023/01/26 11:36:49 Job state: STOPPED
2023/01/26 11:36:49 Job state: STARTING
2023/01/26 11:36:49 Job state: RUNNING
2023/01/26 11:37:25 Failed to execute job: failed to get metrics
caused by:
rpc error: code = Unavailable desc = connection error: desc = "transport: Error
while dialing dial tcp 127.0.0.1:8099: connect: connection refused"
caused by:
rpc error: code = Unavailable desc = error reading from server: EOF
panic: Failed to execute job: failed to get metrics
caused by:
rpc error: code = Unavailable desc = connection error: desc = "transport: Error
while dialing dial tcp 127.0.0.1:8099: connect: connection refused"
caused by:
rpc error: code = Unavailable desc = error reading from server: EOF
goroutine 1 [running]:
github.com/apache/beam/sdks/v2/go/pkg/beam/log.Fatalf({0x1735768,
0xc00004e0c0}, {0x1593136?, 0xc0000f6450?}, {0xc000633e70?, 0x0?, 0x0?})
<https://ci-beam.apache.org/job/beam_LoadTests_Go_ParDo_Flink_Batch/ws/src/sdks/go/pkg/beam/log/log.go>:162
+0x8c
main.main()
<https://ci-beam.apache.org/job/beam_LoadTests_Go_ParDo_Flink_Batch/ws/src/sdks/go/test/load/pardo/pardo.go>:109
+0x3aa
> Task :sdks:go:test:load:run FAILED
FAILURE: Build failed with an exception.
* Where:
Build file
'<https://ci-beam.apache.org/job/beam_LoadTests_Go_ParDo_Flink_Batch/ws/src/sdks/go/test/load/build.gradle'>
line: 31
* What went wrong:
Execution failed for task ':sdks:go:test:load:run'.
> Process 'command 'sh'' finished with non-zero exit value 2
* Try:
> Run with --stacktrace option to get the stack trace.
> Run with --info or --debug option to get more log output.
* Get more help at https://help.gradle.org
BUILD FAILED in 50s
12 actionable tasks: 2 executed, 10 up-to-date
Publishing build scan...
https://gradle.com/s/e5icqtddauync
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]
