See
<https://builds.apache.org/job/beam_PostCommit_Java_Nexmark_Flink/3/display/redirect>
------------------------------------------
[...truncated 3.33 MB...]
Jun 19, 2018 6:18:03 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)
(4e2d22e9cef6f5bed31c9beea3427e7d) switched from RUNNING to FINISHED.
Jun 19, 2018 6:18:03 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)
(329acacf6c989b2b88f035c9b60ca392) switched from RUNNING to FINISHED.
Jun 19, 2018 6:18:03 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)
(329acacf6c989b2b88f035c9b60ca392).
Jun 19, 2018 6:18:03 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)
(329acacf6c989b2b88f035c9b60ca392) [FINISHED]
Jun 19, 2018 6:18:03 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)
(3a9c4bb7d97dce8fc457491630517d74) switched from RUNNING to FINISHED.
Jun 19, 2018 6:18:03 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)
(3a9c4bb7d97dce8fc457491630517d74).
Jun 19, 2018 6:18:03 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3ce067bd)
(1/1) (4fdebb3dabee8e78d4af1fc205473968) switched from CREATED to SCHEDULED.
Jun 19, 2018 6:18:03 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)
(3a9c4bb7d97dce8fc457491630517d74) [FINISHED]
Jun 19, 2018 6:18:03 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) 329acacf6c989b2b88f035c9b60ca392.
Jun 19, 2018 6:18:03 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3ce067bd)
(1/1) (4fdebb3dabee8e78d4af1fc205473968) switched from SCHEDULED to DEPLOYING.
Jun 19, 2018 6:18:03 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 6:18:03 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) 3a9c4bb7d97dce8fc457491630517d74.
Jun 19, 2018 6:18:03 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)
(329acacf6c989b2b88f035c9b60ca392) switched from RUNNING to FINISHED.
Jun 19, 2018 6:18:03 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)
(3a9c4bb7d97dce8fc457491630517d74) switched from RUNNING to FINISHED.
Jun 19, 2018 6:18:03 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 6:18:03 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3ce067bd)
(1/1) (4fdebb3dabee8e78d4af1fc205473968) switched from CREATED to DEPLOYING.
Jun 19, 2018 6:18:03 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)
(4fdebb3dabee8e78d4af1fc205473968) [DEPLOYING]
Jun 19, 2018 6:18:03 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)
(4fdebb3dabee8e78d4af1fc205473968) [DEPLOYING].
Jun 19, 2018 6:18:03 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Registering task at network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3ce067bd) (1/1)
(4fdebb3dabee8e78d4af1fc205473968) [DEPLOYING].
Jun 19, 2018 6:18:03 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3ce067bd)
(1/1) (4fdebb3dabee8e78d4af1fc205473968) switched from DEPLOYING to RUNNING.
Jun 19, 2018 6:18:03 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3ce067bd)
(1/1) (4fdebb3dabee8e78d4af1fc205473968) switched from DEPLOYING to RUNNING.
Jun 19, 2018 6:18:03 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3ce067bd)
(1/1) (4fdebb3dabee8e78d4af1fc205473968) switched from RUNNING to FINISHED.
Jun 19, 2018 6:18:03 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3ce067bd) (1/1)
(4fdebb3dabee8e78d4af1fc205473968).
Jun 19, 2018 6:18:03 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)
(4fdebb3dabee8e78d4af1fc205473968) [FINISHED]
Jun 19, 2018 6:18:03 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)
4fdebb3dabee8e78d4af1fc205473968.
Jun 19, 2018 6:18:03 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3ce067bd)
(1/1) (4fdebb3dabee8e78d4af1fc205473968) switched from RUNNING to FINISHED.
Jun 19, 2018 6:18:03 PM org.apache.flink.runtime.executiongraph.ExecutionGraph
transitionState
INFO: Job main-jenkins-0619181647-9efedbe (d0e0b3138e3b9ae1f46483741f04da56)
switched from state RUNNING to FINISHED.
Jun 19, 2018 6:18:03 PM org.apache.flink.runtime.dispatcher.Dispatcher
jobReachedGloballyTerminalState
INFO: Job d0e0b3138e3b9ae1f46483741f04da56 reached globally terminal state
FINISHED.
Jun 19, 2018 6:18:03 PM org.apache.flink.runtime.jobmaster.JobMaster postStop
INFO: Stopping the JobMaster for job
main-jenkins-0619181647-9efedbe(d0e0b3138e3b9ae1f46483741f04da56).
Jun 19, 2018 6:18:03 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
closeJobManagerConnection
INFO: Close JobManager connection for job d0e0b3138e3b9ae1f46483741f04da56.
Jun 19, 2018 6:18:03 PM org.apache.flink.runtime.jobmaster.JobMaster
dissolveResourceManagerConnection
INFO: Close ResourceManager connection 5753988c3776c086ec6d3fb546afa270:
JobManager is shutting down..
Jun 19, 2018 6:18:03 PM org.apache.flink.runtime.jobmaster.slotpool.SlotPool
suspend
INFO: Suspending SlotPool.
Jun 19, 2018 6:18:03 PM
org.apache.flink.runtime.resourcemanager.ResourceManager
closeJobManagerConnection
INFO: Disconnect job manager
a124400c4315be29ea482efdeb1a4920@akka://flink/user/jobmanager_25 for job
d0e0b3138e3b9ae1f46483741f04da56 from the resource manager.
Jun 19, 2018 6:18:03 PM org.apache.flink.runtime.jobmaster.slotpool.SlotPool
postStop
INFO: Stopping SlotPool.
Jun 19, 2018 6:18:03 PM org.apache.flink.runtime.minicluster.MiniCluster
closeAsync
INFO: Shutting down Flink Mini Cluster
Jun 19, 2018 6:18:03 PM
org.apache.flink.runtime.taskexecutor.TaskExecutor$JobLeaderListenerImpl
jobManagerLostLeadership
INFO: JobManager for job d0e0b3138e3b9ae1f46483741f04da56 with leader id
a124400c4315be29ea482efdeb1a4920 lost leadership.
Jun 19, 2018 6:18:03 PM org.apache.flink.runtime.rest.RestServerEndpoint
closeAsync
INFO: Shutting down rest endpoint.
Jun 19, 2018 6:18:03 PM org.apache.flink.runtime.dispatcher.Dispatcher postStop
INFO: Stopping dispatcher
akka://flink/user/dispatcher462aee94-e784-48a7-bd69-82230dc8df35.
Jun 19, 2018 6:18:03 PM org.apache.flink.runtime.dispatcher.Dispatcher
terminateJobManagerRunners
INFO: Stopping all currently running jobs of dispatcher
akka://flink/user/dispatcher462aee94-e784-48a7-bd69-82230dc8df35.
Jun 19, 2018 6:18:03 PM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager close
INFO: Closing the SlotManager.
Jun 19, 2018 6:18:03 PM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager suspend
INFO: Suspending the SlotManager.
Jun 19, 2018 6:18:03 PM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager
unregisterTaskManager
INFO: Unregister TaskManager c1e7b6d21c6f320ce89345634562bb1b from the
SlotManager.
Jun 19, 2018 6:18:03 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:
a44996e0cf028a79b888587b0539f2d0, jobId: d0e0b3138e3b9ae1f46483741f04da56).
Jun 19, 2018 6:18:03 PM org.apache.flink.runtime.taskexecutor.JobLeaderService
removeJob
INFO: Remove job d0e0b3138e3b9ae1f46483741f04da56 from job leader monitoring.
Jun 19, 2018 6:18:03 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
closeJobManagerConnection
INFO: Close JobManager connection for job d0e0b3138e3b9ae1f46483741f04da56.
Jun 19, 2018 6:18:03 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
postStop
INFO: Stopping TaskExecutor akka://flink/user/taskmanager_24.
Jun 19, 2018 6:18:03 PM
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager shutdown
INFO: Shutting down TaskExecutorLocalStateStoresManager.
Jun 19, 2018 6:18:03 PM org.apache.flink.runtime.io.disk.iomanager.IOManager
shutdown
INFO: I/O manager removed spill file directory
/tmp/flink-io-85bbd478-4def-43bb-b297-475b8340cfd1
Jun 19, 2018 6:18:03 PM org.apache.flink.runtime.io.network.NetworkEnvironment
shutdown
INFO: Shutting down the network environment and its components.
Jun 19, 2018 6:18:03 PM
org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator
shutDown
INFO: Shutting down stack trace sample coordinator.
Jun 19, 2018 6:18:03 PM org.apache.flink.runtime.webmonitor.WebMonitorEndpoint
lambda$shutDownInternal$4
INFO: Removing cache directory /tmp/flink-web-ui
Jun 19, 2018 6:18:03 PM org.apache.flink.runtime.taskexecutor.JobLeaderService
stop
INFO: Stop job leader service.
Jun 19, 2018 6:18:03 PM org.apache.flink.runtime.dispatcher.Dispatcher
lambda$postStop$0
INFO: Stopped dispatcher
akka://flink/user/dispatcher462aee94-e784-48a7-bd69-82230dc8df35.
Jun 19, 2018 6:18:03 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
postStop
INFO: Stopped TaskExecutor akka://flink/user/taskmanager_24.
Jun 19, 2018 6:18:03 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService
stopService
INFO: Stopping Akka RPC service.
Jun 19, 2018 6:18:03 PM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Jun 19, 2018 6:18:03 PM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Jun 19, 2018 6:18:03 PM org.apache.flink.runtime.blob.BlobServer close
INFO: Stopped BLOB server at 0.0.0.0:46867
Jun 19, 2018 6:18:03 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService
lambda$stopService$4
INFO: Stopped Akka RPC service.
Jun 19, 2018 6:18:03 PM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: Execution finished in 5312 msecs
Jun 19, 2018 6:18:03 PM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: Final accumulator values:
Jun 19, 2018 6:18:03 PM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: __metricscontainers :
org.apache.beam.runners.core.metrics.MetricsContainerStepMap@ea391e7d
2018-06-19T18:18:03.418Z Waiting for main pipeline to 'finish'
2018-06-19T18:18:03.418Z DONE Query12
==========================================================================================
Run started 2018-06-19T18:16:46.944Z and ran for PT76.474S
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 0.7 153609.8 100000
0001 0.5 189753.3 92000
0002 0.4 251256.3 351
0003 10.9 9160.9 580
0004 5.3 1881.8 40
0005 5.2 19241.9 12
0006 4.7 2115.1 103
0007 6.0 16556.3 1
0008 7.8 12810.7 6000
0009 5.1 1960.0 298
0010 5.8 17199.9 1
0011 6.6 15101.2 1919
0012 5.3 18932.2 1919
==========================================================================================
==========================================================================================
Run started 2018-06-19T18:16:46.944Z and ran for PT76.785S
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 0.7 153609.8 100000
0001 0.5 189753.3 92000
0002 0.4 251256.3 351
0003 10.9 9160.9 580
0004 5.3 1881.8 40
0005 5.2 19241.9 12
0006 4.7 2115.1 103
0007 6.0 16556.3 1
0008 7.8 12810.7 6000
0009 5.1 1960.0 298
0010 5.8 17199.9 1
0011 6.6 15101.2 1919
Exception in thread "main" 0012 5.3 18932.2
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 13,5,main])
completed. Took 1 mins 20.026 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 3m 44s
62 actionable tasks: 58 executed, 4 from cache
Publishing build scan...
https://gradle.com/s/wbib4nqxat3pq
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
Not sending mail to unregistered user [email protected]
