See
<https://ci-beam.apache.org/job/beam_LoadTests_Java_CoGBK_Dataflow_V2_Streaming_Java17/87/display/redirect?page=changes>
Changes:
[noreply] Mapped JOB_STATE_RESOURCE_CLEANING_UP to State.RUNNING.
[ryanthompson591] fixed typo in typehints
[zyichi] Remove unused prebuild_sdk_container_base_iamge option from validate
[hengfeng] feat: add more custom metrics
[noreply] [BEAM-14103][Playgrounf][Bugfix] Fix google analytics id (#17092)
[noreply] Minor: Make ScopedReadStateSupplier final (#16992)
[noreply] [BEAM-14113] Improve SamzaJobServerDriver extensibility (#17099)
[noreply] [BEAM-14116] Chunk commit requests dynamically (#17004)
[noreply] Merge pull request #17079 from [BEAM-13660] Add types and queries in
[noreply] [BEAM-13888] Add unit testing to ioutilx (#17058)
[noreply] Merge pull request #16822 from [BEAM-13841][Playground] Add
Application
[noreply] Minor: Make serializableCoder warning gramatically correct english
[noreply] [BEAM-14091] Fixing Interactive Beam show/collect for remote runners
------------------------------------------
[...truncated 775.47 KB...]
passed through:
==>
dist_proc/windmill/client/streaming_rpc_client.cc:697
==>
dist_proc/dax/workflow/****/streaming/merge_windows_fn.cc:222
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:222
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:222
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:222
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:222
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:222
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:222
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:222
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:222
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:222
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:222
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:222
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:222
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:222
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:222
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:222
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:222
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:222
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:222
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:222
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:222
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:222
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:222
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:222
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:222
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:222
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/windmi
Mar 17, 2022 4:03:45 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-03-17T16:03:44.621Z: 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 17, 2022 4:03:45 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-03-17T16:03:44.697Z: Worker pool stopped.
Mar 17, 2022 4:03:53 PM org.apache.beam.runners.dataflow.DataflowPipelineJob
logTerminalState
INFO: Job 2022-03-17_05_33_17-15156894379266467156 finished with status
CANCELLED.
Load test results for test (ID): 0d417360-61a6-455b-a253-ba7f15da465e and
timestamp: 2022-03-17T12:33:12.270000000Z:
Metric: Value:
dataflow_v2_java17_runtime_sec 12326.478
dataflow_v2_java17_total_bytes_count 3.78690776E10
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:20220317123039
Untagged:
us.gcr.io/apache-beam-testing/java-postcommit-it/java@sha256:9e2ac9cf49716cd991f377754cbb64532d5dd6ce720188b64d6dae3e6265e63b
Deleted: sha256:2de597a5274795d155795a62dfa26489640b9b2db76f38e7e1ad5568cec22d79
Deleted: sha256:01084484f98299e349e53fe5ac3d0468c389b4357544c4bdd4c1cee6f476f351
Deleted: sha256:89d9b569987b1f98b16e7b6f900a4e937b2860125ffc07b913d0449d51e1c580
Deleted: sha256:0a581de2c9cb020efcad0c45bc14876be8862720d1a491375a71a9091c7c449c
Deleted: sha256:004d63a5319e8b05590cedaf14ba8ff6ec8f32e06a58e5f38ca5a1c2df1cc6d0
Deleted: sha256:b4f2906541ac4508a3c3aaa06eaaa6add07a766fb0f8d052ee2d5590136ac6a8
Deleted: sha256:0790d3b9f0382b339fb1016e3aca7a961660f3dd581e478984bf40528888ead3
Deleted: sha256:0831af310198d337d5da00acd010dcc5bb6aab58a707655c0b0d79f4bea1ef15
Deleted: sha256:d8244a87ef8fa53bb10314914f8b76ade27c21f40de468fd437a58f8aa0c107e
Deleted: sha256:ec34ca1abcace3651aac3e6a7a3cb7d04c50791435da3ce95e47cd2735e5ce01
Deleted: sha256:9cbed822988f60f6dd0b4bacd4e7b08ea9efff54dc335a5966121e7ae6780ec4
Deleted: sha256:0a59d9baa1e84796f175a6a08b11b46164e4322b8bdf132acca2a56d3feecc09
Deleted: sha256:9e14f34a681ac4f16d27f374cae4db9ebc456ab7189fdb163785eafe7356f577
Deleted: sha256:8657509d0a6348875c8a22f05bd6a3ec7b1dc57801336c94690d23e0873e4bb3
Deleted: sha256:1d081b2880ee0d6db24adb7917bbac3981067a2255693ad4f657d2b62e1f61a7
Deleted: sha256:bd6f7808f780ff473c3aad7ac1f6f11d061bf631eb0f6a7bf900d3d4c09dc51d
Deleted: sha256:f429fa328a2ee2dfad587b60f1bc68c152b2cb34222a0daa2a0bf6ab91b7986c
Deleted: sha256:8371e94ca7b4b5b038956f1bf0b7bcd2426c64d6aed554d17d29222c1c5688bd
Deleted: sha256:413ed0400770024664d125c05385108f1466e9c3a960703d13c7c571654f3104
Deleted: sha256:7e81ea86e717b0479c5b72720337a0e7edf5158ee694cdb00290c4e269a9bc1e
Deleted: sha256:6c2fd24af21f98df03092e4159b81a8b0bfcaef87c1cc30bc0f7a689003e1713
Deleted: sha256:078d178abe02a8ab89831fa0767505a0636a49c663918fe5220fc13a39ba89a6
Deleted: sha256:9c38377a6a7fecb9f98c9240116f623627e84f4d5d7b5b69193a44df81636c79
Deleted: sha256:db53446f9f811022cab20c1d75dd372a991186051e6ad348610814cb815077da
Deleted: sha256:68fb003f5bbdb1f66495121518243349c3a263883089e1a20ac9b0ed22ec9a6c
Deleted: sha256:f3c7a214be31b57435a2764a9e90b6730bfe2da7185c49c0f464cab3e490938a
Deleted: sha256:ab606285db362a76287610b6e3bb6c881f45b6dbcf8c37586ff2c9939c614952
Deleted: sha256:8ef2719f33c1c3a77f67455a41ff50aa90582dca6c754bf4362ec1755ef70697
Deleted: sha256:571b0b18dbc5937f7c4edb7fc79cd3091e79251e42951cd67460497d44272176
Deleted: sha256:fe04087d24cb16b097048bf92fe682ecc64ffd4cfbb2becf1c6c7757f9c47ba0
Tag: [us.gcr.io/apache-beam-testing/java-postcommit-it/java:20220317123039]
- referencing digest:
[us.gcr.io/apache-beam-testing/java-postcommit-it/java@sha256:9e2ac9cf49716cd991f377754cbb64532d5dd6ce720188b64d6dae3e6265e63b]
Deleted [[us.gcr.io/apache-beam-testing/java-postcommit-it/java:20220317123039]
(referencing
[us.gcr.io/apache-beam-testing/java-postcommit-it/java@sha256:9e2ac9cf49716cd991f377754cbb64532d5dd6ce720188b64d6dae3e6265e63b])].
Removing untagged image
us.gcr.io/apache-beam-testing/java-postcommit-it/java@sha256:9e2ac9cf49716cd991f377754cbb64532d5dd6ce720188b64d6dae3e6265e63b
Digests:
-
us.gcr.io/apache-beam-testing/java-postcommit-it/java@sha256:9e2ac9cf49716cd991f377754cbb64532d5dd6ce720188b64d6dae3e6265e63b
Deleted
[us.gcr.io/apache-beam-testing/java-postcommit-it/java@sha256:9e2ac9cf49716cd991f377754cbb64532d5dd6ce720188b64d6dae3e6265e63b].
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 33m 34s
109 actionable tasks: 72 executed, 33 from cache, 4 up-to-date
Publishing build scan...
https://gradle.com/s/qsanxfo3bf5ty
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]
