See 
<https://ci-beam.apache.org/job/beam_LoadTests_Java_CoGBK_Dataflow_V2_Streaming_Java11/163/display/redirect>

Changes:


------------------------------------------
[...truncated 48.08 KB...]
1c6a92bd04bd: Preparing
2e84b2cd629a: Preparing
3233a81acadc: Preparing
5461a9724d64: Preparing
bdcb92e8950b: Preparing
e12deef2713a: Preparing
a9e4c9343539: Preparing
47ee2d19f81a: Preparing
ab9d251e27cb: Preparing
2e84b2cd629a: Waiting
5461a9724d64: Waiting
8a5844586fdb: Preparing
3233a81acadc: Waiting
a4aba4e59b40: Preparing
5499f2905579: Preparing
bdcb92e8950b: Waiting
a9e4c9343539: Waiting
47ee2d19f81a: Waiting
a36ba9e322f7: Preparing
8a5844586fdb: Waiting
a4aba4e59b40: Waiting
5499f2905579: Waiting
a5d8ec5405f9: Waiting
a36ba9e322f7: Waiting
ab9d251e27cb: Waiting
8da5421b804b: Pushed
909ecb9172e0: Pushed
2be90649daa8: Pushed
a5d8ec5405f9: Pushed
dd91861233dd: Pushed
98901f8af3ee: Pushed
2e84b2cd629a: Pushed
3233a81acadc: Pushed
a9e4c9343539: Layer already exists
47ee2d19f81a: Layer already exists
ab9d251e27cb: Layer already exists
8a5844586fdb: Layer already exists
a4aba4e59b40: Layer already exists
bdcb92e8950b: Pushed
5499f2905579: Layer already exists
a36ba9e322f7: Layer already exists
e12deef2713a: Pushed
1c6a92bd04bd: Pushed
5461a9724d64: Pushed
20211127124332: digest: 
sha256:c44ba3d6e18b4542f8294f3b50b46035b75f98347237d9d9b8b821045e9ca16d size: 
4311

> Task :sdks:java:testing:load-tests:run
Nov 27, 2021 12:45:17 PM 
org.apache.beam.runners.dataflow.options.DataflowPipelineOptions$StagingLocationFactory
 create
INFO: No stagingLocation provided, falling back to gcpTempLocation
Nov 27, 2021 12:45:17 PM org.apache.beam.runners.dataflow.DataflowRunner 
fromOptions
INFO: PipelineOptions.filesToStage was not specified. Defaulting to files from 
the classpath: will stage 197 files. Enable logging at DEBUG level to see which 
files will be staged.
Nov 27, 2021 12:45:18 PM org.apache.beam.sdk.Pipeline validate
WARNING: The following transforms do not have stable unique names: Window.Into()
Nov 27, 2021 12:45:18 PM org.apache.beam.runners.dataflow.DataflowRunner run
INFO: Executing pipeline on the Dataflow Service, which will have billing 
implications related to Google Compute Engine usage and other Google Cloud 
Services.
Nov 27, 2021 12:45:20 PM org.apache.beam.runners.dataflow.util.PackageUtil 
stageClasspathElements
INFO: Uploading 197 files from PipelineOptions.filesToStage to staging location 
to prepare for execution.
Nov 27, 2021 12:45:20 PM org.apache.beam.runners.dataflow.util.PackageUtil 
stageClasspathElements
INFO: Staging files complete: 197 files cached, 0 files newly uploaded in 0 
seconds
Nov 27, 2021 12:45:21 PM org.apache.beam.runners.dataflow.DataflowRunner run
INFO: Staging portable pipeline proto to 
gs://temp-storage-for-perf-tests/loadtests/staging/
Nov 27, 2021 12:45:21 PM org.apache.beam.runners.dataflow.util.PackageUtil 
tryStagePackage
INFO: Uploading <111716 bytes, hash 
43eb46937e01796d53e29ba9dd6cc2a2e764819e4b77a5fe014d88429ba4b374> to 
gs://temp-storage-for-perf-tests/loadtests/staging/pipeline-Q-tGk34BeW1T4pup3WzCoudkgZ5Ld6X-AU2IQpuks3Q.pb
Nov 27, 2021 12:45:22 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding Read input/DataflowRunner.StreamingUnboundedRead.ReadWithIds as 
step s1
Nov 27, 2021 12:45:22 PM 
org.apache.beam.sdk.io.synthetic.SyntheticUnboundedSource split
INFO: Split into 20 bundles of sizes: 
[org.apache.beam.sdk.io.synthetic.SyntheticUnboundedSource@177515d1, 
org.apache.beam.sdk.io.synthetic.SyntheticUnboundedSource@52ff99cd, 
org.apache.beam.sdk.io.synthetic.SyntheticUnboundedSource@4c2af006, 
org.apache.beam.sdk.io.synthetic.SyntheticUnboundedSource@44032fde, 
org.apache.beam.sdk.io.synthetic.SyntheticUnboundedSource@7b676112, 
org.apache.beam.sdk.io.synthetic.SyntheticUnboundedSource@5578be42, 
org.apache.beam.sdk.io.synthetic.SyntheticUnboundedSource@4e49ce2b, 
org.apache.beam.sdk.io.synthetic.SyntheticUnboundedSource@136965e3, 
org.apache.beam.sdk.io.synthetic.SyntheticUnboundedSource@53c6f96d, 
org.apache.beam.sdk.io.synthetic.SyntheticUnboundedSource@435cc7f9, 
org.apache.beam.sdk.io.synthetic.SyntheticUnboundedSource@4364712f, 
org.apache.beam.sdk.io.synthetic.SyntheticUnboundedSource@1b7a52dd, 
org.apache.beam.sdk.io.synthetic.SyntheticUnboundedSource@7f93dd4e, 
org.apache.beam.sdk.io.synthetic.SyntheticUnboundedSource@5ad5be4a, 
org.apache.beam.sdk.io.synthetic.SyntheticUnboundedSource@3ad85136, 
org.apache.beam.sdk.io.synthetic.SyntheticUnboundedSource@737d100a, 
org.apache.beam.sdk.io.synthetic.SyntheticUnboundedSource@12e5da86, 
org.apache.beam.sdk.io.synthetic.SyntheticUnboundedSource@6535117e, 
org.apache.beam.sdk.io.synthetic.SyntheticUnboundedSource@1d1cbd0f, 
org.apache.beam.sdk.io.synthetic.SyntheticUnboundedSource@6fa13e6]
Nov 27, 2021 12:45:22 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding Read input/StripIds as step s2
Nov 27, 2021 12:45:22 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding Collect start time metrics (input) as step s3
Nov 27, 2021 12:45:22 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding Window.Into()/Window.Assign as step s4
Nov 27, 2021 12:45:22 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding Read co-input/DataflowRunner.StreamingUnboundedRead.ReadWithIds as 
step s5
Nov 27, 2021 12:45:22 PM 
org.apache.beam.sdk.io.synthetic.SyntheticUnboundedSource split
INFO: Split into 20 bundles of sizes: 
[org.apache.beam.sdk.io.synthetic.SyntheticUnboundedSource@3f183caa, 
org.apache.beam.sdk.io.synthetic.SyntheticUnboundedSource@7b66322e, 
org.apache.beam.sdk.io.synthetic.SyntheticUnboundedSource@63538bb4, 
org.apache.beam.sdk.io.synthetic.SyntheticUnboundedSource@24534cb0, 
org.apache.beam.sdk.io.synthetic.SyntheticUnboundedSource@5a50d9fc, 
org.apache.beam.sdk.io.synthetic.SyntheticUnboundedSource@106d77da, 
org.apache.beam.sdk.io.synthetic.SyntheticUnboundedSource@6f9c5048, 
org.apache.beam.sdk.io.synthetic.SyntheticUnboundedSource@5114b7c7, 
org.apache.beam.sdk.io.synthetic.SyntheticUnboundedSource@dd71b20, 
org.apache.beam.sdk.io.synthetic.SyntheticUnboundedSource@767f6ee7, 
org.apache.beam.sdk.io.synthetic.SyntheticUnboundedSource@7b6c6e70, 
org.apache.beam.sdk.io.synthetic.SyntheticUnboundedSource@f324455, 
org.apache.beam.sdk.io.synthetic.SyntheticUnboundedSource@3a894088, 
org.apache.beam.sdk.io.synthetic.SyntheticUnboundedSource@370c1968, 
org.apache.beam.sdk.io.synthetic.SyntheticUnboundedSource@2f0bfe17, 
org.apache.beam.sdk.io.synthetic.SyntheticUnboundedSource@3206174f, 
org.apache.beam.sdk.io.synthetic.SyntheticUnboundedSource@42fb8c87, 
org.apache.beam.sdk.io.synthetic.SyntheticUnboundedSource@15eb0ae9, 
org.apache.beam.sdk.io.synthetic.SyntheticUnboundedSource@65e0b505, 
org.apache.beam.sdk.io.synthetic.SyntheticUnboundedSource@67de7a99]
Nov 27, 2021 12:45:22 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding Read co-input/StripIds as step s6
Nov 27, 2021 12:45:22 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding Collect start time metrics (co-input) as step s7
Nov 27, 2021 12:45:22 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding Window.Into()2/Window.Assign as step s8
Nov 27, 2021 12:45:22 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding CoGroupByKey/MakeUnionTable0 as step s9
Nov 27, 2021 12:45:22 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding CoGroupByKey/MakeUnionTable1 as step s10
Nov 27, 2021 12:45:22 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding CoGroupByKey/Flatten as step s11
Nov 27, 2021 12:45:22 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding CoGroupByKey/GBK as step s12
Nov 27, 2021 12:45:22 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding CoGroupByKey/ConstructCoGbkResultFn as step s13
Nov 27, 2021 12:45:22 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding Ungroup and reiterate as step s14
Nov 27, 2021 12:45:22 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding Collect total bytes as step s15
Nov 27, 2021 12:45:22 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding Collect end time metrics as step s16
Nov 27, 2021 12:45:22 PM org.apache.beam.runners.dataflow.DataflowRunner run
INFO: Dataflow SDK version: 2.36.0-SNAPSHOT
Nov 27, 2021 12:45:23 PM org.apache.beam.runners.dataflow.DataflowRunner run
INFO: To access the Dataflow monitoring console, please navigate to 
https://console.cloud.google.com/dataflow/jobs/us-central1/2021-11-27_04_45_23-6887480424228758737?project=apache-beam-testing
Nov 27, 2021 12:45:23 PM org.apache.beam.runners.dataflow.DataflowRunner run
INFO: Submitted job: 2021-11-27_04_45_23-6887480424228758737
Nov 27, 2021 12:45:23 PM org.apache.beam.runners.dataflow.DataflowRunner run
INFO: To cancel the job using the 'gcloud' tool, run:
> gcloud dataflow jobs --project=apache-beam-testing cancel 
> --region=us-central1 2021-11-27_04_45_23-6887480424228758737
Nov 27, 2021 12:45:31 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
WARNING: 2021-11-27T12:45:29.329Z: The workflow name is not a valid Cloud 
Label. Labels applied to Cloud resources (such as GCE Instances) for monitoring 
will be labeled with this modified job name: 
load0tests0java110dataflow0v20streaming0cogbk01-jenkins-11-tsvn. For the best 
monitoring experience, please name your job with a valid Cloud Label. For 
details, see: 
https://cloud.google.com/compute/docs/labeling-resources#restrictions
Nov 27, 2021 12:45:35 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2021-11-27T12:45:34.097Z: Worker configuration: e2-standard-2 in 
us-central1-a.
Nov 27, 2021 12:45:35 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2021-11-27T12:45:34.661Z: Expanding SplittableParDo operations into 
optimizable parts.
Nov 27, 2021 12:45:35 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2021-11-27T12:45:34.702Z: Expanding CollectionToSingleton operations into 
optimizable parts.
Nov 27, 2021 12:45:35 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2021-11-27T12:45:34.774Z: Expanding CoGroupByKey operations into 
optimizable parts.
Nov 27, 2021 12:45:35 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2021-11-27T12:45:34.842Z: Expanding SplittableProcessKeyed operations 
into optimizable parts.
Nov 27, 2021 12:45:35 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2021-11-27T12:45:34.873Z: Expanding GroupByKey operations into streaming 
Read/Write steps
Nov 27, 2021 12:45:35 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2021-11-27T12:45:34.950Z: Lifting ValueCombiningMappingFns into 
MergeBucketsMappingFns
Nov 27, 2021 12:45:35 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2021-11-27T12:45:35.061Z: Fusing adjacent ParDo, Read, Write, and Flatten 
operations
Nov 27, 2021 12:45:35 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2021-11-27T12:45:35.093Z: Unzipping flatten CoGroupByKey-Flatten for 
input CoGroupByKey-MakeUnionTable0-ParMultiDo-ConstructUnionTable-.output
Nov 27, 2021 12:45:35 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2021-11-27T12:45:35.119Z: Fusing unzipped copy of 
CoGroupByKey/GBK/WriteStream, through flatten CoGroupByKey/Flatten, into 
producer CoGroupByKey/MakeUnionTable0/ParMultiDo(ConstructUnionTable)
Nov 27, 2021 12:45:35 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2021-11-27T12:45:35.151Z: Fusing consumer CoGroupByKey/GBK/WriteStream 
into CoGroupByKey/MakeUnionTable1/ParMultiDo(ConstructUnionTable)
Nov 27, 2021 12:45:35 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2021-11-27T12:45:35.189Z: Fusing consumer Read 
input/ParDo(OutputSingleSource)/ParMultiDo(OutputSingleSource) into Read 
input/Impulse
Nov 27, 2021 12:45:35 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2021-11-27T12:45:35.222Z: Fusing consumer 
Read-input-ParDo-UnboundedSourceAsSDFWrapper--ParMultiDo-UnboundedSourceAsSDFWrapper-/PairWithRestriction
 into Read input/ParDo(OutputSingleSource)/ParMultiDo(OutputSingleSource)
Nov 27, 2021 12:45:35 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2021-11-27T12:45:35.257Z: Fusing consumer 
Read-input-ParDo-UnboundedSourceAsSDFWrapper--ParMultiDo-UnboundedSourceAsSDFWrapper-/SplitWithSizing
 into 
Read-input-ParDo-UnboundedSourceAsSDFWrapper--ParMultiDo-UnboundedSourceAsSDFWrapper-/PairWithRestriction
Nov 27, 2021 12:45:35 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2021-11-27T12:45:35.290Z: Fusing consumer Read 
input/ParDo(StripIds)/ParMultiDo(StripIds) into 
Read-input-ParDo-UnboundedSourceAsSDFWrapper--ParMultiDo-UnboundedSourceAsSDFWrapper-/ProcessElementAndRestrictionWithSizing
Nov 27, 2021 12:45:35 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2021-11-27T12:45:35.336Z: Fusing consumer Collect start time metrics 
(input)/ParMultiDo(TimeMonitor) into Read 
input/ParDo(StripIds)/ParMultiDo(StripIds)
Nov 27, 2021 12:45:35 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2021-11-27T12:45:35.374Z: Fusing consumer Window.Into()/Window.Assign 
into Collect start time metrics (input)/ParMultiDo(TimeMonitor)
Nov 27, 2021 12:45:35 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2021-11-27T12:45:35.403Z: Fusing consumer 
CoGroupByKey/MakeUnionTable0/ParMultiDo(ConstructUnionTable) into 
Window.Into()/Window.Assign
Nov 27, 2021 12:45:35 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2021-11-27T12:45:35.437Z: Fusing consumer Read 
co-input/ParDo(OutputSingleSource)/ParMultiDo(OutputSingleSource) into Read 
co-input/Impulse
Nov 27, 2021 12:45:35 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2021-11-27T12:45:35.471Z: Fusing consumer 
Read-co-input-ParDo-UnboundedSourceAsSDFWrapper--ParMultiDo-UnboundedSourceAsSDFWrapper-/PairWithRestriction
 into Read co-input/ParDo(OutputSingleSource)/ParMultiDo(OutputSingleSource)
Nov 27, 2021 12:45:37 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2021-11-27T12:45:35.506Z: Fusing consumer 
Read-co-input-ParDo-UnboundedSourceAsSDFWrapper--ParMultiDo-UnboundedSourceAsSDFWrapper-/SplitWithSizing
 into 
Read-co-input-ParDo-UnboundedSourceAsSDFWrapper--ParMultiDo-UnboundedSourceAsSDFWrapper-/PairWithRestriction
Nov 27, 2021 12:45:37 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2021-11-27T12:45:35.554Z: Fusing consumer Read 
co-input/ParDo(StripIds)/ParMultiDo(StripIds) into 
Read-co-input-ParDo-UnboundedSourceAsSDFWrapper--ParMultiDo-UnboundedSourceAsSDFWrapper-/ProcessElementAndRestrictionWithSizing
Nov 27, 2021 12:45:37 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2021-11-27T12:45:35.580Z: Fusing consumer Collect start time metrics 
(co-input)/ParMultiDo(TimeMonitor) into Read 
co-input/ParDo(StripIds)/ParMultiDo(StripIds)
Nov 27, 2021 12:45:37 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2021-11-27T12:45:35.612Z: Fusing consumer Window.Into()2/Window.Assign 
into Collect start time metrics (co-input)/ParMultiDo(TimeMonitor)
Nov 27, 2021 12:45:37 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2021-11-27T12:45:35.643Z: Fusing consumer 
CoGroupByKey/MakeUnionTable1/ParMultiDo(ConstructUnionTable) into 
Window.Into()2/Window.Assign
Nov 27, 2021 12:45:37 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2021-11-27T12:45:35.682Z: Fusing consumer CoGroupByKey/GBK/MergeBuckets 
into CoGroupByKey/GBK/ReadStream
Nov 27, 2021 12:45:37 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2021-11-27T12:45:35.717Z: Fusing consumer 
CoGroupByKey/ConstructCoGbkResultFn/ParMultiDo(ConstructCoGbkResult) into 
CoGroupByKey/GBK/MergeBuckets
Nov 27, 2021 12:45:37 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2021-11-27T12:45:35.755Z: Fusing consumer Ungroup and 
reiterate/ParMultiDo(UngroupAndReiterate) into 
CoGroupByKey/ConstructCoGbkResultFn/ParMultiDo(ConstructCoGbkResult)
Nov 27, 2021 12:45:37 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2021-11-27T12:45:35.784Z: Fusing consumer Collect total 
bytes/ParMultiDo(ByteMonitor) into Ungroup and 
reiterate/ParMultiDo(UngroupAndReiterate)
Nov 27, 2021 12:45:37 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2021-11-27T12:45:35.818Z: Fusing consumer Collect end time 
metrics/ParMultiDo(TimeMonitor) into Collect total bytes/ParMultiDo(ByteMonitor)
Nov 27, 2021 12:45:37 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2021-11-27T12:45:36.243Z: Starting 5 ****s in us-central1-a...
Nov 27, 2021 12:46:03 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2021-11-27T12:46:02.233Z: Your project already contains 100 
Dataflow-created metric descriptors, so new user metrics of the form 
custom.googleapis.com/* will not be created. However, all user metrics are also 
available in the metric dataflow.googleapis.com/job/user_counter. If you rely 
on the custom metrics, you can delete old / unused metric descriptors. See 
https://developers.google.com/apis-explorer/#p/monitoring/v3/monitoring.projects.metricDescriptors.list
 and 
https://developers.google.com/apis-explorer/#p/monitoring/v3/monitoring.projects.metricDescriptors.delete
Nov 27, 2021 12:46:19 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2021-11-27T12:46:19.385Z: Autoscaling: Raised the number of ****s to 5 so 
that the pipeline can catch up with its backlog and keep up with its input rate.
Nov 27, 2021 12:47:19 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2021-11-27T12:47:17.737Z: Workers have started successfully.
Nov 27, 2021 12:47:19 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2021-11-27T12:47:17.769Z: Workers have started successfully.
Nov 27, 2021 2:12:39 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
SEVERE: 2021-11-27T14:12:36.310Z: Staged package 
amazon-kinesis-client-1.14.2-qtBh3OuKuLE7S26ITTJzYsoYfG-mWjqbGmv3VJPhec8.jar at 
location 
'gs://temp-storage-for-perf-tests/loadtests/staging/amazon-kinesis-client-1.14.2-qtBh3OuKuLE7S26ITTJzYsoYfG-mWjqbGmv3VJPhec8.jar'
 is inaccessible.
Nov 27, 2021 2:12:42 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
SEVERE: 2021-11-27T14:12:42.146Z: Staged package 
jakarta.activation-api-1.2.2-oYepORA671hJp6-EvX4nvi0SDEEK8pFDc3X_4GH08J0.jar at 
location 
'gs://temp-storage-for-perf-tests/loadtests/staging/jakarta.activation-api-1.2.2-oYepORA671hJp6-EvX4nvi0SDEEK8pFDc3X_4GH08J0.jar'
 is inaccessible.
Nov 27, 2021 2:12:42 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
SEVERE: 2021-11-27T14:12:42.188Z: Staged package 
jakarta.xml.bind-api-2.3.3-wEU59HLppt0MdoXqgtZ3KCJpq457rKLhRQDjgeDGzsU.jar at 
location 
'gs://temp-storage-for-perf-tests/loadtests/staging/jakarta.xml.bind-api-2.3.3-wEU59HLppt0MdoXqgtZ3KCJpq457rKLhRQDjgeDGzsU.jar'
 is inaccessible.
Nov 27, 2021 2:12:43 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
WARNING: 2021-11-27T14:12:43.367Z: One or more access checks for temp location 
or staged files failed. Please refer to other error messages for details. For 
more information on security and permissions, please see 
https://cloud.google.com/dataflow/security-and-permissions.
Nov 27, 2021 4:00:35 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2021-11-27T16:00:34.493Z: Cancel request is committed for workflow job: 
2021-11-27_04_45_23-6887480424228758737.
Nov 27, 2021 4:00:35 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2021-11-27T16:00:34.521Z: Cleaning up.
Nov 27, 2021 4:00:35 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2021-11-27T16:00:34.590Z: Stopping **** pool...
Nov 27, 2021 4:00:35 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2021-11-27T16:00:34.656Z: Stopping **** pool...
Nov 27, 2021 4:02:57 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2021-11-27T16:02:55.989Z: Autoscaling: Reduced the number of ****s to 0 
based on low average **** CPU utilization, and the pipeline having sufficiently 
low backlog and keeping up with input rate.
Nov 27, 2021 4:02:57 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2021-11-27T16:02:56.023Z: Worker pool stopped.
Nov 27, 2021 4:03:01 PM org.apache.beam.runners.dataflow.DataflowPipelineJob 
logTerminalState
INFO: Job 2021-11-27_04_45_23-6887480424228758737 finished with status 
CANCELLED.
Load test results for test (ID): 55206b0c-aefb-4f05-a172-41d13136a7e2 and 
timestamp: 2021-11-27T12:45:18.190000000Z:
                 Metric:                    Value:
dataflow_v2_java11_runtime_sec                 11571.355
dataflow_v2_java11_total_bytes_count             2.07269107E10
Exception in thread "main" java.lang.RuntimeException: Invalid job state: 
CANCELLED.
        at 
org.apache.beam.sdk.loadtests.JobFailure.handleFailure(JobFailure.java:51)
        at org.apache.beam.sdk.loadtests.LoadTest.run(LoadTest.java:139)
        at 
org.apache.beam.sdk.loadtests.CoGroupByKeyLoadTest.run(CoGroupByKeyLoadTest.java:62)
        at 
org.apache.beam.sdk.loadtests.CoGroupByKeyLoadTest.main(CoGroupByKeyLoadTest.java:157)

> Task :sdks:java:testing:load-tests:run FAILED

> Task :runners:google-cloud-dataflow-java:cleanUpDockerImages
Untagged: us.gcr.io/apache-beam-testing/java-postcommit-it/java:20211127124332
Untagged: 
us.gcr.io/apache-beam-testing/java-postcommit-it/java@sha256:c44ba3d6e18b4542f8294f3b50b46035b75f98347237d9d9b8b821045e9ca16d
Tag: [us.gcr.io/apache-beam-testing/java-postcommit-it/java:20211127124332]
- referencing digest: 
[us.gcr.io/apache-beam-testing/java-postcommit-it/java@sha256:c44ba3d6e18b4542f8294f3b50b46035b75f98347237d9d9b8b821045e9ca16d]

Deleted [[us.gcr.io/apache-beam-testing/java-postcommit-it/java:20211127124332] 
(referencing 
[us.gcr.io/apache-beam-testing/java-postcommit-it/java@sha256:c44ba3d6e18b4542f8294f3b50b46035b75f98347237d9d9b8b821045e9ca16d])].
Removing untagged image 
us.gcr.io/apache-beam-testing/java-postcommit-it/java@sha256:c44ba3d6e18b4542f8294f3b50b46035b75f98347237d9d9b8b821045e9ca16d
Digests:
- 
us.gcr.io/apache-beam-testing/java-postcommit-it/java@sha256:c44ba3d6e18b4542f8294f3b50b46035b75f98347237d9d9b8b821045e9ca16d
Deleted 
[us.gcr.io/apache-beam-testing/java-postcommit-it/java@sha256:c44ba3d6e18b4542f8294f3b50b46035b75f98347237d9d9b8b821045e9ca16d].

FAILURE: Build failed with an exception.

* What went wrong:
Execution failed for task ':sdks:java:testing:load-tests:run'.
> Process 'command '/usr/lib/jvm/java-8-openjdk-amd64/bin/java'' 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 7.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See 
https://docs.gradle.org/6.9.1/userguide/command_line_interface.html#sec:command_line_warnings

BUILD FAILED in 3h 19m 45s
101 actionable tasks: 70 executed, 29 from cache, 2 up-to-date

Publishing build scan...
https://gradle.com/s/ixk722wtnlutc

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]

Reply via email to