See
<https://ci-beam.apache.org/job/beam_LoadTests_Java_GBK_Dataflow_V2_Streaming_Java11/285/display/redirect?page=changes>
Changes:
[brachipa] [BEAM-14094]Fix null pointer exception in HllCountInitFn
[brachipa] [BEAM-14094]Fix null pointer exception in HllCountInitFn
[egalpin] [BEAM-14003] Adds compat for Elasticsearch 8.0.0
[egalpin] [BEAM-13136] Removes support for Elasticsearch 2.x
[noreply] Merge pull request #17149 from [BEAM-13883] [Playground] Increase test
[Kiley Sok] ignore test
[noreply] [BEAM-13948] Add unstack(), a non-deferred column operation on
[noreply] [BEAM-10976] Bundle finalization: E2E support (#17045)
------------------------------------------
[...truncated 257.99 KB...]
passed through:
==>
dist_proc/windmill/client/streaming_rpc_client.cc:706
==>
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:706
==>
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:706
==>
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:706
==>
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:706
==>
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:706
==>
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:706
==>
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:706
==>
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:706
==>
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:706
==>
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:706
==>
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:706
==>
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:706
==>
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:706
==>
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:706
==>
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:706
==>
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:706
==>
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:706
==>
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:706
==>
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:706
==>
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:706
==>
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:706
==>
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:706
==>
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:706
==>
dist_proc/dax/workflow/****/streaming/merge_windows_fn.cc:222
Mar 31, 2022 3:55:28 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-03-31T15:55:27.881Z: 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.
Mar 31, 2022 3:59:35 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-03-31T15:59:32.529Z: 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.
Mar 31, 2022 4:00:38 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-03-31T16:00:38.545Z: Cancel request is committed for workflow job:
2022-03-31_05_49_14-3374833349481113765.
Mar 31, 2022 4:00:38 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-03-31T16:00:38.593Z: Cleaning up.
Mar 31, 2022 4:00:38 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-03-31T16:00:38.663Z: Stopping **** pool...
Mar 31, 2022 4:00:38 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-03-31T16:00:38.717Z: Stopping **** pool...
Mar 31, 2022 4:03:30 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-03-31T16:03:29.819Z: 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 31, 2022 4:03:30 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-03-31T16:03:29.849Z: Worker pool stopped.
Mar 31, 2022 4:03:36 PM org.apache.beam.runners.dataflow.DataflowPipelineJob
logTerminalState
INFO: Job 2022-03-31_05_49_14-3374833349481113765 finished with status
CANCELLED.
Load test results for test (ID): 5718e2f6-a832-4855-a7d5-a5f7988b9025 and
timestamp: 2022-03-31T12:49:09.292000000Z:
Metric: Value:
dataflow_v2_java11_runtime_sec 10953.432
dataflow_v2_java11_total_bytes_count 6.16097904E9
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.GroupByKeyLoadTest.run(GroupByKeyLoadTest.java:57)
at
org.apache.beam.sdk.loadtests.GroupByKeyLoadTest.main(GroupByKeyLoadTest.java:131)
> 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:20220331124657
Untagged:
us.gcr.io/apache-beam-testing/java-postcommit-it/java@sha256:98bd9094a9fdbdc00c14958bf825670bf17495b5f5b6e96044db6d9403bddeb9
Deleted: sha256:c025c0c2172196e9e00c6f45cadb17138ce1c9abc8b70c7139c0fa08264d1433
Deleted: sha256:e1b74a18323307e2ffb850a90f2cd2af08181f56d0d13222471fb7801f3d1662
Deleted: sha256:5a63ec675b2c74d3c8cfafa4670a9bb5a5c44e466db6a21cc4af7aac5fbb8c3c
Deleted: sha256:2eecacd0012545da2f60993c5166ca8979f440ae1f8b0f4a80bda15efe370d9c
Deleted: sha256:a85c9af7afd76ea0fd755d74bdaa8c1d986064681d74c8e54308901b1388db82
Deleted: sha256:0c3df8d934069b19ab549cae255cbb74575505946d86858807fc6a361bf4272f
Deleted: sha256:7e2eb384bac522714ab9bda671fef46d29eb6ad32a4c9f879a10ab88232cff69
Deleted: sha256:fc83d0bd0bffad30369af5bc1c196c57865f8186ab90252750b2d368020ea9b8
Deleted: sha256:86e07e329ab675161a5ccf0c272ca28d91aa928493967d7718de46b97ebbb133
Deleted: sha256:8cf998f48dddbe5b7f19a767a03b3a39ce333fdd6ba6aa314adcb51ff43f066a
Deleted: sha256:c7c57da7ce3999563a11a2e6b1f8e53e65fcb4c4b43df9e8a6e453a0062f8572
Deleted: sha256:436423e7c77282de98c9c7909714695446ea1105ae68fd8ee6438a59b029a624
Deleted: sha256:e089c9abdfc33fedcf31d2e4b2dc82a801a6901f51d76c4ec60282d259d1c1d9
Deleted: sha256:c64414c2807ea7966637aeadc555cffbfaafd346ceb0cd592beaf49da545c190
Deleted: sha256:ed6b9f347b6327ff9f094a0f56f5f03ae0deee0ab4efcd71f195fe49ce83db7a
Deleted: sha256:25b92e7cebbbde3819ebc47a07162e90680723b763fcb429b96b01c5d56a3a78
Deleted: sha256:8f07cb71bc9fa3f7ff877172849942ccac50829a59c76d1d3783ecd5bbc763cf
Deleted: sha256:878c662a2dc4b7cb342db5054833a45f06250a9d5a83dc35f4b5f981e2835b68
Deleted: sha256:cf9b1b4a0c8bbe3565102a68f4c4f01a84d73ff570e41c0e0957701c40bde6d0
Deleted: sha256:8bed1faa58fe05a6965bad4a0ca8767fc7087343ad470ba2b5370381bd978c86
Deleted: sha256:61025b79bc6c11d23e0c09fd98f3e62c9e83363083fda4841deb32bb70032df2
Deleted: sha256:0440fcfe16bf48ec154a47e09f6441bdc4e9872cddf2c6fa1211c466fe3cbc03
Deleted: sha256:0f6cac8e88963bdd562b95d63266b17e54148c7ad2b68b35d9ce00aa8a257b5f
Deleted: sha256:e154ee9e1e8ab252dc89801c2df2bf36dfd2edafc5e6d9108e2e86f03c067b51
Deleted: sha256:fc767afb57f0f8d1bcdcbe7dae9ef023501ddb36c8c5d582ace041c641bf624d
Deleted: sha256:0bda86b9a9367ebb8aa388e131ac18212671e7c0114f792b33e519aa852d71f5
Deleted: sha256:1adc55888dcd586d3edcf1ba591d280bd783ae8405607a0d89f7b4b5313f6488
Deleted: sha256:d842065ae59ce1c7c18e0cf4dd354c2b7fcd1565a5b5e7be2100a9bf9184f913
Deleted: sha256:38b89d7f61df16b8dc261de19243d4994605a5cc8e7dfd4a63d35a63a573d1e6
Deleted: sha256:fe63ffccad2fbd4d096a1454a7016e03818a6f33cedf235a5995c73832dfb2e5
Deleted: sha256:e7733f8bc95ab372d903347cb86b6d74cdc5e142e35bf0cac5961f7bbdf0a776
Deleted: sha256:6d08261850b64f9b96b12c8c83d47289914694867a65591327c49ef77292a619
Deleted: sha256:7f7d09ef8bf5a65ab614e6199d45c50bcdc4279f4d5b3d288909a249394f98c0
Deleted: sha256:45bc066ae3d5eeb635c0560fbb89a191c8006b826febf7546063ae69216b18bd
Tag: [us.gcr.io/apache-beam-testing/java-postcommit-it/java:20220331124657]
- referencing digest:
[us.gcr.io/apache-beam-testing/java-postcommit-it/java@sha256:98bd9094a9fdbdc00c14958bf825670bf17495b5f5b6e96044db6d9403bddeb9]
Deleted [[us.gcr.io/apache-beam-testing/java-postcommit-it/java:20220331124657]
(referencing
[us.gcr.io/apache-beam-testing/java-postcommit-it/java@sha256:98bd9094a9fdbdc00c14958bf825670bf17495b5f5b6e96044db6d9403bddeb9])].
Removing untagged image
us.gcr.io/apache-beam-testing/java-postcommit-it/java@sha256:98bd9094a9fdbdc00c14958bf825670bf17495b5f5b6e96044db6d9403bddeb9
Digests:
-
us.gcr.io/apache-beam-testing/java-postcommit-it/java@sha256:98bd9094a9fdbdc00c14958bf825670bf17495b5f5b6e96044db6d9403bddeb9
Deleted
[us.gcr.io/apache-beam-testing/java-postcommit-it/java@sha256:98bd9094a9fdbdc00c14958bf825670bf17495b5f5b6e96044db6d9403bddeb9].
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 17m 1s
109 actionable tasks: 72 executed, 33 from cache, 4 up-to-date
Publishing build scan...
https://gradle.com/s/fis6m3gsa6ic4
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]
