See
<https://ci-beam.apache.org/job/beam_LoadTests_Java_CoGBK_Dataflow_V2_Streaming_Java17/72/display/redirect?page=changes>
Changes:
[egalpin] Use default context output rather than outputWithTimestamp for
[stranniknm] Palo Alto case study - fix link
[rogelio.hernandez] [BEAM-12777] Removed current docs version redirect
[noreply] Merge pull request #16850: [BEAM-11205] Upgrade Libraries BOM
[noreply] Merge pull request #16484 from [BEAM-13633] [Playground] Implement
[noreply] Add 2022 events blog post (#16975)
[noreply] Clean up Go formatter suggestions (#16973)
[noreply] [BEAM-14012] Add go fmt to Github Actions (#16978)
[noreply] [BEAM-13911] Add basic tests to Go direct runner. (#16979)
[noreply] [BEAM-13960] Add support for more types when converting from between
row
------------------------------------------
[...truncated 774.19 KB...]
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
==>
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
==>
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/windmi
Mar 02, 2022 4:03:28 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-03-02T16:03:28.556Z: 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 02, 2022 4:03:28 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-03-02T16:03:28.601Z: Worker pool stopped.
Mar 02, 2022 4:03:36 PM org.apache.beam.runners.dataflow.DataflowPipelineJob
logTerminalState
INFO: Job 2022-03-02_04_39_58-14157234965447229207 finished with status
CANCELLED.
Load test results for test (ID): c8be7bac-0c31-448b-82b7-fbf8e213e04c and
timestamp: 2022-03-02T12:39:52.927000000Z:
Metric: Value:
dataflow_v2_java17_runtime_sec 11907.599
dataflow_v2_java17_total_bytes_count 3.7305674E10
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:20220302123746
Untagged:
us.gcr.io/apache-beam-testing/java-postcommit-it/java@sha256:696b0c18a8c3e5416fa9de4e456e9fa73e601dd1063b73978a2e1733d5ef82b0
Deleted: sha256:bd2231812ea39dbbe935087819774756a0f0458904ce6d4d08eef3d81f0ba9c9
Deleted: sha256:a17918d6f3b5b4fd0e8616b007a01f946d86a5ccaf1fb0b4c61c2e8837a02991
Deleted: sha256:399e0cadd4dcae5e076613b56258bb0df1ba1580abef3c2014a0b6910b38f074
Deleted: sha256:1c7bde8db26720434da223e0644b9fc4c305acbbfb8d985d36c299ab4ca70e40
Deleted: sha256:17a44b4d11d8e7ec3327d872f69d53198533e10e0bb8833028a8591af58f00b5
Deleted: sha256:5452ffac731a4f3ad6e18cc591d04209525241c8884f44bc7185d603c241b90b
Deleted: sha256:f5fe5642e3246097e84d197e1928ba94eeb2b2a89d1f24119714e2ef8a9359b2
Deleted: sha256:4fa7afe238b3dc6b2cb03f3754fcd88219704691476388696523f77496d0a0d7
Deleted: sha256:03ff7099e9b07eac2f3db7bbf5c71d0e57483cb57fb4ebd8e5b034ff9555c150
Deleted: sha256:c87401a423863d07b1c76625adfeb6fc8d82fc4b1fb92a601e1c09c91cdc5112
Deleted: sha256:e57610f2be566d722b09eb290eb4ad7ba63e9f31185620348bd5caf56756d315
Deleted: sha256:fa36a3ab397a54511783bcca1b167f983311a13b6a8669e7931dc18cead17a06
Deleted: sha256:5a97d1daa974873c1fdc282a31af60040ce7e24050f9899ae76363992279397b
Deleted: sha256:2014d7bc03daafa79d51030200158b429b78f1b62efbc0d176bbaec919ba44e5
Deleted: sha256:c6b34fe5b40a7c7e7f22b85b84ae57f5f6f1376895d5d597e0258e7129b9e4dd
Deleted: sha256:bd6a5d41952b5320f610540883ad5ef55a82da21c41176a1ccd9088a7765868a
Deleted: sha256:0fb6d2176ff041ec9015b5dcab97cf92ed1662aa47ad7725d2e09e4f2dd990b1
Deleted: sha256:75d5a482125f68c274774995dd1d5c69fb7bc9fa593488bfae230681bb9ccbfd
Deleted: sha256:0dec6be1e8f549d1065d72c83d574568df55453f13ca634f041f252a5b5f0894
Deleted: sha256:3f065c71c23f117ec772509eb068fa8c9bf0a468c3a5d1ba40862c959fbd6c1c
Deleted: sha256:33975ac00f0a543e262526909718fd914062e7853b666e559ebc4eecff51941a
Deleted: sha256:1f6a11373d6b7a749bd96f5393c62d60bfd63b1bd79aea17f276c2675b00555e
Deleted: sha256:ff7a3f7ea865088ef753b738d4b8211bce14634bf50f7e268394d63ec9232641
Deleted: sha256:c9a0e64b5c83d4f4b0132b52a9ef943d01e7161841f9f438214d7b4b4b14f1aa
Deleted: sha256:15e86cedf0ba7b31058553b009ab65b2568f51ae2c9edb488dbb8f6e1493cd8f
Deleted: sha256:aefd58cb364b251a31a432ede9a6c54639527756f74b6e24e59c2449dc626a66
Deleted: sha256:16f8d12b20dbaa5a383a339f5d7fbda569794ec54300acd00afb556750471fd2
Deleted: sha256:401bef75155e37ef0679e3480b71fe21cb0e73326042b8424cd1dfa40dd16ac1
Deleted: sha256:1de44c5fe8807a52445950d5431c2cfb2f6b89a71d843d03a67d0c8f148f4a7c
Deleted: sha256:090db9e705564073beb65a7f5ed2a6135e680c1d0580fa8529403b5128153edd
Tag: [us.gcr.io/apache-beam-testing/java-postcommit-it/java:20220302123746]
- referencing digest:
[us.gcr.io/apache-beam-testing/java-postcommit-it/java@sha256:696b0c18a8c3e5416fa9de4e456e9fa73e601dd1063b73978a2e1733d5ef82b0]
Deleted [[us.gcr.io/apache-beam-testing/java-postcommit-it/java:20220302123746]
(referencing
[us.gcr.io/apache-beam-testing/java-postcommit-it/java@sha256:696b0c18a8c3e5416fa9de4e456e9fa73e601dd1063b73978a2e1733d5ef82b0])].
Removing untagged image
us.gcr.io/apache-beam-testing/java-postcommit-it/java@sha256:696b0c18a8c3e5416fa9de4e456e9fa73e601dd1063b73978a2e1733d5ef82b0
Digests:
-
us.gcr.io/apache-beam-testing/java-postcommit-it/java@sha256:696b0c18a8c3e5416fa9de4e456e9fa73e601dd1063b73978a2e1733d5ef82b0
Deleted
[us.gcr.io/apache-beam-testing/java-postcommit-it/java@sha256:696b0c18a8c3e5416fa9de4e456e9fa73e601dd1063b73978a2e1733d5ef82b0].
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 26m 13s
109 actionable tasks: 72 executed, 33 from cache, 4 up-to-date
Publishing build scan...
https://gradle.com/s/b7fwb6lbw4ipw
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]
