See
<https://builds.apache.org/job/beam_PostCommit_Java_Nexmark_Dataflow/832/display/redirect?page=changes>
Changes:
[lcwik] Migrate to using the full Gradle distribution rather than binary-only.
------------------------------------------
[...truncated 699.30 KB...]
INFO: 2018-10-26T19:53:16.899Z: Executing operation
Query6/Query6.WinningBids/CoGroupByKey/GBK/Close
Oct 26, 2018 7:53:17 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-26T19:53:17.137Z: Executing operation
Query6/Query6.WinningBids/CoGroupByKey/GBK/Read+Query6/Query6.WinningBids/CoGroupByKey/GBK/GroupByWindow+Query6/Query6.WinningBids/CoGroupByKey/ConstructCoGbkResultFn+Query6/Query6.WinningBids/Query6.WinningBids.Join+Query6/Query6.Rekey+Query6/Window.Into()/Window.Assign+Query6/Combine.perKey(MovingMeanSellingPrice)/GroupByKey+Query6/Combine.perKey(MovingMeanSellingPrice)/Combine.GroupedValues/Partial+Query6/Combine.perKey(MovingMeanSellingPrice)/GroupByKey/Reify+Query6/Combine.perKey(MovingMeanSellingPrice)/GroupByKey/Write
Oct 26, 2018 7:53:20 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-26T19:53:18.419Z: Autoscaling: Raised the number of workers to 4
based on the rate of progress in the currently running step(s).
Oct 26, 2018 7:53:21 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-26T19:53:20.624Z: Autoscaling: Raised the number of workers to 4
based on the rate of progress in the currently running step(s).
Oct 26, 2018 7:53:28 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-26T19:53:27.756Z: Cleaning up.
Oct 26, 2018 7:53:28 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-26T19:53:27.885Z: Stopping worker pool...
Oct 26, 2018 7:53:33 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-26T19:53:33.036Z: Executing operation
Query6/Combine.perKey(MovingMeanSellingPrice)/GroupByKey/Close
Oct 26, 2018 7:53:33 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-26T19:53:33.133Z: Executing operation
Query6/Combine.perKey(MovingMeanSellingPrice)/GroupByKey/Read+Query6/Combine.perKey(MovingMeanSellingPrice)/Combine.GroupedValues+Query6/Combine.perKey(MovingMeanSellingPrice)/Combine.GroupedValues/Extract+Query6/Query6.Select+Query6/Query6.Forget+Query6/Query6.Debug+Query6/Query6.Stamp+Query6.Format+Query6.DevNull
Oct 26, 2018 7:53:34 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-26T19:53:32.319Z: Executing operation
Query11/Count.PerElement/Combine.perKey(Count)/GroupByKey/Close
Oct 26, 2018 7:53:34 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-26T19:53:32.416Z: Executing operation
Query11/Count.PerElement/Combine.perKey(Count)/GroupByKey/Read+Query11/Count.PerElement/Combine.perKey(Count)/Combine.GroupedValues+Query11/Query11.ToResult+Query11/Query11.Forget+Query11/Query11.Debug+Query11/Query11.Stamp+Query11.Format+Query11.DevNull
Oct 26, 2018 7:53:35 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-26T19:53:35.351Z: Cleaning up.
Oct 26, 2018 7:53:35 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-26T19:53:35.484Z: Stopping worker pool...
Oct 26, 2018 7:53:43 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-26T19:53:42.079Z: Executing operation
Query3/CoGroupByKey/GBK/Close
Oct 26, 2018 7:53:43 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-26T19:53:42.169Z: Executing operation
Query3/CoGroupByKey/GBK/Read+Query3/CoGroupByKey/GBK/GroupByWindow+Query3/CoGroupByKey/ConstructCoGbkResultFn+Query3/Query3.Join/BatchStatefulParDoOverrides.GbkBeforeStatefulParDo/ReifyWindows+Query3/Query3.Join/BatchStatefulParDoOverrides.GbkBeforeStatefulParDo/PartitionKeys/Write
Oct 26, 2018 7:53:48 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-26T19:53:48.262Z: Executing operation
Query3/Query3.Join/BatchStatefulParDoOverrides.GbkBeforeStatefulParDo/PartitionKeys/Close
Oct 26, 2018 7:53:48 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-26T19:53:48.356Z: Executing operation
Query3/Query3.Join/BatchStatefulParDoOverrides.GbkBeforeStatefulParDo/PartitionKeys/Read+Query3/Query3.Join/ParDo(BatchStateful)+Query3/Query3.Project+Query3/Query3.Forget+Query3/Query3.Debug+Query3/Query3.Stamp+Query3.Format+Query3.DevNull
Oct 26, 2018 7:53:51 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-26T19:53:50.120Z: Cleaning up.
Oct 26, 2018 7:53:51 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-26T19:53:50.223Z: Stopping worker pool...
Oct 26, 2018 7:53:52 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-26T19:53:52.278Z: Cleaning up.
Oct 26, 2018 7:53:52 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-26T19:53:52.397Z: Stopping worker pool...
Oct 26, 2018 7:54:00 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-26T19:53:58.431Z: Executing operation
Query5/Count.PerElement/Combine.perKey(Count)/GroupByKey/Close
Oct 26, 2018 7:54:00 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-26T19:53:58.518Z: Executing operation
Query5/Count.PerElement/Combine.perKey(Count)/GroupByKey/Read+Query5/Count.PerElement/Combine.perKey(Count)/Combine.GroupedValues+Query5/Query5.ToSingletons+Query5/Combine.globally(Anonymous)/WithKeys/AddKeys/Map+Query5/Combine.globally(Anonymous)/Combine.perKeyWithFanout(Anonymous)/AddNonce+Query5/Combine.globally(Anonymous)/Combine.perKeyWithFanout(Anonymous)/PrepareCold/Map+Query5/Combine.globally(Anonymous)/Combine.perKeyWithFanout(Anonymous)/PostCombine/GroupByKey/Reify+Query5/Combine.globally(Anonymous)/Combine.perKeyWithFanout(Anonymous)/PostCombine/GroupByKey/Write+Query5/Combine.globally(Anonymous)/Combine.perKeyWithFanout(Anonymous)/PreCombineHot/GroupByKey/Reify+Query5/Combine.globally(Anonymous)/Combine.perKeyWithFanout(Anonymous)/PreCombineHot/GroupByKey/Write
Oct 26, 2018 7:54:06 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-26T19:54:04.607Z: Executing operation
Query9/Query9/CoGroupByKey/GBK/Close
Oct 26, 2018 7:54:06 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-26T19:54:04.729Z: Executing operation
Query9/Query9/CoGroupByKey/GBK/Read+Query9/Query9/CoGroupByKey/GBK/GroupByWindow+Query9/Query9/CoGroupByKey/ConstructCoGbkResultFn+Query9/Query9/Query9.Join+Query9/Query9.Forget+Query9/Query9.Debug+Query9/Query9.Stamp+Query9.Format+Query9.DevNull
Oct 26, 2018 7:54:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-26T19:54:09.348Z: Executing operation
Query12/Count.PerElement/Combine.perKey(Count)/GroupByKey/Close
Oct 26, 2018 7:54:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-26T19:54:09.460Z: Executing operation
Query12/Count.PerElement/Combine.perKey(Count)/GroupByKey/Read+Query12/Count.PerElement/Combine.perKey(Count)/Combine.GroupedValues+Query12/Count.PerElement/Combine.perKey(Count)/Combine.GroupedValues/Extract+Query12/Query12.ToResult+Query12/Query12.Forget+Query12/Query12.Debug+Query12/Query12.Stamp+Query12.Format+Query12.DevNull
Oct 26, 2018 7:54:13 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-26T19:54:11.521Z: Executing operation
Query7/Combine.GloballyAsSingletonView/Combine.globally(MaxLong)/Combine.perKeyWithFanout(MaxLong)/PreCombineHot/GroupByKey/Close
Oct 26, 2018 7:54:13 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-26T19:54:11.628Z: Executing operation
Query7/Combine.GloballyAsSingletonView/Combine.globally(MaxLong)/Combine.perKeyWithFanout(MaxLong)/PreCombineHot/GroupByKey/Read+Query7/Combine.GloballyAsSingletonView/Combine.globally(MaxLong)/Combine.perKeyWithFanout(MaxLong)/PreCombineHot/Combine.GroupedValues+Query7/Combine.GloballyAsSingletonView/Combine.globally(MaxLong)/Combine.perKeyWithFanout(MaxLong)/PreCombineHot/Combine.GroupedValues/Extract+Query7/Combine.GloballyAsSingletonView/Combine.globally(MaxLong)/Combine.perKeyWithFanout(MaxLong)/StripNonce/Map+Query7/Combine.GloballyAsSingletonView/Combine.globally(MaxLong)/Combine.perKeyWithFanout(MaxLong)/Window.Remerge/Identity/Map+Query7/Combine.GloballyAsSingletonView/Combine.globally(MaxLong)/Combine.perKeyWithFanout(MaxLong)/PostCombine/GroupByKey+Query7/Combine.GloballyAsSingletonView/Combine.globally(MaxLong)/Combine.perKeyWithFanout(MaxLong)/PostCombine/Combine.GroupedValues/Partial+Query7/Combine.GloballyAsSingletonView/Combine.globally(MaxLong)/Combine.perKeyWithFanout(MaxLong)/PostCombine/GroupByKey/Reify+Query7/Combine.GloballyAsSingletonView/Combine.globally(MaxLong)/Combine.perKeyWithFanout(MaxLong)/PostCombine/GroupByKey/Write
Oct 26, 2018 7:54:15 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-26T19:54:15.265Z: Executing operation
Query4/Query4.WinningBids/CoGroupByKey/GBK/Close
Oct 26, 2018 7:54:16 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-26T19:54:15.500Z: Executing operation
Query4/Query4.WinningBids/CoGroupByKey/GBK/Read+Query4/Query4.WinningBids/CoGroupByKey/GBK/GroupByWindow+Query4/Query4.WinningBids/CoGroupByKey/ConstructCoGbkResultFn+Query4/Query4.WinningBids/Query4.WinningBids.Join+Query4/Query4.WinningBidsMonitor+Query4/Query4.Rekey+Query4/Window.Into()/Window.Assign+Query4/Combine.perKeyWithFanout(Mean)/AddNonce+Query4/Combine.perKeyWithFanout(Mean)/PrepareCold/Map+Query4/Combine.perKeyWithFanout(Mean)/PostCombine/GroupByKey/Reify+Query4/Combine.perKeyWithFanout(Mean)/PostCombine/GroupByKey/Write+Query4/Combine.perKeyWithFanout(Mean)/PreCombineHot/GroupByKey/Reify+Query4/Combine.perKeyWithFanout(Mean)/PreCombineHot/GroupByKey/Write
Oct 26, 2018 7:54:16 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-26T19:54:14.875Z: Executing operation
Query7/Combine.GloballyAsSingletonView/Combine.globally(MaxLong)/Combine.perKeyWithFanout(MaxLong)/PostCombine/GroupByKey/Close
Oct 26, 2018 7:54:16 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-26T19:54:15.161Z: Executing operation
Query7/Combine.GloballyAsSingletonView/Combine.globally(MaxLong)/Combine.perKeyWithFanout(MaxLong)/PostCombine/GroupByKey/Read+Query7/Combine.GloballyAsSingletonView/Combine.globally(MaxLong)/Combine.perKeyWithFanout(MaxLong)/PostCombine/Combine.GroupedValues+Query7/Combine.GloballyAsSingletonView/Combine.globally(MaxLong)/Combine.perKeyWithFanout(MaxLong)/PostCombine/Combine.GroupedValues/Extract+Query7/Combine.GloballyAsSingletonView/Combine.globally(MaxLong)/Values/Values/Map+Query7/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/ParDo(UseWindowHashAsKeyAndWindowAsSortKey)+Query7/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Write
Oct 26, 2018 7:54:16 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-26T19:54:15.838Z: Cleaning up.
Oct 26, 2018 7:54:16 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-26T19:54:15.945Z: Stopping worker pool...
Oct 26, 2018 7:54:17 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-26T19:54:16.906Z: Executing operation
Query5/Combine.globally(Anonymous)/Combine.perKeyWithFanout(Anonymous)/PreCombineHot/GroupByKey/Close
Oct 26, 2018 7:54:17 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-26T19:54:17.014Z: Executing operation
Query5/Combine.globally(Anonymous)/Combine.perKeyWithFanout(Anonymous)/PreCombineHot/GroupByKey/Read+Query5/Combine.globally(Anonymous)/Combine.perKeyWithFanout(Anonymous)/PreCombineHot/Combine.GroupedValues+Query5/Combine.globally(Anonymous)/Combine.perKeyWithFanout(Anonymous)/StripNonce/Map+Query5/Combine.globally(Anonymous)/Combine.perKeyWithFanout(Anonymous)/Window.Remerge/Identity/Map+Query5/Combine.globally(Anonymous)/Combine.perKeyWithFanout(Anonymous)/PostCombine/GroupByKey/Reify+Query5/Combine.globally(Anonymous)/Combine.perKeyWithFanout(Anonymous)/PostCombine/GroupByKey/Write
Oct 26, 2018 7:54:17 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-26T19:54:16.179Z: Executing operation
Query10/Query10.GroupByKey/Close
Oct 26, 2018 7:54:17 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-26T19:54:16.306Z: Executing operation
Query10/Query10.GroupByKey/Read+Query10/Query10.GroupByKey/GroupByWindow+Query10/Query10.CheckForLateEvents+Query10/Query10.UploadEvents+Query10/Query10.WindowLogFiles/Window.Assign+Query10/Query10.GroupByKey2/Reify+Query10/Query10.GroupByKey2/Write
Oct 26, 2018 7:54:18 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-26T19:54:17.184Z: Executing operation
Query7/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Close
Oct 26, 2018 7:54:18 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-26T19:54:17.288Z: Executing operation
Query7/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Read+Query7/Combine.GloballyAsSingletonView/ParDo(IsmRecordForSingularValuePerWindow)
Oct 26, 2018 7:54:22 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-26T19:54:20.848Z: Executing operation
Query7/Combine.GloballyAsSingletonView/CreateDataflowView
Oct 26, 2018 7:54:22 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-26T19:54:21.063Z: Executing operation
Query7/Query7.Select+Query7/Query7.Forget+Query7/Query7.Debug+Query7/Query7.Stamp+Query7.Format+Query7.DevNull
Oct 26, 2018 7:54:24 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-26T19:54:22.861Z: Executing operation
Query5/Combine.globally(Anonymous)/Combine.perKeyWithFanout(Anonymous)/PostCombine/GroupByKey/Close
Oct 26, 2018 7:54:24 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-26T19:54:22.982Z: Executing operation
Query5/Combine.globally(Anonymous)/Combine.perKeyWithFanout(Anonymous)/PostCombine/GroupByKey/Read+Query5/Combine.globally(Anonymous)/Combine.perKeyWithFanout(Anonymous)/PostCombine/Combine.GroupedValues+Query5/Combine.globally(Anonymous)/Values/Values/Map+Query5/Query5.Select+Query5/Query5.Forget+Query5/Query5.Debug+Query5/Query5.Stamp+Query5.Format+Query5.DevNull
Oct 26, 2018 7:54:24 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-26T19:54:22.682Z: Cleaning up.
Oct 26, 2018 7:54:24 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-26T19:54:22.790Z: Stopping worker pool...
Oct 26, 2018 7:54:26 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-26T19:54:24.500Z: Cleaning up.
Oct 26, 2018 7:54:26 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-26T19:54:24.609Z: Stopping worker pool...
Oct 26, 2018 7:54:26 PM org.apache.beam.runners.dataflow.DataflowPipelineJob
waitUntilFinish
WARNING: No terminal state was returned. State value RUNNING
2018-10-26T19:54:26.736Z Waiting for main pipeline to 'finish'
2018-10-26T19:54:26.761Z RUNNING Query10
Oct 26, 2018 7:54:26 PM org.apache.beam.runners.dataflow.DataflowPipelineJob
waitUntilFinish
WARNING: No terminal state was returned. State value RUNNING
2018-10-26T19:54:26.827Z Waiting for main pipeline to 'finish'
2018-10-26T19:54:26.855Z RUNNING Query6
==========================================================================================
Run started 2018-10-26T19:50:13.212Z and ran for PT253.655S
Exception in thread "main"
java.lang.RuntimeException: java.lang.NoClassDefFoundError:
org/apache/beam/repackaged/beam_sdks_java_test_utils/com/google/common/collect/Iterables
Default configuration:
{"debug":true,"query":0,"sourceType":"DIRECT","sinkType":"DEVNULL","exportSummaryToBigQuery":false,"pubSubMode":"COMBINED","numEvents":100000,"numEventGenerators":100,"rateShape":"SINE","firstEventRate":10000,"nextEventRate":10000,"rateUnit":"PER_SECOND","ratePeriodSec":600,"preloadSeconds":0,"streamTimeout":240,"isRateLimited":false,"useWallclockEventTime":false,"avgPersonByteSize":200,"avgAuctionByteSize":500,"avgBidByteSize":100,"hotAuctionRatio":2,"hotSellersRatio":4,"hotBiddersRatio":4,"windowSizeSec":10,"windowPeriodSec":5,"watermarkHoldbackSec":0,"numInFlightAuctions":100,"numActivePeople":1000,"coderStrategy":"HAND","cpuDelayMs":0,"diskBusyBytes":0,"auctionSkip":123,"fanout":5,"maxAuctionsWaitingTime":600,"occasionalDelaySec":3,"probDelayedEvent":0.1,"maxLogEvents":100000,"usePubsubPublishTime":false,"outOfOrderGroupSize":1}
at org.apache.beam.sdk.nexmark.Main.runAll(Main.java:144)
Configurations:
Conf Description
at org.apache.beam.sdk.nexmark.Main.main(Main.java:477)
0000 query:0; exportSummaryToBigQuery:true; numEvents:10000000
0001 query:1; exportSummaryToBigQuery:true; numEvents:10000000
0002 query:2; exportSummaryToBigQuery:true; numEvents:10000000
0003 query:3; exportSummaryToBigQuery:true; numEvents:10000000
0004 query:4; exportSummaryToBigQuery:true; numEvents:1000000
0005 query:5; exportSummaryToBigQuery:true; numEvents:10000000
0006 query:6; exportSummaryToBigQuery:true; numEvents:1000000
0007 query:7; exportSummaryToBigQuery:true; numEvents:10000000
0008 query:8; exportSummaryToBigQuery:true; numEvents:10000000
0009 query:9; exportSummaryToBigQuery:true; numEvents:1000000
0010 query:10; exportSummaryToBigQuery:true; numEvents:10000000
0011 query:11; exportSummaryToBigQuery:true; numEvents:10000000
0012 query:12; exportSummaryToBigQuery:true; numEvents:10000000
Performance:
Conf Runtime(sec) (Baseline) Events(/sec) (Baseline) Results
(Baseline)
0000 *** not run ***
0001 *** not run ***
0002 *** not run ***
0003 *** not run ***
0004 *** not run ***
0005 *** not run ***
0006 *** not run ***
0007 *** not run ***
0008 *** not run ***
0009 *** not run ***
0010 *** not run ***
0011 *** not run ***
0012 *** not run ***
==========================================================================================
Caused by: java.lang.NoClassDefFoundError:
org/apache/beam/repackaged/beam_sdks_java_test_utils/com/google/common/collect/Iterables
at
org.apache.beam.sdk.testutils.metrics.MetricsReader.checkIfMetricResultIsUnique(MetricsReader.java:128)
at
org.apache.beam.sdk.testutils.metrics.MetricsReader.getCounterMetric(MetricsReader.java:65)
at
org.apache.beam.sdk.nexmark.NexmarkLauncher.currentPerf(NexmarkLauncher.java:250)
at
org.apache.beam.sdk.nexmark.NexmarkLauncher.monitor(NexmarkLauncher.java:435)
at
org.apache.beam.sdk.nexmark.NexmarkLauncher.run(NexmarkLauncher.java:1156)
at org.apache.beam.sdk.nexmark.Main$Run.call(Main.java:108)
at org.apache.beam.sdk.nexmark.Main$Run.call(Main.java:96)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
Caused by: java.lang.ClassNotFoundException:
org.apache.beam.repackaged.beam_sdks_java_test_utils.com.google.common.collect.Iterables
at java.net.URLClassLoader.findClass(URLClassLoader.java:381)
at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:349)
at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
... 13 more
Oct 26, 2018 7:54:29 PM org.apache.beam.runners.dataflow.DataflowPipelineJob
waitUntilFinish
2018-10-26T19:54:29.317Z Waiting for main pipeline to 'finish'
WARNING: No terminal state was returned. State value RUNNING
2018-10-26T19:54:29.345Z RUNNING Query11
Oct 26, 2018 7:54:30 PM org.apache.beam.runners.dataflow.DataflowPipelineJob
waitUntilFinish
2018-10-26T19:54:30.872Z Waiting for main pipeline to 'finish'
WARNING: No terminal state was returned. State value RUNNING
2018-10-26T19:54:30.900Z RUNNING Query7
Oct 26, 2018 7:54:32 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-26T19:54:31.542Z: Executing operation
Query4/Combine.perKeyWithFanout(Mean)/PreCombineHot/GroupByKey/Close
Oct 26, 2018 7:54:32 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-26T19:54:31.645Z: Executing operation
Query4/Combine.perKeyWithFanout(Mean)/PreCombineHot/GroupByKey/Read+Query4/Combine.perKeyWithFanout(Mean)/PreCombineHot/Combine.GroupedValues+Query4/Combine.perKeyWithFanout(Mean)/StripNonce/Map+Query4/Combine.perKeyWithFanout(Mean)/Window.Remerge/Identity/Map+Query4/Combine.perKeyWithFanout(Mean)/PostCombine/GroupByKey/Reify+Query4/Combine.perKeyWithFanout(Mean)/PostCombine/GroupByKey/Write
Oct 26, 2018 7:54:33 PM org.apache.beam.runners.dataflow.DataflowPipelineJob
waitUntilFinish
2018-10-26T19:54:33.402Z Waiting for main pipeline to 'finish'
WARNING: No terminal state was returned. State value RUNNING
2018-10-26T19:54:33.428Z RUNNING Query0
Oct 26, 2018 7:54:34 PM org.apache.beam.runners.dataflow.DataflowPipelineJob
waitUntilFinish
2018-10-26T19:54:34.034Z Waiting for main pipeline to 'finish'
WARNING: No terminal state was returned. State value RUNNING
2018-10-26T19:54:34.058Z RUNNING Query3
2018-10-26T19:54:34.939Z Waiting for main pipeline to 'finish'
Oct 26, 2018 7:54:34 PM org.apache.beam.runners.dataflow.DataflowPipelineJob
waitUntilFinish
WARNING: No terminal state was returned. State value RUNNING
2018-10-26T19:54:34.963Z RUNNING Query5
Oct 26, 2018 7:54:35 PM org.apache.beam.runners.dataflow.DataflowPipelineJob
waitUntilFinish
2018-10-26T19:54:35.114Z Waiting for main pipeline to 'finish'
WARNING: No terminal state was returned. State value RUNNING
2018-10-26T19:54:35.142Z RUNNING Query1
Oct 26, 2018 7:54:35 PM org.apache.beam.runners.dataflow.DataflowPipelineJob
waitUntilFinish
WARNING: No terminal state was returned. State value RUNNING
2018-10-26T19:54:35.223Z Waiting for main pipeline to 'finish'
2018-10-26T19:54:35.250Z RUNNING Query12
Oct 26, 2018 7:54:35 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-26T19:54:35.286Z: Executing operation
Query4/Combine.perKeyWithFanout(Mean)/PostCombine/GroupByKey/Close
Oct 26, 2018 7:54:35 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-26T19:54:35.383Z: Executing operation
Query4/Combine.perKeyWithFanout(Mean)/PostCombine/GroupByKey/Read+Query4/Combine.perKeyWithFanout(Mean)/PostCombine/Combine.GroupedValues+Query4/Query4.Project+Query4/Query4.Forget+Query4/Query4.Debug+Query4/Query4.Stamp+Query4.Format+Query4.DevNull
Oct 26, 2018 7:54:37 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-26T19:54:37.319Z: Cleaning up.
Oct 26, 2018 7:54:37 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-26T19:54:37.426Z: Stopping worker pool...
Oct 26, 2018 7:54:38 PM org.apache.beam.runners.dataflow.DataflowPipelineJob
waitUntilFinish
2018-10-26T19:54:38.567Z Waiting for main pipeline to 'finish'
WARNING: No terminal state was returned. State value RUNNING
2018-10-26T19:54:38.594Z RUNNING Query8
Oct 26, 2018 7:54:39 PM org.apache.beam.runners.dataflow.DataflowPipelineJob
waitUntilFinish
2018-10-26T19:54:39.435Z Waiting for main pipeline to 'finish'
WARNING: No terminal state was returned. State value RUNNING
2018-10-26T19:54:39.461Z RUNNING Query2
Oct 26, 2018 7:54:42 PM org.apache.beam.runners.dataflow.DataflowPipelineJob
waitUntilFinish
2018-10-26T19:54:42.225Z Waiting for main pipeline to 'finish'
WARNING: No terminal state was returned. State value RUNNING
2018-10-26T19:54:42.251Z RUNNING Query9
Oct 26, 2018 7:54:42 PM org.apache.beam.runners.dataflow.DataflowPipelineJob
waitUntilFinish
2018-10-26T19:54:42.284Z Waiting for main pipeline to 'finish'
WARNING: No terminal state was returned. State value RUNNING
2018-10-26T19:54:42.311Z RUNNING Query4
> Task :beam-sdks-java-nexmark:run FAILED
:beam-sdks-java-nexmark:run (Thread[Task worker for ':' Thread 11,5,main])
completed. Took 4 mins 30.302 secs.
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':beam-sdks-java-nexmark:run'.
> Process 'command '/usr/local/asfpackages/java/jdk1.8.0_172/bin/java''
> finished with non-zero exit value 1
* 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 5.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See
https://docs.gradle.org/4.10.2/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 7m 28s
68 actionable tasks: 64 executed, 4 from cache
Publishing build scan...
https://gradle.com/s/vjkiys2xc3age
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]
