See 
<https://ci-beam.apache.org/job/beam_PostCommit_Java_Nexmark_Flink/7439/display/redirect>

Changes:


------------------------------------------
[...truncated 23.59 MB...]
Jul 23, 2021 6:32:20 AM 
org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager 
processResourceRequirements
INFO: Clearing resource requirements of job 664cb609d1c53b9ac366c1a83e5fc5ab
Jul 23, 2021 6:32:20 AM 
org.apache.flink.runtime.resourcemanager.ResourceManager 
closeJobManagerConnection
INFO: Disconnect job manager 
a3f26ad57bd55999462e356eaf4a4be0@akka://flink/user/rpc/jobmanager_59 for job 
664cb609d1c53b9ac366c1a83e5fc5ab from the resource manager.
Jul 23, 2021 6:32:20 AM 
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:0, state:ALLOCATED, resource profile: 
ResourceProfile{taskHeapMemory=64.000gb (68719476736 bytes), 
taskOffHeapMemory=64.000gb (68719476736 bytes), managedMemory=8.000mb (8388608 
bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: 
9c89f482003fa9d5fa6ac5560ca790be, jobId: 664cb609d1c53b9ac366c1a83e5fc5ab).
Jul 23, 2021 6:32:20 AM 
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:7, state:ALLOCATED, resource profile: 
ResourceProfile{taskHeapMemory=64.000gb (68719476736 bytes), 
taskOffHeapMemory=64.000gb (68719476736 bytes), managedMemory=8.000mb (8388608 
bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: 
6501b8a65dd8745232e7097c914ed33e, jobId: 664cb609d1c53b9ac366c1a83e5fc5ab).
2021-07-23T06:32:20.767Z 1 samples not enough to calculate steady-state event 
rate
Jul 23, 2021 6:32:20 AM 
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:9, state:ALLOCATED, resource profile: 
ResourceProfile{taskHeapMemory=64.000gb (68719476736 bytes), 
taskOffHeapMemory=64.000gb (68719476736 bytes), managedMemory=8.000mb (8388608 
bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: 
5316abca8c65bdcd1650d039fb8ec4fa, jobId: 664cb609d1c53b9ac366c1a83e5fc5ab).
Jul 23, 2021 6:32:20 AM org.apache.beam.sdk.testutils.metrics.MetricsReader 
getCounterMetric
SEVERE: Failed to get metric fatal, from namespace SessionSideInputJoin
Jul 23, 2021 6:32:20 AM 
org.apache.flink.runtime.taskexecutor.TaskExecutor$JobLeaderListenerImpl 
jobManagerLostLeadership
INFO: JobManager for job 664cb609d1c53b9ac366c1a83e5fc5ab with leader id 
a3f26ad57bd55999462e356eaf4a4be0 lost leadership.
Jul 23, 2021 6:32:20 AM 
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:4, state:ALLOCATED, resource profile: 
ResourceProfile{taskHeapMemory=64.000gb (68719476736 bytes), 
taskOffHeapMemory=64.000gb (68719476736 bytes), managedMemory=8.000mb (8388608 
bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: 
2d95f7b7e4ea6f15d10627b171dcac9c, jobId: 664cb609d1c53b9ac366c1a83e5fc5ab).

==========================================================================================
Run started 2021-07-23T06:31:11.693Z and ran for PT69.075S

Default configuration:
{"debug":true,"query":null,"sourceType":"DIRECT","generateEventFilePathPrefix":null,"sinkType":"DEVNULL","exportSummaryToBigQuery":false,"pubSubMode":"COMBINED","pubsubMessageSerializationMethod":"CODER","sideInputType":"DIRECT","sideInputRowCount":500,"sideInputNumShards":3,"sideInputUrl":null,"sessionGap":600000,"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,"numKeyBuckets":20000,"pardoCPUFactor":1.0}

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:PORTABILITY_BATCH; exportSummaryToBigQuery:true; streamTimeout:60
  0014  query:BOUNDED_SIDE_INPUT_JOIN; exportSummaryToBigQuery:true; 
streamTimeout:60
  0015  query:SESSION_SIDE_INPUT_JOIN; exportSummaryToBigQuery:true; 
streamTimeout:60

Performance:
Jul 23, 2021 6:32:20 AM 
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
  Conf  Runtime(sec)    (Baseline)  Events(/sec)    (Baseline)       Results    
(Baseline)
  0000           1.4                     73046.0                      100000    
          
INFO: Free slot TaskSlot(index:1, state:ALLOCATED, resource profile: 
ResourceProfile{taskHeapMemory=64.000gb (68719476736 bytes), 
taskOffHeapMemory=64.000gb (68719476736 bytes), managedMemory=8.000mb (8388608 
bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: 
e18d3e79d6eee6ce12bda5fe149fe503, jobId: 664cb609d1c53b9ac366c1a83e5fc5ab).
  0001           0.6                    155521.0                       92000    
          
  0002           0.3                    374531.8                         351    
          
  0003           0.4                    239234.4                         580    
          
  0004           1.3                      7692.3                          40    
          
  0005           1.4                     70771.4                          12    
          
  0006           0.6                     16155.1                         401    
          
  0007           9.1                     10967.3                           1    
          
  0008           0.5                    184842.9                        6000    
          
  0009           0.4                     28571.4                         298    
          
  0010           1.2                     86881.0                           1    
          
  0011           1.3                     76452.6                        1919    
          
  0012           0.6                    168067.2                        1919    
          
  0013  *** not run ***
  0014          21.5                      4642.7                       92000    
          
  0015           1.5                     66577.9                       92000    
          
==========================================================================================

Jul 23, 2021 6:32:20 AM 
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:13, state:ALLOCATED, resource profile: 
ResourceProfile{taskHeapMemory=64.000gb (68719476736 bytes), 
taskOffHeapMemory=64.000gb (68719476736 bytes), managedMemory=8.000mb (8388608 
bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: 
323f4e3afd609140e06e2804572c98cd, jobId: 664cb609d1c53b9ac366c1a83e5fc5ab).
Jul 23, 2021 6:32:20 AM 
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:12, state:ALLOCATED, resource profile: 
ResourceProfile{taskHeapMemory=64.000gb (68719476736 bytes), 
taskOffHeapMemory=64.000gb (68719476736 bytes), managedMemory=8.000mb (8388608 
bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: 
8031db7a3d405c635e948e909bee0a32, jobId: 664cb609d1c53b9ac366c1a83e5fc5ab).
Jul 23, 2021 6:32:20 AM 
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:14, state:ALLOCATED, resource profile: 
ResourceProfile{taskHeapMemory=64.000gb (68719476736 bytes), 
taskOffHeapMemory=64.000gb (68719476736 bytes), managedMemory=8.000mb (8388608 
bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: 
0ca41177c6be7d50da72aae6dd7b7f80, jobId: 664cb609d1c53b9ac366c1a83e5fc5ab).
Jul 23, 2021 6:32:20 AM 
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:6, state:ALLOCATED, resource profile: 
ResourceProfile{taskHeapMemory=64.000gb (68719476736 bytes), 
taskOffHeapMemory=64.000gb (68719476736 bytes), managedMemory=8.000mb (8388608 
bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: 
528ab25300e9ee0b3579450dcae28b7e, jobId: 664cb609d1c53b9ac366c1a83e5fc5ab).
Jul 23, 2021 6:32:20 AM org.apache.flink.runtime.webmonitor.WebMonitorEndpoint 
lambda$shutDownInternal$5
INFO: Removing cache directory /tmp/flink-web-ui
Jul 23, 2021 6:32:20 AM 
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:2, state:ALLOCATED, resource profile: 
ResourceProfile{taskHeapMemory=64.000gb (68719476736 bytes), 
taskOffHeapMemory=64.000gb (68719476736 bytes), managedMemory=8.000mb (8388608 
bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: 
dcc729a2150cf7a098d89529f671ce1f, jobId: 664cb609d1c53b9ac366c1a83e5fc5ab).
Jul 23, 2021 6:32:20 AM org.apache.flink.runtime.rest.RestServerEndpoint 
lambda$closeAsync$1
INFO: Shut down complete.
Jul 23, 2021 6:32:20 AM 
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:10, state:ALLOCATED, resource profile: 
ResourceProfile{taskHeapMemory=64.000gb (68719476736 bytes), 
taskOffHeapMemory=64.000gb (68719476736 bytes), managedMemory=8.000mb (8388608 
bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: 
2303e25cd4459559ca3e9001480e38af, jobId: 664cb609d1c53b9ac366c1a83e5fc5ab).
Jul 23, 2021 6:32:20 AM 
org.apache.flink.runtime.resourcemanager.ResourceManager deregisterApplication
INFO: Shut down cluster because application is in CANCELED, diagnostics 
DispatcherResourceManagerComponent has been closed..
Jul 23, 2021 6:32:20 AM 
org.apache.flink.runtime.entrypoint.component.DispatcherResourceManagerComponent
 closeAsyncInternal
INFO: Closing components.
Jul 23, 2021 6:32:20 AM 
org.apache.flink.runtime.dispatcher.runner.AbstractDispatcherLeaderProcess 
closeInternal
INFO: Stopping SessionDispatcherLeaderProcess.
Jul 23, 2021 6:32:20 AM org.apache.flink.runtime.dispatcher.Dispatcher onStop
INFO: Stopping dispatcher akka://flink/user/rpc/dispatcher_58.
Jul 23, 2021 6:32:20 AM 
org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager 
close
INFO: Closing the slot manager.
Jul 23, 2021 6:32:20 AM org.apache.flink.runtime.dispatcher.Dispatcher 
terminateRunningJobs
INFO: Stopping all currently running jobs of dispatcher 
akka://flink/user/rpc/dispatcher_58.
Jul 23, 2021 6:32:20 AM 
org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager 
suspend
INFO: Suspending the slot manager.
Jul 23, 2021 6:32:20 AM org.apache.flink.runtime.dispatcher.Dispatcher 
lambda$onStop$0
INFO: Stopped dispatcher akka://flink/user/rpc/dispatcher_58.
Jul 23, 2021 6:32:20 AM 
org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService stop
INFO: Stop job leader service.
Jul 23, 2021 6:32:20 AM 
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager shutdown
INFO: Shutting down TaskExecutorLocalStateStoresManager.
Jul 23, 2021 6:32:20 AM org.apache.flink.runtime.io.disk.FileChannelManagerImpl 
lambda$getFileCloser$0
INFO: FileChannelManager removed spill file directory 
/tmp/flink-io-d5de63a0-9acd-4dfb-804f-ca23f0abc4ca
Jul 23, 2021 6:32:20 AM 
org.apache.flink.runtime.io.network.NettyShuffleEnvironment close
INFO: Shutting down the network environment and its components.
Jul 23, 2021 6:32:20 AM org.apache.flink.runtime.io.disk.FileChannelManagerImpl 
lambda$getFileCloser$0
INFO: FileChannelManager removed spill file directory 
/tmp/flink-netty-shuffle-4004ddd5-2bfb-48af-911d-a5e456946d41
Jul 23, 2021 6:32:20 AM org.apache.flink.runtime.taskexecutor.KvStateService 
shutdown
INFO: Shutting down the kvState service and its components.
Jul 23, 2021 6:32:20 AM 
org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService stop
INFO: Stop job leader service.
Jul 23, 2021 6:32:20 AM org.apache.flink.runtime.filecache.FileCache shutdown
INFO: removed file cache directory 
/tmp/flink-dist-cache-7c9e0fba-275d-411c-8c50-567219ce93dd
Jul 23, 2021 6:32:20 AM org.apache.flink.runtime.taskexecutor.TaskExecutor 
handleOnStopException
INFO: Stopped TaskExecutor akka://flink/user/rpc/taskmanager_56.
Jul 23, 2021 6:32:20 AM org.apache.flink.runtime.rpc.akka.AkkaRpcService 
stopService
INFO: Stopping Akka RPC service.
Jul 23, 2021 6:32:20 AM org.apache.flink.runtime.rpc.akka.AkkaRpcService 
stopService
INFO: Stopping Akka RPC service.
Jul 23, 2021 6:32:20 AM org.apache.flink.runtime.rpc.akka.AkkaRpcService 
lambda$stopService$7
INFO: Stopped Akka RPC service.
Jul 23, 2021 6:32:20 AM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Jul 23, 2021 6:32:20 AM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Jul 23, 2021 6:32:20 AM org.apache.flink.runtime.blob.BlobServer close
INFO: Stopped BLOB server at 0.0.0.0:43471
Jul 23, 2021 6:32:20 AM org.apache.flink.runtime.rpc.akka.AkkaRpcService 
lambda$stopService$7
INFO: Stopped Akka RPC service.

==========================================================================================
Run started 2021-07-23T06:31:11.693Z and ran for PT72.009S

Default configuration:
{"debug":true,"query":null,"sourceType":"DIRECT","generateEventFilePathPrefix":null,"sinkType":"DEVNULL","exportSummaryToBigQuery":false,"pubSubMode":"COMBINED","pubsubMessageSerializationMethod":"CODER","sideInputType":"DIRECT","sideInputRowCount":500,"sideInputNumShards":3,"sideInputUrl":null,"sessionGap":600000,"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,"numKeyBuckets":20000,"pardoCPUFactor":1.0}

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:PORTABILITY_BATCH; exportSummaryToBigQuery:true; streamTimeout:60
  0014  query:BOUNDED_SIDE_INPUT_JOIN; exportSummaryToBigQuery:true; 
streamTimeout:60
  0015  query:SESSION_SIDE_INPUT_JOIN; exportSummaryToBigQuery:true; 
streamTimeout:60

Performance:
  Conf  Runtime(sec)    (Baseline)  Events(/sec)    (Baseline)       Results    
(Baseline)
  0000           1.4                     73046.0                      100000    
          
  0001           0.6                    155521.0                       92000    
          
  0002           0.3                    374531.8                         351    
          
  0003           0.4                    239234.4                         580    
          
  0004           1.3                      7692.3                          40    
          
Exception in thread "main"   0005           1.4                     70771.4     
                     12              
  0006           0.6                     16155.1                         401    
          
  0007           9.1                     10967.3                           1    
          
  0008           0.5                    184842.9                        6000    
          
  0009           0.4                     28571.4                         298    
          
  0010           1.2                     86881.0                           1    
          
  0011           1.3                     76452.6                        1919    
          
  0012           0.6                    168067.2                        1919    
          
  0013  *** not run ***
  0014          21.5                      4642.7                       92000    
          
  0015           1.5                     66577.9                       92000    
          
==========================================================================================

com.google.cloud.bigquery.BigQueryException: 502 Bad Gateway
POST 
https://www.googleapis.com/bigquery/v2/projects/apache-beam-testing/datasets/nexmark/tables/nexmark_8_FlinkRunner_streaming/insertAll?prettyPrint=false
<!DOCTYPE html>
<html lang=en>
  <meta charset=utf-8>
  <meta name=viewport content="initial-scale=1, minimum-scale=1, 
width=device-width">
  <title>Error 502 (Server Error)!!1</title>
  <style>
    *{margin:0;padding:0}html,code{font:15px/22px 
arial,sans-serif}html{background:#fff;color:#222;padding:15px}body{margin:7% 
auto 0;max-width:390px;min-height:180px;padding:30px 0 15px}* > 
body{background:url(//www.google.com/images/errors/robot.png) 100% 5px 
no-repeat;padding-right:205px}p{margin:11px 0 
22px;overflow:hidden}ins{color:#777;text-decoration:none}a img{border:0}@media 
screen and 
(max-width:772px){body{background:none;margin-top:0;max-width:none;padding-right:0}}#logo{background:url(//www.google.com/images/branding/googlelogo/1x/googlelogo_color_150x54dp.png)
 no-repeat;margin-left:-5px}@media only screen and 
(min-resolution:192dpi){#logo{background:url(//www.google.com/images/branding/googlelogo/2x/googlelogo_color_150x54dp.png)
 no-repeat 0% 0%/100% 
100%;-moz-border-image:url(//www.google.com/images/branding/googlelogo/2x/googlelogo_color_150x54dp.png)
 0}}@media only screen and 
(-webkit-min-device-pixel-ratio:2){#logo{background:url(//www.google.com/images/branding/googlelogo/2x/googlelogo_color_150x54dp.png)
 no-repeat;-webkit-background-size:100% 
100%}}#logo{display:inline-block;height:54px;width:150px}
  </style>
  <a href=//www.google.com/><span id=logo aria-label=Google></span></a>
  <p><b>502.</b> <ins>That’s an error.</ins>
  <p>The server encountered a temporary error and could not complete your 
request.<p>Please try again in 30 seconds.  <ins>That’s all we know.</ins>

        at 
com.google.cloud.bigquery.spi.v2.HttpBigQueryRpc.translate(HttpBigQueryRpc.java:115)
        at 
com.google.cloud.bigquery.spi.v2.HttpBigQueryRpc.insertAll(HttpBigQueryRpc.java:494)
        at 
com.google.cloud.bigquery.BigQueryImpl.insertAll(BigQueryImpl.java:1036)
        at 
org.apache.beam.sdk.testutils.publishing.BigQueryClient.insertAll(BigQueryClient.java:123)
        at 
org.apache.beam.sdk.testutils.publishing.BigQueryClient.insertRow(BigQueryClient.java:98)
        at 
org.apache.beam.sdk.testutils.publishing.BigQueryClient.insertRow(BigQueryClient.java:89)
        at 
org.apache.beam.sdk.testutils.publishing.BigQueryResultsPublisher.publish(BigQueryResultsPublisher.java:47)
        at org.apache.beam.sdk.nexmark.Main.savePerfsToBigQuery(Main.java:203)
        at org.apache.beam.sdk.nexmark.Main.runAll(Main.java:164)
        at org.apache.beam.sdk.nexmark.Main.main(Main.java:495)
Caused by: com.google.api.client.googleapis.json.GoogleJsonResponseException: 
502 Bad Gateway
POST 
https://www.googleapis.com/bigquery/v2/projects/apache-beam-testing/datasets/nexmark/tables/nexmark_8_FlinkRunner_streaming/insertAll?prettyPrint=false
<!DOCTYPE html>
<html lang=en>
  <meta charset=utf-8>
  <meta name=viewport content="initial-scale=1, minimum-scale=1, 
width=device-width">
  <title>Error 502 (Server Error)!!1</title>
  <style>
    *{margin:0;padding:0}html,code{font:15px/22px 
arial,sans-serif}html{background:#fff;color:#222;padding:15px}body{margin:7% 
auto 0;max-width:390px;min-height:180px;padding:30px 0 15px}* > 
body{background:url(//www.google.com/images/errors/robot.png) 100% 5px 
no-repeat;padding-right:205px}p{margin:11px 0 
22px;overflow:hidden}ins{color:#777;text-decoration:none}a img{border:0}@media 
screen and 
(max-width:772px){body{background:none;margin-top:0;max-width:none;padding-right:0}}#logo{background:url(//www.google.com/images/branding/googlelogo/1x/googlelogo_color_150x54dp.png)
 no-repeat;margin-left:-5px}@media only screen and 
(min-resolution:192dpi){#logo{background:url(//www.google.com/images/branding/googlelogo/2x/googlelogo_color_150x54dp.png)
 no-repeat 0% 0%/100% 
100%;-moz-border-image:url(//www.google.com/images/branding/googlelogo/2x/googlelogo_color_150x54dp.png)
 0}}@media only screen and 
(-webkit-min-device-pixel-ratio:2){#logo{background:url(//www.google.com/images/branding/googlelogo/2x/googlelogo_color_150x54dp.png)
 no-repeat;-webkit-background-size:100% 
100%}}#logo{display:inline-block;height:54px;width:150px}
  </style>
  <a href=//www.google.com/><span id=logo aria-label=Google></span></a>
  <p><b>502.</b> <ins>That’s an error.</ins>
  <p>The server encountered a temporary error and could not complete your 
request.<p>Please try again in 30 seconds.  <ins>That’s all we know.</ins>

        at 
com.google.api.client.googleapis.json.GoogleJsonResponseException.from(GoogleJsonResponseException.java:146)
        at 
com.google.api.client.googleapis.services.json.AbstractGoogleJsonClientRequest.newExceptionOnError(AbstractGoogleJsonClientRequest.java:118)
        at 
com.google.api.client.googleapis.services.json.AbstractGoogleJsonClientRequest.newExceptionOnError(AbstractGoogleJsonClientRequest.java:37)
        at 
com.google.api.client.googleapis.services.AbstractGoogleClientRequest$1.interceptResponse(AbstractGoogleClientRequest.java:428)
        at com.google.api.client.http.HttpRequest.execute(HttpRequest.java:1111)
        at 
com.google.api.client.googleapis.services.AbstractGoogleClientRequest.executeUnparsed(AbstractGoogleClientRequest.java:514)
        at 
com.google.api.client.googleapis.services.AbstractGoogleClientRequest.executeUnparsed(AbstractGoogleClientRequest.java:455)
        at 
com.google.api.client.googleapis.services.AbstractGoogleClientRequest.execute(AbstractGoogleClientRequest.java:565)
        at 
com.google.cloud.bigquery.spi.v2.HttpBigQueryRpc.insertAll(HttpBigQueryRpc.java:492)
        ... 8 more

> Task :sdks:java:testing:nexmark:run FAILED

FAILURE: Build failed with an exception.

* What went wrong:
Execution failed for task ':sdks:java:testing:nexmark:run'.
> Process 'command '/usr/lib/jvm/java-8-openjdk-amd64/bin/java'' finished with 
> non-zero exit value 1

* Try:
Run with --stacktrace option to get the stack trace. Run with --info or --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 7.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See 
https://docs.gradle.org/6.8.3/userguide/command_line_interface.html#sec:command_line_warnings

BUILD FAILED in 1m 19s
115 actionable tasks: 2 executed, 113 up-to-date

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

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]

Reply via email to