See
<https://ci-beam.apache.org/job/beam_LoadTests_Java_CoGBK_Dataflow_V2_Streaming_Java17/71/display/redirect?page=changes>
Changes:
[noreply] Build wheels for Python 3.9
[noreply] Merge pull request #16892 from [BEAM-13755] [Playground] Scroll the
[noreply] Merge pull request #16880 from [BEAM-13963][Playground] Get bucket
name
[noreply] Merge pull request #16870 from [BEAM-13874][Playground] Tag multifile
[noreply] Merge pull request #16910 from [BEAM-13724] [Playground] Get the
default
[noreply] [BEAM-14008] Fix incorrect guava import (#16966)
[noreply] Fix ignored exception in BatchSpannerRead. (#16960)
[noreply] [BEAM-13917] Improve coverage of databaseio package (#16956)
[noreply] [BEAM-13925] Add entry files to process new prs and pr updates for PR
[noreply] [BEAM-13899] Improve coverage of debug package (#16951)
[noreply] [BEAM-13907] Improve coverage of textio package (#16937)
[noreply] [BEAM-9150] Fix beam_PostRelease_Python_Candidate (python RC
validation
------------------------------------------
[...truncated 653.07 KB...]
dist_proc/windmill/client/streaming_rpc_client.cc:697
==>
dist_proc/dax/workflow/****/streaming/merge_windows_fn.cc:230
generic::internal: The work item requesting state read is no longer valid on
the backend. The work has already completed or will be retried. This is
expected during autoscaling events.
passed through:
==>
dist_proc/windmill/client/streaming_rpc_client.cc:697
==>
dist_proc/dax/workflow/****/streaming/merge_windows_fn.cc:230
generic::internal: The work item requesting state read is no longer valid on
the backend. The work has already completed or will be retried. This is
expected during autoscaling events.
passed through:
==>
dist_proc/windmill/client/streaming_rpc_client.cc:697
==>
dist_proc/dax/workflow/****/streaming/merge_windows_fn.cc:230
generic::internal: The work item requesting state read is no longer valid on
the backend. The work has already completed or will be retried. This is
expected during autoscaling events.
passed through:
==>
dist_proc/windmill/client/streaming_rpc_client.cc:697
==>
dist_proc/dax/workflow/****/streaming/merge_windows_fn.cc:230
generic::internal: The work item requesting state read is no longer valid on
the backend. The work has already completed or will be retried. This is
expected during autoscaling events.
passed through:
==>
dist_proc/windmill/client/streaming_rpc_client.cc:697
==>
dist_proc/dax/workflow/****/streaming/merge_windows_fn.cc:230
generic::internal: The work item requesting state read is no longer valid on
the backend. The work has already completed or will be retried. This is
expected during autoscaling events.
passed through:
==>
dist_proc/windmill/client/streaming_rpc_client.cc:697
==>
dist_proc/dax/workflow/****/streaming/merge_windows_fn.cc:230
generic::internal: The work item requesting state read is no longer valid on
the backend. The work has already completed or will be retried. This is
expected during autoscaling events.
passed through:
==>
dist_proc/windmill/client/streaming_rpc_client.cc:697
==>
dist_proc/dax/workflow/****/streaming/merge_windows_fn.cc:230
generic::internal: The work item requesting state read is no longer valid on
the backend. The work has already completed or will be retried. This is
expected during autoscaling events.
passed through:
==>
dist_proc/windmill/client/streaming_rpc_client.cc:697
==>
dist_proc/dax/workflow/****/streaming/merge_windows_fn.cc:230
generic::internal: The work item requesting state read is no longer valid on
the backend. The work has already completed or will be retried. This is
expected during autoscaling events.
passed through:
==>
dist_proc/windmill/client/streaming_rpc_client.cc:697
==>
dist_proc/dax/workflow/****/streaming/merge_windows_fn.cc:230
generic::internal: The work item requesting state read is no longer valid on
the backend. The work has already completed or will be retried. This is
expected during autoscaling events.
passed through:
==>
dist_proc/windmill/client/streaming_rpc_client.cc:697
==>
dist_proc/dax/workflow/****/streaming/merge_windows_fn.cc:230
generic::internal: The work item requesting state read is no longer valid on
the backend. The work has already completed or will be retried. This is
expected during autoscaling events.
passed through:
==>
dist_proc/windmill/client/streaming_rpc_client.cc:697
==>
dist_proc/dax/workflow/****/streaming/merge_windows_fn.cc:230
generic::internal: The work item requesting state read is no longer valid on
the backend. The work has already completed or will be retried. This is
expected during autoscaling events.
passed through:
==>
dist_proc/windmill/client/streaming_rpc_client.cc:697
==>
dist_proc/dax/workflow/****/streaming/windmill_cache_access.cc:40
==>
dist_proc/dax/workflow/****/streaming/merge_windows_fn.cc:230
generic::internal: The work item requesting state read is no longer valid on
the backend. The work has already completed or will be retried. This is
expected during autoscaling events.
passed through:
==>
dist_proc/windmill/client/streaming_rpc_client.cc:697
==>
dist_proc/dax/workflow/****/streaming/merge_windows_fn.cc:230
generic::internal: The work item requesting state read is no longer valid on
the backend. The work has already completed or will be retried. This is
expected during autoscaling events.
passed through:
==>
dist_proc/windmill/client/streaming_rpc_client.cc:697
==>
dist_proc/dax/workflow/****/streaming/merge_windows_fn.cc:230
generic::internal: The work item requesting state read is no longer valid on
the backend. The work has already completed or will be retried. This is
expected during autoscaling events.
passed through:
==>
dist_proc/windmill/client/streaming_rpc_client.cc:697
==>
dist_proc/dax/workflow/****/streaming/merge_windows_fn.cc:230
generic::internal: The work item requesting state read is no longer valid on
the backend. The work has already completed or will be retried. This is
expected during autoscaling events.
passed through:
==>
dist_proc/windmill/client/streaming_rpc_client.cc:697
==>
dist_proc/dax/workflow/****/streaming/merge_windows_fn.cc:230
generic::internal: The work item requesting state read is no longer valid on
the backend. The work has already completed or will be retried. This is
expected during autoscaling events.
passed through:
==>
dist_proc/windmill/client/streaming_rpc_client.cc:697
==>
dist_proc/dax/workflow/****/streaming/merge_windows_fn.cc:230
generic::internal: The work item requesting state read is no longer valid on
the backend. The work has already completed or will be retried. This is
expected during autoscaling events.
passed through:
==>
dist_proc/windmill/client/streaming_rpc_client.cc:697
==>
dist_proc/dax/workflow/****/streaming/merge_windows_fn.cc:230
generic::internal: The work item requesting state read is no longer valid on
the backend. The work has already completed or will be retried. This is
expected during autoscaling events.
passed through:
==>
dist_proc/windmill/client/streaming_rpc_client.cc:697
==>
dist_proc/dax/workflow/****/streaming/merge_windows_fn.cc:230
generic::internal: The work item requesting state read is no longer valid on
the backend. The work has already completed or will be retried. This is
expected during autoscaling events.
passed through:
==>
dist_proc/windmill/client/streaming_rpc_client.cc:697
==>
dist_proc/dax/workflow/****/streaming/merge_windows_fn.cc:230
generic::internal: The work item requesting state read is no longer valid on
the backend. The work has already completed or will be retried. This is
expected during autoscaling events.
passed through:
==>
dist_proc/windmill/client/streaming_rpc_client.cc:697
==>
dist_proc/dax/workflow/****/streaming/merge_windows_fn.cc:230
generic::internal: The work item requesting state read is no longer valid on
the backend. The work has already completed or will be retried. This is
expected during autoscaling events.
passed through:
==>
dist_proc/windmill/client/streaming_rpc_client.cc:697
==>
dist_proc/dax/workflow/****/streaming/merge_windows_fn.cc:230
generic::internal: The work item requesting state read is no longer valid on
the backend. The work has already completed or will be retried. This is
expected during autoscaling events.
passed through:
==>
dist_proc/windmill/client/streaming_rpc_client.cc:697
==>
dist_proc/dax/workflow/****/streaming/merge_windows_fn.cc:230
generic::internal: The work item requesting state read is no longer valid on
the backend. The work has already completed or will be retried. This is
expected during autoscaling events.
passed through:
==>
dist_proc/windmill/client/streaming_rpc_client.cc:697
==>
dist_proc/dax/workflow/****/streaming/merge_windows_fn.cc:230
generic::internal: The work item requesting state read is no longer valid on
the backend. The work has already completed or will be retried. This is
expected during autoscaling events.
passed through:
==>
dist_proc/windmill/client/streaming_rpc_client.cc:697
==>
di
Mar 01, 2022 4:00:47 PM org.apache.beam.sdk.metrics.MetricsEnvironment
getCurrentContainer
WARNING: Reporting metrics are not supported in the current execution
environment.
Mar 01, 2022 4:00:47 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-03-01T16:00:43.740Z: Cancel request is committed for workflow job:
2022-03-01_04_38_30-13844224834732571417.
Mar 01, 2022 4:00:47 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-03-01T16:00:43.779Z: Cleaning up.
Mar 01, 2022 4:00:47 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-03-01T16:00:43.871Z: Stopping **** pool...
Mar 01, 2022 4:00:47 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-03-01T16:00:43.915Z: Stopping **** pool...
Mar 01, 2022 4:03:16 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-03-01T16:03:15.500Z: 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.
Mar 01, 2022 4:03:16 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-03-01T16:03:15.551Z: Worker pool stopped.
Mar 01, 2022 4:03:24 PM org.apache.beam.runners.dataflow.DataflowPipelineJob
logTerminalState
INFO: Job 2022-03-01_04_38_30-13844224834732571417 finished with status
CANCELLED.
Load test results for test (ID): 21c09062-7d49-4893-9a3f-fff6df2a07d0 and
timestamp: 2022-03-01T12:38:25.128000000Z:
Metric: Value:
dataflow_v2_java17_runtime_sec 12006.945
dataflow_v2_java17_total_bytes_count 3.14987614E10
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:cleanUpDockerJavaImages
Untagged: us.gcr.io/apache-beam-testing/java-postcommit-it/java:20220301123604
Untagged:
us.gcr.io/apache-beam-testing/java-postcommit-it/java@sha256:7601b0b9fe14611d3e0cccc40c0e257d8552e91e45f79abe1ee866bd3f788cd6
Deleted: sha256:7c5d44c8736dc53aee22edf6ecb51e28731ab363c6f80f81e84399ec5f28800e
Deleted: sha256:acfbd54b31857ba1a382a0c7b6a03e472cf4872cff1a3501f1a3cbb94ea52cf2
Deleted: sha256:ddc08bd996f3ce82ee09b8f860d608cb957f53b9ae5e5424a0e4887875cfcc7f
Deleted: sha256:a964cb004ea3e12fed2c7ff8a692a4ba3e8f5c6bfef8eecc81af7abcdcd177f2
Deleted: sha256:bb293d81525a6cd3551b1d3b4ef8d4886d77a8160ae102561788c8584ca735b9
Deleted: sha256:216e122f3f133c5cb55a828008895f3c5ee67ce8920830a3f857fa4dcbc9b0f6
Deleted: sha256:bc06d46dcc7d82479b4f44d7a1c24f6706a40873c6a255f28ca2a5620eef01fe
Deleted: sha256:1abf31306df482035062446375ae9a5b4cf6502233da2c6a9a660894e9b2ec17
Deleted: sha256:0cc73153d897110f23a08fa9ba428f5e59042dd40034198125ba431807071973
Deleted: sha256:0b3e5688133e222d134411f9e52cf6809062823f78aa40d824100146897c0ae4
Deleted: sha256:adb03f09c560f729f3cc5a4f520580955e1cb5d2c4a096111a342ae572ab92cc
Deleted: sha256:85b861fd42dc6b205142cef4d90e10c300150efdecf37b2bda5d6b1caceedb82
Deleted: sha256:6d518b6cbd1ffb3adf8710aa32717f4ad72dbc67caf57ba6eb27f786aa1ea3ee
Deleted: sha256:9adef3877bc4fbb34024f95344d5b83cfc494537ea0ac5b101c62d5d14f41988
Deleted: sha256:b3815c9f077612fdbd2227f144c42d6a453efdcf8a0ecea3608714bc1c5ab261
Deleted: sha256:cc8e7382e9d1d9047e80ac2bbbda0ac0441d641ad7c338a9e225fcb0eaa1ca31
Deleted: sha256:c37c2bd9a1a9922c399941ce94de432e44d706eafa2bf7060dbae1a9cfbc943f
Deleted: sha256:96e1fad14081fb2eb5045f9d5f0dd13534921d27b1d3dddc1e4c8071fca545ea
Deleted: sha256:1591b11c7a2aeb2c0c3de66e2f68c2ef693baba9824ecc8e96e4a0a0201c82cc
Deleted: sha256:6e572eacf6ea0beddba0d0824706de666c37784db670364d960734777e5b1b7e
Deleted: sha256:d2b96830acbcc3a42fa5c02f36d80b64d9ec63c6b8e2c6e4a050bc80a8e93a6c
Deleted: sha256:84b809ebd1ca0656b38a0275c86a9aa0c900d9e57ac329663e22a15094977299
Deleted: sha256:29506ed791245ff40bbb3410f2d5d217b8ec74e5360568743c8370825c9c4f5a
Deleted: sha256:f05b746271bb760bf8b2c5697f46cc8b7de6160c41da8c9f66bc682c1993f724
Deleted: sha256:8a2d1c161396583aa63e3806ef2c5250288c0f2bf07f00d9c72ba62e5f317405
Deleted: sha256:2b84efdaa7478c87f14f98eaefd16c037704f58420d54978a8f63ee8774eab3b
Deleted: sha256:e2eb13a6fc0a8bdb0bd55b1895c12e0cdec47b39dc41d18e567ca2f38cac4b0b
Deleted: sha256:84e0b1d8efdfc06bebee3af9babfd8650c882b09706962ed59ac8c8f02101f3a
Deleted: sha256:4bb28389c9bb56331b2d0e6cf885be131e2487a606ddb926ad2f414164589043
Deleted: sha256:a96ea783fd1c04bbaae4ac86d384c056a838081558d43301e86b001a63e4b1a5
Tag: [us.gcr.io/apache-beam-testing/java-postcommit-it/java:20220301123604]
- referencing digest:
[us.gcr.io/apache-beam-testing/java-postcommit-it/java@sha256:7601b0b9fe14611d3e0cccc40c0e257d8552e91e45f79abe1ee866bd3f788cd6]
Deleted [[us.gcr.io/apache-beam-testing/java-postcommit-it/java:20220301123604]
(referencing
[us.gcr.io/apache-beam-testing/java-postcommit-it/java@sha256:7601b0b9fe14611d3e0cccc40c0e257d8552e91e45f79abe1ee866bd3f788cd6])].
Removing untagged image
us.gcr.io/apache-beam-testing/java-postcommit-it/java@sha256:7601b0b9fe14611d3e0cccc40c0e257d8552e91e45f79abe1ee866bd3f788cd6
Digests:
-
us.gcr.io/apache-beam-testing/java-postcommit-it/java@sha256:7601b0b9fe14611d3e0cccc40c0e257d8552e91e45f79abe1ee866bd3f788cd6
Deleted
[us.gcr.io/apache-beam-testing/java-postcommit-it/java@sha256:7601b0b9fe14611d3e0cccc40c0e257d8552e91e45f79abe1ee866bd3f788cd6].
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 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.3.2/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 3h 27m 42s
109 actionable tasks: 72 executed, 33 from cache, 4 up-to-date
Publishing build scan...
https://gradle.com/s/zsgrrnvnx55ae
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]
