See 
<https://ci-beam.apache.org/job/beam_LoadTests_Java_CoGBK_Dataflow_V2_Streaming_Java11/466/display/redirect?page=changes>

Changes:

[noreply] [Tour Of Beam] API adjustments (#23349)

[noreply] Adds support in Samza Runner to run DoFn.processElement in parallel

[noreply] Regenerate Go Protos (#23408)

[noreply] Support google-cloud-spanner v3 and fixes broken unit tests (#23365)

[noreply] Add relevant docs to Cloud Profiler exceptions. (#23404)

[noreply] Update state cache to not fail when measuring object sizes. (#23391)


------------------------------------------
[...truncated 180.08 KB...]
ade6da4a3f5c: Pushed
1589d0600cae: Pushed
f8132b7ad348: Pushed
95c13fa08af1: Pushed
7b7f3078e1db: Layer already exists
826c3ddbb29c: Layer already exists
7747076fc42b: Pushed
b626401ef603: Layer already exists
9b55156abf26: Layer already exists
293d5db30c9f: Layer already exists
03127cdb479b: Layer already exists
9c742cd6c7a5: Layer already exists
81187c367fc4: Pushed
9a11f1cf0513: Pushed
ae337d30db42: Pushed
20220929144913: digest: 
sha256:4fae1778917ba47595301706fab436ab443970c50a603976e54a892ea72ea604 size: 
4935

> Task :sdks:java:testing:load-tests:run
Sep 29, 2022 2:49:48 PM 
org.apache.beam.runners.dataflow.options.DataflowPipelineOptions$StagingLocationFactory
 create
INFO: No stagingLocation provided, falling back to gcpTempLocation
Sep 29, 2022 2:49:48 PM org.apache.beam.runners.dataflow.DataflowRunner 
fromOptions
INFO: PipelineOptions.filesToStage was not specified. Defaulting to files from 
the classpath: will stage 227 files. Enable logging at DEBUG level to see which 
files will be staged.
Sep 29, 2022 2:49:49 PM org.apache.beam.sdk.Pipeline validate
WARNING: The following transforms do not have stable unique names: Window.Into()
Sep 29, 2022 2:49:49 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.
Sep 29, 2022 2:49:52 PM org.apache.beam.runners.dataflow.util.PackageUtil 
stageClasspathElements
INFO: Uploading 227 files from PipelineOptions.filesToStage to staging location 
to prepare for execution.
Sep 29, 2022 2:49:52 PM org.apache.beam.runners.dataflow.util.PackageUtil 
stageClasspathElements
INFO: Staging files complete: 227 files cached, 0 files newly uploaded in 0 
seconds
Sep 29, 2022 2:49:52 PM org.apache.beam.runners.dataflow.DataflowRunner run
INFO: Staging portable pipeline proto to 
gs://temp-storage-for-perf-tests/loadtests/staging/
Sep 29, 2022 2:49:52 PM org.apache.beam.runners.dataflow.util.PackageUtil 
tryStagePackage
INFO: Uploading <122021 bytes, hash 
d65672c1af4b1d2bdde65ac34c5376232f47e9de1e39b56ae5a33b3b95c911c3> to 
gs://temp-storage-for-perf-tests/loadtests/staging/pipeline-1lZywa9LHSvd5lrDTFN2Iy9H6d4eObVq5aM7O5XJEcM.pb
Sep 29, 2022 2:49:54 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding Read input/DataflowRunner.StreamingUnboundedRead.ReadWithIds as 
step s1
Sep 29, 2022 2:49:54 PM 
org.apache.beam.sdk.io.synthetic.SyntheticUnboundedSource split
INFO: Split into 20 bundles: [SyntheticUnboundedSource{startOffset=0, 
endOffset=100000}, SyntheticUnboundedSource{startOffset=100000, 
endOffset=200000}, SyntheticUnboundedSource{startOffset=200000, 
endOffset=300000}, SyntheticUnboundedSource{startOffset=300000, 
endOffset=400000}, SyntheticUnboundedSource{startOffset=400000, 
endOffset=500000}, SyntheticUnboundedSource{startOffset=500000, 
endOffset=600000}, SyntheticUnboundedSource{startOffset=600000, 
endOffset=700000}, SyntheticUnboundedSource{startOffset=700000, 
endOffset=800000}, SyntheticUnboundedSource{startOffset=800000, 
endOffset=900000}, SyntheticUnboundedSource{startOffset=900000, 
endOffset=1000000}, SyntheticUnboundedSource{startOffset=1000000, 
endOffset=1100000}, SyntheticUnboundedSource{startOffset=1100000, 
endOffset=1200000}, SyntheticUnboundedSource{startOffset=1200000, 
endOffset=1300000}, SyntheticUnboundedSource{startOffset=1300000, 
endOffset=1400000}, SyntheticUnboundedSource{startOffset=1400000, 
endOffset=1500000}, SyntheticUnboundedSource{startOffset=1500000, 
endOffset=1600000}, SyntheticUnboundedSource{startOffset=1600000, 
endOffset=1700000}, SyntheticUnboundedSource{startOffset=1700000, 
endOffset=1800000}, SyntheticUnboundedSource{startOffset=1800000, 
endOffset=1900000}, SyntheticUnboundedSource{startOffset=1900000, 
endOffset=2000000}]
Sep 29, 2022 2:49:54 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding Read input/StripIds as step s2
Sep 29, 2022 2:49:54 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding Collect start time metrics (input) as step s3
Sep 29, 2022 2:49:54 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding Window.Into()/Window.Assign as step s4
Sep 29, 2022 2:49:54 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding Read co-input/DataflowRunner.StreamingUnboundedRead.ReadWithIds as 
step s5
Sep 29, 2022 2:49:54 PM 
org.apache.beam.sdk.io.synthetic.SyntheticUnboundedSource split
INFO: Split into 20 bundles: [SyntheticUnboundedSource{startOffset=0, 
endOffset=100000}, SyntheticUnboundedSource{startOffset=100000, 
endOffset=200000}, SyntheticUnboundedSource{startOffset=200000, 
endOffset=300000}, SyntheticUnboundedSource{startOffset=300000, 
endOffset=400000}, SyntheticUnboundedSource{startOffset=400000, 
endOffset=500000}, SyntheticUnboundedSource{startOffset=500000, 
endOffset=600000}, SyntheticUnboundedSource{startOffset=600000, 
endOffset=700000}, SyntheticUnboundedSource{startOffset=700000, 
endOffset=800000}, SyntheticUnboundedSource{startOffset=800000, 
endOffset=900000}, SyntheticUnboundedSource{startOffset=900000, 
endOffset=1000000}, SyntheticUnboundedSource{startOffset=1000000, 
endOffset=1100000}, SyntheticUnboundedSource{startOffset=1100000, 
endOffset=1200000}, SyntheticUnboundedSource{startOffset=1200000, 
endOffset=1300000}, SyntheticUnboundedSource{startOffset=1300000, 
endOffset=1400000}, SyntheticUnboundedSource{startOffset=1400000, 
endOffset=1500000}, SyntheticUnboundedSource{startOffset=1500000, 
endOffset=1600000}, SyntheticUnboundedSource{startOffset=1600000, 
endOffset=1700000}, SyntheticUnboundedSource{startOffset=1700000, 
endOffset=1800000}, SyntheticUnboundedSource{startOffset=1800000, 
endOffset=1900000}, SyntheticUnboundedSource{startOffset=1900000, 
endOffset=2000000}]
Sep 29, 2022 2:49:54 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding Read co-input/StripIds as step s6
Sep 29, 2022 2:49:54 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding Collect start time metrics (co-input) as step s7
Sep 29, 2022 2:49:54 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding Window.Into()2/Window.Assign as step s8
Sep 29, 2022 2:49:54 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding CoGroupByKey/MakeUnionTable0 as step s9
Sep 29, 2022 2:49:54 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding CoGroupByKey/MakeUnionTable1 as step s10
Sep 29, 2022 2:49:54 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding CoGroupByKey/Flatten as step s11
Sep 29, 2022 2:49:54 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding CoGroupByKey/GBK as step s12
Sep 29, 2022 2:49:54 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding CoGroupByKey/ConstructCoGbkResultFn as step s13
Sep 29, 2022 2:49:54 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding Ungroup and reiterate as step s14
Sep 29, 2022 2:49:54 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding Collect total bytes as step s15
Sep 29, 2022 2:49:55 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding Collect end time metrics as step s16
Sep 29, 2022 2:49:55 PM org.apache.beam.runners.dataflow.DataflowRunner run
INFO: Dataflow SDK version: 2.43.0-SNAPSHOT
Sep 29, 2022 2:49:58 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/2022-09-29_07_49_55-2917505944354619996?project=apache-beam-testing
Sep 29, 2022 2:49:58 PM org.apache.beam.runners.dataflow.DataflowRunner run
INFO: Submitted job: 2022-09-29_07_49_55-2917505944354619996
Sep 29, 2022 2:49:58 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 2022-09-29_07_49_55-2917505944354619996
Sep 29, 2022 2:50:08 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
WARNING: 2022-09-29T14:50:06.918Z: 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: 
load0tests0java110dataflow0v20streaming0cogbk03-jenkins-09-o9ie. 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
Sep 29, 2022 2:50:16 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-29T14:50:14.128Z: Worker configuration: e2-standard-2 in 
us-central1-a.
Sep 29, 2022 2:50:16 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-29T14:50:15.472Z: Expanding SplittableParDo operations into 
optimizable parts.
Sep 29, 2022 2:50:16 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-29T14:50:15.501Z: Expanding CollectionToSingleton operations into 
optimizable parts.
Sep 29, 2022 2:50:16 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-29T14:50:15.574Z: Expanding CoGroupByKey operations into 
optimizable parts.
Sep 29, 2022 2:50:16 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-29T14:50:15.661Z: Expanding SplittableProcessKeyed operations 
into optimizable parts.
Sep 29, 2022 2:50:16 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-29T14:50:15.691Z: Expanding GroupByKey operations into streaming 
Read/Write steps
Sep 29, 2022 2:50:16 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-29T14:50:15.750Z: Lifting ValueCombiningMappingFns into 
MergeBucketsMappingFns
Sep 29, 2022 2:50:16 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-29T14:50:15.868Z: Fusing adjacent ParDo, Read, Write, and Flatten 
operations
Sep 29, 2022 2:50:16 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-29T14:50:15.908Z: Unzipping flatten CoGroupByKey-Flatten for 
input CoGroupByKey-MakeUnionTable0-ParMultiDo-ConstructUnionTable-.output
Sep 29, 2022 2:50:16 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-29T14:50:15.930Z: Fusing unzipped copy of 
CoGroupByKey/GBK/WriteStream, through flatten CoGroupByKey/Flatten, into 
producer CoGroupByKey/MakeUnionTable0/ParMultiDo(ConstructUnionTable)
Sep 29, 2022 2:50:16 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-29T14:50:15.955Z: Fusing consumer CoGroupByKey/GBK/WriteStream 
into CoGroupByKey/MakeUnionTable1/ParMultiDo(ConstructUnionTable)
Sep 29, 2022 2:50:16 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-29T14:50:15.981Z: Fusing consumer Read 
input/ParDo(OutputSingleSource)/ParMultiDo(OutputSingleSource) into Read 
input/Impulse
Sep 29, 2022 2:50:16 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-29T14:50:16.005Z: Fusing consumer 
Read-input-ParDo-UnboundedSourceAsSDFWrapper--ParMultiDo-UnboundedSourceAsSDFWrapper-/PairWithRestriction
 into Read input/ParDo(OutputSingleSource)/ParMultiDo(OutputSingleSource)
Sep 29, 2022 2:50:16 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-29T14:50:16.033Z: Fusing consumer 
Read-input-ParDo-UnboundedSourceAsSDFWrapper--ParMultiDo-UnboundedSourceAsSDFWrapper-/SplitWithSizing
 into 
Read-input-ParDo-UnboundedSourceAsSDFWrapper--ParMultiDo-UnboundedSourceAsSDFWrapper-/PairWithRestriction
Sep 29, 2022 2:50:16 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-29T14:50:16.055Z: Fusing consumer Read 
input/ParDo(StripIds)/ParMultiDo(StripIds) into 
Read-input-ParDo-UnboundedSourceAsSDFWrapper--ParMultiDo-UnboundedSourceAsSDFWrapper-/ProcessElementAndRestrictionWithSizing
Sep 29, 2022 2:50:16 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-29T14:50:16.090Z: Fusing consumer Collect start time metrics 
(input)/ParMultiDo(TimeMonitor) into Read 
input/ParDo(StripIds)/ParMultiDo(StripIds)
Sep 29, 2022 2:50:19 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-29T14:50:16.112Z: Fusing consumer Window.Into()/Window.Assign 
into Collect start time metrics (input)/ParMultiDo(TimeMonitor)
Sep 29, 2022 2:50:19 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-29T14:50:16.151Z: Fusing consumer 
CoGroupByKey/MakeUnionTable0/ParMultiDo(ConstructUnionTable) into 
Window.Into()/Window.Assign
Sep 29, 2022 2:50:19 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-29T14:50:16.174Z: Fusing consumer Read 
co-input/ParDo(OutputSingleSource)/ParMultiDo(OutputSingleSource) into Read 
co-input/Impulse
Sep 29, 2022 2:50:19 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-29T14:50:16.204Z: Fusing consumer 
Read-co-input-ParDo-UnboundedSourceAsSDFWrapper--ParMultiDo-UnboundedSourceAsSDFWrapper-/PairWithRestriction
 into Read co-input/ParDo(OutputSingleSource)/ParMultiDo(OutputSingleSource)
Sep 29, 2022 2:50:19 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-29T14:50:16.229Z: Fusing consumer 
Read-co-input-ParDo-UnboundedSourceAsSDFWrapper--ParMultiDo-UnboundedSourceAsSDFWrapper-/SplitWithSizing
 into 
Read-co-input-ParDo-UnboundedSourceAsSDFWrapper--ParMultiDo-UnboundedSourceAsSDFWrapper-/PairWithRestriction
Sep 29, 2022 2:50:19 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-29T14:50:16.257Z: Fusing consumer Read 
co-input/ParDo(StripIds)/ParMultiDo(StripIds) into 
Read-co-input-ParDo-UnboundedSourceAsSDFWrapper--ParMultiDo-UnboundedSourceAsSDFWrapper-/ProcessElementAndRestrictionWithSizing
Sep 29, 2022 2:50:19 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-29T14:50:16.283Z: Fusing consumer Collect start time metrics 
(co-input)/ParMultiDo(TimeMonitor) into Read 
co-input/ParDo(StripIds)/ParMultiDo(StripIds)
Sep 29, 2022 2:50:19 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-29T14:50:16.312Z: Fusing consumer Window.Into()2/Window.Assign 
into Collect start time metrics (co-input)/ParMultiDo(TimeMonitor)
Sep 29, 2022 2:50:19 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-29T14:50:16.347Z: Fusing consumer 
CoGroupByKey/MakeUnionTable1/ParMultiDo(ConstructUnionTable) into 
Window.Into()2/Window.Assign
Sep 29, 2022 2:50:19 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-29T14:50:16.374Z: Fusing consumer CoGroupByKey/GBK/MergeBuckets 
into CoGroupByKey/GBK/ReadStream
Sep 29, 2022 2:50:19 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-29T14:50:16.400Z: Fusing consumer 
CoGroupByKey/ConstructCoGbkResultFn/ParMultiDo(ConstructCoGbkResult) into 
CoGroupByKey/GBK/MergeBuckets
Sep 29, 2022 2:50:19 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-29T14:50:16.437Z: Fusing consumer Ungroup and 
reiterate/ParMultiDo(UngroupAndReiterate) into 
CoGroupByKey/ConstructCoGbkResultFn/ParMultiDo(ConstructCoGbkResult)
Sep 29, 2022 2:50:19 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-29T14:50:16.461Z: Fusing consumer Collect total 
bytes/ParMultiDo(ByteMonitor) into Ungroup and 
reiterate/ParMultiDo(UngroupAndReiterate)
Sep 29, 2022 2:50:19 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-29T14:50:16.498Z: Fusing consumer Collect end time 
metrics/ParMultiDo(TimeMonitor) into Collect total bytes/ParMultiDo(ByteMonitor)
Sep 29, 2022 2:50:19 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-29T14:50:16.654Z: Running job using Streaming Engine
Sep 29, 2022 2:50:19 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-29T14:50:16.955Z: Starting 5 ****s in us-central1-a...
Sep 29, 2022 2:50:45 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-29T14:50:43.968Z: 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
Sep 29, 2022 2:51:01 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-29T14:51:00.219Z: 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.
Sep 29, 2022 2:52:16 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-29T14:52:14.412Z: Workers have started successfully.
Sep 29, 2022 3:00:44 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-29T15:00:41.879Z: Cleaning up.
Sep 29, 2022 3:00:44 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-29T15:00:41.965Z: Stopping **** pool...
Sep 29, 2022 3:00:44 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-29T15:00:42.029Z: Stopping **** pool...
Sep 29, 2022 3:03:00 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-29T15:02:59.930Z: 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.
Sep 29, 2022 3:03:00 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-29T15:02:59.998Z: Worker pool stopped.
Sep 29, 2022 3:03:07 PM org.apache.beam.runners.dataflow.DataflowPipelineJob 
logTerminalState
INFO: Job 2022-09-29_07_49_55-2917505944354619996 finished with status DONE.
Load test results for test (ID): f50afa86-6de5-41ab-8210-12cc82493326 and 
timestamp: 2022-09-29T14:49:49.316000000Z:
                 Metric:                    Value:
dataflow_v2_java11_runtime_sec                   362.487
dataflow_v2_java11_total_bytes_count                 3.99996E8

> Task :runners:google-cloud-dataflow-java:cleanUpDockerJavaImages
Untagged: us.gcr.io/apache-beam-testing/java-postcommit-it/java:20220929144913
Untagged: 
us.gcr.io/apache-beam-testing/java-postcommit-it/java@sha256:4fae1778917ba47595301706fab436ab443970c50a603976e54a892ea72ea604
Deleted: sha256:eccd89203747c2ee16ee5a62a8c6bd546a270e7969830b69896d280f1100c560
Deleted: sha256:3f5eb9b0f9da531b839493089c82d1ec470556a60cb82c0a2db195d070770b58
Deleted: sha256:eb611d97863c4f720ab3465f445b4f45d797027e589b78f2972b94b66b41ae20
Deleted: sha256:0a76046df23c6da1810192b4c581f317389c0dea05ed7e1d3b6fa6c6a3723403
Deleted: sha256:ddaea22c4aceed8d48ec379176ffa0c4978177e7e14b0b151acdfaf9b7b8369d
Deleted: sha256:2007939f72a1b4a8241ade8b3e8f58bd122c2864b269121a199343144f5639b6
Deleted: sha256:41c8ef849f04d47bf16b8bd752ad4f73f3e48ec0f23608ffada986713a9d3093
Deleted: sha256:dd472427ccf3d33c6f79cd82b733dee8b6619eb043f42ad18b16a0709e41f7ce
Deleted: sha256:4945d830fc655eac30d680fe149bbe7a9898042c01109b3f41b0d8a7269a46f7
Deleted: sha256:d9adbaf4957c5fad3d2199056ab00315dd6ab927785a2e21364305560950d1cb
Deleted: sha256:84a33f7b7444b026dda609313a578b5b4544cb90577fde51d7475af7365e1e49
Deleted: sha256:cc3274ce18113c2da6935b5ecb644d7703fef43a9cc043406f44512df935beba
Deleted: sha256:18de44bf1af2b236791c05dd434b62a275caa845e6416b860c48c165edefad73
Deleted: sha256:33791239b0341fc913d57dbdcfe4629381ee8640cf5cbf4c48b1520865e2b5c2
Deleted: sha256:ae79640b5aeb4cb42489aac7caf21ec3b6ae430e93782d80c75bfc4a2f5ae370
Deleted: sha256:e31b7210a73173c21e5a74a77af13bdd77d128e4b38657842e753ffd7e6982fa
Deleted: sha256:abbdf463c81d818b7da1ced72c96bf6e9a78adcc8890c64b7db72d297b2427ee
Deleted: sha256:fb9048388f7c883d9a04a91662e8d339a70d032945057e2ef7df1840fc789a5c
Deleted: sha256:738bd04d5fb912c332a8e0005e28ab4d3dcd6db325983beee9ba45efe86cd6b0
Deleted: sha256:4a8c7466b0fc95727ae137427a212185877adcd9366e019bed1fa0b846789856
Deleted: sha256:93848ba9c5dd26359580434e5c99920ed04cc876ec5dfbb1408b06805890df89
Deleted: sha256:63145d7cc6cd1cc5b01ea4328ddaeef5733b883e8e346554900316a6c4800a51
Deleted: sha256:21a5fe0b806a0153c03a43fd47ca002747a2ba56838b1c8afbd29332de54c665
Deleted: sha256:d0661b6a36ea833cf94b10d0baaed71ba0604507a7f14eb27562ce81aded55dd
Deleted: sha256:82485ed406c50af62855c7a6927de5fd6ff55944e88f7ae98f1685e6ead92285
Deleted: sha256:8cad8c7e629b3511624755a76b3fd58958056dadfc6a3de544523aca1d2beefc
Deleted: sha256:b75b386f48225930cb59a26f549aa204509d5070d3fb3f66a84ba437bfdb424b
Deleted: sha256:f6519efde4b812c3728e479d056b13ba1f805b5ecdcc37ee52ff5d6b9ae8dd39
Deleted: sha256:4f740d6eb3a8b3a57f9ed35f65aabfa10ff4127c8f600b3359568d201b56e06c
Deleted: sha256:3329cc88a9920d8098c4e2d5a4c58c139afd75f8a6e1fc9b77324da4a66bccaa
Deleted: sha256:869d5715fd9cde381c5a9c35e6c66a61227320b9ebb09f106695a3d74308aeb0
Deleted: sha256:0bf70806b9fbc4275d7f135ae23595eb3bbccbb9983efa4b2817d253cd6f95f6
Deleted: sha256:742b8638e0dba092a6a0881476ea75ff62602409a7ee8b6d1d58cd9f76ad5425
Deleted: sha256:b985db2dbcdaf2c1608a69c7bb78cc10936e2eb8b30c1b7946e63b24924d3863
Tag: [us.gcr.io/apache-beam-testing/java-postcommit-it/java:20220929144913]
- referencing digest: 
[us.gcr.io/apache-beam-testing/java-postcommit-it/java@sha256:4fae1778917ba47595301706fab436ab443970c50a603976e54a892ea72ea604]

Deleted [[us.gcr.io/apache-beam-testing/java-postcommit-it/java:20220929144913] 
(referencing 
[us.gcr.io/apache-beam-testing/java-postcommit-it/java@sha256:4fae1778917ba47595301706fab436ab443970c50a603976e54a892ea72ea604])].
Removing untagged image 
us.gcr.io/apache-beam-testing/java-postcommit-it/java@sha256:773bac1eb618378ebc0f0192c4cbeae04ebbc82f8ec6c78d3aa3bbccdfa7828b
Digests:
- 
us.gcr.io/apache-beam-testing/java-postcommit-it/java@sha256:773bac1eb618378ebc0f0192c4cbeae04ebbc82f8ec6c78d3aa3bbccdfa7828b
ERROR: (gcloud.container.images.delete) Not found: response: 
{'docker-distribution-api-version': 'registry/2.0', 'content-type': 
'application/json', 'date': 'Thu, 29 Sep 2022 15:03:16 GMT', 'server': 'Docker 
Registry', 'cache-control': 'private', 'x-xss-protection': '0', 
'x-frame-options': 'SAMEORIGIN', 'transfer-encoding': 'chunked', 'status': 
'404', 'content-length': '168', '-content-encoding': 'gzip'}
Failed to compute blob liveness for manifest: 
'sha256:773bac1eb618378ebc0f0192c4cbeae04ebbc82f8ec6c78d3aa3bbccdfa7828b': None

> Task :runners:google-cloud-dataflow-java:cleanUpDockerJavaImages FAILED

FAILURE: Build failed with an exception.

* Where:
Build file 
'<https://ci-beam.apache.org/job/beam_LoadTests_Java_CoGBK_Dataflow_V2_Streaming_Java11/ws/src/runners/google-cloud-dataflow-java/build.gradle'>
 line: 302

* What went wrong:
Execution failed for task 
':runners:google-cloud-dataflow-java:cleanUpDockerJavaImages'.
> Process 'command './scripts/cleanup_untagged_gcr_images.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.

* Get more help at https://help.gradle.org

Deprecated Gradle features were used in this build, making it incompatible with 
Gradle 8.0.

You can use '--warning-mode all' to show the individual deprecation warnings 
and determine if they come from your own scripts or plugins.

See 
https://docs.gradle.org/7.5.1/userguide/command_line_interface.html#sec:command_line_warnings

Execution optimizations have been disabled for 1 invalid unit(s) of work during 
this build to ensure correctness.
Please consult deprecation warnings for more details.

BUILD FAILED in 14m 5s
105 actionable tasks: 8 executed, 97 up-to-date

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

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