See
<https://ci-beam.apache.org/job/beam_PostCommit_Java_Tpcds_Spark/1288/display/redirect>
Changes:
------------------------------------------
[...truncated 117.11 KB...]
23/04/05 03:35:36 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating org.apache.beam.sdk.transforms.MapElements$2@72e66a1d
23/04/05 03:35:36 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating org.apache.beam.sdk.io.FileIO$ReadMatches$ToReadableFileFn@36180f79
23/04/05 03:35:36 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.runners.core.construction.SplittableParDo$PairWithRestrictionFn@5ae8b460
23/04/05 03:35:36 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.runners.core.construction.SplittableParDo$SplitRestrictionFn@28a93736
23/04/05 03:35:36 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.runners.core.construction.SplittableParDo$ExplodeWindowsFn@4fff598d
23/04/05 03:35:36 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating org.apache.beam.sdk.transforms.MapElements$2@611b2c28
23/04/05 03:35:36 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Entering directly-translatable composite transform: 'Read customer_demographics
(parquet)/ParquetIO.ReadFiles/ParDo(SplitRead)/ParMultiDo(SplitRead)/ProcessKeyedElements/Reshuffle'
23/04/05 03:35:36 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating Reshuffle
23/04/05 03:35:36 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating org.apache.beam.sdk.transforms.MapElements$2@2e1f5a53
23/04/05 03:35:36 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.runners.core.construction.SplittableParDoNaiveBounded$NaiveProcessFn@57a0d779
23/04/05 03:35:36 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating Read(CreateSource)
23/04/05 03:35:36 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating org.apache.beam.sdk.io.FileIO$MatchAll$MatchFn@53347359
23/04/05 03:35:36 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating org.apache.beam.sdk.transforms.Reshuffle$AssignShardFn@63b584a3
23/04/05 03:35:36 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Entering directly-translatable composite transform: 'Read web_sales
(parquet)/FileIO.MatchAll/Reshuffle.ViaRandomKey/Reshuffle'
23/04/05 03:35:36 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating Reshuffle
23/04/05 03:35:36 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating org.apache.beam.sdk.transforms.MapElements$2@764c1c54
23/04/05 03:35:36 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating org.apache.beam.sdk.io.FileIO$ReadMatches$ToReadableFileFn@685cf7d6
23/04/05 03:35:36 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.runners.core.construction.SplittableParDo$PairWithRestrictionFn@4d704ad6
23/04/05 03:35:36 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.runners.core.construction.SplittableParDo$SplitRestrictionFn@11ec6bbe
23/04/05 03:35:36 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.runners.core.construction.SplittableParDo$ExplodeWindowsFn@350d5594
23/04/05 03:35:36 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating org.apache.beam.sdk.transforms.MapElements$2@760f8605
23/04/05 03:35:36 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Entering directly-translatable composite transform: 'Read web_sales
(parquet)/ParquetIO.ReadFiles/ParDo(SplitRead)/ParMultiDo(SplitRead)/ProcessKeyedElements/Reshuffle'
23/04/05 03:35:36 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating Reshuffle
23/04/05 03:35:36 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating org.apache.beam.sdk.transforms.MapElements$2@71719e1b
23/04/05 03:35:36 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.runners.core.construction.SplittableParDoNaiveBounded$NaiveProcessFn@e37e89e
23/04/05 03:35:36 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating Read(CreateSource)
23/04/05 03:35:36 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating org.apache.beam.sdk.io.FileIO$MatchAll$MatchFn@63d69aad
23/04/05 03:35:36 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating org.apache.beam.sdk.transforms.Reshuffle$AssignShardFn@462b16d
23/04/05 03:35:36 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Entering directly-translatable composite transform: 'Read store_sales
(parquet)/FileIO.MatchAll/Reshuffle.ViaRandomKey/Reshuffle'
23/04/05 03:35:36 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating Reshuffle
23/04/05 03:35:36 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating org.apache.beam.sdk.transforms.MapElements$2@2e007c93
23/04/05 03:35:36 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating org.apache.beam.sdk.io.FileIO$ReadMatches$ToReadableFileFn@7830e189
23/04/05 03:35:36 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.runners.core.construction.SplittableParDo$PairWithRestrictionFn@469fbe60
23/04/05 03:35:36 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.runners.core.construction.SplittableParDo$SplitRestrictionFn@28e20b0f
23/04/05 03:35:36 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.runners.core.construction.SplittableParDo$ExplodeWindowsFn@4db6122d
23/04/05 03:35:36 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating org.apache.beam.sdk.transforms.MapElements$2@670c2cf0
23/04/05 03:35:36 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Entering directly-translatable composite transform: 'Read store_sales
(parquet)/ParquetIO.ReadFiles/ParDo(SplitRead)/ParMultiDo(SplitRead)/ProcessKeyedElements/Reshuffle'
23/04/05 03:35:36 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating Reshuffle
23/04/05 03:35:36 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating org.apache.beam.sdk.transforms.MapElements$2@57a74f5f
23/04/05 03:35:36 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.runners.core.construction.SplittableParDoNaiveBounded$NaiveProcessFn@60d8f771
23/04/05 03:35:36 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating Read(CreateSource)
23/04/05 03:35:36 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating org.apache.beam.sdk.io.FileIO$MatchAll$MatchFn@350122a6
23/04/05 03:35:36 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating org.apache.beam.sdk.transforms.Reshuffle$AssignShardFn@5448cd40
23/04/05 03:35:36 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Entering directly-translatable composite transform: 'Read date_dim
(parquet)/FileIO.MatchAll/Reshuffle.ViaRandomKey/Reshuffle'
23/04/05 03:35:36 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating Reshuffle
23/04/05 03:35:36 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating org.apache.beam.sdk.transforms.MapElements$2@37c7458f
23/04/05 03:35:36 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating org.apache.beam.sdk.io.FileIO$ReadMatches$ToReadableFileFn@3ff4a3da
23/04/05 03:35:36 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.runners.core.construction.SplittableParDo$PairWithRestrictionFn@2f1b9d96
23/04/05 03:35:36 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.runners.core.construction.SplittableParDo$SplitRestrictionFn@56dc632e
23/04/05 03:35:36 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.runners.core.construction.SplittableParDo$ExplodeWindowsFn@c35fa74
23/04/05 03:35:36 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating org.apache.beam.sdk.transforms.MapElements$2@221701ca
23/04/05 03:35:36 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Entering directly-translatable composite transform: 'Read date_dim
(parquet)/ParquetIO.ReadFiles/ParDo(SplitRead)/ParMultiDo(SplitRead)/ProcessKeyedElements/Reshuffle'
23/04/05 03:35:36 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating Reshuffle
23/04/05 03:35:36 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating org.apache.beam.sdk.transforms.MapElements$2@a5e7a95
23/04/05 03:35:36 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.runners.core.construction.SplittableParDoNaiveBounded$NaiveProcessFn@371212a9
23/04/05 03:35:36 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating Read(CreateSource)
23/04/05 03:35:36 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating org.apache.beam.sdk.io.FileIO$MatchAll$MatchFn@334664b
23/04/05 03:35:36 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating org.apache.beam.sdk.transforms.Reshuffle$AssignShardFn@73db40d0
23/04/05 03:35:36 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Entering directly-translatable composite transform: 'Read catalog_sales
(parquet)/FileIO.MatchAll/Reshuffle.ViaRandomKey/Reshuffle'
23/04/05 03:35:36 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating Reshuffle
23/04/05 03:35:36 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating org.apache.beam.sdk.transforms.MapElements$2@5b6d77ed
23/04/05 03:35:36 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating org.apache.beam.sdk.io.FileIO$ReadMatches$ToReadableFileFn@4ac440f8
23/04/05 03:35:36 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.runners.core.construction.SplittableParDo$PairWithRestrictionFn@28b1d7cd
23/04/05 03:35:36 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.runners.core.construction.SplittableParDo$SplitRestrictionFn@4dc48e0d
23/04/05 03:35:36 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.runners.core.construction.SplittableParDo$ExplodeWindowsFn@657e6810
23/04/05 03:35:36 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating org.apache.beam.sdk.transforms.MapElements$2@6a35f2ae
23/04/05 03:35:36 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Entering directly-translatable composite transform: 'Read catalog_sales
(parquet)/ParquetIO.ReadFiles/ParDo(SplitRead)/ParMultiDo(SplitRead)/ProcessKeyedElements/Reshuffle'
23/04/05 03:35:36 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating Reshuffle
23/04/05 03:35:36 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating org.apache.beam.sdk.transforms.MapElements$2@22a5828a
23/04/05 03:35:36 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.runners.core.construction.SplittableParDoNaiveBounded$NaiveProcessFn@2d295c07
23/04/05 03:35:36 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating Read(CreateSource)
23/04/05 03:35:36 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating org.apache.beam.sdk.io.FileIO$MatchAll$MatchFn@237abb45
23/04/05 03:35:36 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating org.apache.beam.sdk.transforms.Reshuffle$AssignShardFn@6b7c7140
23/04/05 03:35:36 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Entering directly-translatable composite transform: 'Read customer
(parquet)/FileIO.MatchAll/Reshuffle.ViaRandomKey/Reshuffle'
23/04/05 03:35:36 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating Reshuffle
23/04/05 03:35:36 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating org.apache.beam.sdk.transforms.MapElements$2@62daaca
23/04/05 03:35:36 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating org.apache.beam.sdk.io.FileIO$ReadMatches$ToReadableFileFn@6d069165
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.runners.core.construction.SplittableParDo$PairWithRestrictionFn@523001ab
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.runners.core.construction.SplittableParDo$SplitRestrictionFn@449a09b9
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.runners.core.construction.SplittableParDo$ExplodeWindowsFn@3918dab1
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating org.apache.beam.sdk.transforms.MapElements$2@32060617
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Entering directly-translatable composite transform: 'Read customer
(parquet)/ParquetIO.ReadFiles/ParDo(SplitRead)/ParMultiDo(SplitRead)/ProcessKeyedElements/Reshuffle'
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating Reshuffle
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating org.apache.beam.sdk.transforms.MapElements$2@50518cec
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.runners.core.construction.SplittableParDoNaiveBounded$NaiveProcessFn@715a7217
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.sdk.schemas.transforms.Convert$ConvertTransform$1@39f2e043
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.sdk.schemas.transforms.Convert$ConvertTransform$1@399ed2ef
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.sdk.extensions.sql.impl.rel.BeamCalcRel$CalcFn@6d2660d8
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating Flatten.PCollections
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating Flatten.PCollections
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.sdk.schemas.transforms.CoGroup$JoinInformation$1@67d90e51
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.sdk.schemas.transforms.CoGroup$JoinInformation$1@62a20d4f
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.sdk.transforms.join.CoGroupByKey$ConstructUnionTableFn@33a25551
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.sdk.transforms.join.CoGroupByKey$ConstructUnionTableFn@5b7cbd38
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating Flatten.PCollections
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating GroupByKey
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.sdk.transforms.join.CoGroupByKey$ConstructCoGbkResultFn@7de61772
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.sdk.schemas.transforms.CoGroup$ConvertCoGbkResult@2c4beb78
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating org.apache.beam.sdk.schemas.transforms.Select$SelectDoFn@1d1eca90
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.sdk.schemas.transforms.Convert$ConvertTransform$1@6023479e
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.sdk.extensions.sql.impl.rel.BeamCalcRel$CalcFn@5152371b
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.sdk.schemas.transforms.Convert$ConvertTransform$1@d94fa83
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.sdk.extensions.sql.impl.rel.BeamCalcRel$CalcFn@72f76c6c
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating Flatten.PCollections
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating Flatten.PCollections
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.sdk.schemas.transforms.CoGroup$JoinInformation$1@1bf767de
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.sdk.schemas.transforms.CoGroup$JoinInformation$1@5cd26526
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.sdk.transforms.join.CoGroupByKey$ConstructUnionTableFn@7c073d34
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.sdk.transforms.join.CoGroupByKey$ConstructUnionTableFn@6db2ea60
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating Flatten.PCollections
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating GroupByKey
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.sdk.transforms.join.CoGroupByKey$ConstructCoGbkResultFn@4dbdfd10
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.sdk.schemas.transforms.CoGroup$ConvertCoGbkResult@21de804f
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating org.apache.beam.sdk.schemas.transforms.Select$SelectDoFn@1506a105
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.sdk.extensions.sql.impl.rel.BeamCalcRel$CalcFn@3750acd7
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating org.apache.beam.sdk.transforms.MapElements$2@3092244b
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating GroupByKey
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Entering directly-translatable composite transform:
'SqlTransform/BeamAggregationRel_7121/Group.CombineFieldsByFields/Combine'
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating Combine.GroupedValues
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.sdk.schemas.transforms.Group$CombineFieldsByFields$1@9d3eafb
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.sdk.extensions.sql.impl.rel.BeamAggregationRel$Transform$1@1a4591dd
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating Flatten.PCollections
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating Flatten.PCollections
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.sdk.schemas.transforms.CoGroup$JoinInformation$1@13b09e3a
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.sdk.schemas.transforms.CoGroup$JoinInformation$1@328673c0
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.sdk.transforms.join.CoGroupByKey$ConstructUnionTableFn@7a7d6a4c
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.sdk.transforms.join.CoGroupByKey$ConstructUnionTableFn@7541dc14
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating Flatten.PCollections
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating GroupByKey
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.sdk.transforms.join.CoGroupByKey$ConstructCoGbkResultFn@29ee4e1c
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.sdk.schemas.transforms.CoGroup$ConvertCoGbkResult@2f59923f
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating org.apache.beam.sdk.schemas.transforms.Select$SelectDoFn@754a8edb
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.sdk.schemas.transforms.Convert$ConvertTransform$1@2dbb13de
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating Flatten.PCollections
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating Flatten.PCollections
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.sdk.schemas.transforms.CoGroup$JoinInformation$1@467f0c62
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.sdk.schemas.transforms.CoGroup$JoinInformation$1@4dca5b7d
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.sdk.transforms.join.CoGroupByKey$ConstructUnionTableFn@2b269165
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.sdk.transforms.join.CoGroupByKey$ConstructUnionTableFn@4ef1ba6e
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating Flatten.PCollections
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating GroupByKey
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.sdk.transforms.join.CoGroupByKey$ConstructCoGbkResultFn@2e3217a2
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.sdk.schemas.transforms.CoGroup$ConvertCoGbkResult@78ead267
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating org.apache.beam.sdk.schemas.transforms.Select$SelectDoFn@2bec1701
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.sdk.extensions.sql.impl.rel.BeamCalcRel$CalcFn@212c67f9
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.sdk.schemas.transforms.Convert$ConvertTransform$1@df38bb5
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.sdk.extensions.sql.impl.rel.BeamCalcRel$CalcFn@33a7e722
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.sdk.extensions.sql.impl.rel.BeamCalcRel$CalcFn@20a025a9
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating Flatten.PCollections
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating Flatten.PCollections
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.sdk.schemas.transforms.CoGroup$JoinInformation$1@32931d15
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.sdk.schemas.transforms.CoGroup$JoinInformation$1@6b012cc
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.sdk.transforms.join.CoGroupByKey$ConstructUnionTableFn@72fd5100
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.sdk.transforms.join.CoGroupByKey$ConstructUnionTableFn@69176c81
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating Flatten.PCollections
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating GroupByKey
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.sdk.transforms.join.CoGroupByKey$ConstructCoGbkResultFn@7a29b240
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.sdk.schemas.transforms.CoGroup$ConvertCoGbkResult@2efdc743
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating org.apache.beam.sdk.schemas.transforms.Select$SelectDoFn@727bffc7
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.sdk.extensions.sql.impl.rel.BeamCalcRel$CalcFn@2f51188a
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating org.apache.beam.sdk.transforms.MapElements$2@671993b0
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating GroupByKey
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Entering directly-translatable composite transform:
'SqlTransform/BeamAggregationRel_7129/Group.CombineFieldsByFields/Combine'
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating Combine.GroupedValues
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.sdk.schemas.transforms.Group$CombineFieldsByFields$1@ac7c0a
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.sdk.extensions.sql.impl.rel.BeamAggregationRel$Transform$1@96746a1
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating Flatten.PCollections
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating Flatten.PCollections
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.sdk.schemas.transforms.CoGroup$JoinInformation$1@600110c5
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.sdk.schemas.transforms.CoGroup$JoinInformation$1@30ae3659
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.sdk.transforms.join.CoGroupByKey$ConstructUnionTableFn@2fa16949
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.sdk.transforms.join.CoGroupByKey$ConstructUnionTableFn@77357d82
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating Flatten.PCollections
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating GroupByKey
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.sdk.transforms.join.CoGroupByKey$ConstructCoGbkResultFn@40f42ab3
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.sdk.schemas.transforms.CoGroup$ConvertCoGbkResult@1a203733
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating org.apache.beam.sdk.schemas.transforms.Select$SelectDoFn@6f541f3e
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.sdk.extensions.sql.impl.rel.BeamCalcRel$CalcFn@523ef6f9
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.sdk.schemas.transforms.Convert$ConvertTransform$1@7cd1f901
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.sdk.extensions.sql.impl.rel.BeamCalcRel$CalcFn@493e2d0
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.sdk.extensions.sql.impl.rel.BeamCalcRel$CalcFn@6604c1b3
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating Flatten.PCollections
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating Flatten.PCollections
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.sdk.schemas.transforms.CoGroup$JoinInformation$1@6b26de34
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.sdk.schemas.transforms.CoGroup$JoinInformation$1@1d2da999
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.sdk.transforms.join.CoGroupByKey$ConstructUnionTableFn@4877eea5
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.sdk.transforms.join.CoGroupByKey$ConstructUnionTableFn@79dd4159
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating Flatten.PCollections
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating GroupByKey
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.sdk.transforms.join.CoGroupByKey$ConstructCoGbkResultFn@6f5ee01e
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.sdk.schemas.transforms.CoGroup$ConvertCoGbkResult@2c9a8f0d
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating org.apache.beam.sdk.schemas.transforms.Select$SelectDoFn@32e3d9b0
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.sdk.extensions.sql.impl.rel.BeamCalcRel$CalcFn@2bead270
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating org.apache.beam.sdk.transforms.MapElements$2@83fbed8
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating GroupByKey
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Entering directly-translatable composite transform:
'SqlTransform/BeamAggregationRel_7136/Group.CombineFieldsByFields/Combine'
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating Combine.GroupedValues
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.sdk.schemas.transforms.Group$CombineFieldsByFields$1@6834d0bf
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.sdk.extensions.sql.impl.rel.BeamAggregationRel$Transform$1@66c74767
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating Flatten.PCollections
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating Flatten.PCollections
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.sdk.schemas.transforms.CoGroup$JoinInformation$1@6559ff86
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.sdk.schemas.transforms.CoGroup$JoinInformation$1@2ceab33c
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.sdk.transforms.join.CoGroupByKey$ConstructUnionTableFn@6260bc48
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.sdk.transforms.join.CoGroupByKey$ConstructUnionTableFn@eb2c8f9
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating Flatten.PCollections
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating GroupByKey
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.sdk.transforms.join.CoGroupByKey$ConstructCoGbkResultFn@688333d8
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.sdk.schemas.transforms.CoGroup$ConvertCoGbkResult@719043f
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating org.apache.beam.sdk.schemas.transforms.Select$SelectDoFn@565aad2
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.sdk.extensions.sql.impl.rel.BeamCalcRel$CalcFn@3c0efe4e
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating org.apache.beam.sdk.transforms.MapElements$2@79219e6d
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating GroupByKey
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Entering directly-translatable composite transform:
'SqlTransform/BeamAggregationRel_7139/Group.CombineFieldsByFields/Combine'
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating Combine.GroupedValues
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.sdk.schemas.transforms.Group$CombineFieldsByFields$1@46faa2f9
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating
org.apache.beam.sdk.extensions.sql.impl.rel.BeamAggregationRel$Transform$1@379a4ad8
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Entering directly-translatable composite transform:
'SqlTransform/BeamSortRel_7140/extractTopOffsetAndFetch'
23/04/05 03:35:37 INFO org.apache.beam.runners.spark.SparkRunner$Evaluator:
Evaluating Combine.globally(Top(ReversedBeamSqlRowComparator))
FATAL: command execution failed
java.io.IOException: Backing channel 'apache-beam-jenkins-16' is disconnected.
at
hudson.remoting.RemoteInvocationHandler.channelOrFail(RemoteInvocationHandler.java:215)
at
hudson.remoting.RemoteInvocationHandler.invoke(RemoteInvocationHandler.java:285)
at com.sun.proxy.$Proxy149.isAlive(Unknown Source)
at hudson.Launcher$RemoteLauncher$ProcImpl.isAlive(Launcher.java:1215)
at hudson.Launcher$RemoteLauncher$ProcImpl.join(Launcher.java:1207)
at hudson.Launcher$ProcStarter.join(Launcher.java:524)
at hudson.plugins.gradle.Gradle.perform(Gradle.java:317)
at hudson.tasks.BuildStepMonitor$1.perform(BuildStepMonitor.java:20)
at
hudson.model.AbstractBuild$AbstractBuildExecution.perform(AbstractBuild.java:814)
at hudson.model.Build$BuildExecution.build(Build.java:199)
at hudson.model.Build$BuildExecution.doRun(Build.java:164)
at
hudson.model.AbstractBuild$AbstractBuildExecution.run(AbstractBuild.java:522)
at hudson.model.Run.execute(Run.java:1896)
at hudson.model.FreeStyleBuild.run(FreeStyleBuild.java:44)
at hudson.model.ResourceController.execute(ResourceController.java:101)
at hudson.model.Executor.run(Executor.java:442)
Caused by: java.io.IOException: Pipe closed after 0 cycles
at
org.apache.sshd.common.channel.ChannelPipedInputStream.read(ChannelPipedInputStream.java:126)
at
org.apache.sshd.common.channel.ChannelPipedInputStream.read(ChannelPipedInputStream.java:105)
at
hudson.remoting.FlightRecorderInputStream.read(FlightRecorderInputStream.java:94)
at
hudson.remoting.ChunkedInputStream.readHeader(ChunkedInputStream.java:75)
at
hudson.remoting.ChunkedInputStream.readUntilBreak(ChunkedInputStream.java:105)
at
hudson.remoting.ChunkedCommandTransport.readBlock(ChunkedCommandTransport.java:39)
at
hudson.remoting.AbstractSynchronousByteArrayCommandTransport.read(AbstractSynchronousByteArrayCommandTransport.java:34)
at
hudson.remoting.SynchronousCommandTransport$ReaderThread.run(SynchronousCommandTransport.java:61)
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
ERROR: apache-beam-jenkins-16 is offline; cannot locate jdk_1.8_latest
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
