See
<https://builds.apache.org/job/beam_PostCommit_Java_Nexmark_Flink/1113/display/redirect>
------------------------------------------
[...truncated 45.64 MB...]
Nov 16, 2018 6:17:14 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@59ae5177)
(4/16) (70a75939ca1558ec2ba6c04a67561f67) switched from DEPLOYING to RUNNING.
Nov 16, 2018 6:17:14 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@59ae5177)
(9/16) (1f5f7bf814f24765a80a4bd1c7c46125) switched from RUNNING to FINISHED.
Nov 16, 2018 6:17:14 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@59ae5177)
(4/16) (70a75939ca1558ec2ba6c04a67561f67) switched from RUNNING to FINISHED.
Nov 16, 2018 6:17:14 AM org.apache.flink.runtime.executiongraph.ExecutionGraph
transitionState
INFO: Job main-jenkins-1116061639-f5a95e1e (d98f6f081dd37ede5ce8c1f3ce871ca3)
switched from state RUNNING to FINISHED.
Nov 16, 2018 6:17:14 AM org.apache.flink.runtime.dispatcher.Dispatcher
jobReachedGloballyTerminalState
INFO: Job d98f6f081dd37ede5ce8c1f3ce871ca3 reached globally terminal state
FINISHED.
Nov 16, 2018 6:17:14 AM org.apache.flink.runtime.jobmaster.JobMaster postStop
INFO: Stopping the JobMaster for job
main-jenkins-1116061639-f5a95e1e(d98f6f081dd37ede5ce8c1f3ce871ca3).
Nov 16, 2018 6:17:14 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
closeJobManagerConnection
INFO: Close JobManager connection for job d98f6f081dd37ede5ce8c1f3ce871ca3.
Nov 16, 2018 6:17:14 AM org.apache.flink.runtime.jobmaster.JobMaster
dissolveResourceManagerConnection
INFO: Close ResourceManager connection 74a92dd6edec9d10d902727f667c5143:
JobManager is shutting down..
Nov 16, 2018 6:17:14 AM org.apache.flink.runtime.jobmaster.slotpool.SlotPool
suspend
INFO: Suspending SlotPool.
Nov 16, 2018 6:17:14 AM
org.apache.flink.runtime.resourcemanager.ResourceManager
closeJobManagerConnection
INFO: Disconnect job manager
9acd0df7f569b3cef581ffb83e464105@akka://flink/user/jobmanager_11 for job
d98f6f081dd37ede5ce8c1f3ce871ca3 from the resource manager.
Nov 16, 2018 6:17:14 AM org.apache.flink.runtime.jobmaster.slotpool.SlotPool
postStop
INFO: Stopping SlotPool.
Nov 16, 2018 6:17:14 AM
org.apache.flink.runtime.taskexecutor.TaskExecutor$JobLeaderListenerImpl
jobManagerLostLeadership
INFO: JobManager for job d98f6f081dd37ede5ce8c1f3ce871ca3 with leader id
9acd0df7f569b3cef581ffb83e464105 lost leadership.
Nov 16, 2018 6:17:14 AM org.apache.flink.runtime.minicluster.MiniCluster
closeAsync
INFO: Shutting down Flink Mini Cluster
Nov 16, 2018 6:17:14 AM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable freeSlot
INFO: Free slot TaskSlot(index:12, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{f064d87c5ab0a965175cd8c0470b5f1f}, jobId:
d98f6f081dd37ede5ce8c1f3ce871ca3).
Nov 16, 2018 6:17:14 AM org.apache.flink.runtime.dispatcher.Dispatcher postStop
INFO: Stopping dispatcher
akka://flink/user/dispatcher502d3953-da62-4c40-ab99-73e86b4e7573.
Nov 16, 2018 6:17:14 AM org.apache.flink.runtime.rest.RestServerEndpoint
closeAsync
INFO: Shutting down rest endpoint.
Nov 16, 2018 6:17:14 AM org.apache.flink.runtime.dispatcher.Dispatcher
terminateJobManagerRunners
INFO: Stopping all currently running jobs of dispatcher
akka://flink/user/dispatcher502d3953-da62-4c40-ab99-73e86b4e7573.
Nov 16, 2018 6:17:14 AM
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:
AllocationID{b8d769a62deae9a10c53dbbd7bda320e}, jobId:
d98f6f081dd37ede5ce8c1f3ce871ca3).
Nov 16, 2018 6:17:14 AM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager close
INFO: Closing the SlotManager.
Nov 16, 2018 6:17:14 AM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager suspend
INFO: Suspending the SlotManager.
Nov 16, 2018 6:17:14 AM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable freeSlot
INFO: Free slot TaskSlot(index:15, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{6e762efb480541bcdc26dd3754845c19}, jobId:
d98f6f081dd37ede5ce8c1f3ce871ca3).
Nov 16, 2018 6:17:14 AM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable freeSlot
INFO: Free slot TaskSlot(index:9, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{7e3738cbb56b71e78fee98ee7144f683}, jobId:
d98f6f081dd37ede5ce8c1f3ce871ca3).
Nov 16, 2018 6:17:14 AM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable freeSlot
INFO: Free slot TaskSlot(index:5, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{b6a466da47c02947c8aa18a517fc9603}, jobId:
d98f6f081dd37ede5ce8c1f3ce871ca3).
Nov 16, 2018 6:17:14 AM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable freeSlot
INFO: Free slot TaskSlot(index:4, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{736b96e9bb44cb431a65a15d7666834b}, jobId:
d98f6f081dd37ede5ce8c1f3ce871ca3).
Nov 16, 2018 6:17:14 AM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable freeSlot
INFO: Free slot TaskSlot(index:3, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{5096d6c3e795652e02df8077ff531114}, jobId:
d98f6f081dd37ede5ce8c1f3ce871ca3).
Nov 16, 2018 6:17:14 AM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable freeSlot
INFO: Free slot TaskSlot(index:8, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{e0157b28166979bbd344b5bc71aac17b}, jobId:
d98f6f081dd37ede5ce8c1f3ce871ca3).
Nov 16, 2018 6:17:14 AM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable freeSlot
INFO: Free slot TaskSlot(index:10, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{506256710189970239fc58babaa10f10}, jobId:
d98f6f081dd37ede5ce8c1f3ce871ca3).
Nov 16, 2018 6:17:14 AM
org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator
shutDown
INFO: Shutting down stack trace sample coordinator.
Nov 16, 2018 6:17:14 AM org.apache.flink.runtime.dispatcher.Dispatcher
lambda$postStop$0
INFO: Stopped dispatcher
akka://flink/user/dispatcher502d3953-da62-4c40-ab99-73e86b4e7573.
Nov 16, 2018 6:17:14 AM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable freeSlot
INFO: Free slot TaskSlot(index:11, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{3c4535240bcd186873fdce1614668839}, jobId:
d98f6f081dd37ede5ce8c1f3ce871ca3).
Nov 16, 2018 6:17:14 AM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable freeSlot
INFO: Free slot TaskSlot(index:1, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{01e5e12b782c0d2e48aafea7f9944440}, jobId:
d98f6f081dd37ede5ce8c1f3ce871ca3).
Nov 16, 2018 6:17:14 AM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable freeSlot
INFO: Free slot TaskSlot(index:14, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{3e45d55eec7bebd87f0a0aeacc207373}, jobId:
d98f6f081dd37ede5ce8c1f3ce871ca3).
Nov 16, 2018 6:17:14 AM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable freeSlot
INFO: Free slot TaskSlot(index:7, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{7a8154eab995c091071bf2c7cc7f02c8}, jobId:
d98f6f081dd37ede5ce8c1f3ce871ca3).
Nov 16, 2018 6:17:14 AM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable freeSlot
INFO: Free slot TaskSlot(index:13, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{942efdee7c39e7f7f03238b760c2df52}, jobId:
d98f6f081dd37ede5ce8c1f3ce871ca3).
Nov 16, 2018 6:17:14 AM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable freeSlot
INFO: Free slot TaskSlot(index:6, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{8f01451f587cb7a088c541594c6ee73a}, jobId:
d98f6f081dd37ede5ce8c1f3ce871ca3).
Nov 16, 2018 6:17:14 AM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable freeSlot
INFO: Free slot TaskSlot(index:2, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{7bd998ad9a26c73a9a38cd436cd41a50}, jobId:
d98f6f081dd37ede5ce8c1f3ce871ca3).
Nov 16, 2018 6:17:14 AM org.apache.flink.runtime.taskexecutor.JobLeaderService
removeJob
INFO: Remove job d98f6f081dd37ede5ce8c1f3ce871ca3 from job leader monitoring.
Nov 16, 2018 6:17:14 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
closeJobManagerConnection
INFO: Close JobManager connection for job d98f6f081dd37ede5ce8c1f3ce871ca3.
Nov 16, 2018 6:17:14 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
closeJobManagerConnection
INFO: Close JobManager connection for job d98f6f081dd37ede5ce8c1f3ce871ca3.
Nov 16, 2018 6:17:14 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
postStop
INFO: Stopping TaskExecutor akka://flink/user/taskmanager_10.
Nov 16, 2018 6:17:14 AM
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager shutdown
INFO: Shutting down TaskExecutorLocalStateStoresManager.
Nov 16, 2018 6:17:14 AM org.apache.flink.runtime.io.disk.iomanager.IOManager
shutdown
INFO: I/O manager removed spill file directory
/tmp/flink-io-b652a526-7e62-43ef-b78e-8a0f141aa9e4
Nov 16, 2018 6:17:14 AM org.apache.flink.runtime.io.network.NetworkEnvironment
shutdown
INFO: Shutting down the network environment and its components.
Nov 16, 2018 6:17:14 AM org.apache.flink.runtime.taskexecutor.JobLeaderService
stop
INFO: Stop job leader service.
Nov 16, 2018 6:17:14 AM org.apache.flink.runtime.webmonitor.WebMonitorEndpoint
lambda$shutDownInternal$5
INFO: Removing cache directory /tmp/flink-web-ui
Nov 16, 2018 6:17:14 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
postStop
INFO: Stopped TaskExecutor akka://flink/user/taskmanager_10.
Nov 16, 2018 6:17:14 AM org.apache.flink.runtime.rpc.akka.AkkaRpcService
stopService
INFO: Stopping Akka RPC service.
Nov 16, 2018 6:17:14 AM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Nov 16, 2018 6:17:14 AM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Nov 16, 2018 6:17:14 AM org.apache.flink.runtime.blob.BlobServer close
INFO: Stopped BLOB server at 0.0.0.0:33011
Nov 16, 2018 6:17:14 AM org.apache.flink.runtime.rpc.akka.AkkaRpcService
lambda$stopService$4
INFO: Stopped Akka RPC service.
Nov 16, 2018 6:17:14 AM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: Execution finished in 6455 msecs
Nov 16, 2018 6:17:14 AM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: Final accumulator values:
Nov 16, 2018 6:17:14 AM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: __metricscontainers :
org.apache.beam.runners.core.metrics.MetricsContainerStepMap@be783c91
2018-11-16T06:17:14.960Z Waiting for main pipeline to 'finish'
2018-11-16T06:17:14.960Z DONE SqlQuery7
2018-11-16T06:17:14.961Z Running query:AVERAGE_SELLING_PRICE_BY_SELLER;
exportSummaryToBigQuery:true; numEvents:10000; streamTimeout:60
2018-11-16T06:17:14.961Z skipping since configuration is not implemented
2018-11-16T06:17:14.961Z Running query:HIGHEST_BID;
exportSummaryToBigQuery:true; streamTimeout:60
2018-11-16T06:17:14.961Z skipping since configuration is not implemented
2018-11-16T06:17:14.961Z Running query:MONITOR_NEW_USERS;
exportSummaryToBigQuery:true; streamTimeout:60
==========================================================================================
Run started 2018-11-16T06:16:36.807Z and ran for PT38.154S
Default configuration:
{"debug":true,"query":null,"sourceType":"DIRECT","sinkType":"DEVNULL","exportSummaryToBigQuery":false,"pubSubMode":"COMBINED","sideInputType":"DIRECT","sideInputRowCount":500,"sideInputNumShards":3,"sideInputUrl":null,"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}
2018-11-16T06:17:14.961Z skipping since configuration is not implemented
2018-11-16T06:17:14.961Z Running query:WINNING_BIDS;
exportSummaryToBigQuery:true; numEvents:10000; streamTimeout:60
Configurations:
Conf Description
0000 query:PASSTHROUGH; exportSummaryToBigQuery:true; streamTimeout:60
0001 query:CURRENCY_CONVERSION; exportSummaryToBigQuery:true;
streamTimeout:60
0002 query:SELECTION; exportSummaryToBigQuery:true; streamTimeout:60
0003 query:LOCAL_ITEM_SUGGESTION; exportSummaryToBigQuery:true;
streamTimeout:60
0004 query:AVERAGE_PRICE_FOR_CATEGORY; exportSummaryToBigQuery:true;
numEvents:10000; streamTimeout:60
0005 query:HOT_ITEMS; exportSummaryToBigQuery:true; streamTimeout:60
0006 query:AVERAGE_SELLING_PRICE_BY_SELLER; exportSummaryToBigQuery:true;
numEvents:10000; streamTimeout:60
0007 query:HIGHEST_BID; exportSummaryToBigQuery:true; streamTimeout:60
0008 query:MONITOR_NEW_USERS; exportSummaryToBigQuery:true; streamTimeout:60
0009 query:WINNING_BIDS; exportSummaryToBigQuery:true; numEvents:10000;
streamTimeout:60
0010 query:LOG_TO_SHARDED_FILES; exportSummaryToBigQuery:true;
streamTimeout:60
0011 query:USER_SESSIONS; exportSummaryToBigQuery:true; streamTimeout:60
0012 query:PROCESSING_TIME_WINDOWS; exportSummaryToBigQuery:true;
streamTimeout:60
0013 query:BOUNDED_SIDE_INPUT_JOIN; exportSummaryToBigQuery:true;
streamTimeout:60
Performance:
Conf Runtime(sec) (Baseline) Events(/sec) (Baseline) Results
(Baseline)
2018-11-16T06:17:14.961Z skipping since configuration is not implemented
2018-11-16T06:17:14.961Z Running query:LOG_TO_SHARDED_FILES;
exportSummaryToBigQuery:true; streamTimeout:60
0000 2.0 51072.5 92000
0001 0.9 108577.6 92000
0002 0.5 187265.9 351
0003 10.2 9850.3 580
0004 6.0 1670.6 4
0005 6.3 15855.4 1
0006 *** not run ***
0007 *** not run ***
0008 *** not run ***
0009 *** not run ***
0010 *** not run ***
0011 *** not run ***
0012 *** not run ***
0013 *** not run ***
==========================================================================================
2018-11-16T06:17:14.962Z skipping since configuration is not implemented
2018-11-16T06:17:14.962Z Running query:USER_SESSIONS;
exportSummaryToBigQuery:true; streamTimeout:60
2018-11-16T06:17:14.962Z skipping since configuration is not implemented
2018-11-16T06:17:14.962Z Running query:PROCESSING_TIME_WINDOWS;
exportSummaryToBigQuery:true; streamTimeout:60
2018-11-16T06:17:14.962Z skipping since configuration is not implemented
2018-11-16T06:17:14.962Z Running query:BOUNDED_SIDE_INPUT_JOIN;
exportSummaryToBigQuery:true; streamTimeout:60
2018-11-16T06:17:14.962Z skipping since configuration is not implemented
==========================================================================================
Run started 2018-11-16T06:16:36.807Z and ran for PT39.562S
Default configuration:
{"debug":true,"query":null,"sourceType":"DIRECT","sinkType":"DEVNULL","exportSummaryToBigQuery":false,"pubSubMode":"COMBINED","sideInputType":"DIRECT","sideInputRowCount":500,"sideInputNumShards":3,"sideInputUrl":null,"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:PASSTHROUGH; exportSummaryToBigQuery:true; streamTimeout:60
0001 query:CURRENCY_CONVERSION; exportSummaryToBigQuery:true;
streamTimeout:60
0002 query:SELECTION; exportSummaryToBigQuery:true; streamTimeout:60
0003 query:LOCAL_ITEM_SUGGESTION; exportSummaryToBigQuery:true;
streamTimeout:60
0004 query:AVERAGE_PRICE_FOR_CATEGORY; exportSummaryToBigQuery:true;
numEvents:10000; streamTimeout:60
Exception in thread "main" 0005 query:HOT_ITEMS;
exportSummaryToBigQuery:true; streamTimeout:60
0006 query:AVERAGE_SELLING_PRICE_BY_SELLER; exportSummaryToBigQuery:true;
numEvents:10000; streamTimeout:60
0007 query:HIGHEST_BID; exportSummaryToBigQuery:true; streamTimeout:60
0008 query:MONITOR_NEW_USERS; exportSummaryToBigQuery:true; streamTimeout:60
0009 query:WINNING_BIDS; exportSummaryToBigQuery:true; numEvents:10000;
streamTimeout:60
0010 query:LOG_TO_SHARDED_FILES; exportSummaryToBigQuery:true;
streamTimeout:60
0011 query:USER_SESSIONS; exportSummaryToBigQuery:true; streamTimeout:60
0012 query:PROCESSING_TIME_WINDOWS; exportSummaryToBigQuery:true;
streamTimeout:60
0013 query:BOUNDED_SIDE_INPUT_JOIN; exportSummaryToBigQuery:true;
streamTimeout:60
Performance:
java.lang.NullPointerException
Conf Runtime(sec) (Baseline) Events(/sec) (Baseline) Results
(Baseline)
at
com.google.cloud.bigquery.StandardTableDefinition$StreamingBuffer.fromPb(StandardTableDefinition.java:116)
at
com.google.cloud.bigquery.StandardTableDefinition.fromPb(StandardTableDefinition.java:225)
0000 2.0 51072.5 92000
at
com.google.cloud.bigquery.TableDefinition.fromPb(TableDefinition.java:155)
0001 0.9 108577.6 92000
at
com.google.cloud.bigquery.TableInfo$BuilderImpl.<init>(TableInfo.java:183)
0002 0.5 187265.9 351
at com.google.cloud.bigquery.Table.fromPb(Table.java:593)
0003 10.2 9850.3 580
at
com.google.cloud.bigquery.BigQueryImpl.getTable(BigQueryImpl.java:410)
at
org.apache.beam.sdk.testutils.publishing.BigQueryClient.createTableIfNotExists(BigQueryClient.java:74)
at org.apache.beam.sdk.nexmark.Main.savePerfsToBigQuery(Main.java:184)
at org.apache.beam.sdk.nexmark.Main.runAll(Main.java:148)
at org.apache.beam.sdk.nexmark.Main.runAll(Main.java:98)
at org.apache.beam.sdk.nexmark.Main.main(Main.java:423)
0004 6.0 1670.6 4
0005 6.3 15855.4 1
0006 *** not run ***
0007 *** not run ***
0008 *** not run ***
0009 *** not run ***
0010 *** not run ***
0011 *** not run ***
0012 *** not run ***
0013 *** not run ***
==========================================================================================
> Task :beam-sdks-java-nexmark:run FAILED
:beam-sdks-java-nexmark:run (Thread[Task worker for ':' Thread 3,5,main])
completed. Took 42.5 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_191/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 54s
68 actionable tasks: 2 executed, 66 up-to-date
Publishing build scan...
https://gradle.com/s/brrpuklradcga
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscr...@beam.apache.org
For additional commands, e-mail: builds-h...@beam.apache.org
