See 
<https://ci-beam.apache.org/job/beam_LoadTests_Java_CoGBK_Dataflow_V2_Streaming_Java17/490/display/redirect>

Changes:


------------------------------------------
[...truncated 271.25 KB...]
a96a84ddd75a: Preparing
47a0b225116f: Preparing
c6813289044b: Preparing
f3a12c51479f: Preparing
89a773515f1c: Waiting
a96a84ddd75a: Waiting
b93c1bd012ab: Preparing
47a0b225116f: Waiting
c6813289044b: Waiting
b93c1bd012ab: Waiting
f3a12c51479f: Waiting
5f70bf18a086: Layer already exists
f9faea9377d5: Pushed
a0454a1b9b8e: Pushed
a8fcf82d17ed: Pushed
7b9d5278d476: Pushed
18101db7f83f: Pushed
32e13170dc6d: Pushed
16088f106898: Pushed
784ab5450656: Pushed
0d2cedcd2db5: Pushed
dba77b647936: Pushed
47a0b225116f: Layer already exists
c6813289044b: Layer already exists
f3a12c51479f: Layer already exists
b93c1bd012ab: Layer already exists
d29bc468ffb1: Pushed
179e4cfa64c1: Pushed
89a773515f1c: Pushed
a96a84ddd75a: Pushed
20230426144108: digest: 
sha256:0d97157e8b210bfdc46677db4d9e93c599bb1fcc056e4e71b61835d1935370b7 size: 
4297

> Task :sdks:java:testing:load-tests:run
Apr 26, 2023 2:41:38 PM 
org.apache.beam.runners.dataflow.options.DataflowPipelineOptions$StagingLocationFactory
 create
INFO: No stagingLocation provided, falling back to gcpTempLocation
Apr 26, 2023 2:41:38 PM org.apache.beam.runners.dataflow.DataflowRunner 
fromOptions
INFO: PipelineOptions.filesToStage was not specified. Defaulting to files from 
the classpath: will stage 229 files. Enable logging at DEBUG level to see which 
files will be staged.
Apr 26, 2023 2:41:40 PM org.apache.beam.sdk.Pipeline validate
WARNING: The following transforms do not have stable unique names: Window.Into()
Apr 26, 2023 2:41:40 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.
Apr 26, 2023 2:41:43 PM org.apache.beam.runners.dataflow.util.PackageUtil 
stageClasspathElements
INFO: Uploading 229 files from PipelineOptions.filesToStage to staging location 
to prepare for execution.
Apr 26, 2023 2:41:43 PM org.apache.beam.runners.dataflow.util.PackageUtil 
stageClasspathElements
INFO: Staging files complete: 229 files cached, 0 files newly uploaded in 0 
seconds
Apr 26, 2023 2:41:43 PM org.apache.beam.runners.dataflow.DataflowRunner run
INFO: Staging portable pipeline proto to 
gs://temp-storage-for-perf-tests/loadtests/staging/
Apr 26, 2023 2:41:43 PM org.apache.beam.runners.dataflow.util.PackageUtil 
tryStagePackage
INFO: Uploading <122710 bytes, hash 
335a43075d795a0afeb561aa0a6bdcba28123be19511170b2de27d7ae3cd9c9f> to 
gs://temp-storage-for-perf-tests/loadtests/staging/pipeline-M1pDB115Wgr-tWGqCmvcuigSO-GVERcLLeJ9euPNnJ8.pb
Apr 26, 2023 2:41:46 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding Read input/DataflowRunner.StreamingUnboundedRead.ReadWithIds as 
step s1
Apr 26, 2023 2:41:46 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}]
Apr 26, 2023 2:41:47 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding Read input/StripIds as step s2
Apr 26, 2023 2:41:47 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding Collect start time metrics (input) as step s3
Apr 26, 2023 2:41:47 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding Window.Into()/Window.Assign as step s4
Apr 26, 2023 2:41:47 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding Read co-input/DataflowRunner.StreamingUnboundedRead.ReadWithIds as 
step s5
Apr 26, 2023 2:41:47 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}]
Apr 26, 2023 2:41:47 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding Read co-input/StripIds as step s6
Apr 26, 2023 2:41:47 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding Collect start time metrics (co-input) as step s7
Apr 26, 2023 2:41:47 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding Window.Into()2/Window.Assign as step s8
Apr 26, 2023 2:41:47 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding CoGroupByKey/MakeUnionTable0 as step s9
Apr 26, 2023 2:41:47 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding CoGroupByKey/MakeUnionTable1 as step s10
Apr 26, 2023 2:41:47 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding CoGroupByKey/Flatten as step s11
Apr 26, 2023 2:41:47 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding CoGroupByKey/GBK as step s12
Apr 26, 2023 2:41:47 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding CoGroupByKey/ConstructCoGbkResultFn as step s13
Apr 26, 2023 2:41:47 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding Ungroup and reiterate as step s14
Apr 26, 2023 2:41:47 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding Collect total bytes as step s15
Apr 26, 2023 2:41:47 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding Collect end time metrics as step s16
Apr 26, 2023 2:41:47 PM org.apache.beam.runners.dataflow.DataflowRunner run
INFO: Dataflow SDK version: 2.48.0-SNAPSHOT
Apr 26, 2023 2:41:48 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/2023-04-26_07_41_47-8226312888943241988?project=apache-beam-testing
Apr 26, 2023 2:41:48 PM org.apache.beam.runners.dataflow.DataflowRunner run
INFO: Submitted job: 2023-04-26_07_41_47-8226312888943241988
Apr 26, 2023 2:41:48 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 2023-04-26_07_41_47-8226312888943241988
Apr 26, 2023 2:41:54 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
WARNING: 2023-04-26T14:41:52.694Z: 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: 
load0tests0java170dataflow0v20streaming0cogbk04-jenkins-04-gxoi. 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
Apr 26, 2023 2:41:59 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-04-26T14:41:58.032Z: Worker configuration: e2-standard-2 in 
us-central1-f.
Apr 26, 2023 2:41:59 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-04-26T14:41:59.043Z: Expanding SplittableParDo operations into 
optimizable parts.
Apr 26, 2023 2:42:02 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-04-26T14:41:59.075Z: Expanding CollectionToSingleton operations into 
optimizable parts.
Apr 26, 2023 2:42:02 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-04-26T14:41:59.122Z: Expanding CoGroupByKey operations into 
optimizable parts.
Apr 26, 2023 2:42:02 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-04-26T14:41:59.199Z: Expanding SplittableProcessKeyed operations 
into optimizable parts.
Apr 26, 2023 2:42:02 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-04-26T14:41:59.228Z: Expanding GroupByKey operations into streaming 
Read/Write steps
Apr 26, 2023 2:42:02 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-04-26T14:41:59.298Z: Lifting ValueCombiningMappingFns into 
MergeBucketsMappingFns
Apr 26, 2023 2:42:02 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-04-26T14:41:59.397Z: Fusing adjacent ParDo, Read, Write, and Flatten 
operations
Apr 26, 2023 2:42:02 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-04-26T14:41:59.414Z: Unzipping flatten CoGroupByKey-Flatten for 
input CoGroupByKey-MakeUnionTable0-ParMultiDo-ConstructUnionTable-.output
Apr 26, 2023 2:42:02 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-04-26T14:41:59.442Z: Fusing unzipped copy of 
CoGroupByKey/GBK/WriteStream, through flatten CoGroupByKey/Flatten, into 
producer CoGroupByKey/MakeUnionTable0/ParMultiDo(ConstructUnionTable)
Apr 26, 2023 2:42:02 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-04-26T14:41:59.477Z: Fusing consumer CoGroupByKey/GBK/WriteStream 
into CoGroupByKey/MakeUnionTable1/ParMultiDo(ConstructUnionTable)
Apr 26, 2023 2:42:02 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-04-26T14:41:59.508Z: Fusing consumer Read 
input/ParDo(OutputSingleSource)/ParMultiDo(OutputSingleSource) into Read 
input/Impulse
Apr 26, 2023 2:42:02 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-04-26T14:41:59.532Z: Fusing consumer 
Read-input-ParDo-UnboundedSourceAsSDFWrapper--ParMultiDo-UnboundedSourceAsSDFWrapper-/PairWithRestriction
 into Read input/ParDo(OutputSingleSource)/ParMultiDo(OutputSingleSource)
Apr 26, 2023 2:42:02 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-04-26T14:41:59.562Z: Fusing consumer 
Read-input-ParDo-UnboundedSourceAsSDFWrapper--ParMultiDo-UnboundedSourceAsSDFWrapper-/SplitWithSizing
 into 
Read-input-ParDo-UnboundedSourceAsSDFWrapper--ParMultiDo-UnboundedSourceAsSDFWrapper-/PairWithRestriction
Apr 26, 2023 2:42:02 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-04-26T14:41:59.594Z: Fusing consumer Read 
input/ParDo(StripIds)/ParMultiDo(StripIds) into 
Read-input-ParDo-UnboundedSourceAsSDFWrapper--ParMultiDo-UnboundedSourceAsSDFWrapper-/ProcessElementAndRestrictionWithSizing
Apr 26, 2023 2:42:02 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-04-26T14:41:59.619Z: Fusing consumer Collect start time metrics 
(input)/ParMultiDo(TimeMonitor) into Read 
input/ParDo(StripIds)/ParMultiDo(StripIds)
Apr 26, 2023 2:42:02 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-04-26T14:41:59.644Z: Fusing consumer Window.Into()/Window.Assign 
into Collect start time metrics (input)/ParMultiDo(TimeMonitor)
Apr 26, 2023 2:42:02 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-04-26T14:41:59.668Z: Fusing consumer 
CoGroupByKey/MakeUnionTable0/ParMultiDo(ConstructUnionTable) into 
Window.Into()/Window.Assign
Apr 26, 2023 2:42:02 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-04-26T14:41:59.697Z: Fusing consumer Read 
co-input/ParDo(OutputSingleSource)/ParMultiDo(OutputSingleSource) into Read 
co-input/Impulse
Apr 26, 2023 2:42:02 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-04-26T14:41:59.723Z: Fusing consumer 
Read-co-input-ParDo-UnboundedSourceAsSDFWrapper--ParMultiDo-UnboundedSourceAsSDFWrapper-/PairWithRestriction
 into Read co-input/ParDo(OutputSingleSource)/ParMultiDo(OutputSingleSource)
Apr 26, 2023 2:42:02 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-04-26T14:41:59.747Z: Fusing consumer 
Read-co-input-ParDo-UnboundedSourceAsSDFWrapper--ParMultiDo-UnboundedSourceAsSDFWrapper-/SplitWithSizing
 into 
Read-co-input-ParDo-UnboundedSourceAsSDFWrapper--ParMultiDo-UnboundedSourceAsSDFWrapper-/PairWithRestriction
Apr 26, 2023 2:42:02 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-04-26T14:41:59.772Z: Fusing consumer Read 
co-input/ParDo(StripIds)/ParMultiDo(StripIds) into 
Read-co-input-ParDo-UnboundedSourceAsSDFWrapper--ParMultiDo-UnboundedSourceAsSDFWrapper-/ProcessElementAndRestrictionWithSizing
Apr 26, 2023 2:42:02 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-04-26T14:41:59.804Z: Fusing consumer Collect start time metrics 
(co-input)/ParMultiDo(TimeMonitor) into Read 
co-input/ParDo(StripIds)/ParMultiDo(StripIds)
Apr 26, 2023 2:42:02 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-04-26T14:41:59.829Z: Fusing consumer Window.Into()2/Window.Assign 
into Collect start time metrics (co-input)/ParMultiDo(TimeMonitor)
Apr 26, 2023 2:42:02 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-04-26T14:41:59.861Z: Fusing consumer 
CoGroupByKey/MakeUnionTable1/ParMultiDo(ConstructUnionTable) into 
Window.Into()2/Window.Assign
Apr 26, 2023 2:42:02 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-04-26T14:41:59.886Z: Fusing consumer CoGroupByKey/GBK/MergeBuckets 
into CoGroupByKey/GBK/ReadStream
Apr 26, 2023 2:42:02 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-04-26T14:41:59.915Z: Fusing consumer 
CoGroupByKey/ConstructCoGbkResultFn/ParMultiDo(ConstructCoGbkResult) into 
CoGroupByKey/GBK/MergeBuckets
Apr 26, 2023 2:42:02 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-04-26T14:41:59.950Z: Fusing consumer Ungroup and 
reiterate/ParMultiDo(UngroupAndReiterate) into 
CoGroupByKey/ConstructCoGbkResultFn/ParMultiDo(ConstructCoGbkResult)
Apr 26, 2023 2:42:02 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-04-26T14:41:59.979Z: Fusing consumer Collect total 
bytes/ParMultiDo(ByteMonitor) into Ungroup and 
reiterate/ParMultiDo(UngroupAndReiterate)
Apr 26, 2023 2:42:02 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-04-26T14:42:00.012Z: Fusing consumer Collect end time 
metrics/ParMultiDo(TimeMonitor) into Collect total bytes/ParMultiDo(ByteMonitor)
Apr 26, 2023 2:42:02 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-04-26T14:42:00.173Z: Running job using Streaming Engine
Apr 26, 2023 2:42:02 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-04-26T14:42:00.505Z: Starting 5 ****s in us-central1-f...
Apr 26, 2023 2:42:33 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-04-26T14:42:31.661Z: 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
Apr 26, 2023 2:42:41 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-04-26T14:42:40.055Z: 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.
Apr 26, 2023 2:43:41 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-04-26T14:43:39.432Z: All ****s have finished the startup processes 
and began to receive work requests.
Apr 26, 2023 2:43:41 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-04-26T14:43:40.884Z: Workers have started successfully.
Apr 26, 2023 2:52:03 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-04-26T14:52:03.078Z: Cleaning up.
Apr 26, 2023 2:52:03 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-04-26T14:52:03.159Z: Stopping **** pool...
Apr 26, 2023 2:52:04 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-04-26T14:52:03.227Z: Stopping **** pool...
Apr 26, 2023 2:54:37 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-04-26T14:54:34.689Z: 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.
Apr 26, 2023 2:54:37 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-04-26T14:54:34.728Z: Worker pool stopped.
Apr 26, 2023 2:54:40 PM org.apache.beam.runners.dataflow.DataflowPipelineJob 
logTerminalState
INFO: Job 2023-04-26_07_41_47-8226312888943241988 finished with status DONE.
Load test results for test (ID): a1ce411d-6fc7-4d27-862a-bb37109e9c67 and 
timestamp: 2023-04-26T14:41:39.479000000Z:
                 Metric:                    Value:
dataflow_v2_java17_runtime_sec                   436.966
dataflow_v2_java17_total_bytes_count                 3.99996E8

> Task :runners:google-cloud-dataflow-java:cleanUpDockerJavaImages
Untagged: us.gcr.io/apache-beam-testing/java-postcommit-it/java:20230426144108
Untagged: 
us.gcr.io/apache-beam-testing/java-postcommit-it/java@sha256:0d97157e8b210bfdc46677db4d9e93c599bb1fcc056e4e71b61835d1935370b7
WARNING: Successfully resolved tag to sha256, but it is recommended to use 
sha256 directly.
Tag: [us.gcr.io/apache-beam-testing/java-postcommit-it/java:20230426144108]
- referencing digest: 
[us.gcr.io/apache-beam-testing/java-postcommit-it/java@sha256:0d97157e8b210bfdc46677db4d9e93c599bb1fcc056e4e71b61835d1935370b7]

Deleted [[us.gcr.io/apache-beam-testing/java-postcommit-it/java:20230426144108] 
(referencing 
[us.gcr.io/apache-beam-testing/java-postcommit-it/java@sha256:0d97157e8b210bfdc46677db4d9e93c599bb1fcc056e4e71b61835d1935370b7])].
Removing untagged image 
us.gcr.io/apache-beam-testing/java-postcommit-it/java@sha256:0d97157e8b210bfdc46677db4d9e93c599bb1fcc056e4e71b61835d1935370b7
Digests:
- 
us.gcr.io/apache-beam-testing/java-postcommit-it/java@sha256:0d97157e8b210bfdc46677db4d9e93c599bb1fcc056e4e71b61835d1935370b7
ERROR: (gcloud.container.images.delete) Not found: response: 
{'docker-distribution-api-version': 'registry/2.0', 'content-type': 
'application/json', 'content-encoding': 'gzip', 'date': 'Wed, 26 Apr 2023 
14:54:53 GMT', 'server': 'Docker Registry', 'cache-control': 'private', 
'x-xss-protection': '0', 'x-frame-options': 'SAMEORIGIN', 'transfer-encoding': 
'chunked', 'status': 404}
Failed to compute blob liveness for manifest: 
'sha256:0d97157e8b210bfdc46677db4d9e93c599bb1fcc056e4e71b61835d1935370b7': 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_Java17/ws/src/runners/google-cloud-dataflow-java/build.gradle'>
 line: 305

* 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 9s
111 actionable tasks: 9 executed, 102 up-to-date
Build scan background action failed.
java.lang.IllegalArgumentException: 
com.gradle.enterprise.gradleplugin.internal.extension.a is not an interface
        at java.lang.reflect.Proxy$ProxyClassFactory.apply(Proxy.java:590)
        at java.lang.reflect.Proxy$ProxyClassFactory.apply(Proxy.java:557)
        at java.lang.reflect.WeakCache$Factory.get(WeakCache.java:230)
        at java.lang.reflect.WeakCache.get(WeakCache.java:127)
        at java.lang.reflect.Proxy.getProxyClass0(Proxy.java:419)
        at java.lang.reflect.Proxy.newProxyInstance(Proxy.java:719)
        at 
com.gradle.ProxyFactory$ProxyingInvocationHandler.createLocalProxy(ProxyFactory.java:64)
        at 
com.gradle.ProxyFactory$ProxyingInvocationHandler.lambda$adaptActionArg$1(ProxyFactory.java:59)
        at 
com.gradle.enterprise.gradleplugin.internal.extension.b$3.run(SourceFile:100)
        at 
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
        at java.util.concurrent.FutureTask.run(FutureTask.java:266)
        at 
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
        at 
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
        at java.lang.Thread.run(Thread.java:750)

Publishing build scan...
https://gradle.com/s/7ew3j5diauikq

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