See
<https://builds.apache.org/job/beam_PostCommit_Java_Nexmark_Flink/1/display/redirect>
------------------------------------------
[...truncated 3.33 MB...]
INFO: CHAIN MapPartition (MapPartition at
Query12/Query12.Debug/ParMultiDo(Monitor)) -> FlatMap (FlatMap at
Query12/Query12.Debug/ParMultiDo(Monitor).output) (1/1)
(7cc31d298b3ba691fe13e50bfcf77c79) switched from RUNNING to FINISHED.
Jun 19, 2018 5:17:58 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: CHAIN MapPartition (MapPartition at
Query12/Query12.Stamp/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
Query12/Query12.Stamp/ParMultiDo(Anonymous).output) (1/1)
(bf733e662d84bee4e450ef2630d077f2) switched from RUNNING to FINISHED.
Jun 19, 2018 5:17:58 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: CHAIN MapPartition (MapPartition at Query12.Format/ParMultiDo(Anonymous))
-> FlatMap (FlatMap at Query12.Format/ParMultiDo(Anonymous).output) (1/1)
(6c315c26248748bebad39ea6ab96b396) switched from RUNNING to FINISHED.
Jun 19, 2018 5:17:58 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for CHAIN MapPartition (MapPartition at
Query12.Format/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
Query12.Format/ParMultiDo(Anonymous).output) (1/1)
(6c315c26248748bebad39ea6ab96b396).
Jun 19, 2018 5:17:58 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Ensuring all FileSystem streams are closed for task CHAIN MapPartition
(MapPartition at Query12.Format/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
Query12.Format/ParMultiDo(Anonymous).output) (1/1)
(6c315c26248748bebad39ea6ab96b396) [FINISHED]
Jun 19, 2018 5:17:58 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task CHAIN MapPartition (MapPartition at
Query12.Format/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
Query12.Format/ParMultiDo(Anonymous).output) 6c315c26248748bebad39ea6ab96b396.
Jun 19, 2018 5:17:58 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: CHAIN MapPartition (MapPartition at
Query12.DevNull/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
Query12.DevNull/ParMultiDo(Anonymous).output) (1/1)
(83dab818d449b8cd3688ac062feacda8) switched from RUNNING to FINISHED.
Jun 19, 2018 5:17:58 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for CHAIN MapPartition (MapPartition at
Query12.DevNull/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
Query12.DevNull/ParMultiDo(Anonymous).output) (1/1)
(83dab818d449b8cd3688ac062feacda8).
Jun 19, 2018 5:17:58 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Ensuring all FileSystem streams are closed for task CHAIN MapPartition
(MapPartition at Query12.DevNull/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
Query12.DevNull/ParMultiDo(Anonymous).output) (1/1)
(83dab818d449b8cd3688ac062feacda8) [FINISHED]
Jun 19, 2018 5:17:58 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task CHAIN MapPartition (MapPartition at
Query12.DevNull/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
Query12.DevNull/ParMultiDo(Anonymous).output) 83dab818d449b8cd3688ac062feacda8.
Jun 19, 2018 5:17:58 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3ce067bd)
(1/1) (138f80807811a16fe0cf01eeafb5f80d) switched from CREATED to SCHEDULED.
Jun 19, 2018 5:17:58 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: CHAIN MapPartition (MapPartition at Query12.Format/ParMultiDo(Anonymous))
-> FlatMap (FlatMap at Query12.Format/ParMultiDo(Anonymous).output) (1/1)
(6c315c26248748bebad39ea6ab96b396) switched from RUNNING to FINISHED.
Jun 19, 2018 5:17:58 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3ce067bd)
(1/1) (138f80807811a16fe0cf01eeafb5f80d) switched from SCHEDULED to DEPLOYING.
Jun 19, 2018 5:17:58 PM org.apache.flink.runtime.executiongraph.Execution deploy
INFO: Deploying DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3ce067bd) (1/1) (attempt
#0) to localhost
Jun 19, 2018 5:17:58 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: CHAIN MapPartition (MapPartition at
Query12.DevNull/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
Query12.DevNull/ParMultiDo(Anonymous).output) (1/1)
(83dab818d449b8cd3688ac062feacda8) switched from RUNNING to FINISHED.
Jun 19, 2018 5:17:58 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
submitTask
INFO: Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3ce067bd) (1/1).
Jun 19, 2018 5:17:58 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3ce067bd)
(1/1) (138f80807811a16fe0cf01eeafb5f80d) switched from CREATED to DEPLOYING.
Jun 19, 2018 5:17:58 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Creating FileSystem stream leak safety net for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3ce067bd) (1/1)
(138f80807811a16fe0cf01eeafb5f80d) [DEPLOYING]
Jun 19, 2018 5:17:58 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Loading JAR files for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3ce067bd) (1/1)
(138f80807811a16fe0cf01eeafb5f80d) [DEPLOYING].
Jun 19, 2018 5:17:58 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Registering task at network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3ce067bd) (1/1)
(138f80807811a16fe0cf01eeafb5f80d) [DEPLOYING].
Jun 19, 2018 5:17:58 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3ce067bd)
(1/1) (138f80807811a16fe0cf01eeafb5f80d) switched from DEPLOYING to RUNNING.
Jun 19, 2018 5:17:58 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3ce067bd)
(1/1) (138f80807811a16fe0cf01eeafb5f80d) switched from DEPLOYING to RUNNING.
Jun 19, 2018 5:17:58 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3ce067bd)
(1/1) (138f80807811a16fe0cf01eeafb5f80d) switched from RUNNING to FINISHED.
Jun 19, 2018 5:17:58 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3ce067bd) (1/1)
(138f80807811a16fe0cf01eeafb5f80d).
Jun 19, 2018 5:17:58 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Ensuring all FileSystem streams are closed for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3ce067bd) (1/1)
(138f80807811a16fe0cf01eeafb5f80d) [FINISHED]
Jun 19, 2018 5:17:58 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3ce067bd)
138f80807811a16fe0cf01eeafb5f80d.
Jun 19, 2018 5:17:58 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3ce067bd)
(1/1) (138f80807811a16fe0cf01eeafb5f80d) switched from RUNNING to FINISHED.
Jun 19, 2018 5:17:58 PM org.apache.flink.runtime.executiongraph.ExecutionGraph
transitionState
INFO: Job main-jenkins-0619171616-a7cf5a05 (77b1e673d219349a2a03a5df241f2e62)
switched from state RUNNING to FINISHED.
Jun 19, 2018 5:17:58 PM org.apache.flink.runtime.dispatcher.Dispatcher
jobReachedGloballyTerminalState
INFO: Job 77b1e673d219349a2a03a5df241f2e62 reached globally terminal state
FINISHED.
Jun 19, 2018 5:17:58 PM org.apache.flink.runtime.jobmaster.JobMaster postStop
INFO: Stopping the JobMaster for job
main-jenkins-0619171616-a7cf5a05(77b1e673d219349a2a03a5df241f2e62).
Jun 19, 2018 5:17:58 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
closeJobManagerConnection
INFO: Close JobManager connection for job 77b1e673d219349a2a03a5df241f2e62.
Jun 19, 2018 5:17:58 PM org.apache.flink.runtime.jobmaster.JobMaster
dissolveResourceManagerConnection
INFO: Close ResourceManager connection 3338e50a9f8dd6d99c12ef1515523a80:
JobManager is shutting down..
Jun 19, 2018 5:17:58 PM org.apache.flink.runtime.jobmaster.slotpool.SlotPool
suspend
INFO: Suspending SlotPool.
Jun 19, 2018 5:17:58 PM
org.apache.flink.runtime.resourcemanager.ResourceManager
closeJobManagerConnection
INFO: Disconnect job manager
a9e71b791fd01f6d368381fb6bc24956@akka://flink/user/jobmanager_25 for job
77b1e673d219349a2a03a5df241f2e62 from the resource manager.
Jun 19, 2018 5:17:58 PM org.apache.flink.runtime.jobmaster.slotpool.SlotPool
postStop
INFO: Stopping SlotPool.
Jun 19, 2018 5:17:58 PM org.apache.flink.runtime.minicluster.MiniCluster
closeAsync
INFO: Shutting down Flink Mini Cluster
Jun 19, 2018 5:17:58 PM org.apache.flink.runtime.rest.RestServerEndpoint
closeAsync
INFO: Shutting down rest endpoint.
Jun 19, 2018 5:17:58 PM org.apache.flink.runtime.dispatcher.Dispatcher postStop
INFO: Stopping dispatcher
akka://flink/user/dispatcher6167e33f-f8b6-4e99-99a9-ecdd05006016.
Jun 19, 2018 5:17:58 PM org.apache.flink.runtime.dispatcher.Dispatcher
terminateJobManagerRunners
INFO: Stopping all currently running jobs of dispatcher
akka://flink/user/dispatcher6167e33f-f8b6-4e99-99a9-ecdd05006016.
Jun 19, 2018 5:17:58 PM
org.apache.flink.runtime.taskexecutor.TaskExecutor$JobLeaderListenerImpl
jobManagerLostLeadership
INFO: JobManager for job 77b1e673d219349a2a03a5df241f2e62 with leader id
a9e71b791fd01f6d368381fb6bc24956 lost leadership.
Jun 19, 2018 5:17:58 PM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager close
INFO: Closing the SlotManager.
Jun 19, 2018 5:17:58 PM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager suspend
INFO: Suspending the SlotManager.
Jun 19, 2018 5:17:58 PM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable freeSlot
INFO: Free slot TaskSlot(index:0, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
e86cb402c1dc7dcd62e871e924199b20, jobId: 77b1e673d219349a2a03a5df241f2e62).
Jun 19, 2018 5:17:58 PM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager
unregisterTaskManager
INFO: Unregister TaskManager 0e769fb1f7c828bb598b13515ddcd803 from the
SlotManager.
Jun 19, 2018 5:17:58 PM org.apache.flink.runtime.taskexecutor.JobLeaderService
removeJob
INFO: Remove job 77b1e673d219349a2a03a5df241f2e62 from job leader monitoring.
Jun 19, 2018 5:17:58 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
closeJobManagerConnection
INFO: Close JobManager connection for job 77b1e673d219349a2a03a5df241f2e62.
Jun 19, 2018 5:17:58 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
postStop
INFO: Stopping TaskExecutor akka://flink/user/taskmanager_24.
Jun 19, 2018 5:17:58 PM
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager shutdown
INFO: Shutting down TaskExecutorLocalStateStoresManager.
Jun 19, 2018 5:17:58 PM
org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator
shutDown
INFO: Shutting down stack trace sample coordinator.
Jun 19, 2018 5:17:58 PM org.apache.flink.runtime.dispatcher.Dispatcher
lambda$postStop$0
INFO: Stopped dispatcher
akka://flink/user/dispatcher6167e33f-f8b6-4e99-99a9-ecdd05006016.
Jun 19, 2018 5:17:58 PM org.apache.flink.runtime.io.disk.iomanager.IOManager
shutdown
INFO: I/O manager removed spill file directory
/tmp/flink-io-4c8d5838-ca64-4555-a23f-94851c383ee8
Jun 19, 2018 5:17:58 PM org.apache.flink.runtime.io.network.NetworkEnvironment
shutdown
INFO: Shutting down the network environment and its components.
Jun 19, 2018 5:17:58 PM org.apache.flink.runtime.webmonitor.WebMonitorEndpoint
lambda$shutDownInternal$4
INFO: Removing cache directory /tmp/flink-web-ui
Jun 19, 2018 5:17:58 PM org.apache.flink.runtime.taskexecutor.JobLeaderService
stop
INFO: Stop job leader service.
Jun 19, 2018 5:17:58 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
postStop
INFO: Stopped TaskExecutor akka://flink/user/taskmanager_24.
Jun 19, 2018 5:17:58 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService
stopService
INFO: Stopping Akka RPC service.
Jun 19, 2018 5:17:58 PM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Jun 19, 2018 5:17:58 PM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Jun 19, 2018 5:17:58 PM org.apache.flink.runtime.blob.BlobServer close
INFO: Stopped BLOB server at 0.0.0.0:40201
Jun 19, 2018 5:17:58 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService
lambda$stopService$4
INFO: Stopped Akka RPC service.
Jun 19, 2018 5:17:58 PM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: Execution finished in 6795 msecs
Jun 19, 2018 5:17:58 PM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: Final accumulator values:
Jun 19, 2018 5:17:58 PM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: __metricscontainers :
org.apache.beam.runners.core.metrics.MetricsContainerStepMap@ea391e7d
2018-06-19T17:17:58.194Z Waiting for main pipeline to 'finish'
2018-06-19T17:17:58.194Z DONE Query12
==========================================================================================
Run started 2018-06-19T17:16:13.838Z and ran for PT104.356S
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; streamTimeout:60
0001 query:1; exportSummaryToBigQuery:true; streamTimeout:60
0002 query:2; exportSummaryToBigQuery:true; streamTimeout:60
0003 query:3; exportSummaryToBigQuery:true; streamTimeout:60
0004 query:4; exportSummaryToBigQuery:true; numEvents:10000; streamTimeout:60
0005 query:5; exportSummaryToBigQuery:true; streamTimeout:60
0006 query:6; exportSummaryToBigQuery:true; numEvents:10000; streamTimeout:60
0007 query:7; exportSummaryToBigQuery:true; streamTimeout:60
0008 query:8; exportSummaryToBigQuery:true; streamTimeout:60
0009 query:9; exportSummaryToBigQuery:true; numEvents:10000; streamTimeout:60
0010 query:10; exportSummaryToBigQuery:true; streamTimeout:60
0011 query:11; exportSummaryToBigQuery:true; streamTimeout:60
0012 query:12; exportSummaryToBigQuery:true; streamTimeout:60
Performance:
Conf Runtime(sec) (Baseline) Events(/sec) (Baseline) Results
(Baseline)
0000 1.6 62932.7 100000
0001 1.0 97847.4 92000
0002 0.6 157728.7 351
0003 13.3 7513.7 580
0004 7.3 1361.3 40
0005 6.7 14954.4 12
0006 6.2 1603.1 103
0007 7.9 12737.2 1
0008 9.0 11119.8 6000
0009 6.3 1597.2 298
0010 6.9 14394.7 1
0011 8.8 11312.2 1919
0012 6.7 14821.4 1919
==========================================================================================
==========================================================================================
Run started 2018-06-19T17:16:13.838Z and ran for PT104.959S
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}
Exception in thread "main"
Configurations:
Conf Description
0000 query:0; exportSummaryToBigQuery:true; streamTimeout:60
0001 query:1; exportSummaryToBigQuery:true; streamTimeout:60
0002 query:2; exportSummaryToBigQuery:true; streamTimeout:60
0003 query:3; exportSummaryToBigQuery:true; streamTimeout:60
0004 query:4; exportSummaryToBigQuery:true; numEvents:10000; streamTimeout:60
0005 query:5; exportSummaryToBigQuery:true; streamTimeout:60
0006 query:6; exportSummaryToBigQuery:true; numEvents:10000; streamTimeout:60
0007 query:7; exportSummaryToBigQuery:true; streamTimeout:60
0008 query:8; exportSummaryToBigQuery:true; streamTimeout:60
0009 query:9; exportSummaryToBigQuery:true; numEvents:10000; streamTimeout:60
0010 query:10; exportSummaryToBigQuery:true; streamTimeout:60
0011 query:11; exportSummaryToBigQuery:true; streamTimeout:60
0012 query:12; exportSummaryToBigQuery:true; streamTimeout:60
Performance:
Conf Runtime(sec) (Baseline) Events(/sec) (Baseline) Results
(Baseline)
0000 1.6 62932.7 100000
0001 1.0 97847.4 92000
0002 0.6 157728.7 351
0003 13.3 7513.7 580
0004 7.3 1361.3 40
0005 6.7 14954.4 12
0006 6.2 1603.1 103
0007 7.9 12737.2 1
0008 9.0 11119.8 6000
0009 6.3 1597.2 298
0010 6.9 14394.7 1
0011 8.8 11312.2 1919
0012 6.7 14821.4 1919
==========================================================================================
java.lang.IllegalArgumentException: BigQueryIO.Write needs a GCS temp location
to store temp files.
at
com.google.common.base.Preconditions.checkArgument(Preconditions.java:122)
at
org.apache.beam.sdk.io.gcp.bigquery.BatchLoads.validate(BatchLoads.java:194)
at
org.apache.beam.sdk.Pipeline$ValidateVisitor.enterCompositeTransform(Pipeline.java:640)
at
org.apache.beam.sdk.runners.TransformHierarchy$Node.visit(TransformHierarchy.java:656)
at
org.apache.beam.sdk.runners.TransformHierarchy$Node.visit(TransformHierarchy.java:660)
at
org.apache.beam.sdk.runners.TransformHierarchy$Node.visit(TransformHierarchy.java:660)
at
org.apache.beam.sdk.runners.TransformHierarchy$Node.access$600(TransformHierarchy.java:311)
at
org.apache.beam.sdk.runners.TransformHierarchy.visit(TransformHierarchy.java:245)
at org.apache.beam.sdk.Pipeline.traverseTopologically(Pipeline.java:458)
at org.apache.beam.sdk.Pipeline.validate(Pipeline.java:575)
at org.apache.beam.sdk.Pipeline.run(Pipeline.java:310)
at org.apache.beam.sdk.Pipeline.run(Pipeline.java:297)
at org.apache.beam.sdk.nexmark.Main.savePerfsToBigQuery(Main.java:182)
at org.apache.beam.sdk.nexmark.Main.runAll(Main.java:102)
at org.apache.beam.sdk.nexmark.Main.main(Main.java:395)
> Task :beam-sdks-java-nexmark:run FAILED
:beam-sdks-java-nexmark:run (Thread[Task worker for ':' Thread 7,5,main])
completed. Took 1 mins 49.647 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 6m 3s
62 actionable tasks: 58 executed, 4 from cache
Publishing build scan...
https://gradle.com/s/4loaqr4r3vx3m
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
