See
<https://ci-beam.apache.org/job/beam_LoadTests_Java_CoGBK_Dataflow_V2_Streaming_Java11/265/display/redirect?page=changes>
Changes:
[ihr] [BEAM-13923] Fix the answers placeholders locations in the Java katas
[jakub.kukul] [BEAM-14039] Propagate ignore_unknown_columns parameter.
[stranniknm] [BEAM-14079] playground - improve accessibility
[noreply] [BEAM-13925] Find and address prs that havent been reviewed in a week
[noreply] Fix import path
[noreply] [BEAM-13925] Fix one more import path
[noreply] Add a StatefulDoFn test that sets event time timer within allowed
[noreply] Merge pull request #17056 from [BEAM-14076] [SnowflakeIO] Add support
------------------------------------------
[...truncated 557.93 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/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 11, 2022 4:00:37 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-03-11T16:00:36.647Z: Cancel request is committed for workflow job:
2022-03-11_04_46_03-9236443180827163991.
Mar 11, 2022 4:00:37 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-03-11T16:00:36.676Z: Cleaning up.
Mar 11, 2022 4:00:37 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-03-11T16:00:36.780Z: Stopping **** pool...
Mar 11, 2022 4:00:37 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-03-11T16:00:36.824Z: Stopping **** pool...
Mar 11, 2022 4:03:07 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-03-11T16:03:06.081Z: 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 11, 2022 4:03:07 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-03-11T16:03:06.222Z: Worker pool stopped.
Mar 11, 2022 4:03:12 PM org.apache.beam.runners.dataflow.DataflowPipelineJob
logTerminalState
INFO: Job 2022-03-11_04_46_03-9236443180827163991 finished with status
CANCELLED.
Load test results for test (ID): 6f4cd587-af50-4e63-896b-6a479b72ac13 and
timestamp: 2022-03-11T12:45:58.175000000Z:
Metric: Value:
dataflow_v2_java11_runtime_sec 11490.14
dataflow_v2_java11_total_bytes_count 2.42759814E10
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:20220311124338
Untagged:
us.gcr.io/apache-beam-testing/java-postcommit-it/java@sha256:c2b41c7587cde6ddc81276af420b2b20bfb8c4543dc74d0729ff4ef3fdd1b875
Deleted: sha256:f10d0226981b9d0cc0429da5ecf126a2c09396c76cb78278f14c0a145ca42a0a
Deleted: sha256:9401d34540f6f07f90bf246d9b2da67ac6883a110f8ab863f82cb5a76f10cc1e
Deleted: sha256:aa5384f9874c3e86d37185f893bef797b3f78c923a045a4b0258c2adf4e326a5
Deleted: sha256:07aa5342bdf33cdac34ae38179a95852e85b0993e0a3aea2f8be30956dbf87e6
Deleted: sha256:bf5da7ffc2cd2e662761217fb007c5f220ed12e5911c79243016cfecb7bbabf2
Deleted: sha256:85e24060179450808dc7e54e870de0d7fc130a35723748a40b19a8af1500aa41
Deleted: sha256:917ea2af63da18a0ade501209d9329a813ddfabe01e14a3b26ea47893ad8c4e9
Deleted: sha256:594b0575b8f915fb393d5c96f14c7df18c3d6393f7014fd12bbdca93a9a47a97
Deleted: sha256:9d7112d13acc9cca32caa125bed29863f565d2ae7a424d1fd711e83cbcc69b83
Deleted: sha256:e4914cd5c377848ee8714cf8c1c385d45bbc80aa68f30a90808a72e0a4e6712d
Deleted: sha256:7cba1f8192e5ef6eb28fb69d3d9ef0fce454587b7b7936909cbe5970122a0232
Deleted: sha256:779946275bf20c0aee49ef0b8d8e90950f268e36f3747f4050a908e6b139f66f
Deleted: sha256:e70a24e32b6c9e5a064885821ed506c53558ea6b2dbb25cd3e8407aa28ef0698
Deleted: sha256:f51b602e59cab92b31c23b1a9bc6df54e4ed0cd3ffe93234c5e1c49597edcefe
Deleted: sha256:5b2e43f6512e3fba737d043c7c66130cc8fbff36c38cf5b560257f01a2bf9427
Deleted: sha256:2ce536121832da3d04168f9177d92a315bbabeb584c80ca8ecf3bb45664f7c22
Deleted: sha256:bd8271b8a4de91c21c4182fadee5c4d3ea908d171c03b555e5bddfa671898b6b
Deleted: sha256:55e8b5d567d72a7b5957f5809ec2be36c6984dbadb9f431dc5d476deefbebc29
Deleted: sha256:9c777fb628f148411827f3960a026be2a1874a0993d6f50b6e47c0a6a472ee2a
Deleted: sha256:d3cdae62de540fe4ce507940bbed0c6cd4be138e1997553fd0f2fbbd2a1847bb
Deleted: sha256:b7cb683bb7b0270b7b9fe241537e2e1da5edc377ece12d2ee1b48e2a64f0d0f6
Deleted: sha256:c58ac11dafd16a1a24aa2b19444fd34319d74f821116821891be4866c860f367
Deleted: sha256:ebd2d06f169ad6acea33b845ac4348367f9883903e5925baa5e680e9fe703c18
Deleted: sha256:e56c6c2317c7d74190fc0110b215fc6f5f04cefeba59cc9848efc2dd9652561b
Deleted: sha256:ac9dc628ba11f60f6cf67c5fce7b73ba05c504316379cda360b3a1ffed6d490c
Deleted: sha256:aa40cfc476a54cd6ef3740606cc761a073945675adc7072828df650f7c1c596f
Deleted: sha256:e12d8a330a7981c730784e15c01d70e5eea6ab4b58d9dcc8e8d5149e3f7d7a16
Deleted: sha256:d275f512fc071e7016c1376050614d84181afbf8c87ea570779d6a3e0ecd85c7
Deleted: sha256:9a9f1f28c1b92420a60bc910316bb1d1fce8836cdc55946a8635e92edec0d6dc
Deleted: sha256:3d8555dc3c36afbdcbca620fdc14a5c8f4b548f8b0ed3df45cdfd17ff36efbc9
Tag: [us.gcr.io/apache-beam-testing/java-postcommit-it/java:20220311124338]
- referencing digest:
[us.gcr.io/apache-beam-testing/java-postcommit-it/java@sha256:c2b41c7587cde6ddc81276af420b2b20bfb8c4543dc74d0729ff4ef3fdd1b875]
Deleted [[us.gcr.io/apache-beam-testing/java-postcommit-it/java:20220311124338]
(referencing
[us.gcr.io/apache-beam-testing/java-postcommit-it/java@sha256:c2b41c7587cde6ddc81276af420b2b20bfb8c4543dc74d0729ff4ef3fdd1b875])].
Removing untagged image
us.gcr.io/apache-beam-testing/java-postcommit-it/java@sha256:c2b41c7587cde6ddc81276af420b2b20bfb8c4543dc74d0729ff4ef3fdd1b875
Digests:
-
us.gcr.io/apache-beam-testing/java-postcommit-it/java@sha256:c2b41c7587cde6ddc81276af420b2b20bfb8c4543dc74d0729ff4ef3fdd1b875
Deleted
[us.gcr.io/apache-beam-testing/java-postcommit-it/java@sha256:c2b41c7587cde6ddc81276af420b2b20bfb8c4543dc74d0729ff4ef3fdd1b875].
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 20m
109 actionable tasks: 72 executed, 33 from cache, 4 up-to-date
Publishing build scan...
https://gradle.com/s/xrfiwq3dqbnr4
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]
