lukecwik commented on issue #23562:
URL: https://github.com/apache/beam/issues/23562#issuecomment-1275299129
Logs:
```
Error Message
java.lang.RuntimeException: Dataflow job
2022-09-15_13_08_48-251378908779169791 terminated in state RUNNING but did not
return a failure reason.
Stacktrace
java.lang.RuntimeException: Dataflow job
2022-09-15_13_08_48-251378908779169791 terminated in state RUNNING but did not
return a failure reason.
at
org.apache.beam.runners.dataflow.TestDataflowRunner.run(TestDataflowRunner.java:141)
at
org.apache.beam.runners.dataflow.TestDataflowRunner.run(TestDataflowRunner.java:93)
at
org.apache.beam.runners.dataflow.TestDataflowRunner.run(TestDataflowRunner.java:55)
at org.apache.beam.sdk.Pipeline.run(Pipeline.java:323)
at org.apache.beam.sdk.testing.TestPipeline.run(TestPipeline.java:399)
at org.apache.beam.sdk.testing.TestPipeline.run(TestPipeline.java:335)
at
org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests.testParDoWithOnlyTaggedOutput(ParDoTest.java:809)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at
org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)
at
org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at
org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56)
at
org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
at
org.apache.beam.sdk.testing.TestPipeline$1.evaluate(TestPipeline.java:323)
at
org.junit.rules.ExpectedException$ExpectedExceptionStatement.evaluate(ExpectedException.java:258)
at org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
at
org.junit.runners.BlockJUnit4ClassRunner$1.evaluate(BlockJUnit4ClassRunner.java:100)
at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:366)
at
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:103)
at
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:63)
at org.junit.runners.ParentRunner$4.run(ParentRunner.java:331)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:79)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:329)
at org.junit.runners.ParentRunner.access$100(ParentRunner.java:66)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:293)
at org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
at org.junit.runners.ParentRunner.run(ParentRunner.java:413)
at
org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecutor.runTestClass(JUnitTestClassExecutor.java:110)
at
org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecutor.execute(JUnitTestClassExecutor.java:58)
at
org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecutor.execute(JUnitTestClassExecutor.java:38)
at
org.gradle.api.internal.tasks.testing.junit.AbstractJUnitTestClassProcessor.processTestClass(AbstractJUnitTestClassProcessor.java:62)
at
org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:51)
at sun.reflect.GeneratedMethodAccessor207.invoke(Unknown Source)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at
org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:36)
at
org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at
org.gradle.internal.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:33)
at
org.gradle.internal.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:94)
at com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
at
org.gradle.api.internal.tasks.testing.worker.TestWorker$2.run(TestWorker.java:176)
at
org.gradle.api.internal.tasks.testing.worker.TestWorker.executeAndMaintainThreadName(TestWorker.java:129)
at
org.gradle.api.internal.tasks.testing.worker.TestWorker.execute(TestWorker.java:100)
at
org.gradle.api.internal.tasks.testing.worker.TestWorker.execute(TestWorker.java:60)
at
org.gradle.process.internal.worker.child.ActionExecutionWorker.execute(ActionExecutionWorker.java:56)
at
org.gradle.process.internal.worker.child.SystemApplicationClassLoaderWorker.call(SystemApplicationClassLoaderWorker.java:133)
at
org.gradle.process.internal.worker.child.SystemApplicationClassLoaderWorker.call(SystemApplicationClassLoaderWorker.java:71)
at
worker.org.gradle.process.internal.worker.GradleWorkerMain.run(GradleWorkerMain.java:69)
at
worker.org.gradle.process.internal.worker.GradleWorkerMain.main(GradleWorkerMain.java:74)
Standard Error
Sep 15, 2022 8:02:11 PM org.apache.beam.runners.dataflow.DataflowRunner
validateSdkContainerImageOptions
WARNING: Prefer --sdkContainerImage over deprecated legacy option
--workerHarnessContainerImage.
Sep 15, 2022 8:02:11 PM
org.apache.beam.runners.dataflow.options.DataflowPipelineOptions$StagingLocationFactory
create
INFO: No stagingLocation provided, falling back to gcpTempLocation
Sep 15, 2022 8:02:12 PM org.apache.beam.runners.dataflow.DataflowRunner
fromOptions
INFO: PipelineOptions.filesToStage was not specified. Defaulting to files
from the classpath: will stage 271 files. Enable logging at DEBUG level to see
which files will be staged.
Sep 15, 2022 8:02:12 PM org.apache.beam.runners.dataflow.DataflowRunner
shouldActAsStreaming
WARNING: No unbounded PCollection(s) found in a streaming pipeline! You
might consider using 'streaming=false'!
Sep 15, 2022 8:02:12 PM org.apache.beam.runners.dataflow.DataflowRunner run
INFO: Executing pipeline on the Dataflow Service, which will have billing
implications related to Google Compute Engine usage and other Google Cloud
Services.
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
stageClasspathElements
INFO: Uploading 272 files from PipelineOptions.filesToStage to staging
location to prepare for execution.
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Java_ValidatesRunner_Dataflow_Streaming_PR/src/sdks/java/testing/test-utils/build/libs/beam-sdks-java-test-utils-2.42.0-SNAPSHOT-tests.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/beam-sdks-java-test-utils-2.42.0-SNAPSHOT-tests-mNXvgEv6NsmpwLHJpRoWjvxu4EY_729Kok9w1LcVg7E.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Java_ValidatesRunner_Dataflow_Streaming_PR/src/sdks/java/extensions/protobuf/build/libs/beam-sdks-java-extensions-protobuf-2.42.0-SNAPSHOT.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/beam-sdks-java-extensions-protobuf-2.42.0-SNAPSHOT-oIC6ITU1LcNsPjAgV58RrgRn7TA20BsBGKahs9N3Ow4.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading /usr/lib/jvm/java-8-openjdk-amd64/jre/lib/ext/jaccess.jar to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/jaccess-FBI0Bb27lF3oEBieWAi7SP8X1zBR8k4BJQOVpsoK9a0.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Java_ValidatesRunner_Dataflow_Streaming_PR/src/sdks/java/extensions/google-cloud-platform-core/build/libs/beam-sdks-java-extensions-google-cloud-platform-core-2.42.0-SNAPSHOT-tests.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/beam-sdks-java-extensions-google-cloud-platform-core-2.42.0-SNAPSHOT-tests-_F4HuZx207kQIrIwT4cjEuE_4imtvQTZtWm5OMVxy18.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Java_ValidatesRunner_Dataflow_Streaming_PR/src/runners/direct-java/build/libs/beam-runners-direct-java-2.42.0-SNAPSHOT.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/beam-runners-direct-java-2.42.0-SNAPSHOT-OKb_eTMsOOeJME-caJu5qejwfXaFVW6uZn5WHqsm81s.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/usr/lib/jvm/java-8-openjdk-amd64/jre/lib/ext/icedtea-sound.jar to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/icedtea-sound-CGRxIE9edPHnbxQhM-L5mp8h21H-ySB79uQtSquPV_Q.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Java_ValidatesRunner_Dataflow_Streaming_PR/src/sdks/java/expansion-service/build/libs/beam-sdks-java-expansion-service-2.42.0-SNAPSHOT.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/beam-sdks-java-expansion-service-2.42.0-SNAPSHOT-hmdNYohy9PMhMW19rRoMfpR8w-SjW2DwlRdXqD1fEgM.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading /usr/lib/jvm/java-8-openjdk-amd64/jre/lib/ext/localedata.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/localedata-kJ2mc8rBH5-IklhfR1XzNotlIQ_mnVMA-pgaXv2r8Ag.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Java_ValidatesRunner_Dataflow_Streaming_PR/src/runners/direct-java/build/libs/beam-runners-direct-java-2.42.0-SNAPSHOT-tests.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/beam-runners-direct-java-2.42.0-SNAPSHOT-tests-mJgi9N-ouXTBSk5gG2ZOKFJQPxmcTuZxaZjX31X-3FA.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Java_ValidatesRunner_Dataflow_Streaming_PR/src/runners/core-construction-java/build/libs/beam-runners-core-construction-java-2.42.0-SNAPSHOT-tests.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/beam-runners-core-construction-java-2.42.0-SNAPSHOT-tests-w3a5L4p93pbuZL6Xyxw7prKMzh_sASz_vaQSOxghUow.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Java_ValidatesRunner_Dataflow_Streaming_PR/src/runners/core-java/build/libs/beam-runners-core-java-2.42.0-SNAPSHOT-tests.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/beam-runners-core-java-2.42.0-SNAPSHOT-tests-QytUEfs90bOSl7vfoK4Py-a25ZIcTrsqIP8-A3LjuAM.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading /tmp/test501142518142348369.zip to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/test-XFj508MimNQxNuW3opOUJVNRrplYeJHYzCWblXqRO4c.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Java_ValidatesRunner_Dataflow_Streaming_PR/src/sdks/java/io/google-cloud-platform/build/libs/beam-sdks-java-io-google-cloud-platform-2.42.0-SNAPSHOT.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/beam-sdks-java-io-google-cloud-platform-2.42.0-SNAPSHOT-BfwX2gQ4oqlfOLhen98_ejBtHufLeb6_e5x3ZW_IbtM.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading /usr/lib/jvm/java-8-openjdk-amd64/jre/lib/ext/nashorn.jar to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/nashorn-B0CAb3QpJET_6VsT3hcC_89VtvhV616H8N2bHAIaqWo.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Java_ValidatesRunner_Dataflow_Streaming_PR/src/runners/google-cloud-dataflow-java/build/libs/beam-runners-google-cloud-dataflow-java-2.42.0-SNAPSHOT.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/beam-runners-google-cloud-dataflow-java-2.42.0-SNAPSHOT-K-isk6lb702Z3sl33tOI_RE6gmGi3AbvV-zvDnPK0eg.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Java_ValidatesRunner_Dataflow_Streaming_PR/src/sdks/java/extensions/google-cloud-platform-core/build/libs/beam-sdks-java-extensions-google-cloud-platform-core-2.42.0-SNAPSHOT.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/beam-sdks-java-extensions-google-cloud-platform-core-2.42.0-SNAPSHOT-s8z2lyKaRLUp7kw2SCber9EjeZYR0T3b958RBX7Pw_I.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Java_ValidatesRunner_Dataflow_Streaming_PR/src/sdks/java/io/kafka/build/libs/beam-sdks-java-io-kafka-2.42.0-SNAPSHOT.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/beam-sdks-java-io-kafka-2.42.0-SNAPSHOT-44Pg7i4i5q5cuyvJUk4nIyHjLV98KSlryt0wWKlSQd0.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/.gradle/caches/7.5.1/workerMain/gradle-worker.jar to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/gradle-worker-n-OgJ2TVjV-CaQNIyKl7wVZ6HzIfepld5lER-Wfir5g.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Java_ValidatesRunner_Dataflow_Streaming_PR/src/runners/google-cloud-dataflow-java/build/libs/beam-runners-google-cloud-dataflow-java-2.42.0-SNAPSHOT-tests.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/beam-runners-google-cloud-dataflow-java-2.42.0-SNAPSHOT-tests-CPG_OJWV837P8CLnip8cEsrNOWcCSIyuQZbdhGwAz78.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Java_ValidatesRunner_Dataflow_Streaming_PR/src/sdks/java/extensions/protobuf/build/libs/beam-sdks-java-extensions-protobuf-2.42.0-SNAPSHOT-tests.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/beam-sdks-java-extensions-protobuf-2.42.0-SNAPSHOT-tests-EYzMvd16uLNE9Tu8Gf_PpUo3AJNFSqDBueNsMzZajZg.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Java_ValidatesRunner_Dataflow_Streaming_PR/src/runners/core-java/build/libs/beam-runners-core-java-2.42.0-SNAPSHOT.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/beam-runners-core-java-2.42.0-SNAPSHOT-PcX-SnONu4MDpnwBPllYSJ0ZEUcGXY7E_UcVoeDfWRo.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Java_ValidatesRunner_Dataflow_Streaming_PR/src/runners/java-fn-execution/build/libs/beam-runners-java-fn-execution-2.42.0-SNAPSHOT.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/beam-runners-java-fn-execution-2.42.0-SNAPSHOT-3zBVHeYTXiBN2XFG8DTig9Erxj6Sd2cZjr-yM4DA2xk.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Java_ValidatesRunner_Dataflow_Streaming_PR/src/sdks/java/io/common/build/libs/beam-sdks-java-io-common-2.42.0-SNAPSHOT-tests.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/beam-sdks-java-io-common-2.42.0-SNAPSHOT-tests-iVWiEEe3AZ4kPqUYLoVxNy8xaru6c5AvPUj595pOD3w.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Java_ValidatesRunner_Dataflow_Streaming_PR/src/sdks/java/fn-execution/build/libs/beam-sdks-java-fn-execution-2.42.0-SNAPSHOT.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/beam-sdks-java-fn-execution-2.42.0-SNAPSHOT-bqJgsZ8fJGETbjlGac-7mHOD82Vkk4E71LUdI4AWfQM.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Java_ValidatesRunner_Dataflow_Streaming_PR/src/sdks/java/extensions/python/build/libs/beam-sdks-java-extensions-python-2.42.0-SNAPSHOT-tests.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/beam-sdks-java-extensions-python-2.42.0-SNAPSHOT-tests-UjjllU6oBaBhVJt12qjo_4B2vAwedT0lSmf_UWc3FaM.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Java_ValidatesRunner_Dataflow_Streaming_PR/src/sdks/java/extensions/arrow/build/libs/beam-sdks-java-extensions-arrow-2.42.0-SNAPSHOT.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/beam-sdks-java-extensions-arrow-2.42.0-SNAPSHOT--6o0gUFJinkN4upVAkTzRdayVoYWlnjhjcsg2E3us1A.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Java_ValidatesRunner_Dataflow_Streaming_PR/src/runners/core-construction-java/build/libs/beam-runners-core-construction-java-2.42.0-SNAPSHOT.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/beam-runners-core-construction-java-2.42.0-SNAPSHOT-uM3J7fAT6i0s9B7V8J5RFmx0QXTHccS8EplfaBpV_R4.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading /usr/lib/jvm/java-8-openjdk-amd64/jre/lib/ext/cldrdata.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/cldrdata-gclqV9lOGqQOKesG-a6TAUTGEYlyIDqpyd4M_k7gtWo.jar
Sep 15, 2022 8:02:14 PM
org.apache.beam.runners.dataflow.util.PackageUtil$PackageAttributes
forFileToStage
INFO: Staging custom dataflow-worker.jar as
beam-runners-google-cloud-dataflow-java-legacy-worker-2.42.0-SNAPSHOT-CEvN-67PayfOH3hIk0ZJBQUeDyxUOFL6ZaiE1kNZTsw.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Java_ValidatesRunner_Dataflow_Streaming_PR/src/sdks/java/extensions/python/build/libs/beam-sdks-java-extensions-python-2.42.0-SNAPSHOT.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/beam-sdks-java-extensions-python-2.42.0-SNAPSHOT-rTMTLtL3-97b602OJNyhNd8PzJGC5NopndsVX_MhA84.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Java_ValidatesRunner_Dataflow_Streaming_PR/src/sdks/java/io/google-cloud-platform/build/libs/beam-sdks-java-io-google-cloud-platform-2.42.0-SNAPSHOT-tests.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/beam-sdks-java-io-google-cloud-platform-2.42.0-SNAPSHOT-tests-CwHMEV-PXKOAwLKzzlsOP6hRMody-GKz-Ot17sa7PCs.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Java_ValidatesRunner_Dataflow_Streaming_PR/src/sdks/java/io/common/build/libs/beam-sdks-java-io-common-2.42.0-SNAPSHOT.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/beam-sdks-java-io-common-2.42.0-SNAPSHOT-W2ix8GuwDuguYWEzYabyzdgajOOMv5mm41Hx0BwORQY.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading /usr/lib/jvm/java-8-openjdk-amd64/jre/lib/ext/dnsns.jar to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/dnsns-byzoQxdXengTvA5IlbH9gSIzfhNQElRYltuMJN0vjcc.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/.gradle/caches/modules-2/files-2.1/com.google.guava/guava-testlib/31.1-jre/64d8b6d2ea60f3870ca01baba3dbe047af18e7f8/guava-testlib-31.1-jre.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/guava-testlib-31.1-jre-qtxxsQ1cOsR03Ra-hM-xjSV-WE0eCln4yrZO9DdiJs4.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Java_ValidatesRunner_Dataflow_Streaming_PR/src/sdks/java/core/build/libs/beam-sdks-java-core-2.42.0-SNAPSHOT-tests.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/beam-sdks-java-core-2.42.0-SNAPSHOT-tests-aRq-cNgHXXFC5_9V1owsnRjT83Y7E1VbLZwuSAlsSjo.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Java_ValidatesRunner_Dataflow_Streaming_PR/src/sdks/java/core/build/libs/beam-sdks-java-core-2.42.0-SNAPSHOT.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/beam-sdks-java-core-2.42.0-SNAPSHOT-47DNYPPEnQG4bvKOjVPhcMfAYsoCx2_Wut6gOGI6ng0.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/.gradle/caches/modules-2/files-2.1/org.testcontainers/postgresql/1.16.3/23f907db8b3a2ffb7e716a4b181bbdbff56db790/postgresql-1.16.3.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/postgresql-1.16.3-8Gxu2ZYC877RMTCsx0ktx9Kp4tCn-LrrHV-CH7dvXCU.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Java_ValidatesRunner_Dataflow_Streaming_PR/src/sdks/java/core/build/libs/beam-sdks-java-core-2.42.0-SNAPSHOT-unshaded.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/beam-sdks-java-core-2.42.0-SNAPSHOT-unshaded-GgPT_oGAHgGlCuuN_W9VqxVyYbXqCa12ixWI5pBYahY.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/.gradle/caches/modules-2/files-2.1/org.testcontainers/mysql/1.16.3/72888945901d50c47680f39a0c25b1c74ea252c2/mysql-1.16.3.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/mysql-1.16.3-Cl3zQcMSEcjFM_206vS6_EsPOZMpTuBTFbFYljY7BkE.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/.gradle/caches/modules-2/files-2.1/com.pholser/junit-quickcheck-generators/1.0/207d65e679fa3ad7a72f6da127e98016541ae0f9/junit-quickcheck-generators-1.0.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/junit-quickcheck-generators-1.0-u86qlcOxtiiYw9NSEq511or0FpMctdvTP8Qybc6huyw.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/.gradle/caches/modules-2/files-2.1/org.powermock/powermock-module-junit4/2.0.9/9f13da80a3d75cc9579b55389e919f661ec42f0/powermock-module-junit4-2.0.9.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/powermock-module-junit4-2.0.9-0OioMYOpqKGP-D4VkqYR-iBsqwg4RmzjZ-PQqFGidOI.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/.gradle/caches/modules-2/files-2.1/com.pholser/junit-quickcheck-core/1.0/8dc0588b5ffbb74d7dc8cbd653d4a90a8b0741eb/junit-quickcheck-core-1.0.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/junit-quickcheck-core-1.0-gOjYYEjAcz4maNmRYLsyCbGn-8VebMHPUe7CESrb8NI.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/.gradle/caches/modules-2/files-2.1/org.powermock/powermock-module-junit4-common/2.0.9/661b819ad3e8b5cab72bea3816ba2602d82d7f00/powermock-module-junit4-common-2.0.9.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/powermock-module-junit4-common-2.0.9-RG-XX_qYlgq26vzLXE0eLLV0f32AzaZTVIoC1YQonoM.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/.gradle/caches/modules-2/files-2.1/org.testcontainers/database-commons/1.16.3/cda7e5a32568b98aff3cfba684e33877e49ac7bb/database-commons-1.16.3.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/database-commons-1.16.3-lruXlPCBLP21-NsQ75Mn17-YBlfcFBeZOzeNze5AjyQ.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/.gradle/caches/modules-2/files-2.1/org.testcontainers/jdbc/1.16.3/3a1226e4758bdf0f4713b1c2f2d794fc792963f8/jdbc-1.16.3.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/jdbc-1.16.3-vEK7543OGRBryFyIgFFebq7nOIFq79Lz48cw__Ge9x4.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/.gradle/caches/modules-2/files-2.1/org.testcontainers/testcontainers/1.16.3/a5d2ad12ebe0d4b66e4fd9f4657571213b5f64c3/testcontainers-1.16.3.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/testcontainers-1.16.3-6q_d_TE0oTZ4mxJSiJfn0kQDsdsg6zZjf888Bg3qcPo.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/.gradle/caches/modules-2/files-2.1/org.hamcrest/hamcrest-core/2.1/70dd49dea4507315b1fa3bc1aa59b1442d55957a/hamcrest-core-2.1.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/hamcrest-core-2.1-4JEJ5UoonYhQa5v-yYfd0Zn0IXyUZBMmaDUbmk8Avuk.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/.gradle/caches/modules-2/files-2.1/junit/junit/4.13.1/cdd00374f1fee76b11e2a9d127405aa3f6be5b6a/junit-4.13.1.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/junit-4.13.1-wwcZ25dNZFJ5P-GRs2OKV3cAVIW64UWSQERTD_pfYSI.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Java_ValidatesRunner_Dataflow_Streaming_PR/src/model/pipeline/build/libs/beam-model-pipeline-2.42.0-SNAPSHOT.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/beam-model-pipeline-2.42.0-SNAPSHOT-8AWBD0xnrHxlP8MwIBcyaqMqs_Tb93IE_pbSIqHp_vQ.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/.gradle/caches/modules-2/files-2.1/org.apache.beam/beam-vendor-guava-26_0-jre/0.1/f309c3047ca99428e567afa42d233fb3e839bde1/beam-vendor-guava-26_0-jre-0.1.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/beam-vendor-guava-26_0-jre-0.1-8quizfXTrmcvJyOXi3zWDFtP5EofgqjksY5sIbsBqws.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/.gradle/caches/modules-2/files-2.1/org.hamcrest/hamcrest/2.1/9420ba32c29217b54eebd26ff7f9234d31c3fbb2/hamcrest-2.1.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/hamcrest-2.1-upOy46ViMiukMvChtTrdzFXLGIJTMZoCDtd_gk5pIFA.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Java_ValidatesRunner_Dataflow_Streaming_PR/src/model/fn-execution/build/libs/beam-model-fn-execution-2.42.0-SNAPSHOT.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/beam-model-fn-execution-2.42.0-SNAPSHOT-AND7iFiwEiv0AGOp7YzujGZZQSJ8RhkocpQwjlAN7gg.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/.gradle/caches/modules-2/files-2.1/org.powermock/powermock-api-mockito2/2.0.9/7e16a11ab06b718121a7537476c55b3c9551ae03/powermock-api-mockito2-2.0.9.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/powermock-api-mockito2-2.0.9-_jth3_RBY3JMYEZgWRmgzLXyS_DhTy87ikSJTvBPvyw.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Java_ValidatesRunner_Dataflow_Streaming_PR/src/model/job-management/build/libs/beam-model-job-management-2.42.0-SNAPSHOT.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/beam-model-job-management-2.42.0-SNAPSHOT-OzvBraZ8Iy-siV4mIYEjGXXuHkD5Fsfw_K5RE1lfi9E.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/.gradle/caches/modules-2/files-2.1/org.apache.beam/beam-vendor-grpc-1_48_1/0.1/2eb9368bb32243cbde59e680f44963f8ce93858f/beam-vendor-grpc-1_48_1-0.1.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/beam-vendor-grpc-1_48_1-0.1-DvxwqkryUDDdKcz-Yhxw7Mc5tz_hetgo9qJvADf1a3M.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/.gradle/caches/modules-2/files-2.1/org.powermock/powermock-api-support/2.0.9/65deba8a4207715b7d8fa6c1b8d8cac06e6ecb00/powermock-api-support-2.0.9.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/powermock-api-support-2.0.9-SeTLkEWqv5uygP0hsTQAgAYoD-OU70KORo5d5aHs7uI.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/.gradle/caches/modules-2/files-2.1/org.mockito/mockito-core/3.7.7/5d43943be9b57c8ff47d2b9640ea0a7fc7211cf2/mockito-core-3.7.7.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/mockito-core-3.7.7-6dG9IxcdjZMXsBOmplY9rqbVMTnC3CGBb2-vJSvEZkE.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/.gradle/caches/modules-2/files-2.1/org.mockito/mockito-inline/4.5.1/3d1dffee9a8a1998ec782383ca2f818848f2d5f1/mockito-inline-4.5.1.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/mockito-inline-4.5.1-7lLhwpmmMhhPuidKk3CZPgkUBCn15RbmxVcP1ldLKX8.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/.gradle/caches/modules-2/files-2.1/org.powermock/powermock-core/2.0.9/50e5d2652fd311ee9c33919dfadd44504a582210/powermock-core-2.0.9.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/powermock-core-2.0.9-5Rg9Hhl7zWfo-G7rWsxMxLSnqpk-naokn42NaXPwbEk.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/.gradle/caches/modules-2/files-2.1/org.powermock/powermock-reflect/2.0.9/4bb9ed43e5221926fb86cae44b445de110a51d05/powermock-reflect-2.0.9.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/powermock-reflect-2.0.9-oTdL02i1K1SyUtUoG5ORNjtYy2Z6Y3UkL9aj9IK8jCM.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/.gradle/caches/modules-2/files-2.1/net.bytebuddy/byte-buddy/1.12.14/3502dd682cac2a7334b159e13d5935e4a34ba192/byte-buddy-1.12.14.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/byte-buddy-1.12.14-ahof_fV49UwDPzsTmzaL4-t1FGuvzVjuJ8KsCQ8ogAE.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/.gradle/caches/modules-2/files-2.1/com.google.cloud.bigdataoss/util/2.2.6/529d3b62efcd018882ae2df1133d444cdc301c49/util-2.2.6.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/util-2.2.6-4Yoch4Aw-nQmP_Kbw1BBsvvW9rHQ5yukvW6y13Ccddk.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/.gradle/caches/modules-2/files-2.1/com.google.cloud.bigdataoss/gcsio/2.2.6/e6fcb9e11dd65099426d8d9b20a5c522913b1750/gcsio-2.2.6.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/gcsio-2.2.6-C92XLy8naI6xX5pl1gDwtVehshDiDVafi_aVGrdNkr4.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/.gradle/caches/modules-2/files-2.1/com.google.apis/google-api-services-clouddebugger/v2-rev20220318-2.0.0/f3da206252a1dcfdefeb384e019896d24dbc67ef/google-api-services-clouddebugger-v2-rev20220318-2.0.0.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/google-api-services-clouddebugger-v2-rev20220318-2.0.0-7LxdZTjs-X9Y2a6zEYP3hhgAWwECC2BXdyJsAI_wQeY.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/.gradle/caches/modules-2/files-2.1/com.google.apis/google-api-services-storage/v1-rev20220705-2.0.0/e1760aa74ae68bbdd0a8918893526b45c4d0aa3a/google-api-services-storage-v1-rev20220705-2.0.0.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/google-api-services-storage-v1-rev20220705-2.0.0-xgJ9bFgIlAJiDOM4NRyi79QU-BMAeES8JSzrX0d4n08.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/.gradle/caches/modules-2/files-2.1/com.google.apis/google-api-services-dataflow/v1b3-rev20220812-2.0.0/f290aee8c0a4740f900fe649b5ce7dfb07878a35/google-api-services-dataflow-v1b3-rev20220812-2.0.0.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/google-api-services-dataflow-v1b3-rev20220812-2.0.0-99sK6Aq2zDThzwlP7B7XmLtrZ7u-rVdLtYtTNqJklho.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/.gradle/caches/modules-2/files-2.1/com.google.apis/google-api-services-cloudresourcemanager/v1-rev20220828-2.0.0/56197d5f5155b3da5577d324b7a83ef5de174d35/google-api-services-cloudresourcemanager-v1-rev20220828-2.0.0.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/google-api-services-cloudresourcemanager-v1-rev20220828-2.0.0-bpDc4V-1NLfPOFs_JhDoQOnhuXlY3K3na2G_qY4Z7UQ.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/.gradle/caches/modules-2/files-2.1/com.google.cloud/google-cloud-bigquery/2.15.0/38de127d620f641fb57c70e2554806ca65d5186c/google-cloud-bigquery-2.15.0.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/google-cloud-bigquery-2.15.0-POkkqqTS21bChswtRygO3g-FfNjofDKMwUzvX7keP-w.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/.gradle/caches/modules-2/files-2.1/com.google.apis/google-api-services-bigquery/v2-rev20220827-2.0.0/31ee3860a65f4c13e21bebe837490cf31b7bdd85/google-api-services-bigquery-v2-rev20220827-2.0.0.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/google-api-services-bigquery-v2-rev20220827-2.0.0-BK2Feh8J30vLotPQc5P4lQMmRLw7XzQRNk_NUNXNqrQ.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/.gradle/caches/modules-2/files-2.1/com.google.apis/google-api-services-pubsub/v1-rev20220829-2.0.0/7dba444fcd7ee8f50ae18dc6657b10140b8ff3ea/google-api-services-pubsub-v1-rev20220829-2.0.0.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/google-api-services-pubsub-v1-rev20220829-2.0.0-V8Vgry3X8A7tXqxPEwZN1UkxIbwBxlZiKvzYzS-fCK4.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/.gradle/caches/modules-2/files-2.1/com.google.cloud.datastore/datastore-v1-proto-client/2.9.0/de80b9f873e0c6f4e9353ed899e5a40037e57017/datastore-v1-proto-client-2.9.0.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/datastore-v1-proto-client-2.9.0-TcBqF2mH0xi69IU9w5hBiURCa6BbFFv5LN-CIrclzco.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/.gradle/caches/modules-2/files-2.1/com.google.apis/google-api-services-healthcare/v1-rev20220818-2.0.0/9da6581f04a0aac53b04fb9a761ae4835b5ff429/google-api-services-healthcare-v1-rev20220818-2.0.0.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/google-api-services-healthcare-v1-rev20220818-2.0.0-GTEPAeaqYcWT0rvGJLKzo3GLlt1VIkKsvv2y2QljVm4.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/.gradle/caches/modules-2/files-2.1/com.google.api-client/google-api-client-jackson2/2.0.0/ca6231dbccd129d8799d27c6f54a3752305e6d44/google-api-client-jackson2-2.0.0.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/google-api-client-jackson2-2.0.0-eG8HNbasYP7L7N9d3RM92Txx_mP4tPsgaNDzVn0BkpA.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/.gradle/caches/modules-2/files-2.1/com.google.apis/google-api-services-iamcredentials/v1-rev20210326-1.32.1/6fc1114b8f34438789915acbea5c638b5f34b4e/google-api-services-iamcredentials-v1-rev20210326-1.32.1.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/google-api-services-iamcredentials-v1-rev20210326-1.32.1-rzLlTs22sMZOFz3yEOfAB70ZZw2Gl99hr42n_k-f8-M.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/.gradle/caches/modules-2/files-2.1/com.google.api-client/google-api-client/2.0.0/c3daf5048a26a73182b5e6c81ad141fb859f0787/google-api-client-2.0.0.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/google-api-client-2.0.0--vAvQHDE9ZHn0aWRFh2jvuLQjiu5xFeGRVWej1XPa3s.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/.gradle/caches/modules-2/files-2.1/com.google.cloud.bigtable/bigtable-client-core/1.26.3/19d34c440b8e8f0d6b722cf6c475f82c13d484f8/bigtable-client-core-1.26.3.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/bigtable-client-core-1.26.3-GEzkVxiwF7w6wu62mI8m3J8ms6FoRGBCWc1CCh-ad3U.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/.gradle/caches/modules-2/files-2.1/com.google.cloud/google-cloud-pubsublite/1.6.3/9af69abd71ede9ec4b57a69bdfc56f38b61f20f9/google-cloud-pubsublite-1.6.3.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/google-cloud-pubsublite-1.6.3-cODCLCxTA0K_iNCO8XUL1lnaIiICXXoONL5e78kSecE.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/.gradle/caches/modules-2/files-2.1/com.google.api.grpc/grpc-google-cloud-pubsublite-v1/1.5.0/9425fa1c8d6d03b924b84e3b7b537b4bd5ef5a2f/grpc-google-cloud-pubsublite-v1-1.5.0.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/grpc-google-cloud-pubsublite-v1-1.5.0-vGcvwWnN6j4Eibkw5yzC2gyPo3PD5k8nPUrjIeD8wBM.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/.gradle/caches/modules-2/files-2.1/com.google.api.grpc/proto-google-cloud-pubsublite-v1/1.6.3/9c6f8a4181507cdb7f31fdac992c3311af70443f/proto-google-cloud-pubsublite-v1-1.6.3.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/proto-google-cloud-pubsublite-v1-1.6.3-pvgyqWwt3mr8pcJy8oQf4-rF9QlxVWjtQDUXV5ZJpno.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/.gradle/caches/modules-2/files-2.1/com.google.cloud/google-cloud-spanner/6.29.0/1949cef3afae5f67e8a66f86512d13b82056c9ce/google-cloud-spanner-6.29.0.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/google-cloud-spanner-6.29.0-JkVlovRFHWNHM1SygzLSS_RWhzO87_5fnG8Y6_QaBP8.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/.gradle/caches/modules-2/files-2.1/com.google.cloud/google-cloud-spanner/6.29.0/d64eb4938901fb73b99b78ea48131ff2d590c985/google-cloud-spanner-6.29.0-tests.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/google-cloud-spanner-6.29.0-tests-unyY83ll3lag_v3msZnO1AlKXxs1BvFvsV-TiEtlcpY.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/.gradle/caches/modules-2/files-2.1/com.google.cloud/google-cloud-core-http/2.8.6/51b31548319cbcae62cd24b05db9709e67e87a7c/google-cloud-core-http-2.8.6.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/google-cloud-core-http-2.8.6-_CeP1_W4qYIclgUGt3LYW0JWpTKTwIm4sPBMMT7Bck4.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/.gradle/caches/modules-2/files-2.1/com.google.cloud/google-cloud-bigquerystorage/2.20.1/c9ce129d82580e24790a655db286f4e9fb06da4f/google-cloud-bigquerystorage-2.20.1.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/google-cloud-bigquerystorage-2.20.1-HG4Nhtq1FLE37K_XDDE71xRqDL_9vaKW7AL5KDxUvvc.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Java_ValidatesRunner_Dataflow_Streaming_PR/src/sdks/java/testing/test-utils/build/libs/beam-sdks-java-test-utils-2.42.0-SNAPSHOT.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/beam-sdks-java-test-utils-2.42.0-SNAPSHOT-FnT_pdpecQ8neZWBWYfJKh35DgkkEuWfhpgvJw2PLXY.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/.gradle/caches/modules-2/files-2.1/com.google.cloud/google-cloud-firestore/3.4.2/a949ed407182d7a189cf8db3806889d653d8cb53/google-cloud-firestore-3.4.2.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/google-cloud-firestore-3.4.2-JZN1EknH3mP3myOb1SnbYCPZBWSU6KCZ9vki7eytpgA.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/.gradle/caches/modules-2/files-2.1/com.google.cloud/google-cloud-bigtable/2.11.0/da866d913b293b6b66c0d72ba0bde1410b026a05/google-cloud-bigtable-2.11.0.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/google-cloud-bigtable-2.11.0-vU0YG54pp-OK49mUHt4otrctLAEbDwliSlZ8yOQhkZ0.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/.gradle/caches/modules-2/files-2.1/com.google.cloud/google-cloud-core-grpc/2.8.6/e2f70a64c1fb964a1310a7f833b4ed69cb81b57e/google-cloud-core-grpc-2.8.6.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/google-cloud-core-grpc-2.8.6-4xrTpAZETGx1wGUpto7x5jv4bjrrQrDApspumVul-Xk.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/.gradle/caches/modules-2/files-2.1/com.google.cloud/google-cloud-pubsub/1.120.13/e6c5f31d463560674f86b8743c85b3760c66e5a1/google-cloud-pubsub-1.120.13.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/google-cloud-pubsub-1.120.13-l0C_p2qlymZpzZzAPe61JuWruxP9SIWAE3y5s7gelBk.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/.gradle/caches/modules-2/files-2.1/com.google.cloud/google-cloud-monitoring/3.4.1/6fcafcbb723c8fc0c7f3c69e4ec677680b3871fd/google-cloud-monitoring-3.4.1.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/google-cloud-monitoring-3.4.1-rCueLFPk2EJr7Do4ntR3_xhEf8xoI6_P7EppS2dZTTY.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/.gradle/caches/modules-2/files-2.1/io.opencensus/opencensus-exporter-stats-stackdriver/0.31.0/4b7edb65452da93fc9b576c8f0a612f1f6c053ed/opencensus-exporter-stats-stackdriver-0.31.0.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/opencensus-exporter-stats-stackdriver-0.31.0-PxtDHFYMsu_ZpKNp8bPzWxbj9e1leJhDRGs1w2GUnSI.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/.gradle/caches/modules-2/files-2.1/com.google.api/gax-grpc/2.18.7/99757e36ea5a7053631d7a1c353859f5c4f8b7a9/gax-grpc-2.18.7.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/gax-grpc-2.18.7-Di9cxRgLv76QimGTyJOo1oBZlWxPnSz2idEpLUQlaNY.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/.gradle/caches/modules-2/files-2.1/com.google.api/gax-grpc/2.18.7/a262f2b5c4e3621cbb1ecf44894b818ca41c3110/gax-grpc-2.18.7-testlib.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/gax-grpc-2.18.7-testlib-nm9KU0g_jE2T5WNOmikj_Bu_GkrTrXZbz8WE7yzPCGc.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/.gradle/caches/modules-2/files-2.1/com.google.api/gax-httpjson/0.103.7/47998a83b366c0dd7234fa512b8c468a88c90be2/gax-httpjson-0.103.7.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/gax-httpjson-0.103.7-AiM24m5xoZjrcqLbV_FM_4qgp226BXc_ZG8DZ2f8GMc.jar
Sep 15, 2022 8:02:14 PM org.apache.beam.runners.dataflow.util.PackageUtil
tryStagePackage
INFO: Uploading
/home/jenkins/.gradle/caches/modules-2/files-2.1/com.google.cloud/google-cloud-core/2.8.6/72b5a9d56d1afc3d75df5e7a0dfc201eda15d2ce/google-cloud-core-2.8.6.jar
to
gs://temp-storage-for-validates-runner-tests/pardotest0multipleinputsandoutputtests0testsamesideinputreadtwice-jenkins-0915200211-3b1f60b3/output/results/staging/google-cloud-core-2.8.6-UpDSSeIadJkGdv8FLXFzczvoKPCnUAS6fCgpXje6RAk.jar
Sep 15, 202
...[truncated 2434879 chars]...
tonIterables) as step s41
Sep 15, 2022 9:24:27 PM
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding
PAssert$49/GroupGlobally/Create.Values/Read(CreateSource)/Read(CreateSource)/Read(BoundedToUnboundedSourceAdapter)/DataflowRunner.StreamingUnboundedRead.ReadWithIds
as step s42
Sep 15, 2022 9:24:27 PM
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding
PAssert$49/GroupGlobally/Create.Values/Read(CreateSource)/Read(CreateSource)/Read(BoundedToUnboundedSourceAdapter)/StripIds
as step s43
Sep 15, 2022 9:24:27 PM
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding PAssert$49/GroupGlobally/Flatten.PCollections as step s44
Sep 15, 2022 9:24:27 PM
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding PAssert$49/GroupGlobally/Window.Into()/Flatten.PCollections as
step s45
Sep 15, 2022 9:24:27 PM
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding PAssert$49/GroupGlobally/WithKeys/AddKeys/Map as step s46
Sep 15, 2022 9:24:27 PM
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding PAssert$49/GroupGlobally/GroupByKey as step s47
Sep 15, 2022 9:24:27 PM
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding PAssert$49/GroupGlobally/Values/Values/Map as step s48
Sep 15, 2022 9:24:27 PM
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding PAssert$49/GroupGlobally/ParDo(Concat) as step s49
Sep 15, 2022 9:24:27 PM
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding PAssert$49/GetPane/Map as step s50
Sep 15, 2022 9:24:27 PM
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding PAssert$49/RunChecks as step s51
Sep 15, 2022 9:24:27 PM
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding PAssert$49/VerifyAssertions/ParDo(DefaultConclude) as step s52
Sep 15, 2022 9:24:27 PM org.apache.beam.runners.dataflow.DataflowRunner run
INFO: Dataflow SDK version: 2.42.0-SNAPSHOT
Sep 15, 2022 9:24:28 PM org.apache.beam.runners.dataflow.DataflowRunner run
INFO: To access the Dataflow monitoring console, please navigate to
https://console.cloud.google.com/dataflow/jobs/us-central1/2022-09-15_14_24_27-1459555830228686178?project=apache-beam-testing
Sep 15, 2022 9:24:28 PM org.apache.beam.runners.dataflow.DataflowRunner run
INFO: Submitted job: 2022-09-15_14_24_27-1459555830228686178
Sep 15, 2022 9:24:28 PM org.apache.beam.runners.dataflow.DataflowRunner run
INFO: To cancel the job using the 'gcloud' tool, run:
> gcloud dataflow jobs --project=apache-beam-testing cancel
--region=us-central1 2022-09-15_14_24_27-1459555830228686178
Sep 15, 2022 9:24:28 PM org.apache.beam.runners.dataflow.TestDataflowRunner
run
INFO: Running Dataflow job 2022-09-15_14_24_27-1459555830228686178 with 1
expected assertions.
Sep 15, 2022 9:24:34 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
WARNING: 2022-09-15T21:24:31.408Z: The workflow name is not a valid Cloud
Label. Labels applied to Cloud resources (such as GCE Instances) for monitoring
will be labeled with this modified job name:
pardotest0multipleinputsandoutputtests0testpardowithsidein-l0un. For the best
monitoring experience, please name your job with a valid Cloud Label. For
details, see:
https://cloud.google.com/compute/docs/labeling-resources#restrictions
Sep 15, 2022 9:24:42 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:24:40.625Z: Worker configuration: e2-standard-4 in
us-central1-b.
Sep 15, 2022 9:24:42 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:24:41.671Z: Expanding CoGroupByKey operations into
optimizable parts.
Sep 15, 2022 9:24:42 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:24:42.020Z: Expanding SplittableProcessKeyed operations
into optimizable parts.
Sep 15, 2022 9:24:42 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:24:42.054Z: Expanding GroupByKey operations into
streaming Read/Write steps
Sep 15, 2022 9:24:42 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:24:42.295Z: Lifting ValueCombiningMappingFns into
MergeBucketsMappingFns
Sep 15, 2022 9:24:42 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:24:42.672Z: Fusing adjacent ParDo, Read, Write, and
Flatten operations
Sep 15, 2022 9:24:42 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:24:42.702Z: Elided trivial flatten
Sep 15, 2022 9:24:42 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:24:42.727Z: Unzipping flatten s44 for input
s41.org.apache.beam.sdk.values.PCollection.<init>:405#b9cbe708fa1314da
Sep 15, 2022 9:24:42 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:24:42.759Z: Fusing unzipped copy of
PAssert$49/GroupGlobally/WithKeys/AddKeys/Map, through flatten
PAssert$49/GroupGlobally/Flatten.PCollections, into producer
PAssert$49/GroupGlobally/ParDo(ToSingletonIterables)
Sep 15, 2022 9:24:42 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:24:42.802Z: Unzipping flatten s44-u93 for input
s46.org.apache.beam.sdk.values.PCollection.<init>:405#26dc76f1303bdd9f-c91
Sep 15, 2022 9:24:42 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:24:42.835Z: Fusing unzipped copy of
PAssert$49/GroupGlobally/GroupByKey/WriteStream, through flatten
PAssert$49/GroupGlobally/Flatten.PCollections/Unzipped-1, into producer
PAssert$49/GroupGlobally/WithKeys/AddKeys/Map
Sep 15, 2022 9:24:45 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:24:42.869Z: Fusing consumer
PAssert$49/GroupGlobally/WithKeys/AddKeys/Map into
PAssert$49/GroupGlobally/Create.Values/Read(CreateSource)/Read(CreateSource)/Read(BoundedToUnboundedSourceAdapter)/StripIds
Sep 15, 2022 9:24:45 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:24:42.902Z: Fusing consumer
PAssert$49/GroupGlobally/GroupByKey/WriteStream into
PAssert$49/GroupGlobally/WithKeys/AddKeys/Map
Sep 15, 2022 9:24:45 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:24:42.937Z: Fusing consumer
CreateSideInputUnread/Read(CreateSource)/Read(CreateSource)/Read(BoundedToUnboundedSourceAdapter)/StripIds
into
CreateSideInputUnread/Read(CreateSource)/Read(CreateSource)/Read(BoundedToUnboundedSourceAdapter)/DataflowRunner.StreamingUnboundedRead.ReadWithIds
Sep 15, 2022 9:24:45 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:24:42.971Z: Fusing consumer
ViewSideInputUnread/Combine.GloballyAsSingletonView/CombineValues/WithKeys/AddKeys/Map
into
CreateSideInputUnread/Read(CreateSource)/Read(CreateSource)/Read(BoundedToUnboundedSourceAdapter)/StripIds
Sep 15, 2022 9:24:45 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:24:42.994Z: Fusing consumer
ViewSideInputUnread/Combine.GloballyAsSingletonView/CombineValues/Combine.perKey(Singleton)/GroupByKey+ViewSideInputUnread/Combine.GloballyAsSingletonView/CombineValues/Combine.perKey(Singleton)/Combine.GroupedValues/Partial
into
ViewSideInputUnread/Combine.GloballyAsSingletonView/CombineValues/WithKeys/AddKeys/Map
Sep 15, 2022 9:24:45 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:24:43.017Z: Fusing consumer
ViewSideInputUnread/Combine.GloballyAsSingletonView/CombineValues/Combine.perKey(Singleton)/GroupByKey/WriteStream
into
ViewSideInputUnread/Combine.GloballyAsSingletonView/CombineValues/Combine.perKey(Singleton)/GroupByKey+ViewSideInputUnread/Combine.GloballyAsSingletonView/CombineValues/Combine.perKey(Singleton)/Combine.GroupedValues/Partial
Sep 15, 2022 9:24:45 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:24:43.047Z: Fusing consumer
ViewSideInputUnread/Combine.GloballyAsSingletonView/CombineValues/Combine.perKey(Singleton)/Combine.GroupedValues
into
ViewSideInputUnread/Combine.GloballyAsSingletonView/CombineValues/Combine.perKey(Singleton)/GroupByKey/ReadStream
Sep 15, 2022 9:24:45 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:24:43.083Z: Fusing consumer
ViewSideInputUnread/Combine.GloballyAsSingletonView/CombineValues/Combine.perKey(Singleton)/Combine.GroupedValues/Extract
into
ViewSideInputUnread/Combine.GloballyAsSingletonView/CombineValues/Combine.perKey(Singleton)/Combine.GroupedValues
Sep 15, 2022 9:24:45 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:24:43.121Z: Fusing consumer
ViewSideInputUnread/Combine.GloballyAsSingletonView/CombineValues/Values/Values/Map
into
ViewSideInputUnread/Combine.GloballyAsSingletonView/CombineValues/Combine.perKey(Singleton)/Combine.GroupedValues/Extract
Sep 15, 2022 9:24:45 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:24:43.153Z: Fusing consumer
ViewSideInputUnread/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/WithKeys/AddKeys/Map
into
ViewSideInputUnread/Combine.GloballyAsSingletonView/CombineValues/Values/Values/Map
Sep 15, 2022 9:24:45 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:24:43.187Z: Fusing consumer
ViewSideInputUnread/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/GroupByKey+ViewSideInputUnread/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/Combine.GroupedValues/Partial
into
ViewSideInputUnread/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/WithKeys/AddKeys/Map
Sep 15, 2022 9:24:45 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:24:43.219Z: Fusing consumer
ViewSideInputUnread/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/GroupByKey/WriteStream
into
ViewSideInputUnread/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/GroupByKey+ViewSideInputUnread/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/Combine.GroupedValues/Partial
Sep 15, 2022 9:24:45 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:24:43.252Z: Fusing consumer
CreateSideInput2/Read(CreateSource)/Read(CreateSource)/Read(BoundedToUnboundedSourceAdapter)/StripIds
into
CreateSideInput2/Read(CreateSource)/Read(CreateSource)/Read(BoundedToUnboundedSourceAdapter)/DataflowRunner.StreamingUnboundedRead.ReadWithIds
Sep 15, 2022 9:24:45 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:24:43.285Z: Fusing consumer
ViewSideInput2/Combine.GloballyAsSingletonView/CombineValues/WithKeys/AddKeys/Map
into
CreateSideInput2/Read(CreateSource)/Read(CreateSource)/Read(BoundedToUnboundedSourceAdapter)/StripIds
Sep 15, 2022 9:24:45 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:24:43.318Z: Fusing consumer
ViewSideInput2/Combine.GloballyAsSingletonView/CombineValues/Combine.perKey(Singleton)/GroupByKey+ViewSideInput2/Combine.GloballyAsSingletonView/CombineValues/Combine.perKey(Singleton)/Combine.GroupedValues/Partial
into
ViewSideInput2/Combine.GloballyAsSingletonView/CombineValues/WithKeys/AddKeys/Map
Sep 15, 2022 9:24:45 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:24:43.382Z: Fusing consumer
ViewSideInput2/Combine.GloballyAsSingletonView/CombineValues/Combine.perKey(Singleton)/GroupByKey/WriteStream
into
ViewSideInput2/Combine.GloballyAsSingletonView/CombineValues/Combine.perKey(Singleton)/GroupByKey+ViewSideInput2/Combine.GloballyAsSingletonView/CombineValues/Combine.perKey(Singleton)/Combine.GroupedValues/Partial
Sep 15, 2022 9:24:45 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:24:43.405Z: Fusing consumer
ViewSideInput2/Combine.GloballyAsSingletonView/CombineValues/Combine.perKey(Singleton)/Combine.GroupedValues
into
ViewSideInput2/Combine.GloballyAsSingletonView/CombineValues/Combine.perKey(Singleton)/GroupByKey/ReadStream
Sep 15, 2022 9:24:45 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:24:43.443Z: Fusing consumer
ViewSideInput2/Combine.GloballyAsSingletonView/CombineValues/Combine.perKey(Singleton)/Combine.GroupedValues/Extract
into
ViewSideInput2/Combine.GloballyAsSingletonView/CombineValues/Combine.perKey(Singleton)/Combine.GroupedValues
Sep 15, 2022 9:24:45 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:24:43.465Z: Fusing consumer
ViewSideInput2/Combine.GloballyAsSingletonView/CombineValues/Values/Values/Map
into
ViewSideInput2/Combine.GloballyAsSingletonView/CombineValues/Combine.perKey(Singleton)/Combine.GroupedValues/Extract
Sep 15, 2022 9:24:45 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:24:43.497Z: Fusing consumer
ViewSideInput2/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/WithKeys/AddKeys/Map
into
ViewSideInput2/Combine.GloballyAsSingletonView/CombineValues/Values/Values/Map
Sep 15, 2022 9:24:45 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:24:43.534Z: Fusing consumer
ViewSideInput2/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/GroupByKey+ViewSideInput2/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/Combine.GroupedValues/Partial
into
ViewSideInput2/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/WithKeys/AddKeys/Map
Sep 15, 2022 9:24:45 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:24:43.566Z: Fusing consumer
ViewSideInput2/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/GroupByKey/WriteStream
into
ViewSideInput2/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/GroupByKey+ViewSideInput2/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/Combine.GroupedValues/Partial
Sep 15, 2022 9:24:45 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:24:43.634Z: Fusing consumer
CreateSideInput1/Read(CreateSource)/Read(CreateSource)/Read(BoundedToUnboundedSourceAdapter)/StripIds
into
CreateSideInput1/Read(CreateSource)/Read(CreateSource)/Read(BoundedToUnboundedSourceAdapter)/DataflowRunner.StreamingUnboundedRead.ReadWithIds
Sep 15, 2022 9:24:45 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:24:43.670Z: Fusing consumer
ViewSideInput1/Combine.GloballyAsSingletonView/CombineValues/WithKeys/AddKeys/Map
into
CreateSideInput1/Read(CreateSource)/Read(CreateSource)/Read(BoundedToUnboundedSourceAdapter)/StripIds
Sep 15, 2022 9:24:45 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:24:43.704Z: Fusing consumer
ViewSideInput1/Combine.GloballyAsSingletonView/CombineValues/Combine.perKey(Singleton)/GroupByKey+ViewSideInput1/Combine.GloballyAsSingletonView/CombineValues/Combine.perKey(Singleton)/Combine.GroupedValues/Partial
into
ViewSideInput1/Combine.GloballyAsSingletonView/CombineValues/WithKeys/AddKeys/Map
Sep 15, 2022 9:24:45 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:24:43.730Z: Fusing consumer
ViewSideInput1/Combine.GloballyAsSingletonView/CombineValues/Combine.perKey(Singleton)/GroupByKey/WriteStream
into
ViewSideInput1/Combine.GloballyAsSingletonView/CombineValues/Combine.perKey(Singleton)/GroupByKey+ViewSideInput1/Combine.GloballyAsSingletonView/CombineValues/Combine.perKey(Singleton)/Combine.GroupedValues/Partial
Sep 15, 2022 9:24:45 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:24:43.760Z: Fusing consumer
ViewSideInput1/Combine.GloballyAsSingletonView/CombineValues/Combine.perKey(Singleton)/Combine.GroupedValues
into
ViewSideInput1/Combine.GloballyAsSingletonView/CombineValues/Combine.perKey(Singleton)/GroupByKey/ReadStream
Sep 15, 2022 9:24:45 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:24:43.793Z: Fusing consumer
ViewSideInput1/Combine.GloballyAsSingletonView/CombineValues/Combine.perKey(Singleton)/Combine.GroupedValues/Extract
into
ViewSideInput1/Combine.GloballyAsSingletonView/CombineValues/Combine.perKey(Singleton)/Combine.GroupedValues
Sep 15, 2022 9:24:45 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:24:43.827Z: Fusing consumer
ViewSideInput1/Combine.GloballyAsSingletonView/CombineValues/Values/Values/Map
into
ViewSideInput1/Combine.GloballyAsSingletonView/CombineValues/Combine.perKey(Singleton)/Combine.GroupedValues/Extract
Sep 15, 2022 9:24:45 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:24:43.849Z: Fusing consumer
ViewSideInput1/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/WithKeys/AddKeys/Map
into
ViewSideInput1/Combine.GloballyAsSingletonView/CombineValues/Values/Values/Map
Sep 15, 2022 9:24:45 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:24:43.895Z: Fusing consumer
ViewSideInput1/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/GroupByKey+ViewSideInput1/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/Combine.GroupedValues/Partial
into
ViewSideInput1/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/WithKeys/AddKeys/Map
Sep 15, 2022 9:24:45 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:24:43.928Z: Fusing consumer
ViewSideInput1/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/GroupByKey/WriteStream
into
ViewSideInput1/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/GroupByKey+ViewSideInput1/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/Combine.GroupedValues/Partial
Sep 15, 2022 9:24:45 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:24:43.962Z: Fusing consumer
ViewSideInput1/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/Combine.GroupedValues
into
ViewSideInput1/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/GroupByKey/ReadStream
Sep 15, 2022 9:24:45 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:24:43.989Z: Fusing consumer
ViewSideInput1/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/Combine.GroupedValues/Extract
into
ViewSideInput1/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/Combine.GroupedValues
Sep 15, 2022 9:24:45 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:24:44.014Z: Fusing consumer
ViewSideInput1/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/Values/Values/Map
into
ViewSideInput1/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/Combine.GroupedValues/Extract
Sep 15, 2022 9:24:45 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:24:44.050Z: Fusing consumer
ViewSideInput1/Combine.GloballyAsSingletonView/CreatePCollectionView/ParDo(StreamingPCollectionViewWriter)
into
ViewSideInput1/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/Values/Values/Map
Sep 15, 2022 9:24:45 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:24:44.076Z: Fusing consumer
ViewSideInputUnread/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/Combine.GroupedValues
into
ViewSideInputUnread/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/GroupByKey/ReadStream
Sep 15, 2022 9:24:45 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:24:44.121Z: Fusing consumer
ViewSideInputUnread/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/Combine.GroupedValues/Extract
into
ViewSideInputUnread/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/Combine.GroupedValues
Sep 15, 2022 9:24:45 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:24:44.156Z: Fusing consumer
ViewSideInputUnread/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/Values/Values/Map
into
ViewSideInputUnread/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/Combine.GroupedValues/Extract
Sep 15, 2022 9:24:45 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:24:44.189Z: Fusing consumer
ViewSideInputUnread/Combine.GloballyAsSingletonView/CreatePCollectionView/ParDo(StreamingPCollectionViewWriter)
into
ViewSideInputUnread/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/Values/Values/Map
Sep 15, 2022 9:24:45 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:24:44.223Z: Fusing consumer
ViewSideInput2/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/Combine.GroupedValues
into
ViewSideInput2/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/GroupByKey/ReadStream
Sep 15, 2022 9:24:45 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:24:44.256Z: Fusing consumer
ViewSideInput2/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/Combine.GroupedValues/Extract
into
ViewSideInput2/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/Combine.GroupedValues
Sep 15, 2022 9:24:45 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:24:44.290Z: Fusing consumer
ViewSideInput2/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/Values/Values/Map
into
ViewSideInput2/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/Combine.GroupedValues/Extract
Sep 15, 2022 9:24:45 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:24:44.324Z: Fusing consumer
ViewSideInput2/Combine.GloballyAsSingletonView/CreatePCollectionView/ParDo(StreamingPCollectionViewWriter)
into
ViewSideInput2/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/Values/Values/Map
Sep 15, 2022 9:24:45 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:24:44.397Z: Fusing consumer
Create.Values/Read(CreateSource)/Read(CreateSource)/Read(BoundedToUnboundedSourceAdapter)/StripIds
into
Create.Values/Read(CreateSource)/Read(CreateSource)/Read(BoundedToUnboundedSourceAdapter)/DataflowRunner.StreamingUnboundedRead.ReadWithIds
Sep 15, 2022 9:24:45 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:24:44.428Z: Fusing consumer ParDo(Test) into
Create.Values/Read(CreateSource)/Read(CreateSource)/Read(BoundedToUnboundedSourceAdapter)/StripIds
Sep 15, 2022 9:24:45 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:24:44.463Z: Fusing consumer
PAssert$49/GroupGlobally/Reify.Window/ParDo(Anonymous) into ParDo(Test)
Sep 15, 2022 9:24:45 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:24:44.496Z: Fusing consumer
PAssert$49/GroupGlobally/ParDo(ToSingletonIterables) into
PAssert$49/GroupGlobally/Reify.Window/ParDo(Anonymous)
Sep 15, 2022 9:24:45 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:24:44.517Z: Fusing consumer
PAssert$49/GroupGlobally/Create.Values/Read(CreateSource)/Read(CreateSource)/Read(BoundedToUnboundedSourceAdapter)/StripIds
into
PAssert$49/GroupGlobally/Create.Values/Read(CreateSource)/Read(CreateSource)/Read(BoundedToUnboundedSourceAdapter)/DataflowRunner.StreamingUnboundedRead.ReadWithIds
Sep 15, 2022 9:24:45 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:24:44.544Z: Fusing consumer
PAssert$49/GroupGlobally/GroupByKey/MergeBuckets into
PAssert$49/GroupGlobally/GroupByKey/ReadStream
Sep 15, 2022 9:24:45 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:24:44.627Z: Fusing consumer
PAssert$49/GroupGlobally/Values/Values/Map into
PAssert$49/GroupGlobally/GroupByKey/MergeBuckets
Sep 15, 2022 9:24:45 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:24:44.663Z: Fusing consumer
PAssert$49/GroupGlobally/ParDo(Concat) into
PAssert$49/GroupGlobally/Values/Values/Map
Sep 15, 2022 9:24:45 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:24:44.685Z: Fusing consumer PAssert$49/GetPane/Map into
PAssert$49/GroupGlobally/ParDo(Concat)
Sep 15, 2022 9:24:45 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:24:44.716Z: Fusing consumer PAssert$49/RunChecks into
PAssert$49/GetPane/Map
Sep 15, 2022 9:24:45 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:24:44.746Z: Fusing consumer
PAssert$49/VerifyAssertions/ParDo(DefaultConclude) into PAssert$49/RunChecks
Sep 15, 2022 9:24:45 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:24:45.245Z: Executing operation
ViewSideInputUnread/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/GroupByKey/ReadStream+ViewSideInputUnread/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/Combine.GroupedValues+ViewSideInputUnread/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/Combine.GroupedValues/Extract+ViewSideInputUnread/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/Values/Values/Map+ViewSideInputUnread/Combine.GloballyAsSingletonView/CreatePCollectionView/ParDo(StreamingPCollectionViewWriter)
Sep 15, 2022 9:24:45 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:24:45.291Z: Executing operation
ViewSideInput1/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/GroupByKey/ReadStream+ViewSideInput1/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/Combine.GroupedValues+ViewSideInput1/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/Combine.GroupedValues/Extract+ViewSideInput1/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/Values/Values/Map+ViewSideInput1/Combine.GloballyAsSingletonView/CreatePCollectionView/ParDo(StreamingPCollectionViewWriter)
Sep 15, 2022 9:24:45 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:24:45.327Z: Executing operation
ViewSideInput1/Combine.GloballyAsSingletonView/CombineValues/Combine.perKey(Singleton)/GroupByKey/ReadStream+ViewSideInput1/Combine.GloballyAsSingletonView/CombineValues/Combine.perKey(Singleton)/Combine.GroupedValues+ViewSideInput1/Combine.GloballyAsSingletonView/CombineValues/Combine.perKey(Singleton)/Combine.GroupedValues/Extract+ViewSideInput1/Combine.GloballyAsSingletonView/CombineValues/Values/Values/Map+ViewSideInput1/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/WithKeys/AddKeys/Map+ViewSideInput1/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/GroupByKey+ViewSideInput1/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/Combine.GroupedValues/Partial+ViewSideInput1/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(
Concatenate)/GroupByKey/WriteStream
Sep 15, 2022 9:24:45 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:24:45.327Z: Starting 1 workers in us-central1-b...
Sep 15, 2022 9:24:45 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:24:45.398Z: Executing operation
CreateSideInput1/Read(CreateSource)/Read(CreateSource)/Read(BoundedToUnboundedSourceAdapter)/DataflowRunner.StreamingUnboundedRead.ReadWithIds+CreateSideInput1/Read(CreateSource)/Read(CreateSource)/Read(BoundedToUnboundedSourceAdapter)/StripIds+ViewSideInput1/Combine.GloballyAsSingletonView/CombineValues/WithKeys/AddKeys/Map+ViewSideInput1/Combine.GloballyAsSingletonView/CombineValues/Combine.perKey(Singleton)/GroupByKey+ViewSideInput1/Combine.GloballyAsSingletonView/CombineValues/Combine.perKey(Singleton)/Combine.GroupedValues/Partial+ViewSideInput1/Combine.GloballyAsSingletonView/CombineValues/Combine.perKey(Singleton)/GroupByKey/WriteStream
Sep 15, 2022 9:24:45 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:24:45.435Z: Executing operation
ViewSideInput2/Combine.GloballyAsSingletonView/CombineValues/Combine.perKey(Singleton)/GroupByKey/ReadStream+ViewSideInput2/Combine.GloballyAsSingletonView/CombineValues/Combine.perKey(Singleton)/Combine.GroupedValues+ViewSideInput2/Combine.GloballyAsSingletonView/CombineValues/Combine.perKey(Singleton)/Combine.GroupedValues/Extract+ViewSideInput2/Combine.GloballyAsSingletonView/CombineValues/Values/Values/Map+ViewSideInput2/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/WithKeys/AddKeys/Map+ViewSideInput2/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/GroupByKey+ViewSideInput2/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/Combine.GroupedValues/Partial+ViewSideInput2/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(
Concatenate)/GroupByKey/WriteStream
Sep 15, 2022 9:24:45 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:24:45.478Z: Executing operation
CreateSideInput2/Read(CreateSource)/Read(CreateSource)/Read(BoundedToUnboundedSourceAdapter)/DataflowRunner.StreamingUnboundedRead.ReadWithIds+CreateSideInput2/Read(CreateSource)/Read(CreateSource)/Read(BoundedToUnboundedSourceAdapter)/StripIds+ViewSideInput2/Combine.GloballyAsSingletonView/CombineValues/WithKeys/AddKeys/Map+ViewSideInput2/Combine.GloballyAsSingletonView/CombineValues/Combine.perKey(Singleton)/GroupByKey+ViewSideInput2/Combine.GloballyAsSingletonView/CombineValues/Combine.perKey(Singleton)/Combine.GroupedValues/Partial+ViewSideInput2/Combine.GloballyAsSingletonView/CombineValues/Combine.perKey(Singleton)/GroupByKey/WriteStream
Sep 15, 2022 9:24:45 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:24:45.521Z: Executing operation
ViewSideInputUnread/Combine.GloballyAsSingletonView/CombineValues/Combine.perKey(Singleton)/GroupByKey/ReadStream+ViewSideInputUnread/Combine.GloballyAsSingletonView/CombineValues/Combine.perKey(Singleton)/Combine.GroupedValues+ViewSideInputUnread/Combine.GloballyAsSingletonView/CombineValues/Combine.perKey(Singleton)/Combine.GroupedValues/Extract+ViewSideInputUnread/Combine.GloballyAsSingletonView/CombineValues/Values/Values/Map+ViewSideInputUnread/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/WithKeys/AddKeys/Map+ViewSideInputUnread/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/GroupByKey+ViewSideInputUnread/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/Combine.GroupedValues/Partial+ViewSideInputUnread/Combine.GloballyAsSingletonView/CreatePCollectionView/Combi
ne.globally(Concatenate)/Combine.perKey(Concatenate)/GroupByKey/WriteStream
Sep 15, 2022 9:24:45 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:24:45.567Z: Executing operation
CreateSideInputUnread/Read(CreateSource)/Read(CreateSource)/Read(BoundedToUnboundedSourceAdapter)/DataflowRunner.StreamingUnboundedRead.ReadWithIds+CreateSideInputUnread/Read(CreateSource)/Read(CreateSource)/Read(BoundedToUnboundedSourceAdapter)/StripIds+ViewSideInputUnread/Combine.GloballyAsSingletonView/CombineValues/WithKeys/AddKeys/Map+ViewSideInputUnread/Combine.GloballyAsSingletonView/CombineValues/Combine.perKey(Singleton)/GroupByKey+ViewSideInputUnread/Combine.GloballyAsSingletonView/CombineValues/Combine.perKey(Singleton)/Combine.GroupedValues/Partial+ViewSideInputUnread/Combine.GloballyAsSingletonView/CombineValues/Combine.perKey(Singleton)/GroupByKey/WriteStream
Sep 15, 2022 9:24:47 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:24:45.635Z: Executing operation
PAssert$49/GroupGlobally/GroupByKey/ReadStream+PAssert$49/GroupGlobally/GroupByKey/MergeBuckets+PAssert$49/GroupGlobally/Values/Values/Map+PAssert$49/GroupGlobally/ParDo(Concat)+PAssert$49/GetPane/Map+PAssert$49/RunChecks+PAssert$49/VerifyAssertions/ParDo(DefaultConclude)
Sep 15, 2022 9:24:47 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:24:45.682Z: Executing operation
PAssert$49/GroupGlobally/Create.Values/Read(CreateSource)/Read(CreateSource)/Read(BoundedToUnboundedSourceAdapter)/DataflowRunner.StreamingUnboundedRead.ReadWithIds+PAssert$49/GroupGlobally/Create.Values/Read(CreateSource)/Read(CreateSource)/Read(BoundedToUnboundedSourceAdapter)/StripIds+PAssert$49/GroupGlobally/WithKeys/AddKeys/Map+PAssert$49/GroupGlobally/GroupByKey/WriteStream
Sep 15, 2022 9:24:47 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:24:45.733Z: Executing operation
Create.Values/Read(CreateSource)/Read(CreateSource)/Read(BoundedToUnboundedSourceAdapter)/DataflowRunner.StreamingUnboundedRead.ReadWithIds+Create.Values/Read(CreateSource)/Read(CreateSource)/Read(BoundedToUnboundedSourceAdapter)/StripIds+ParDo(Test)+PAssert$49/GroupGlobally/Reify.Window/ParDo(Anonymous)+PAssert$49/GroupGlobally/ParDo(ToSingletonIterables)+PAssert$49/GroupGlobally/WithKeys/AddKeys/Map+PAssert$49/GroupGlobally/GroupByKey/WriteStream
Sep 15, 2022 9:24:47 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:24:45.771Z: Executing operation
ViewSideInput2/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/GroupByKey/ReadStream+ViewSideInput2/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/Combine.GroupedValues+ViewSideInput2/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/Combine.GroupedValues/Extract+ViewSideInput2/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/Values/Values/Map+ViewSideInput2/Combine.GloballyAsSingletonView/CreatePCollectionView/ParDo(StreamingPCollectionViewWriter)
Sep 15, 2022 9:24:56 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:24:54.768Z: Your project already contains 100
Dataflow-created metric descriptors, so new user metrics of the form
custom.googleapis.com/* will not be created. However, all user metrics are also
available in the metric dataflow.googleapis.com/job/user_counter. If you rely
on the custom metrics, you can delete old / unused metric descriptors. See
https://developers.google.com/apis-explorer/#p/monitoring/v3/monitoring.projects.metricDescriptors.list
and
https://developers.google.com/apis-explorer/#p/monitoring/v3/monitoring.projects.metricDescriptors.delete
Sep 15, 2022 9:25:31 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:25:29.855Z: Autoscaling: Raised the number of workers to
1 so that the pipeline can catch up with its backlog and keep up with its input
rate.
Sep 15, 2022 9:26:04 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:26:02.657Z: Workers have started successfully.
Sep 15, 2022 9:28:37 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:28:35.301Z: Finished operation
ViewSideInput2/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/GroupByKey/ReadStream+ViewSideInput2/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/Combine.GroupedValues+ViewSideInput2/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/Combine.GroupedValues/Extract+ViewSideInput2/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/Values/Values/Map+ViewSideInput2/Combine.GloballyAsSingletonView/CreatePCollectionView/ParDo(StreamingPCollectionViewWriter)
Sep 15, 2022 9:28:37 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:28:35.301Z: Finished operation
ViewSideInput2/Combine.GloballyAsSingletonView/CombineValues/Combine.perKey(Singleton)/GroupByKey/ReadStream+ViewSideInput2/Combine.GloballyAsSingletonView/CombineValues/Combine.perKey(Singleton)/Combine.GroupedValues+ViewSideInput2/Combine.GloballyAsSingletonView/CombineValues/Combine.perKey(Singleton)/Combine.GroupedValues/Extract+ViewSideInput2/Combine.GloballyAsSingletonView/CombineValues/Values/Values/Map+ViewSideInput2/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/WithKeys/AddKeys/Map+ViewSideInput2/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/GroupByKey+ViewSideInput2/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/Combine.GroupedValues/Partial+ViewSideInput2/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(C
oncatenate)/GroupByKey/WriteStream
Sep 15, 2022 9:28:37 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:28:35.301Z: Finished operation
PAssert$49/GroupGlobally/GroupByKey/ReadStream+PAssert$49/GroupGlobally/GroupByKey/MergeBuckets+PAssert$49/GroupGlobally/Values/Values/Map+PAssert$49/GroupGlobally/ParDo(Concat)+PAssert$49/GetPane/Map+PAssert$49/RunChecks+PAssert$49/VerifyAssertions/ParDo(DefaultConclude)
Sep 15, 2022 9:28:37 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:28:35.301Z: Finished operation
ViewSideInputUnread/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/GroupByKey/ReadStream+ViewSideInputUnread/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/Combine.GroupedValues+ViewSideInputUnread/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/Combine.GroupedValues/Extract+ViewSideInputUnread/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/Values/Values/Map+ViewSideInputUnread/Combine.GloballyAsSingletonView/CreatePCollectionView/ParDo(StreamingPCollectionViewWriter)
Sep 15, 2022 9:28:37 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:28:35.301Z: Finished operation
Create.Values/Read(CreateSource)/Read(CreateSource)/Read(BoundedToUnboundedSourceAdapter)/DataflowRunner.StreamingUnboundedRead.ReadWithIds+Create.Values/Read(CreateSource)/Read(CreateSource)/Read(BoundedToUnboundedSourceAdapter)/StripIds+ParDo(Test)+PAssert$49/GroupGlobally/Reify.Window/ParDo(Anonymous)+PAssert$49/GroupGlobally/ParDo(ToSingletonIterables)+PAssert$49/GroupGlobally/WithKeys/AddKeys/Map+PAssert$49/GroupGlobally/GroupByKey/WriteStream
Sep 15, 2022 9:28:37 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:28:35.301Z: Finished operation
ViewSideInput1/Combine.GloballyAsSingletonView/CombineValues/Combine.perKey(Singleton)/GroupByKey/ReadStream+ViewSideInput1/Combine.GloballyAsSingletonView/CombineValues/Combine.perKey(Singleton)/Combine.GroupedValues+ViewSideInput1/Combine.GloballyAsSingletonView/CombineValues/Combine.perKey(Singleton)/Combine.GroupedValues/Extract+ViewSideInput1/Combine.GloballyAsSingletonView/CombineValues/Values/Values/Map+ViewSideInput1/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/WithKeys/AddKeys/Map+ViewSideInput1/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/GroupByKey+ViewSideInput1/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/Combine.GroupedValues/Partial+ViewSideInput1/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(C
oncatenate)/GroupByKey/WriteStream
Sep 15, 2022 9:28:37 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:28:35.301Z: Finished operation
CreateSideInput2/Read(CreateSource)/Read(CreateSource)/Read(BoundedToUnboundedSourceAdapter)/DataflowRunner.StreamingUnboundedRead.ReadWithIds+CreateSideInput2/Read(CreateSource)/Read(CreateSource)/Read(BoundedToUnboundedSourceAdapter)/StripIds+ViewSideInput2/Combine.GloballyAsSingletonView/CombineValues/WithKeys/AddKeys/Map+ViewSideInput2/Combine.GloballyAsSingletonView/CombineValues/Combine.perKey(Singleton)/GroupByKey+ViewSideInput2/Combine.GloballyAsSingletonView/CombineValues/Combine.perKey(Singleton)/Combine.GroupedValues/Partial+ViewSideInput2/Combine.GloballyAsSingletonView/CombineValues/Combine.perKey(Singleton)/GroupByKey/WriteStream
Sep 15, 2022 9:28:37 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:28:35.301Z: Finished operation
CreateSideInputUnread/Read(CreateSource)/Read(CreateSource)/Read(BoundedToUnboundedSourceAdapter)/DataflowRunner.StreamingUnboundedRead.ReadWithIds+CreateSideInputUnread/Read(CreateSource)/Read(CreateSource)/Read(BoundedToUnboundedSourceAdapter)/StripIds+ViewSideInputUnread/Combine.GloballyAsSingletonView/CombineValues/WithKeys/AddKeys/Map+ViewSideInputUnread/Combine.GloballyAsSingletonView/CombineValues/Combine.perKey(Singleton)/GroupByKey+ViewSideInputUnread/Combine.GloballyAsSingletonView/CombineValues/Combine.perKey(Singleton)/Combine.GroupedValues/Partial+ViewSideInputUnread/Combine.GloballyAsSingletonView/CombineValues/Combine.perKey(Singleton)/GroupByKey/WriteStream
Sep 15, 2022 9:28:37 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:28:35.301Z: Finished operation
PAssert$49/GroupGlobally/Create.Values/Read(CreateSource)/Read(CreateSource)/Read(BoundedToUnboundedSourceAdapter)/DataflowRunner.StreamingUnboundedRead.ReadWithIds+PAssert$49/GroupGlobally/Create.Values/Read(CreateSource)/Read(CreateSource)/Read(BoundedToUnboundedSourceAdapter)/StripIds+PAssert$49/GroupGlobally/WithKeys/AddKeys/Map+PAssert$49/GroupGlobally/GroupByKey/WriteStream
Sep 15, 2022 9:28:37 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:28:35.301Z: Finished operation
ViewSideInput1/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/GroupByKey/ReadStream+ViewSideInput1/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/Combine.GroupedValues+ViewSideInput1/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/Combine.GroupedValues/Extract+ViewSideInput1/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/Values/Values/Map+ViewSideInput1/Combine.GloballyAsSingletonView/CreatePCollectionView/ParDo(StreamingPCollectionViewWriter)
Sep 15, 2022 9:28:37 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:28:35.301Z: Finished operation
ViewSideInputUnread/Combine.GloballyAsSingletonView/CombineValues/Combine.perKey(Singleton)/GroupByKey/ReadStream+ViewSideInputUnread/Combine.GloballyAsSingletonView/CombineValues/Combine.perKey(Singleton)/Combine.GroupedValues+ViewSideInputUnread/Combine.GloballyAsSingletonView/CombineValues/Combine.perKey(Singleton)/Combine.GroupedValues/Extract+ViewSideInputUnread/Combine.GloballyAsSingletonView/CombineValues/Values/Values/Map+ViewSideInputUnread/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/WithKeys/AddKeys/Map+ViewSideInputUnread/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/GroupByKey+ViewSideInputUnread/Combine.GloballyAsSingletonView/CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/Combine.GroupedValues/Partial+ViewSideInputUnread/Combine.GloballyAsSingletonView/CreatePCollectionView/Combin
e.globally(Concatenate)/Combine.perKey(Concatenate)/GroupByKey/WriteStream
Sep 15, 2022 9:28:37 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:28:35.301Z: Finished operation
CreateSideInput1/Read(CreateSource)/Read(CreateSource)/Read(BoundedToUnboundedSourceAdapter)/DataflowRunner.StreamingUnboundedRead.ReadWithIds+CreateSideInput1/Read(CreateSource)/Read(CreateSource)/Read(BoundedToUnboundedSourceAdapter)/StripIds+ViewSideInput1/Combine.GloballyAsSingletonView/CombineValues/WithKeys/AddKeys/Map+ViewSideInput1/Combine.GloballyAsSingletonView/CombineValues/Combine.perKey(Singleton)/GroupByKey+ViewSideInput1/Combine.GloballyAsSingletonView/CombineValues/Combine.perKey(Singleton)/Combine.GroupedValues/Partial+ViewSideInput1/Combine.GloballyAsSingletonView/CombineValues/Combine.perKey(Singleton)/GroupByKey/WriteStream
Sep 15, 2022 9:28:37 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:28:35.429Z: Cleaning up.
Sep 15, 2022 9:28:37 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:28:35.501Z: Stopping worker pool...
Sep 15, 2022 9:30:53 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:30:52.083Z: Autoscaling: Reduced the number of workers
to 0 based on low average worker CPU utilization, and the pipeline having
sufficiently low backlog and keeping up with input rate.
Sep 15, 2022 9:30:53 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-09-15T21:30:52.120Z: Worker pool stopped.
Sep 15, 2022 9:30:59 PM org.apache.beam.runners.dataflow.DataflowPipelineJob
logTerminalState
INFO: Job 2022-09-15_14_24_27-1459555830228686178 finished with status DONE.
Sep 15, 2022 9:30:59 PM org.apache.beam.runners.dataflow.TestDataflowRunner
run
WARNING: Dataflow job 2022-09-15_14_24_27-1459555830228686178 did not output
a success or failure metric.
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
