See 
<https://ci-beam.apache.org/job/beam_LoadTests_Java_GBK_Dataflow_V2_Streaming_Java11/124/display/redirect?page=changes>

Changes:

[zhoufek] [BEAM-9487] Multiple Trigger.may_lose_data fixes

[zhoufek] [BEAM-9487] Remove CONDITION_NOT_GUARANTEED as potential data loss

[zhoufek] [BEAM-9487] Do AfterAny, AfterAll, and AfterEach checks properly (i.e.

[zhoufek] [BEAM-9487] Remove unused import

[zhoufek] [BEAM-9487] Reintroduce flag but do not use it

[zhoufek] [BEAM-9487] Add test that shows AfterCount finishing

[zhoufek] [BEAM-9487] Make _ParallelTriggerFn.may_finish clearer

[Robert Bradshaw] Revert "Merge pull request #15441 from [BEAM-8823] Make 
FnApiRunner work

[Robert Bradshaw] [BEAM-13040] Add some test cases enforcing side input waiting.

[Robert Bradshaw] lint

[brachipa] [BEAM-12393] sql support for Zeta Sql

[aydar.zaynutdinov] [BEAM-12988] [Playground]

[brachipa] [BEAM-12393] package private

[brachipa] [BEAM-12393] returning more generic interface

[noreply] [BEAM-13066] Produce abstract iterables from IterableCoder. (#15662)

[noreply] [BEAM-11936] Fix some errorprone warnings (#15648)

[noreply] [BEAM-13068] Add xlangx.DecodeStructPayload (#15741)

[Luke Cwik] [BEAM-13015] Implement a simplified cancellable blocking queue with


------------------------------------------
[...truncated 95.09 KB...]
generic::aborted: SDK harness sdk-0-0 disconnected.
passed through:
==>
    dist_proc/dax/workflow/****/fnapi_service_impl.cc:644
generic::aborted: SDK harness sdk-0-0 disconnected.
generic::aborted: SDK harness sdk-0-0 disconnected.
passed through:
==>
    dist_proc/dax/workflow/****/fnapi_service_impl.cc:644
generic::aborted: SDK harness sdk-0-0 disconnected.
generic::aborted: SDK harness sdk-0-0 disconnected.
passed through:
==>
    dist_proc/dax/workflow/****/fnapi_service_impl.cc:644
generic::aborted: SDK harness sdk-0-0 disconnected.
generic::aborted: SDK harness sdk-0-0 disconnected.
passed through:
==>
    dist_proc/dax/workflow/****/fnapi_service_impl.cc:644
generic::aborted: SDK harness sdk-0-0 disconnected.
generic::aborted: SDK harness sdk-0-0 disconnected.
passed through:
==>
    dist_proc/dax/workflow/****/fnapi_service_impl.cc:644
generic::aborted: SDK harness sdk-0-0 disconnected.
generic::aborted: SDK harness sdk-0-0 disconnected.
passed through:
==>
    dist_proc/dax/workflow/****/fnapi_service_impl.cc:644
generic::aborted: SDK harness sdk-0-0 disconnected.
generic::aborted: SDK harness sdk-0-0 disconnected.
passed through:
==>
    dist_proc/dax/workflow/****/fnapi_service_impl.cc:644
generic::aborted: SDK harness sdk-0-0 disconnected.
generic::aborted: SDK harness sdk-0-0 disconnected.
passed through:
==>
    dist_proc/dax/workflow/****/fnapi_service_impl.cc:644
generic::aborted: SDK harness sdk-0-0 disconnected.
generic::aborted: SDK harness sdk-0-0 disconnected.
passed through:
==>
    dist_proc/dax/workflow/****/fnapi_service_impl.cc:644
generic::aborted: SDK harness sdk-0-0 disconnected.
generic::aborted: SDK harness sdk-0-0 disconnected.
passed through:
==>
    dist_proc/dax/workflow/****/fnapi_service_impl.cc:644
generic::aborted: SDK harness sdk-0-0 disconnected.
generic::aborted: SDK harness sdk-0-0 disconnected.
passed through:
==>
    dist_proc/dax/workflow/****/fnapi_service_impl.cc:644
generic::aborted: SDK harness sdk-0-0 disconnected.
generic::aborted: SDK harness sdk-0-0 disconnected.
passed through:
==>
    dist_proc/dax/workflow/****/fnapi_service_impl.cc:644
generic::aborted: SDK harness sdk-0-0 disconnected.
generic::aborted: SDK harness sdk-0-0 disconnected.
passed through:
==>
    dist_proc/dax/workflow/****/fnapi_service_impl.cc:644
generic::aborted: SDK harness sdk-0-0 disconnected.
generic::aborted: SDK harness sdk-0-0 disconnected.
passed through:
==>
    dist_proc/dax/workflow/****/fnapi_service_impl.cc:644
generic::aborted: SDK harness sdk-0-0 disconnected.
generic::aborted: SDK harness sdk-0-0 disconnected.
passed through:
==>
    dist_proc/dax/workflow/****/fnapi_service_impl.cc:644
generic::aborted: SDK harness sdk-0-0 disconnected.
generic::aborted: SDK harness sdk-0-0 disconnected.
passed through:
==>
    dist_proc/dax/workflow/****/fnapi_service_impl.cc:644
generic::aborted: SDK harness sdk-0-0 disconnected.
generic::aborted: SDK harness sdk-0-0 disconnected.
passed through:
==>
    dist_proc/dax/workflow/****/fnapi_service_impl.cc:644
generic::aborted: SDK harness sdk-0-0 disconnected.
generic::aborted: SDK harness sdk-0-0 disconnected.
passed through:
==>
    dist_proc/dax/workflow/****/fnapi_service_impl.cc:644
generic::aborted: SDK harness sdk-0-0 disconnected.
generic::aborted: SDK harness sdk-0-0 disconnected.
passed through:
==>
    dist_proc/dax/workflow/****/fnapi_service_impl.cc:644
generic::aborted: SDK harness sdk-0-0 disconnected.
generic::aborted: SDK harness sdk-0-0 disconnected.
passed through:
==>
    dist_proc/dax/workflow/****/fnapi_service_impl.cc:644
generic::aborted: SDK harness sdk-0-0 disconnected.
generic::aborted: SDK harness sdk-0-0 disconnected.
passed through:
==>
    dist_proc/dax/workflow/****/fnapi_service_impl.cc:644
generic::aborted: SDK harness sdk-0-0 disconnected.
generic::aborted: SDK harness sdk-0-0 disconnected.
passed through:
==>
    dist_proc/dax/workflow/****/fnapi_service_impl.cc:644
generic::aborted: SDK harness sdk-0-0 disconnected.
generic::aborted: SDK harness sdk-0-0 disconnected.
passed through:
==>
    dist_proc/dax/workflow/****/fnapi_service_impl.cc:644
Oct 19, 2021 2:58:28 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2021-10-19T14:58:26.665Z: 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.
Oct 19, 2021 3:13:54 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
SEVERE: 2021-10-19T15:13:49.117Z: generic::aborted: SDK harness sdk-0-0 
disconnected.
generic::aborted: SDK harness sdk-0-0 disconnected.
passed through:
==>
    dist_proc/dax/workflow/****/fnapi_service_impl.cc:644
generic::aborted: SDK harness sdk-0-0 disconnected.
generic::aborted: SDK harness sdk-0-0 disconnected.
passed through:
==>
    dist_proc/dax/workflow/****/fnapi_service_impl.cc:644
generic::aborted: SDK harness sdk-0-0 disconnected.
passed through:
==>
    dist_proc/dax/workflow/****/fnapi_service_impl.cc:644
generic::aborted: SDK harness sdk-0-0 disconnected.
passed through:
==>
    dist_proc/dax/workflow/****/fnapi_service_impl.cc:644
generic::aborted: SDK harness sdk-0-0 disconnected.
generic::aborted: SDK harness sdk-0-0 disconnected.
passed through:
==>
    dist_proc/dax/workflow/****/fnapi_service_impl.cc:644
generic::aborted: SDK harness sdk-0-0 disconnected.
generic::aborted: SDK harness sdk-0-0 disconnected.
passed through:
==>
    dist_proc/dax/workflow/****/fnapi_service_impl.cc:644
generic::aborted: SDK harness sdk-0-0 disconnected.
generic::aborted: SDK harness sdk-0-0 disconnected.
passed through:
==>
    dist_proc/dax/workflow/****/fnapi_service_impl.cc:644
generic::aborted: SDK harness sdk-0-0 disconnected.
generic::aborted: SDK harness sdk-0-0 disconnected.
passed through:
==>
    dist_proc/dax/workflow/****/fnapi_service_impl.cc:644
generic::aborted: SDK harness sdk-0-0 disconnected.
generic::aborted: SDK harness sdk-0-0 disconnected.
passed through:
==>
    dist_proc/dax/workflow/****/fnapi_service_impl.cc:644
generic::aborted: SDK harness sdk-0-0 disconnected.
generic::aborted: SDK harness sdk-0-0 disconnected.
passed through:
==>
    dist_proc/dax/workflow/****/fnapi_service_impl.cc:644
generic::aborted: SDK harness sdk-0-0 disconnected.
generic::aborted: SDK harness sdk-0-0 disconnected.
generic::aborted: SDK harness sdk-0-0 disconnected.
passed through:
==>
    dist_proc/dax/workflow/****/fnapi_service_impl.cc:644
generic::aborted: SDK harness sdk-0-0 disconnected.
generic::aborted: SDK harness sdk-0-0 disconnected.
generic::aborted: SDK harness sdk-0-0 disconnected.
passed through:
==>
    dist_proc/dax/workflow/****/fnapi_service_impl.cc:644
generic::aborted: SDK harness sdk-0-0 disconnected.
generic::aborted: SDK harness sdk-0-0 disconnected.
passed through:
==>
    dist_proc/dax/workflow/****/fnapi_service_impl.cc:644
Oct 19, 2021 3:14:29 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2021-10-19T15:14:29.003Z: 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.
Oct 19, 2021 3:22:34 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2021-10-19T15:22:34.235Z: 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.
Oct 19, 2021 3:30:34 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2021-10-19T15:30:33.797Z: 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.
Oct 19, 2021 4:00:31 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2021-10-19T16:00:30.364Z: Cancel request is committed for workflow job: 
2021-10-19_05_23_17-16521991910126226445.
Oct 19, 2021 4:00:31 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2021-10-19T16:00:30.415Z: Cleaning up.
Oct 19, 2021 4:00:31 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2021-10-19T16:00:30.512Z: Stopping **** pool...
Oct 19, 2021 4:00:31 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2021-10-19T16:00:30.603Z: Stopping **** pool...
Oct 19, 2021 4:02:59 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2021-10-19T16:02:58.905Z: 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.
Oct 19, 2021 4:02:59 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2021-10-19T16:02:58.942Z: Worker pool stopped.
Oct 19, 2021 4:03:04 PM org.apache.beam.runners.dataflow.DataflowPipelineJob 
logTerminalState
INFO: Job 2021-10-19_05_23_17-16521991910126226445 finished with status 
CANCELLED.
Load test results for test (ID): 0511c8df-9439-4a0c-a4e2-fbd43f7523f2 and 
timestamp: 2021-10-19T12:22:53.624000000Z:
                 Metric:                    Value:
dataflow_v2_java11_runtime_sec                 12892.699
dataflow_v2_java11_total_bytes_count              9.57446822E9
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:141)
        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:cleanUpDockerImages
Untagged: us.gcr.io/apache-beam-testing/java-postcommit-it/java:20211019121758
Untagged: 
us.gcr.io/apache-beam-testing/java-postcommit-it/java@sha256:9ae47d0f921353627ee7219146187767a0877cebf67d1fad3f37f13c66101a56
Tag: [us.gcr.io/apache-beam-testing/java-postcommit-it/java:20211019121758]
- referencing digest: 
[us.gcr.io/apache-beam-testing/java-postcommit-it/java@sha256:9ae47d0f921353627ee7219146187767a0877cebf67d1fad3f37f13c66101a56]

Deleted [[us.gcr.io/apache-beam-testing/java-postcommit-it/java:20211019121758] 
(referencing 
[us.gcr.io/apache-beam-testing/java-postcommit-it/java@sha256:9ae47d0f921353627ee7219146187767a0877cebf67d1fad3f37f13c66101a56])].
Removing untagged image 
us.gcr.io/apache-beam-testing/java-postcommit-it/java@sha256:9ae47d0f921353627ee7219146187767a0877cebf67d1fad3f37f13c66101a56
Digests:
- 
us.gcr.io/apache-beam-testing/java-postcommit-it/java@sha256:9ae47d0f921353627ee7219146187767a0877cebf67d1fad3f37f13c66101a56
Deleted 
[us.gcr.io/apache-beam-testing/java-postcommit-it/java@sha256:9ae47d0f921353627ee7219146187767a0877cebf67d1fad3f37f13c66101a56].

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 7.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See 
https://docs.gradle.org/6.9.1/userguide/command_line_interface.html#sec:command_line_warnings

BUILD FAILED in 3h 46m 19s
101 actionable tasks: 72 executed, 27 from cache, 2 up-to-date

Publishing build scan...
https://gradle.com/s/xw3mufl5w77b6

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]

Reply via email to