See
<https://ci-beam.apache.org/job/beam_PerformanceTests_Cdap/130/display/redirect>
Changes:
------------------------------------------
[...truncated 3.99 MB...]
14:47:14.464 [Test ****] INFO
org.apache.beam.runners.dataflow.DataflowPipelineTranslator - Adding
PAssert$0/GetPane/Map as step s23
14:47:14.467 [Test ****] DEBUG
org.apache.beam.sdk.runners.TransformHierarchy - Visiting output value
PAssert$0/GetPane/Map/ParMultiDo(Anonymous).output [PCollection@751180603]
14:47:14.467 [Test ****] DEBUG
org.apache.beam.runners.dataflow.DataflowPipelineTranslator - Checking
translation of PAssert$0/GetPane/Map/ParMultiDo(Anonymous).output
[PCollection@751180603]
14:47:14.467 [Test ****] DEBUG
org.apache.beam.sdk.runners.TransformHierarchy - Visiting primitive node
Node{fullName=PAssert$0/RunChecks,
transform=PrimitiveParDoSingleFactory.ParDoSingle}
14:47:14.467 [Test ****] DEBUG
org.apache.beam.runners.dataflow.DataflowPipelineTranslator - Translating
PrimitiveParDoSingleFactory.ParDoSingle
14:47:14.471 [Test ****] INFO
org.apache.beam.runners.dataflow.DataflowPipelineTranslator - Adding
PAssert$0/RunChecks as step s24
14:47:14.475 [Test ****] DEBUG
org.apache.beam.sdk.runners.TransformHierarchy - Visiting output value
PAssert$0/RunChecks/ParMultiDo(SingletonChecker).output [PCollection@1778700964]
14:47:14.475 [Test ****] DEBUG
org.apache.beam.runners.dataflow.DataflowPipelineTranslator - Checking
translation of PAssert$0/RunChecks/ParMultiDo(SingletonChecker).output
[PCollection@1778700964]
14:47:14.475 [Test ****] DEBUG
org.apache.beam.sdk.runners.TransformHierarchy - Visiting composite node
Node{fullName=PAssert$0/VerifyAssertions,
transform=PAssert.DefaultConcludeTransform}
14:47:14.475 [Test ****] DEBUG
org.apache.beam.sdk.runners.TransformHierarchy - Visiting primitive node
Node{fullName=PAssert$0/VerifyAssertions/ParDo(DefaultConclude),
transform=PrimitiveParDoSingleFactory.ParDoSingle}
14:47:14.475 [Test ****] DEBUG
org.apache.beam.runners.dataflow.DataflowPipelineTranslator - Translating
PrimitiveParDoSingleFactory.ParDoSingle
14:47:14.479 [Test ****] INFO
org.apache.beam.runners.dataflow.DataflowPipelineTranslator - Adding
PAssert$0/VerifyAssertions/ParDo(DefaultConclude) as step s25
14:47:14.482 [Test ****] DEBUG
org.apache.beam.sdk.runners.TransformHierarchy - Visiting output value
PAssert$0/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude).output
[PCollection@149816309]
14:47:14.482 [Test ****] DEBUG
org.apache.beam.runners.dataflow.DataflowPipelineTranslator - Checking
translation of
PAssert$0/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude).output
[PCollection@149816309]
14:47:14.493 [Test ****] INFO
org.apache.beam.runners.dataflow.DataflowRunner - Dataflow SDK version:
2.42.0-SNAPSHOT
14:47:15.228 [Test ****] INFO
org.apache.beam.runners.dataflow.DataflowRunner - To access the Dataflow
monitoring console, please navigate to
https://console.cloud.google.com/dataflow/jobs/us-central1/2022-09-05_07_47_14-9029732330486113013?project=apache-beam-testing
14:47:15.228 [Test ****] INFO
org.apache.beam.runners.dataflow.DataflowRunner - Submitted job:
2022-09-05_07_47_14-9029732330486113013
14:47:15.228 [Test ****] INFO
org.apache.beam.runners.dataflow.DataflowRunner - To cancel the job using the
'gcloud' tool, run:
> gcloud dataflow jobs --project=apache-beam-testing cancel
--region=us-central1 2022-09-05_07_47_14-9029732330486113013
14:47:15.228 [Test ****] DEBUG
org.apache.beam.sdk.runners.TransformHierarchy - Visiting composite node
RootNode
14:47:15.228 [Test ****] DEBUG
org.apache.beam.sdk.runners.TransformHierarchy - Visiting composite node
Node{fullName=Read using CdapIO, transform=CdapIO.Read}
14:47:15.228 [Test ****] DEBUG
org.apache.beam.sdk.runners.TransformHierarchy - Visiting composite node
Node{fullName=Read using CdapIO/HadoopFormatIO.Read,
transform=HadoopFormatIO.Read}
14:47:15.228 [Test ****] DEBUG
org.apache.beam.sdk.runners.TransformHierarchy - Visiting primitive node
Node{fullName=Read using
CdapIO/HadoopFormatIO.Read/Read(HadoopInputFormatBoundedSource),
transform=Read(HadoopInputFormatBoundedSource)}
14:47:15.228 [Test ****] DEBUG
org.apache.beam.sdk.runners.TransformHierarchy - Visiting output value Read
using
CdapIO/HadoopFormatIO.Read/Read(HadoopInputFormatBoundedSource)/ParDo(BoundedSourceAsSDFWrapper)/ParMultiDo(BoundedSourceAsSDFWrapper).output
[PCollection@575197504]
14:47:15.228 [Test ****] DEBUG
org.apache.beam.sdk.runners.TransformHierarchy - Visiting primitive node
Node{fullName=Collect read time,
transform=PrimitiveParDoSingleFactory.ParDoSingle}
14:47:15.228 [Test ****] DEBUG
org.apache.beam.sdk.runners.TransformHierarchy - Visiting output value Collect
read time/ParMultiDo(TimeMonitor).output [PCollection@1339273738]
14:47:15.228 [Test ****] DEBUG
org.apache.beam.sdk.runners.TransformHierarchy - Visiting composite node
Node{fullName=Get values only, transform=Values}
14:47:15.228 [Test ****] DEBUG
org.apache.beam.sdk.runners.TransformHierarchy - Visiting composite node
Node{fullName=Get values only/Values, transform=MapElements}
14:47:15.228 [Test ****] DEBUG
org.apache.beam.sdk.runners.TransformHierarchy - Visiting primitive node
Node{fullName=Get values only/Values/Map,
transform=PrimitiveParDoSingleFactory.ParDoSingle}
14:47:15.228 [Test ****] DEBUG
org.apache.beam.sdk.runners.TransformHierarchy - Visiting output value Get
values only/Values/Map/ParMultiDo(Anonymous).output [PCollection@1416134608]
14:47:15.228 [Test ****] DEBUG
org.apache.beam.sdk.runners.TransformHierarchy - Visiting primitive node
Node{fullName=Values as string,
transform=PrimitiveParDoSingleFactory.ParDoSingle}
14:47:15.228 [Test ****] DEBUG
org.apache.beam.sdk.runners.TransformHierarchy - Visiting output value Values
as string/ParMultiDo(SelectName).output [PCollection@1813742285]
14:47:15.228 [Test ****] DEBUG
org.apache.beam.sdk.runners.TransformHierarchy - Visiting composite node
Node{fullName=Calculate hashcode, transform=Combine.globally(Hashing)}
14:47:15.228 [Test ****] DEBUG
org.apache.beam.sdk.runners.TransformHierarchy - Visiting composite node
Node{fullName=Calculate hashcode/WithKeys, transform=WithKeys}
14:47:15.228 [Test ****] DEBUG
org.apache.beam.sdk.runners.TransformHierarchy - Visiting composite node
Node{fullName=Calculate hashcode/WithKeys/AddKeys, transform=MapElements}
14:47:15.228 [Test ****] DEBUG
org.apache.beam.sdk.runners.TransformHierarchy - Visiting primitive node
Node{fullName=Calculate hashcode/WithKeys/AddKeys/Map,
transform=PrimitiveParDoSingleFactory.ParDoSingle}
14:47:15.228 [Test ****] DEBUG
org.apache.beam.sdk.runners.TransformHierarchy - Visiting output value
Calculate hashcode/WithKeys/AddKeys/Map/ParMultiDo(Anonymous).output
[PCollection@213063852]
14:47:15.228 [Test ****] DEBUG
org.apache.beam.sdk.runners.TransformHierarchy - Visiting composite node
Node{fullName=Calculate hashcode/Combine.perKey(Hashing),
transform=Combine.perKey(Hashing)}
14:47:15.228 [Test ****] DEBUG
org.apache.beam.sdk.runners.TransformHierarchy - Visiting primitive node
Node{fullName=Calculate hashcode/Combine.perKey(Hashing)/GroupByKey,
transform=GroupByKey}
14:47:15.228 [Test ****] DEBUG
org.apache.beam.sdk.runners.TransformHierarchy - Visiting output value
Calculate hashcode/Combine.perKey(Hashing)/GroupByKey.out
[PCollection@554515010]
14:47:15.228 [Test ****] DEBUG
org.apache.beam.sdk.runners.TransformHierarchy - Visiting primitive node
Node{fullName=Calculate hashcode/Combine.perKey(Hashing)/Combine.GroupedValues,
transform=DataflowRunner.CombineGroupedValues}
14:47:15.228 [Test ****] DEBUG
org.apache.beam.sdk.runners.TransformHierarchy - Visiting output value
Calculate
hashcode/Combine.perKey(Hashing)/Combine.GroupedValues/ParDo(Anonymous)/ParMultiDo(Anonymous).output
[PCollection@1290733383]
14:47:15.228 [Test ****] DEBUG
org.apache.beam.sdk.runners.TransformHierarchy - Visiting composite node
Node{fullName=Calculate hashcode/Values, transform=Values}
14:47:15.228 [Test ****] DEBUG
org.apache.beam.sdk.runners.TransformHierarchy - Visiting composite node
Node{fullName=Calculate hashcode/Values/Values, transform=MapElements}
14:47:15.228 [Test ****] DEBUG
org.apache.beam.sdk.runners.TransformHierarchy - Visiting primitive node
Node{fullName=Calculate hashcode/Values/Values/Map,
transform=PrimitiveParDoSingleFactory.ParDoSingle}
14:47:15.228 [Test ****] DEBUG
org.apache.beam.sdk.runners.TransformHierarchy - Visiting output value
Calculate hashcode/Values/Values/Map/ParMultiDo(Anonymous).output
[PCollection@2000630624]
14:47:15.228 [Test ****] DEBUG
org.apache.beam.sdk.runners.TransformHierarchy - Visiting composite node
Node{fullName=Calculate hashcode/View.AsIterable,
transform=BatchViewOverrides.BatchViewAsIterable}
14:47:15.228 [Test ****] DEBUG
org.apache.beam.sdk.runners.TransformHierarchy - Visiting primitive node
Node{fullName=Calculate
hashcode/View.AsIterable/ParDo(ToIsmRecordForGlobalWindow),
transform=PrimitiveParDoSingleFactory.ParDoSingle}
14:47:15.228 [Test ****] DEBUG
org.apache.beam.sdk.runners.TransformHierarchy - Visiting output value
Calculate
hashcode/View.AsIterable/ParDo(ToIsmRecordForGlobalWindow)/ParMultiDo(ToIsmRecordForGlobalWindow).output
[PCollection@513635174]
14:47:15.228 [Test ****] DEBUG
org.apache.beam.sdk.runners.TransformHierarchy - Visiting primitive node
Node{fullName=Calculate hashcode/View.AsIterable/CreateDataflowView,
transform=CreateDataflowView}
14:47:15.228 [Test ****] DEBUG
org.apache.beam.sdk.runners.TransformHierarchy - Visiting output value
Calculate hashcode/View.AsIterable/MapElements/Map/ParMultiDo(Anonymous).output
[PCollection@1792086750]
14:47:15.228 [Test ****] DEBUG
org.apache.beam.sdk.runners.TransformHierarchy - Visiting composite node
Node{fullName=Calculate hashcode/CreateVoid, transform=Create.Values}
14:47:15.228 [Test ****] DEBUG
org.apache.beam.sdk.runners.TransformHierarchy - Visiting primitive node
Node{fullName=Calculate hashcode/CreateVoid/Read(CreateSource),
transform=Read(CreateSource)}
14:47:15.228 [Test ****] DEBUG
org.apache.beam.sdk.runners.TransformHierarchy - Visiting output value
Calculate
hashcode/CreateVoid/Read(CreateSource)/ParDo(BoundedSourceAsSDFWrapper)/ParMultiDo(BoundedSourceAsSDFWrapper).output
[PCollection@752572788]
14:47:15.228 [Test ****] DEBUG
org.apache.beam.sdk.runners.TransformHierarchy - Visiting primitive node
Node{fullName=Calculate hashcode/ProduceDefault,
transform=PrimitiveParDoSingleFactory.ParDoSingle}
14:47:15.228 [Test ****] DEBUG
org.apache.beam.sdk.runners.TransformHierarchy - Visiting output value
Calculate hashcode/ProduceDefault/ParMultiDo(Anonymous).output
[PCollection@1316317287]
14:47:15.228 [Test ****] DEBUG
org.apache.beam.sdk.runners.TransformHierarchy - Visiting primitive node
Node{fullName=Calculate hashcode/Flatten.PCollections,
transform=Flatten.PCollections}
14:47:15.228 [Test ****] DEBUG
org.apache.beam.sdk.runners.TransformHierarchy - Visiting output value
Calculate hashcode/Flatten.PCollections.out [PCollection@155833159]
14:47:15.228 [Test ****] DEBUG
org.apache.beam.sdk.runners.TransformHierarchy - Visiting composite node
Node{fullName=PAssert$0, transform=PAssert.GroupThenAssertForSingleton}
14:47:15.228 [Test ****] DEBUG
org.apache.beam.sdk.runners.TransformHierarchy - Visiting composite node
Node{fullName=PAssert$0/GroupGlobally, transform=PAssert.GroupGlobally}
14:47:15.228 [Test ****] DEBUG
org.apache.beam.sdk.runners.TransformHierarchy - Visiting composite node
Node{fullName=PAssert$0/GroupGlobally/Reify.Window, transform=Reify.Window}
14:47:15.229 [Test ****] DEBUG
org.apache.beam.sdk.runners.TransformHierarchy - Visiting primitive node
Node{fullName=PAssert$0/GroupGlobally/Reify.Window/ParDo(Anonymous),
transform=PrimitiveParDoSingleFactory.ParDoSingle}
14:47:15.229 [Test ****] DEBUG
org.apache.beam.sdk.runners.TransformHierarchy - Visiting output value
PAssert$0/GroupGlobally/Reify.Window/ParDo(Anonymous)/ParMultiDo(Anonymous).output
[PCollection@911284082]
14:47:15.229 [Test ****] DEBUG
org.apache.beam.sdk.runners.TransformHierarchy - Visiting primitive node
Node{fullName=PAssert$0/GroupGlobally/ParDo(ToSingletonIterables),
transform=PrimitiveParDoSingleFactory.ParDoSingle}
14:47:15.229 [Test ****] DEBUG
org.apache.beam.sdk.runners.TransformHierarchy - Visiting output value
PAssert$0/GroupGlobally/ParDo(ToSingletonIterables)/ParMultiDo(ToSingletonIterables).output
[PCollection@1592099291]
14:47:15.229 [Test ****] DEBUG
org.apache.beam.sdk.runners.TransformHierarchy - Visiting composite node
Node{fullName=PAssert$0/GroupGlobally/Create.Values, transform=Create.Values}
14:47:15.229 [Test ****] DEBUG
org.apache.beam.sdk.runners.TransformHierarchy - Visiting primitive node
Node{fullName=PAssert$0/GroupGlobally/Create.Values/Read(CreateSource),
transform=Read(CreateSource)}
14:47:15.229 [Test ****] DEBUG
org.apache.beam.sdk.runners.TransformHierarchy - Visiting output value
PAssert$0/GroupGlobally/Create.Values/Read(CreateSource)/ParDo(BoundedSourceAsSDFWrapper)/ParMultiDo(BoundedSourceAsSDFWrapper).output
[PCollection@711332373]
14:47:15.229 [Test ****] DEBUG
org.apache.beam.sdk.runners.TransformHierarchy - Visiting primitive node
Node{fullName=PAssert$0/GroupGlobally/Flatten.PCollections,
transform=Flatten.PCollections}
14:47:15.229 [Test ****] DEBUG
org.apache.beam.sdk.runners.TransformHierarchy - Visiting output value
PAssert$0/GroupGlobally/Flatten.PCollections.out [PCollection@1238166297]
14:47:15.229 [Test ****] DEBUG
org.apache.beam.sdk.runners.TransformHierarchy - Visiting composite node
Node{fullName=PAssert$0/GroupGlobally/Window.Into(), transform=Window.Into()}
14:47:15.229 [Test ****] DEBUG
org.apache.beam.sdk.runners.TransformHierarchy - Visiting primitive node
Node{fullName=PAssert$0/GroupGlobally/Window.Into()/Flatten.PCollections,
transform=Flatten.PCollections}
14:47:15.229 [Test ****] DEBUG
org.apache.beam.sdk.runners.TransformHierarchy - Visiting output value
PAssert$0/GroupGlobally/Window.Into()/Flatten.PCollections.out
[PCollection@1634697653]
14:47:15.229 [Test ****] DEBUG
org.apache.beam.sdk.runners.TransformHierarchy - Visiting composite node
Node{fullName=PAssert$0/GroupGlobally/WithKeys, transform=WithKeys}
14:47:15.229 [Test ****] DEBUG
org.apache.beam.sdk.runners.TransformHierarchy - Visiting composite node
Node{fullName=PAssert$0/GroupGlobally/WithKeys/AddKeys, transform=MapElements}
14:47:15.229 [Test ****] DEBUG
org.apache.beam.sdk.runners.TransformHierarchy - Visiting primitive node
Node{fullName=PAssert$0/GroupGlobally/WithKeys/AddKeys/Map,
transform=PrimitiveParDoSingleFactory.ParDoSingle}
14:47:15.229 [Test ****] DEBUG
org.apache.beam.sdk.runners.TransformHierarchy - Visiting output value
PAssert$0/GroupGlobally/WithKeys/AddKeys/Map/ParMultiDo(Anonymous).output
[PCollection@2068191651]
14:47:15.229 [Test ****] DEBUG
org.apache.beam.sdk.runners.TransformHierarchy - Visiting primitive node
Node{fullName=PAssert$0/GroupGlobally/GroupByKey, transform=GroupByKey}
14:47:15.229 [Test ****] DEBUG
org.apache.beam.sdk.runners.TransformHierarchy - Visiting output value
PAssert$0/GroupGlobally/GroupByKey.out [PCollection@474027124]
14:47:15.229 [Test ****] DEBUG
org.apache.beam.sdk.runners.TransformHierarchy - Visiting composite node
Node{fullName=PAssert$0/GroupGlobally/Values, transform=Values}
14:47:15.229 [Test ****] DEBUG
org.apache.beam.sdk.runners.TransformHierarchy - Visiting composite node
Node{fullName=PAssert$0/GroupGlobally/Values/Values, transform=MapElements}
14:47:15.229 [Test ****] DEBUG
org.apache.beam.sdk.runners.TransformHierarchy - Visiting primitive node
Node{fullName=PAssert$0/GroupGlobally/Values/Values/Map,
transform=PrimitiveParDoSingleFactory.ParDoSingle}
14:47:15.229 [Test ****] DEBUG
org.apache.beam.sdk.runners.TransformHierarchy - Visiting output value
PAssert$0/GroupGlobally/Values/Values/Map/ParMultiDo(Anonymous).output
[PCollection@1512060385]
14:47:15.229 [Test ****] DEBUG
org.apache.beam.sdk.runners.TransformHierarchy - Visiting primitive node
Node{fullName=PAssert$0/GroupGlobally/ParDo(Concat),
transform=PrimitiveParDoSingleFactory.ParDoSingle}
14:47:15.229 [Test ****] DEBUG
org.apache.beam.sdk.runners.TransformHierarchy - Visiting output value
PAssert$0/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat).output
[PCollection@1791706561]
14:47:15.229 [Test ****] DEBUG
org.apache.beam.sdk.runners.TransformHierarchy - Visiting composite node
Node{fullName=PAssert$0/GetPane, transform=MapElements}
14:47:15.229 [Test ****] DEBUG
org.apache.beam.sdk.runners.TransformHierarchy - Visiting primitive node
Node{fullName=PAssert$0/GetPane/Map,
transform=PrimitiveParDoSingleFactory.ParDoSingle}
14:47:15.229 [Test ****] DEBUG
org.apache.beam.sdk.runners.TransformHierarchy - Visiting output value
PAssert$0/GetPane/Map/ParMultiDo(Anonymous).output [PCollection@751180603]
14:47:15.229 [Test ****] DEBUG
org.apache.beam.sdk.runners.TransformHierarchy - Visiting primitive node
Node{fullName=PAssert$0/RunChecks,
transform=PrimitiveParDoSingleFactory.ParDoSingle}
14:47:15.229 [Test ****] DEBUG
org.apache.beam.sdk.runners.TransformHierarchy - Visiting output value
PAssert$0/RunChecks/ParMultiDo(SingletonChecker).output [PCollection@1778700964]
14:47:15.229 [Test ****] DEBUG
org.apache.beam.sdk.runners.TransformHierarchy - Visiting composite node
Node{fullName=PAssert$0/VerifyAssertions,
transform=PAssert.DefaultConcludeTransform}
14:47:15.229 [Test ****] DEBUG
org.apache.beam.sdk.runners.TransformHierarchy - Visiting primitive node
Node{fullName=PAssert$0/VerifyAssertions/ParDo(DefaultConclude),
transform=PrimitiveParDoSingleFactory.ParDoSingle}
14:47:15.229 [Test ****] DEBUG
org.apache.beam.sdk.runners.TransformHierarchy - Visiting output value
PAssert$0/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude).output
[PCollection@149816309]
14:47:17.049 [Test ****] WARN
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2022-09-05T14:47:16.919Z: 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:
cdapioit0testcdapioreadsandwritescorrectlyinbatch-jenkins--xa88. 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
14:47:33.066 [Test ****] INFO
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2022-09-05T14:47:31.872Z: Worker configuration: e2-standard-2 in us-central1-b.
14:47:33.066 [Test ****] INFO
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2022-09-05T14:47:32.904Z: Expanding CoGroupByKey operations into optimizable
parts.
14:47:33.066 [Test ****] DEBUG
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2022-09-05T14:47:32.939Z: Combiner lifting skipped for step
PAssert$0/GroupGlobally/GroupByKey: GroupByKey not followed by a combiner.
14:47:33.066 [Test ****] INFO
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2022-09-05T14:47:33.009Z: Expanding GroupByKey operations into optimizable
parts.
14:47:34.967 [Test ****] INFO
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2022-09-05T14:47:33.067Z: Lifting ValueCombiningMappingFns into
MergeBucketsMappingFns
14:47:34.967 [Test ****] DEBUG
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2022-09-05T14:47:33.183Z: Annotating graph with Autotuner information.
14:47:34.967 [Test ****] INFO
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2022-09-05T14:47:33.218Z: Fusing adjacent ParDo, Read, Write, and Flatten
operations
14:47:34.967 [Test ****] INFO
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2022-09-05T14:47:33.250Z: Elided trivial flatten
14:47:34.967 [Test ****] INFO
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2022-09-05T14:47:33.320Z: Unzipping flatten s17 for input
s15.org.apache.beam.sdk.values.PCollection.<init>:405#4f24fdb6be16210b
14:47:34.967 [Test ****] INFO
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2022-09-05T14:47:33.348Z: Fusing unzipped copy of
PAssert$0/GroupGlobally/WithKeys/AddKeys/Map, through flatten
PAssert$0/GroupGlobally/Flatten.PCollections, into producer
PAssert$0/GroupGlobally/ParDo(ToSingletonIterables)
14:47:34.967 [Test ****] INFO
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2022-09-05T14:47:33.382Z: Unzipping flatten s13 for input
s12.org.apache.beam.sdk.values.PCollection.<init>:405#c47715dbb819979d
14:47:34.968 [Test ****] INFO
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2022-09-05T14:47:33.408Z: Fusing unzipped copy of
PAssert$0/GroupGlobally/Reify.Window/ParDo(Anonymous), through flatten
Calculate hashcode/Flatten.PCollections, into producer Calculate
hashcode/ProduceDefault
14:47:34.968 [Test ****] INFO
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2022-09-05T14:47:33.430Z: Fusing consumer
PAssert$0/GroupGlobally/GroupByKey/Write into
PAssert$0/GroupGlobally/GroupByKey/Reify
14:47:34.968 [Test ****] INFO
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2022-09-05T14:47:33.461Z: Fusing consumer
PAssert$0/GroupGlobally/GroupByKey/GroupByWindow into
PAssert$0/GroupGlobally/GroupByKey/Read
14:47:34.968 [Test ****] INFO
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2022-09-05T14:47:33.486Z: Fusing consumer
PAssert$0/GroupGlobally/Values/Values/Map into
PAssert$0/GroupGlobally/GroupByKey/GroupByWindow
14:47:34.968 [Test ****] INFO
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2022-09-05T14:47:33.510Z: Fusing consumer PAssert$0/GroupGlobally/ParDo(Concat)
into PAssert$0/GroupGlobally/Values/Values/Map
14:47:34.968 [Test ****] INFO
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2022-09-05T14:47:33.540Z: Fusing consumer PAssert$0/GetPane/Map into
PAssert$0/GroupGlobally/ParDo(Concat)
14:47:34.968 [Test ****] INFO
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2022-09-05T14:47:33.575Z: Fusing consumer PAssert$0/RunChecks into
PAssert$0/GetPane/Map
14:47:34.968 [Test ****] INFO
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2022-09-05T14:47:33.608Z: Fusing consumer
PAssert$0/VerifyAssertions/ParDo(DefaultConclude) into PAssert$0/RunChecks
14:47:34.970 [Test ****] INFO
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2022-09-05T14:47:33.644Z: Unzipping flatten s17-u31 for input
s19.org.apache.beam.sdk.values.PCollection.<init>:405#d9ae03fcd5e3bc4a-c29
14:47:34.970 [Test ****] INFO
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2022-09-05T14:47:33.685Z: Fusing unzipped copy of
PAssert$0/GroupGlobally/GroupByKey/Reify, through flatten
PAssert$0/GroupGlobally/Flatten.PCollections/Unzipped-1, into producer
PAssert$0/GroupGlobally/WithKeys/AddKeys/Map
14:47:34.970 [Test ****] INFO
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2022-09-05T14:47:33.720Z: Unzipping flatten s13-u36 for input
s14.org.apache.beam.sdk.values.PCollection.<init>:405#416a1b705666de47-c34
14:47:34.970 [Test ****] INFO
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2022-09-05T14:47:33.754Z: Fusing unzipped copy of
PAssert$0/GroupGlobally/ParDo(ToSingletonIterables), through flatten Calculate
hashcode/Flatten.PCollections/Unzipped-1, into producer
PAssert$0/GroupGlobally/Reify.Window/ParDo(Anonymous)
14:47:34.970 [Test ****] INFO
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2022-09-05T14:47:33.788Z: Fusing consumer Calculate hashcode/ProduceDefault
into Calculate hashcode/CreateVoid/Read(CreateSource)
14:47:34.970 [Test ****] INFO
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2022-09-05T14:47:33.822Z: Fusing consumer
PAssert$0/GroupGlobally/Reify.Window/ParDo(Anonymous) into Calculate
hashcode/Values/Values/Map
14:47:34.970 [Test ****] INFO
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2022-09-05T14:47:33.858Z: Fusing consumer Calculate
hashcode/View.AsIterable/ParDo(ToIsmRecordForGlobalWindow) into Calculate
hashcode/Values/Values/Map
14:47:34.970 [Test ****] INFO
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2022-09-05T14:47:33.886Z: Fusing consumer
PAssert$0/GroupGlobally/ParDo(ToSingletonIterables) into
PAssert$0/GroupGlobally/Reify.Window/ParDo(Anonymous)
14:47:34.970 [Test ****] INFO
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2022-09-05T14:47:33.920Z: Fusing consumer Collect read time into Read using
CdapIO/HadoopFormatIO.Read/Read(HadoopInputFormatBoundedSource)
14:47:34.970 [Test ****] INFO
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2022-09-05T14:47:33.952Z: Fusing consumer Get values only/Values/Map into
Collect read time
14:47:34.970 [Test ****] INFO
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2022-09-05T14:47:33.985Z: Fusing consumer Values as string into Get values
only/Values/Map
14:47:34.970 [Test ****] INFO
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2022-09-05T14:47:34.011Z: Fusing consumer Calculate
hashcode/WithKeys/AddKeys/Map into Values as string
14:47:34.971 [Test ****] INFO
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2022-09-05T14:47:34.037Z: Fusing consumer Calculate
hashcode/Combine.perKey(Hashing)/GroupByKey+Calculate
hashcode/Combine.perKey(Hashing)/Combine.GroupedValues/Partial into Calculate
hashcode/WithKeys/AddKeys/Map
14:47:34.971 [Test ****] INFO
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2022-09-05T14:47:34.063Z: Fusing consumer Calculate
hashcode/Combine.perKey(Hashing)/GroupByKey/Reify into Calculate
hashcode/Combine.perKey(Hashing)/GroupByKey+Calculate
hashcode/Combine.perKey(Hashing)/Combine.GroupedValues/Partial
14:47:34.971 [Test ****] INFO
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2022-09-05T14:47:34.092Z: Fusing consumer Calculate
hashcode/Combine.perKey(Hashing)/GroupByKey/Write into Calculate
hashcode/Combine.perKey(Hashing)/GroupByKey/Reify
14:47:34.971 [Test ****] INFO
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2022-09-05T14:47:34.121Z: Fusing consumer Calculate
hashcode/Combine.perKey(Hashing)/Combine.GroupedValues into Calculate
hashcode/Combine.perKey(Hashing)/GroupByKey/Read
14:47:34.971 [Test ****] INFO
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2022-09-05T14:47:34.155Z: Fusing consumer Calculate
hashcode/Combine.perKey(Hashing)/Combine.GroupedValues/Extract into Calculate
hashcode/Combine.perKey(Hashing)/Combine.GroupedValues
14:47:34.971 [Test ****] INFO
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2022-09-05T14:47:34.179Z: Fusing consumer Calculate hashcode/Values/Values/Map
into Calculate hashcode/Combine.perKey(Hashing)/Combine.GroupedValues/Extract
14:47:34.971 [Test ****] INFO
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2022-09-05T14:47:34.209Z: Fusing consumer
PAssert$0/GroupGlobally/WithKeys/AddKeys/Map into
PAssert$0/GroupGlobally/Create.Values/Read(CreateSource)
14:47:34.971 [Test ****] INFO
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2022-09-05T14:47:34.239Z: Fusing consumer
PAssert$0/GroupGlobally/GroupByKey/Reify into
PAssert$0/GroupGlobally/WithKeys/AddKeys/Map
14:47:34.971 [Test ****] DEBUG
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2022-09-05T14:47:34.274Z: Workflow config is missing a default resource spec.
14:47:34.971 [Test ****] DEBUG
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2022-09-05T14:47:34.336Z: Adding StepResource setup and teardown to workflow
graph.
14:47:34.971 [Test ****] DEBUG
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2022-09-05T14:47:34.370Z: Adding workflow start and stop steps.
14:47:34.971 [Test ****] DEBUG
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2022-09-05T14:47:34.394Z: Assigning stage ids.
14:47:34.971 [Test ****] DEBUG
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2022-09-05T14:47:34.572Z: Executing wait step start56
14:47:34.971 [Test ****] INFO
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2022-09-05T14:47:34.640Z: Executing operation Calculate
hashcode/Combine.perKey(Hashing)/GroupByKey/Create
14:47:34.971 [Test ****] DEBUG
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2022-09-05T14:47:34.700Z: Starting **** pool setup.
14:47:34.971 [Test ****] INFO
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2022-09-05T14:47:34.730Z: Starting 5 ****s in us-central1-b...
14:47:37.463 [Test ****] INFO
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2022-09-05T14:47:35.061Z: Finished operation Calculate
hashcode/Combine.perKey(Hashing)/GroupByKey/Create
14:47:37.463 [Test ****] DEBUG
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2022-09-05T14:47:35.129Z: Value "Calculate
hashcode/Combine.perKey(Hashing)/GroupByKey/Session" materialized.
14:47:37.463 [Test ****] INFO
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2022-09-05T14:47:35.215Z: Executing operation Read using
CdapIO/HadoopFormatIO.Read/Read(HadoopInputFormatBoundedSource)+Collect read
time+Get values only/Values/Map+Values as string+Calculate
hashcode/WithKeys/AddKeys/Map+Calculate
hashcode/Combine.perKey(Hashing)/GroupByKey+Calculate
hashcode/Combine.perKey(Hashing)/Combine.GroupedValues/Partial+Calculate
hashcode/Combine.perKey(Hashing)/GroupByKey/Reify+Calculate
hashcode/Combine.perKey(Hashing)/GroupByKey/Write
14:47:40.336 [Test ****] INFO
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2022-09-05T14:47:38.076Z: 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
14:48:11.665 [Test ****] INFO
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2022-09-05T14:48:11.525Z: Autoscaling: Raised the number of ****s to 4 based on
the rate of progress in the currently running stage(s).
14:48:11.665 [Test ****] INFO
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2022-09-05T14:48:11.559Z: Resized **** pool to 4, though goal was 5. This
could be a quota issue.
14:48:24.275 [Test ****] INFO
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2022-09-05T14:48:21.784Z: Autoscaling: Raised the number of ****s to 5 based on
the rate of progress in the currently running stage(s).
14:48:43.588 [Test ****] INFO
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2022-09-05T14:48:41.879Z: Workers have started successfully.
14:49:20.409 [Test ****] INFO
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2022-09-05T14:49:19.956Z: Finished operation Read using
CdapIO/HadoopFormatIO.Read/Read(HadoopInputFormatBoundedSource)+Collect read
time+Get values only/Values/Map+Values as string+Calculate
hashcode/WithKeys/AddKeys/Map+Calculate
hashcode/Combine.perKey(Hashing)/GroupByKey+Calculate
hashcode/Combine.perKey(Hashing)/Combine.GroupedValues/Partial+Calculate
hashcode/Combine.perKey(Hashing)/GroupByKey/Reify+Calculate
hashcode/Combine.perKey(Hashing)/GroupByKey/Write
14:49:20.409 [Test ****] INFO
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2022-09-05T14:49:20.026Z: Executing operation Calculate
hashcode/Combine.perKey(Hashing)/GroupByKey/Close
14:49:20.409 [Test ****] INFO
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2022-09-05T14:49:20.076Z: Finished operation Calculate
hashcode/Combine.perKey(Hashing)/GroupByKey/Close
14:49:20.409 [Test ****] INFO
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2022-09-05T14:49:20.150Z: Executing operation
PAssert$0/GroupGlobally/GroupByKey/Create
14:49:20.409 [Test ****] INFO
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2022-09-05T14:49:20.284Z: Finished operation
PAssert$0/GroupGlobally/GroupByKey/Create
14:49:22.305 [Test ****] DEBUG
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2022-09-05T14:49:20.410Z: Value "PAssert$0/GroupGlobally/GroupByKey/Session"
materialized.
14:49:22.305 [Test ****] INFO
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2022-09-05T14:49:20.480Z: Executing operation
PAssert$0/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$0/GroupGlobally/WithKeys/AddKeys/Map+PAssert$0/GroupGlobally/GroupByKey/Reify+PAssert$0/GroupGlobally/GroupByKey/Write
14:49:22.305 [Test ****] INFO
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2022-09-05T14:49:20.513Z: Executing operation Calculate
hashcode/Combine.perKey(Hashing)/GroupByKey/Read+Calculate
hashcode/Combine.perKey(Hashing)/Combine.GroupedValues+Calculate
hashcode/Combine.perKey(Hashing)/Combine.GroupedValues/Extract+Calculate
hashcode/Values/Values/Map+PAssert$0/GroupGlobally/Reify.Window/ParDo(Anonymous)+Calculate
hashcode/View.AsIterable/ParDo(ToIsmRecordForGlobalWindow)+PAssert$0/GroupGlobally/ParDo(ToSingletonIterables)+PAssert$0/GroupGlobally/WithKeys/AddKeys/Map+PAssert$0/GroupGlobally/GroupByKey/Reify+PAssert$0/GroupGlobally/GroupByKey/Write
14:49:22.305 [Test ****] INFO
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2022-09-05T14:49:21.696Z: Finished operation
PAssert$0/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$0/GroupGlobally/WithKeys/AddKeys/Map+PAssert$0/GroupGlobally/GroupByKey/Reify+PAssert$0/GroupGlobally/GroupByKey/Write
14:49:26.995 [Test ****] INFO
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2022-09-05T14:49:25.833Z: Finished operation Calculate
hashcode/Combine.perKey(Hashing)/GroupByKey/Read+Calculate
hashcode/Combine.perKey(Hashing)/Combine.GroupedValues+Calculate
hashcode/Combine.perKey(Hashing)/Combine.GroupedValues/Extract+Calculate
hashcode/Values/Values/Map+PAssert$0/GroupGlobally/Reify.Window/ParDo(Anonymous)+Calculate
hashcode/View.AsIterable/ParDo(ToIsmRecordForGlobalWindow)+PAssert$0/GroupGlobally/ParDo(ToSingletonIterables)+PAssert$0/GroupGlobally/WithKeys/AddKeys/Map+PAssert$0/GroupGlobally/GroupByKey/Reify+PAssert$0/GroupGlobally/GroupByKey/Write
14:49:26.995 [Test ****] DEBUG
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2022-09-05T14:49:25.897Z: Value "Calculate
hashcode/View.AsIterable/ParDo(ToIsmRecordForGlobalWindow).out0" materialized.
14:49:26.995 [Test ****] INFO
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2022-09-05T14:49:25.962Z: Executing operation Calculate
hashcode/View.AsIterable/CreateDataflowView
14:49:26.995 [Test ****] INFO
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2022-09-05T14:49:26.017Z: Finished operation Calculate
hashcode/View.AsIterable/CreateDataflowView
14:49:26.995 [Test ****] DEBUG
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2022-09-05T14:49:26.113Z: Value "Calculate
hashcode/View.AsIterable/CreateDataflowView.out0" materialized.
14:49:26.995 [Test ****] INFO
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2022-09-05T14:49:26.181Z: Executing operation Calculate
hashcode/CreateVoid/Read(CreateSource)+Calculate
hashcode/ProduceDefault+PAssert$0/GroupGlobally/Reify.Window/ParDo(Anonymous)+PAssert$0/GroupGlobally/ParDo(ToSingletonIterables)+PAssert$0/GroupGlobally/WithKeys/AddKeys/Map+PAssert$0/GroupGlobally/GroupByKey/Reify+PAssert$0/GroupGlobally/GroupByKey/Write
14:49:29.971 [Test ****] INFO
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2022-09-05T14:49:28.516Z: Finished operation Calculate
hashcode/CreateVoid/Read(CreateSource)+Calculate
hashcode/ProduceDefault+PAssert$0/GroupGlobally/Reify.Window/ParDo(Anonymous)+PAssert$0/GroupGlobally/ParDo(ToSingletonIterables)+PAssert$0/GroupGlobally/WithKeys/AddKeys/Map+PAssert$0/GroupGlobally/GroupByKey/Reify+PAssert$0/GroupGlobally/GroupByKey/Write
14:49:29.971 [Test ****] INFO
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2022-09-05T14:49:28.592Z: Executing operation
PAssert$0/GroupGlobally/GroupByKey/Close
14:49:29.971 [Test ****] INFO
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2022-09-05T14:49:28.650Z: Finished operation
PAssert$0/GroupGlobally/GroupByKey/Close
14:49:29.971 [Test ****] INFO
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2022-09-05T14:49:28.734Z: Executing operation
PAssert$0/GroupGlobally/GroupByKey/Read+PAssert$0/GroupGlobally/GroupByKey/GroupByWindow+PAssert$0/GroupGlobally/Values/Values/Map+PAssert$0/GroupGlobally/ParDo(Concat)+PAssert$0/GetPane/Map+PAssert$0/RunChecks+PAssert$0/VerifyAssertions/ParDo(DefaultConclude)
14:49:32.773 [Test ****] INFO
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2022-09-05T14:49:32.346Z: Finished operation
PAssert$0/GroupGlobally/GroupByKey/Read+PAssert$0/GroupGlobally/GroupByKey/GroupByWindow+PAssert$0/GroupGlobally/Values/Values/Map+PAssert$0/GroupGlobally/ParDo(Concat)+PAssert$0/GetPane/Map+PAssert$0/RunChecks+PAssert$0/VerifyAssertions/ParDo(DefaultConclude)
14:49:32.773 [Test ****] DEBUG
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2022-09-05T14:49:32.427Z: Executing success step success54
14:49:32.773 [Test ****] INFO
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2022-09-05T14:49:32.513Z: Cleaning up.
14:49:32.773 [Test ****] DEBUG
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2022-09-05T14:49:32.560Z: Starting **** pool teardown.
14:49:32.773 [Test ****] INFO
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2022-09-05T14:49:32.590Z: Stopping **** pool...
14:50:29.447 [Thread-8] WARN
org.apache.beam.runners.dataflow.DataflowPipelineJob - Job is already running
in Google Cloud Platform, Ctrl-C will not cancel it.
To cancel the job in the cloud, run:
> gcloud dataflow jobs --project=apache-beam-testing cancel
--region=us-central1 2022-09-05_07_47_14-9029732330486113013
org.apache.beam.sdk.io.cdap.CdapIOIT > testCdapIOReadsAndWritesCorrectlyInBatch
SKIPPED
> Task :sdks:java:io:cdap:integrationTest FAILED
:sdks:java:io:cdap:integrationTest (Thread[Execution **** for ':' Thread
3,5,main]) completed. Took 8 mins 45.873 secs.
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':sdks:java:io:cdap:integrationTest'.
> Process 'Gradle Test Executor 10' finished with non-zero exit value 143
This problem might be caused by incorrect test process configuration.
Please refer to the test execution section in the User Manual at
https://docs.gradle.org/7.4/userguide/java_testing.html#sec:test_execution
* Try:
> Run with --stacktrace option to get the stack trace.
> Run with --debug option to get more log output.
> Run with --scan to get full insights.
* Get more help at https://help.gradle.org
Deprecated Gradle features were used in this build, making it incompatible with
Gradle 8.0.
You can use '--warning-mode all' to show the individual deprecation warnings
and determine if they come from your own scripts or plugins.
See
https://docs.gradle.org/7.4/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 8m 57s
142 actionable tasks: 84 executed, 56 from cache, 2 up-to-date
Publishing build scan...
The message received from the daemon indicates that the daemon has disappeared.
Build request sent: Build{id=c7e8da93-d2f9-4c94-aea3-f9d64bef5c46,
currentDir=<https://ci-beam.apache.org/job/beam_PerformanceTests_Cdap/ws/src}>
Attempting to read last messages from the daemon log...
Daemon pid: 1508863
log file: /home/jenkins/.gradle/daemon/7.4/daemon-1508863.out.log
----- Last 20 lines from daemon log file - daemon-1508863.out.log -----
Please refer to the test execution section in the User Manual at
https://docs.gradle.org/7.4/userguide/java_testing.html#sec:test_execution
* Try:
> Run with --stacktrace option to get the stack trace.
> Run with --debug option to get more log output.
> Run with --scan to get full insights.
* Get more help at https://help.gradle.org
Deprecated Gradle features were used in this build, making it incompatible with
Gradle 8.0.
You can use '--warning-mode all' to show the individual deprecation warnings
and determine if they come from your own scripts or plugins.
See
https://docs.gradle.org/7.4/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 8m 57s
142 actionable tasks: 84 executed, 56 from cache, 2 up-to-date
Publishing build scan...
Daemon vm is shutting down... The daemon has exited normally or was terminated
in response to a user interrupt.
----- End of the daemon log -----
FAILURE: Build failed with an exception.
* What went wrong:
Gradle build daemon disappeared unexpectedly (it may have been killed or may
have crashed)
* Try:
> Run with --stacktrace option to get the stack trace.
> Run with --debug option to get more log output.
> Run with --scan to get full insights.
* Get more help at https://help.gradle.org
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
