See 
<https://builds.apache.org/job/beam_PostCommit_Java_Nexmark_Dataflow/229/display/redirect?page=changes>

Changes:

[jxlewis] Add Amazon SqsIO

------------------------------------------
[...truncated 1.45 MB...]
Aug 22, 2018 9:00:27 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
savePerfsToBigQuery/BatchLoads/TempFilePrefixView/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Values/Values/Map
 as step s24
Aug 22, 2018 9:00:27 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
savePerfsToBigQuery/BatchLoads/TempFilePrefixView/Combine.GloballyAsSingletonView/View.VoidKeyToMultimapMaterialization/ParDo(VoidKeyToMultimapMaterialization)
 as step s25
Aug 22, 2018 9:00:27 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
savePerfsToBigQuery/BatchLoads/TempFilePrefixView/Combine.GloballyAsSingletonView/View.CreatePCollectionView/Combine.globally(Concatenate)/WithKeys/AddKeys/Map
 as step s26
Aug 22, 2018 9:00:27 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
savePerfsToBigQuery/BatchLoads/TempFilePrefixView/Combine.GloballyAsSingletonView/View.CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/GroupByKey
 as step s27
Aug 22, 2018 9:00:27 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
savePerfsToBigQuery/BatchLoads/TempFilePrefixView/Combine.GloballyAsSingletonView/View.CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/Combine.GroupedValues
 as step s28
Aug 22, 2018 9:00:27 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
savePerfsToBigQuery/BatchLoads/TempFilePrefixView/Combine.GloballyAsSingletonView/View.CreatePCollectionView/Combine.globally(Concatenate)/Values/Values/Map
 as step s29
Aug 22, 2018 9:00:27 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
savePerfsToBigQuery/BatchLoads/TempFilePrefixView/Combine.GloballyAsSingletonView/View.CreatePCollectionView/ParDo(StreamingPCollectionViewWriter)
 as step s30
Aug 22, 2018 9:00:27 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
savePerfsToBigQuery/BatchLoads/TempFilePrefixView/Combine.GloballyAsSingletonView/View.CreatePCollectionView/CreateDataflowView
 as step s31
Aug 22, 2018 9:00:27 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding savePerfsToBigQuery/BatchLoads/rewindowIntoGlobal/Window.Assign as 
step s32
Aug 22, 2018 9:00:27 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding savePerfsToBigQuery/BatchLoads/WriteBundlesToFiles as step s33
Aug 22, 2018 9:00:27 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding savePerfsToBigQuery/BatchLoads/GroupByDestination as step s34
Aug 22, 2018 9:00:27 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding savePerfsToBigQuery/BatchLoads/WriteGroupedRecords as step s35
Aug 22, 2018 9:00:27 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding savePerfsToBigQuery/BatchLoads/FlattenFiles as step s36
Aug 22, 2018 9:00:27 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
savePerfsToBigQuery/BatchLoads/ReifyResults/View.AsIterable/View.VoidKeyToMultimapMaterialization/ParDo(VoidKeyToMultimapMaterialization)
 as step s37
Aug 22, 2018 9:00:27 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
savePerfsToBigQuery/BatchLoads/ReifyResults/View.AsIterable/View.CreatePCollectionView/Combine.globally(Concatenate)/WithKeys/AddKeys/Map
 as step s38
Aug 22, 2018 9:00:27 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
savePerfsToBigQuery/BatchLoads/ReifyResults/View.AsIterable/View.CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/GroupByKey
 as step s39
Aug 22, 2018 9:00:27 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
savePerfsToBigQuery/BatchLoads/ReifyResults/View.AsIterable/View.CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/Combine.GroupedValues
 as step s40
Aug 22, 2018 9:00:27 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
savePerfsToBigQuery/BatchLoads/ReifyResults/View.AsIterable/View.CreatePCollectionView/Combine.globally(Concatenate)/Values/Values/Map
 as step s41
Aug 22, 2018 9:00:27 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
savePerfsToBigQuery/BatchLoads/ReifyResults/View.AsIterable/View.CreatePCollectionView/ParDo(StreamingPCollectionViewWriter)
 as step s42
Aug 22, 2018 9:00:27 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
savePerfsToBigQuery/BatchLoads/ReifyResults/View.AsIterable/View.CreatePCollectionView/CreateDataflowView
 as step s43
Aug 22, 2018 9:00:27 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
savePerfsToBigQuery/BatchLoads/ReifyResults/Create.Values/Read(CreateSource)/Read(CreateSource)/Read(BoundedToUnboundedSourceAdapter)/DataflowRunner.StreamingUnboundedRead.ReadWithIds
 as step s44
Aug 22, 2018 9:00:27 PM 
org.apache.beam.runners.core.construction.UnboundedReadFromBoundedSource$BoundedToUnboundedSourceAdapter
 split
WARNING: BoundedSource [0, 1) cannot estimate its size, skips the initial 
splits.
Aug 22, 2018 9:00:27 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
savePerfsToBigQuery/BatchLoads/ReifyResults/Create.Values/Read(CreateSource)/Read(CreateSource)/Read(BoundedToUnboundedSourceAdapter)/StripIds
 as step s45
Aug 22, 2018 9:00:27 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding savePerfsToBigQuery/BatchLoads/ReifyResults/ParDo(Anonymous) as 
step s46
Aug 22, 2018 9:00:27 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding savePerfsToBigQuery/BatchLoads/WritePartitionUntriggered as step 
s47
Aug 22, 2018 9:00:27 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
savePerfsToBigQuery/BatchLoads/MultiPartitionsReshuffle/Window.Into()/Window.Assign
 as step s48
Aug 22, 2018 9:00:27 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding savePerfsToBigQuery/BatchLoads/MultiPartitionsReshuffle/GroupByKey 
as step s49
Aug 22, 2018 9:00:27 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
savePerfsToBigQuery/BatchLoads/MultiPartitionsReshuffle/ExpandIterable as step 
s50
Aug 22, 2018 9:00:27 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
savePerfsToBigQuery/BatchLoads/MultiPartitionsWriteTables/ParMultiDo(WriteTables)
 as step s51
Aug 22, 2018 9:00:27 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
savePerfsToBigQuery/BatchLoads/MultiPartitionsWriteTables/WithKeys/AddKeys/Map 
as step s52
Aug 22, 2018 9:00:27 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
savePerfsToBigQuery/BatchLoads/MultiPartitionsWriteTables/Window.Into()/Window.Assign
 as step s53
Aug 22, 2018 9:00:27 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
savePerfsToBigQuery/BatchLoads/MultiPartitionsWriteTables/GroupByKey as step s54
Aug 22, 2018 9:00:27 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
savePerfsToBigQuery/BatchLoads/MultiPartitionsWriteTables/Values/Values/Map as 
step s55
Aug 22, 2018 9:00:27 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
savePerfsToBigQuery/BatchLoads/MultiPartitionsWriteTables/ParDo(GarbageCollectTemporaryFiles)
 as step s56
Aug 22, 2018 9:00:27 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
savePerfsToBigQuery/BatchLoads/ReifyRenameInput/View.AsIterable/View.VoidKeyToMultimapMaterialization/ParDo(VoidKeyToMultimapMaterialization)
 as step s57
Aug 22, 2018 9:00:27 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
savePerfsToBigQuery/BatchLoads/ReifyRenameInput/View.AsIterable/View.CreatePCollectionView/Combine.globally(Concatenate)/WithKeys/AddKeys/Map
 as step s58
Aug 22, 2018 9:00:27 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
savePerfsToBigQuery/BatchLoads/ReifyRenameInput/View.AsIterable/View.CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/GroupByKey
 as step s59
Aug 22, 2018 9:00:27 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
savePerfsToBigQuery/BatchLoads/ReifyRenameInput/View.AsIterable/View.CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/Combine.GroupedValues
 as step s60
Aug 22, 2018 9:00:27 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
savePerfsToBigQuery/BatchLoads/ReifyRenameInput/View.AsIterable/View.CreatePCollectionView/Combine.globally(Concatenate)/Values/Values/Map
 as step s61
Aug 22, 2018 9:00:27 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
savePerfsToBigQuery/BatchLoads/ReifyRenameInput/View.AsIterable/View.CreatePCollectionView/ParDo(StreamingPCollectionViewWriter)
 as step s62
Aug 22, 2018 9:00:27 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
savePerfsToBigQuery/BatchLoads/ReifyRenameInput/View.AsIterable/View.CreatePCollectionView/CreateDataflowView
 as step s63
Aug 22, 2018 9:00:27 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
savePerfsToBigQuery/BatchLoads/ReifyRenameInput/Create.Values/Read(CreateSource)/Read(CreateSource)/Read(BoundedToUnboundedSourceAdapter)/DataflowRunner.StreamingUnboundedRead.ReadWithIds
 as step s64
Aug 22, 2018 9:00:27 PM 
org.apache.beam.runners.core.construction.UnboundedReadFromBoundedSource$BoundedToUnboundedSourceAdapter
 split
WARNING: BoundedSource [0, 1) cannot estimate its size, skips the initial 
splits.
Aug 22, 2018 9:00:27 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
savePerfsToBigQuery/BatchLoads/ReifyRenameInput/Create.Values/Read(CreateSource)/Read(CreateSource)/Read(BoundedToUnboundedSourceAdapter)/StripIds
 as step s65
Aug 22, 2018 9:00:27 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding savePerfsToBigQuery/BatchLoads/ReifyRenameInput/ParDo(Anonymous) 
as step s66
Aug 22, 2018 9:00:27 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding savePerfsToBigQuery/BatchLoads/WriteRenameUntriggered as step s67
Aug 22, 2018 9:00:27 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
savePerfsToBigQuery/BatchLoads/SinglePartitionsReshuffle/Window.Into()/Window.Assign
 as step s68
Aug 22, 2018 9:00:27 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
savePerfsToBigQuery/BatchLoads/SinglePartitionsReshuffle/GroupByKey as step s69
Aug 22, 2018 9:00:27 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
savePerfsToBigQuery/BatchLoads/SinglePartitionsReshuffle/ExpandIterable as step 
s70
Aug 22, 2018 9:00:27 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
savePerfsToBigQuery/BatchLoads/SinglePartitionWriteTables/ParMultiDo(WriteTables)
 as step s71
Aug 22, 2018 9:00:27 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
savePerfsToBigQuery/BatchLoads/SinglePartitionWriteTables/WithKeys/AddKeys/Map 
as step s72
Aug 22, 2018 9:00:27 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
savePerfsToBigQuery/BatchLoads/SinglePartitionWriteTables/Window.Into()/Window.Assign
 as step s73
Aug 22, 2018 9:00:27 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
savePerfsToBigQuery/BatchLoads/SinglePartitionWriteTables/GroupByKey as step s74
Aug 22, 2018 9:00:27 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
savePerfsToBigQuery/BatchLoads/SinglePartitionWriteTables/Values/Values/Map as 
step s75
Aug 22, 2018 9:00:27 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
savePerfsToBigQuery/BatchLoads/SinglePartitionWriteTables/ParDo(GarbageCollectTemporaryFiles)
 as step s76
Aug 22, 2018 9:00:27 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
savePerfsToBigQuery/BatchLoads/CreateEmptyFailedInserts/Read(CreateSource)/Read(CreateSource)/Read(BoundedToUnboundedSourceAdapter)/DataflowRunner.StreamingUnboundedRead.ReadWithIds
 as step s77
Aug 22, 2018 9:00:27 PM 
org.apache.beam.runners.core.construction.UnboundedReadFromBoundedSource$BoundedToUnboundedSourceAdapter
 split
WARNING: BoundedSource [0, 0) cannot estimate its size, skips the initial 
splits.
Aug 22, 2018 9:00:27 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
savePerfsToBigQuery/BatchLoads/CreateEmptyFailedInserts/Read(CreateSource)/Read(CreateSource)/Read(BoundedToUnboundedSourceAdapter)/StripIds
 as step s78
Aug 22, 2018 9:00:27 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding DropInputs as step s79
Aug 22, 2018 9:00:27 PM org.apache.beam.runners.dataflow.DataflowRunner run
INFO: Staging pipeline description to 
gs://temp-storage-for-perf-tests/nexmark/staging/
Aug 22, 2018 9:00:27 PM org.apache.beam.runners.dataflow.util.PackageUtil 
tryStagePackage
INFO: Uploading <265581 bytes, hash Cr1Em80f6CQqP8Hea_pVgw> to 
gs://temp-storage-for-perf-tests/nexmark/staging/pipeline-Cr1Em80f6CQqP8Hea_pVgw.pb
Dataflow SDK version: 2.7.0-SNAPSHOT
Submitted job: 2018-08-22_14_00_27-17087640727311164007
Aug 22, 2018 9:00:28 PM org.apache.beam.runners.dataflow.DataflowRunner run
INFO: To access the Dataflow monitoring console, please navigate to 
https://console.cloud.google.com/dataflow/jobsDetail/locations/us-central1/jobs/2018-08-22_14_00_27-17087640727311164007?project=apache-beam-testing
Aug 22, 2018 9:00:28 PM org.apache.beam.runners.dataflow.DataflowRunner run
INFO: To cancel the job using the 'gcloud' tool, run:
> gcloud dataflow jobs --project=apache-beam-testing cancel 
> --region=us-central1 2018-08-22_14_00_27-17087640727311164007

==========================================================================================
Run started 2018-08-22T20:28:07.717Z and ran for PT1941.152S

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}

Configurations:
  Conf  Description
  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          30.2                    331268.4                    10000000    
          
  0001          31.3                    319254.2                     9200000    
          
  0002          10.0                   1003411.6                       83527    
          
  0003          54.7                    182965.9                       59431    
          
  0004          65.0                     15373.7                         140    
          
  0005         130.9                     76378.4                        4567    
          
  0006          51.4                     19443.5                       13811    
          
  0007         120.1                     83281.3                         100    
          
  0008          49.0                    204060.8                       92833    
          
  0009          51.9                     19270.8                       32548    
          
  0010         117.3                     85235.5                         100    
          
  0011         216.2                     46245.1                     1839657    
          
  0012         176.7                     56577.4                      587467    
          
        *** Streaming query was stuck for 10 min ***
        *** Streaming query was stuck for 10 min ***
        *** Streaming query was stuck for 10 min ***
        *** Streaming query was stuck for 10 min ***
        *** Streaming query was stuck for 11 min ***
        *** Streaming query was stuck for 11 min ***
        *** Streaming query was stuck for 11 min ***
        *** Streaming query was stuck for 11 min ***
        *** Streaming query was stuck for 12 min ***
        *** Streaming query was stuck for 12 min ***
        *** Streaming query was stuck for 12 min ***
        *** Streaming query was stuck for 12 min ***
        *** Streaming query was stuck for 13 min ***
        *** Streaming query was stuck for 13 min ***
        *** Streaming query was stuck for 13 min ***
        *** Streaming query was stuck for 14 min ***
        *** Streaming query was stuck for 14 min ***
        *** Streaming query was stuck for 14 min ***
        *** Streaming query was stuck for 14 min ***
        *** Streaming query was stuck for 15 min ***
        *** Streaming query was stuck for 15 min ***
        *** Streaming query was stuck for 15 min ***
        *** Streaming query was stuck for 15 min ***
        *** Streaming query was stuck for 16 min ***
        *** Streaming query was stuck for 16 min ***
        *** Streaming query was stuck for 16 min ***
        *** Streaming query was stuck for 16 min ***
        *** Streaming query was stuck for 17 min ***
        *** Streaming query was stuck for 17 min ***
        *** Streaming query was stuck for 17 min ***
        *** Streaming query was stuck for 17 min ***
        *** Streaming query was stuck for 18 min ***
        *** Streaming query was stuck for 18 min ***
Exception in thread "main"         *** Streaming query was stuck for 18 min ***
        *** Streaming query was stuck for 18 min ***
        *** Streaming query was stuck for 19 min ***
        *** Streaming query was stuck for 19 min ***
        *** Streaming query was stuck for 19 min ***
        *** Streaming query was stuck for 20 min ***
        *** Streaming query was stuck for 20 min ***
        *** Streaming query was stuck for 20 min ***
        *** Streaming query was stuck for 20 min ***
        *** Streaming query was stuck for 21 min ***
        *** Streaming query was stuck for 21 min ***
        *** Streaming query was stuck for 21 min ***
        *** Streaming query was stuck for 21 min ***
        *** Streaming query was stuck for 22 min ***
        *** Streaming query was stuck for 22 min ***
        *** Streaming query was stuck for 22 min ***
        *** Streaming query was stuck for 22 min ***
        *** Streaming query was stuck for 23 min ***
==========================================================================================

java.lang.RuntimeException: Execution was not successful
        at org.apache.beam.sdk.nexmark.Main.runAll(Main.java:174)
        at org.apache.beam.sdk.nexmark.Main.main(Main.java:477)

> Task :beam-sdks-java-nexmark:run FAILED
:beam-sdks-java-nexmark:run (Thread[Task worker for ':' Thread 8,5,main]) 
completed. Took 32 mins 22.036 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_152/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.
See 
https://docs.gradle.org/4.8/userguide/command_line_interface.html#sec:command_line_warnings

BUILD FAILED in 34m 15s
65 actionable tasks: 15 executed, 50 up-to-date

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

Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure

Reply via email to