See
<https://ci-beam.apache.org/job/beam_PostCommit_Go_VR_Flink/6977/display/redirect?page=changes>
Changes:
[bulatkazan] [Website] center the main content #24521
[Moritz Mack] [Spark Dataset runner] Broadcast pipeline options
[bulatkazan] [Website] update copy icon positioning #24426
------------------------------------------
[...truncated 130.88 MB...]
"payload": "AA==",
"labels": {
"PTRANSFORM": "beam.createFn"
}
}, {
"urn": "beam:metric:pardo_execution_time:process_bundle_msecs:v1",
"type": "beam:metrics:sum_int64:v1",
"payload": "AA==",
"labels": {
"PTRANSFORM": "beam.addFixedKeyFn"
}
}, {
"urn": "beam:metric:data_channel:read_index:v1",
"type": "beam:metrics:sum_int64:v1",
"payload": "AQ==",
"labels": {
"PTRANSFORM": "fn/read/n1:0"
}
}, {
"urn": "beam:metric:sampled_byte_size:v1",
"type": "beam:metrics:distribution_int64:v1",
"payload": "AQEBAQ==",
"labels": {
"PCOLLECTION": "n1"
}
}, {
"urn": "beam:metric:sampled_byte_size:v1",
"type": "beam:metrics:distribution_int64:v1",
"payload": "BEQREQ==",
"labels": {
"PCOLLECTION": "n3"
}
}, {
"urn": "beam:metric:sampled_byte_size:v1",
"type": "beam:metrics:distribution_int64:v1",
"payload": "BAgCAg==",
"labels": {
"PCOLLECTION": "n2"
}
}]
}
}
Dec 06, 2022 1:08:02 PM
org.apache.flink.runtime.resourcemanager.ResourceManager
closeTaskManagerConnection
INFO: Closing TaskExecutor connection eaac092c-4918-4349-ba40-3bfb9d6940dc
because: The TaskExecutor is shutting down.
Dec 06, 2022 1:08:02 PM
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool
releaseSlots
INFO: Releasing slot [234b0e848b6aa4628ffcec7cf3c64060].
Dec 06, 2022 1:08:02 PM
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool
releaseSlots
INFO: Releasing slot [0029b2c262e39d95aadd44541b452d90].
Dec 06, 2022 1:08:02 PM
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool
releaseSlots
INFO: Releasing slot [971048ed07d35ffd76f923b6f1c093be].
Dec 06, 2022 1:08:02 PM
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool
releaseSlots
INFO: Releasing slot [754e9d76bdd52c8e01638087aef27971].
Dec 06, 2022 1:08:02 PM
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool
releaseSlots
INFO: Releasing slot [8cae1e87a78d7bda519bfd66af970532].
Dec 06, 2022 1:08:02 PM
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool
releaseSlots
INFO: Releasing slot [652c2f44caf67bdf44f51a4cbb39f287].
Dec 06, 2022 1:08:02 PM
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool
releaseSlots
INFO: Releasing slot [48ec47cb56e8789ac3ed1f13aa29e8e4].
Dec 06, 2022 1:08:02 PM
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool
releaseSlots
INFO: Releasing slot [cf91e9d59bc3806a639407fff1e86e49].
Dec 06, 2022 1:08:02 PM
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool
releaseSlots
INFO: Releasing slot [b011edba854cbe12ebf781efcb202fe5].
Dec 06, 2022 1:08:02 PM
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool
releaseSlots
INFO: Releasing slot [98fcef3ca7e5ca6b99caba6918455b82].
Dec 06, 2022 1:08:02 PM
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool
releaseSlots
INFO: Releasing slot [6a03c98a36b615a2a0230543123c758d].
Dec 06, 2022 1:08:02 PM
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool
releaseSlots
INFO: Releasing slot [3fc3d2d988718e17ab9b53bf3c960ca1].
Dec 06, 2022 1:08:02 PM
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool
releaseSlots
INFO: Releasing slot [c90e9c34e212b81601163b16cd62e96e].
Dec 06, 2022 1:08:02 PM
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool
releaseSlots
INFO: Releasing slot [7f3306073e28f80acb52484262412614].
Dec 06, 2022 1:08:02 PM
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool
releaseSlots
INFO: Releasing slot [b10c61391794fe1f622d518f8be508ad].
Dec 06, 2022 1:08:02 PM
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool
releaseSlots
INFO: Releasing slot [de4fcebaf6541c4a9617336cb3613a05].
Dec 06, 2022 1:08:02 PM
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool
releaseSlots
INFO: Releasing slot [6ed4165207ccae260344052fb817e745].
Dec 06, 2022 1:08:02 PM
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool
releaseSlots
INFO: Releasing slot [91c0c736f78c911c5c0295389a8a1ca0].
Dec 06, 2022 1:08:02 PM
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool
releaseSlots
INFO: Releasing slot [b8416b0e007d9e86c86d842a3c7796f2].
Dec 06, 2022 1:08:02 PM
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool
releaseSlots
INFO: Releasing slot [912594c8f31f3519a438b316a3cf81fc].
Dec 06, 2022 1:08:02 PM
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool
releaseSlots
INFO: Releasing slot [7bad94768d72c053cae74b119f725588].
Dec 06, 2022 1:08:02 PM
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool
releaseSlots
INFO: Releasing slot [7d280c602888b30d6698ce1335ea81f6].
Dec 06, 2022 1:08:02 PM
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool
releaseSlots
INFO: Releasing slot [b7b942cd10c95755261c0e203f010e8a].
Dec 06, 2022 1:08:02 PM org.apache.flink.runtime.jobmaster.JobMaster
dissolveResourceManagerConnection
INFO: Close ResourceManager connection 4f43351c9a4776c30bc1af4869bc2da1:
Stopping JobMaster for job
'go0testemitpardoaftergbk0741-jenkins-1206130749-e8bd6e79'
(089e20422845fdd842a21e56d34d3340).
Dec 06, 2022 1:08:02 PM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:16, state:ALLOCATED, resource profile:
ResourceProfile{taskHeapMemory=44.522gb (47804853381 bytes),
taskOffHeapMemory=44.522gb (47804853381 bytes), managedMemory=402.364mb
(421909058 bytes), networkMemory=89.043mb (93368854 bytes)}, allocationId:
0029b2c262e39d95aadd44541b452d90, jobId: 089e20422845fdd842a21e56d34d3340).
Dec 06, 2022 1:08:02 PM
org.apache.flink.runtime.resourcemanager.ResourceManager
closeJobManagerConnection
INFO: Disconnect job manager
8517e6becae62e906f886c61d163422b@akka://flink/user/rpc/jobmanager_259 for job
089e20422845fdd842a21e56d34d3340 from the resource manager.
Dec 06, 2022 1:08:02 PM
org.apache.beam.runners.jobsubmission.InMemoryJobService lambda$run$0
WARNING: Failed to remove job staging directory for token
go-testemitpardoaftergbk-741_53494f94-8d2e-4218-a87d-06435bcef746.
java.io.FileNotFoundException: No files found for spec:
/tmp/beam-artifact-staging/3844c82dc52ae5c5ba32f58173692e10ad16ce80e78766853cb76c97a78b41ae/*
in working directory
<https://ci-beam.apache.org/job/beam_PostCommit_Go_VR_Flink/ws/src/.>
at
org.apache.beam.sdk.io.LocalFileSystem.matchOne(LocalFileSystem.java:307)
at
org.apache.beam.sdk.io.LocalFileSystem.match(LocalFileSystem.java:105)
at org.apache.beam.sdk.io.LocalFileSystem.match(LocalFileSystem.java:98)
at org.apache.beam.sdk.io.FileSystems.match(FileSystems.java:124)
at
org.apache.beam.sdk.io.FileSystems.matchResources(FileSystems.java:217)
at
org.apache.beam.runners.fnexecution.artifact.ArtifactStagingService$1.removeStagedArtifacts(ArtifactStagingService.java:180)
at
org.apache.beam.runners.fnexecution.artifact.ArtifactStagingService.removeStagedArtifacts(ArtifactStagingService.java:115)
at
org.apache.beam.runners.jobsubmission.JobServerDriver.lambda$createJobService$0(JobServerDriver.java:67)
at
org.apache.beam.runners.jobsubmission.InMemoryJobService.lambda$run$0(InMemoryJobService.java:261)
at
org.apache.beam.runners.jobsubmission.JobInvocation.setState(JobInvocation.java:249)
at
org.apache.beam.runners.jobsubmission.JobInvocation.access$200(JobInvocation.java:51)
at
org.apache.beam.runners.jobsubmission.JobInvocation$1.onSuccess(JobInvocation.java:115)
at
org.apache.beam.runners.jobsubmission.JobInvocation$1.onSuccess(JobInvocation.java:101)
at
org.apache.beam.vendor.guava.v26_0_jre.com.google.common.util.concurrent.Futures$CallbackListener.run(Futures.java:1058)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:750)
Dec 06, 2022 1:08:02 PM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:5, state:ALLOCATED, resource profile:
ResourceProfile{taskHeapMemory=44.522gb (47804853381 bytes),
taskOffHeapMemory=44.522gb (47804853381 bytes), managedMemory=402.364mb
(421909058 bytes), networkMemory=89.043mb (93368854 bytes)}, allocationId:
971048ed07d35ffd76f923b6f1c093be, jobId: 089e20422845fdd842a21e56d34d3340).
Dec 06, 2022 1:08:02 PM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:20, state:ALLOCATED, resource profile:
ResourceProfile{taskHeapMemory=44.522gb (47804853381 bytes),
taskOffHeapMemory=44.522gb (47804853381 bytes), managedMemory=402.364mb
(421909058 bytes), networkMemory=89.043mb (93368854 bytes)}, allocationId:
754e9d76bdd52c8e01638087aef27971, jobId: 089e20422845fdd842a21e56d34d3340).
Dec 06, 2022 1:08:02 PM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:6, state:ALLOCATED, resource profile:
ResourceProfile{taskHeapMemory=44.522gb (47804853381 bytes),
taskOffHeapMemory=44.522gb (47804853381 bytes), managedMemory=402.364mb
(421909058 bytes), networkMemory=89.043mb (93368854 bytes)}, allocationId:
8cae1e87a78d7bda519bfd66af970532, jobId: 089e20422845fdd842a21e56d34d3340).
Dec 06, 2022 1:08:02 PM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:13, state:ALLOCATED, resource profile:
ResourceProfile{taskHeapMemory=44.522gb (47804853381 bytes),
taskOffHeapMemory=44.522gb (47804853381 bytes), managedMemory=402.364mb
(421909058 bytes), networkMemory=89.043mb (93368854 bytes)}, allocationId:
652c2f44caf67bdf44f51a4cbb39f287, jobId: 089e20422845fdd842a21e56d34d3340).
Dec 06, 2022 1:08:02 PM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:22, state:ALLOCATED, resource profile:
ResourceProfile{taskHeapMemory=44.522gb (47804853381 bytes),
taskOffHeapMemory=44.522gb (47804853381 bytes), managedMemory=402.364mb
(421909058 bytes), networkMemory=89.043mb (93368854 bytes)}, allocationId:
48ec47cb56e8789ac3ed1f13aa29e8e4, jobId: 089e20422845fdd842a21e56d34d3340).
Dec 06, 2022 1:08:02 PM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:9, state:ALLOCATED, resource profile:
ResourceProfile{taskHeapMemory=44.522gb (47804853381 bytes),
taskOffHeapMemory=44.522gb (47804853381 bytes), managedMemory=402.364mb
(421909058 bytes), networkMemory=89.043mb (93368854 bytes)}, allocationId:
cf91e9d59bc3806a639407fff1e86e49, jobId: 089e20422845fdd842a21e56d34d3340).
Dec 06, 2022 1:08:02 PM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:7, state:ALLOCATED, resource profile:
ResourceProfile{taskHeapMemory=44.522gb (47804853381 bytes),
taskOffHeapMemory=44.522gb (47804853381 bytes), managedMemory=402.364mb
(421909058 bytes), networkMemory=89.043mb (93368854 bytes)}, allocationId:
b011edba854cbe12ebf781efcb202fe5, jobId: 089e20422845fdd842a21e56d34d3340).
Dec 06, 2022 1:08:02 PM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:15, state:ALLOCATED, resource profile:
ResourceProfile{taskHeapMemory=44.522gb (47804853381 bytes),
taskOffHeapMemory=44.522gb (47804853381 bytes), managedMemory=402.364mb
(421909058 bytes), networkMemory=89.043mb (93368854 bytes)}, allocationId:
98fcef3ca7e5ca6b99caba6918455b82, jobId: 089e20422845fdd842a21e56d34d3340).
Dec 06, 2022 1:08:02 PM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:12, state:ALLOCATED, resource profile:
ResourceProfile{taskHeapMemory=44.522gb (47804853381 bytes),
taskOffHeapMemory=44.522gb (47804853381 bytes), managedMemory=402.364mb
(421909058 bytes), networkMemory=89.043mb (93368854 bytes)}, allocationId:
6a03c98a36b615a2a0230543123c758d, jobId: 089e20422845fdd842a21e56d34d3340).
Dec 06, 2022 1:08:02 PM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:10, state:ALLOCATED, resource profile:
ResourceProfile{taskHeapMemory=44.522gb (47804853381 bytes),
taskOffHeapMemory=44.522gb (47804853381 bytes), managedMemory=402.364mb
(421909058 bytes), networkMemory=89.043mb (93368854 bytes)}, allocationId:
3fc3d2d988718e17ab9b53bf3c960ca1, jobId: 089e20422845fdd842a21e56d34d3340).
Dec 06, 2022 1:08:02 PM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:21, state:ALLOCATED, resource profile:
ResourceProfile{taskHeapMemory=44.522gb (47804853381 bytes),
taskOffHeapMemory=44.522gb (47804853381 bytes), managedMemory=402.364mb
(421909058 bytes), networkMemory=89.043mb (93368854 bytes)}, allocationId:
c90e9c34e212b81601163b16cd62e96e, jobId: 089e20422845fdd842a21e56d34d3340).
Dec 06, 2022 1:08:02 PM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:2, state:ALLOCATED, resource profile:
ResourceProfile{taskHeapMemory=44.522gb (47804853381 bytes),
taskOffHeapMemory=44.522gb (47804853381 bytes), managedMemory=402.364mb
(421909058 bytes), networkMemory=89.043mb (93368854 bytes)}, allocationId:
7f3306073e28f80acb52484262412614, jobId: 089e20422845fdd842a21e56d34d3340).
Dec 06, 2022 1:08:02 PM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:11, state:ALLOCATED, resource profile:
ResourceProfile{taskHeapMemory=44.522gb (47804853381 bytes),
taskOffHeapMemory=44.522gb (47804853381 bytes), managedMemory=402.364mb
(421909058 bytes), networkMemory=89.043mb (93368854 bytes)}, allocationId:
b10c61391794fe1f622d518f8be508ad, jobId: 089e20422845fdd842a21e56d34d3340).
Dec 06, 2022 1:08:02 PM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:18, state:ALLOCATED, resource profile:
ResourceProfile{taskHeapMemory=44.522gb (47804853381 bytes),
taskOffHeapMemory=44.522gb (47804853381 bytes), managedMemory=402.364mb
(421909058 bytes), networkMemory=89.043mb (93368854 bytes)}, allocationId:
de4fcebaf6541c4a9617336cb3613a05, jobId: 089e20422845fdd842a21e56d34d3340).
Dec 06, 2022 1:08:02 PM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:3, state:ALLOCATED, resource profile:
ResourceProfile{taskHeapMemory=44.522gb (47804853381 bytes),
taskOffHeapMemory=44.522gb (47804853381 bytes), managedMemory=402.364mb
(421909058 bytes), networkMemory=89.043mb (93368854 bytes)}, allocationId:
6ed4165207ccae260344052fb817e745, jobId: 089e20422845fdd842a21e56d34d3340).
Dec 06, 2022 1:08:02 PM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:1, state:ALLOCATED, resource profile:
ResourceProfile{taskHeapMemory=44.522gb (47804853381 bytes),
taskOffHeapMemory=44.522gb (47804853381 bytes), managedMemory=402.364mb
(421909058 bytes), networkMemory=89.043mb (93368854 bytes)}, allocationId:
91c0c736f78c911c5c0295389a8a1ca0, jobId: 089e20422845fdd842a21e56d34d3340).
Dec 06, 2022 1:08:02 PM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:8, state:ALLOCATED, resource profile:
ResourceProfile{taskHeapMemory=44.522gb (47804853381 bytes),
taskOffHeapMemory=44.522gb (47804853381 bytes), managedMemory=402.364mb
(421909058 bytes), networkMemory=89.043mb (93368854 bytes)}, allocationId:
b8416b0e007d9e86c86d842a3c7796f2, jobId: 089e20422845fdd842a21e56d34d3340).
Dec 06, 2022 1:08:02 PM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:17, state:ALLOCATED, resource profile:
ResourceProfile{taskHeapMemory=44.522gb (47804853381 bytes),
taskOffHeapMemory=44.522gb (47804853381 bytes), managedMemory=402.364mb
(421909058 bytes), networkMemory=89.043mb (93368854 bytes)}, allocationId:
912594c8f31f3519a438b316a3cf81fc, jobId: 089e20422845fdd842a21e56d34d3340).
Dec 06, 2022 1:08:02 PM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:19, state:ALLOCATED, resource profile:
ResourceProfile{taskHeapMemory=44.522gb (47804853381 bytes),
taskOffHeapMemory=44.522gb (47804853381 bytes), managedMemory=402.364mb
(421909058 bytes), networkMemory=89.043mb (93368854 bytes)}, allocationId:
7bad94768d72c053cae74b119f725588, jobId: 089e20422845fdd842a21e56d34d3340).
Dec 06, 2022 1:08:02 PM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:14, state:ALLOCATED, resource profile:
ResourceProfile{taskHeapMemory=44.522gb (47804853381 bytes),
taskOffHeapMemory=44.522gb (47804853381 bytes), managedMemory=402.364mb
(421909058 bytes), networkMemory=89.043mb (93368854 bytes)}, allocationId:
7d280c602888b30d6698ce1335ea81f6, jobId: 089e20422845fdd842a21e56d34d3340).
Dec 06, 2022 1:08:02 PM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:4, state:ALLOCATED, resource profile:
ResourceProfile{taskHeapMemory=44.522gb (47804853381 bytes),
taskOffHeapMemory=44.522gb (47804853381 bytes), managedMemory=402.364mb
(421909058 bytes), networkMemory=89.043mb (93368854 bytes)}, allocationId:
b7b942cd10c95755261c0e203f010e8a, jobId: 089e20422845fdd842a21e56d34d3340).
Dec 06, 2022 1:08:02 PM
org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService stop
INFO: Stop job leader service.
Dec 06, 2022 1:08:02 PM
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager shutdown
INFO: Shutting down TaskExecutorLocalStateStoresManager.
Dec 06, 2022 1:08:02 PM org.apache.flink.runtime.io.disk.FileChannelManagerImpl
lambda$getFileCloser$0
INFO: FileChannelManager removed spill file directory
/tmp/flink-io-db772f9a-13e4-4d71-a66e-3208a9588269
Dec 06, 2022 1:08:02 PM
org.apache.flink.runtime.io.network.NettyShuffleEnvironment close
INFO: Shutting down the network environment and its components.
Dec 06, 2022 1:08:02 PM org.apache.flink.runtime.webmonitor.WebMonitorEndpoint
lambda$shutDownInternal$5
INFO: Removing cache directory /tmp/flink-web-ui
Dec 06, 2022 1:08:02 PM org.apache.flink.runtime.rest.RestServerEndpoint
lambda$closeAsync$1
INFO: Shut down complete.
2022/12/06 13:08:02 Job state: DONE
Dec 06, 2022 1:08:02 PM
org.apache.flink.runtime.resourcemanager.ResourceManager deregisterApplication
INFO: Shut down cluster because application is in CANCELED, diagnostics
DispatcherResourceManagerComponent has been closed..
Dec 06, 2022 1:08:02 PM
org.apache.beam.runners.jobsubmission.InMemoryJobService getJobMetrics
INFO: Getting job metrics for
go0testemitpardoaftergbk0741-jenkins-1206130749-e8bd6e79_d82f7ff8-202b-4fbb-b160-6b5ced56bc1a
Dec 06, 2022 1:08:02 PM
org.apache.flink.runtime.entrypoint.component.DispatcherResourceManagerComponent
closeAsyncInternal
INFO: Closing components.
Dec 06, 2022 1:08:02 PM
org.apache.flink.runtime.dispatcher.runner.AbstractDispatcherLeaderProcess
closeInternal
INFO: Stopping SessionDispatcherLeaderProcess.
Dec 06, 2022 1:08:02 PM
org.apache.beam.runners.jobsubmission.InMemoryJobService getJobMetrics
INFO: Finished getting job metrics for
go0testemitpardoaftergbk0741-jenkins-1206130749-e8bd6e79_d82f7ff8-202b-4fbb-b160-6b5ced56bc1a
Dec 06, 2022 1:08:02 PM
org.apache.flink.runtime.resourcemanager.ResourceManagerServiceImpl closeAsync
INFO: Stopping resource manager service.
Dec 06, 2022 1:08:02 PM
org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager
close
INFO: Closing the slot manager.
Dec 06, 2022 1:08:02 PM
org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager
suspend
INFO: Suspending the slot manager.
--- PASS: TestEmitParDoAfterGBK (16.28s)
PASS
Dec 06, 2022 1:08:02 PM org.apache.flink.runtime.dispatcher.Dispatcher onStop
INFO: Stopping dispatcher akka://flink/user/rpc/dispatcher_258.
Dec 06, 2022 1:08:02 PM org.apache.flink.runtime.dispatcher.Dispatcher
terminateRunningJobs
INFO: Stopping all currently running jobs of dispatcher
akka://flink/user/rpc/dispatcher_258.
Dec 06, 2022 1:08:02 PM org.apache.flink.runtime.io.disk.FileChannelManagerImpl
lambda$getFileCloser$0
INFO: FileChannelManager removed spill file directory
/tmp/flink-netty-shuffle-4bd069b1-c6f0-4ca2-9ef0-81bf155a7716
ok github.com/apache/beam/sdks/v2/go/test/regression 141.753s
Dec 06, 2022 1:08:02 PM org.apache.flink.runtime.dispatcher.Dispatcher
lambda$onStop$1
INFO: Stopped dispatcher akka://flink/user/rpc/dispatcher_258.
Dec 06, 2022 1:08:02 PM org.apache.flink.runtime.taskexecutor.KvStateService
shutdown
INFO: Shutting down the kvState service and its components.
Dec 06, 2022 1:08:02 PM
org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService stop
INFO: Stop job leader service.
Dec 06, 2022 1:08:02 PM org.apache.flink.runtime.filecache.FileCache shutdown
INFO: removed file cache directory
/tmp/flink-dist-cache-e2350ca5-2fff-4f33-bb66-6563ba46a81c
Dec 06, 2022 1:08:02 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
handleOnStopException
INFO: Stopped TaskExecutor akka://flink/user/rpc/taskmanager_256.
FAIL
Dec 06, 2022 1:08:02 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService
stopService
INFO: Stopping Akka RPC service.
$ TEST_EXIT_CODE=0
$ cd ../..
$ exit 1
$ exit 1
> Task :sdks:go:test:flinkValidatesRunner FAILED
FAILURE: Build failed with an exception.
* Where:
Build file
'<https://ci-beam.apache.org/job/beam_PostCommit_Go_VR_Flink/ws/src/sdks/go/test/build.gradle'>
line: 69
* What went wrong:
Execution failed for task ':sdks:go:test:flinkValidatesRunner'.
> Process 'command 'sh'' 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.
* Get more help at https://help.gradle.org
Deprecated Gradle features were used in this build, making it incompatible with
Gradle 8.0.
You can use '--warning-mode all' to show the individual deprecation warnings
and determine if they come from your own scripts or plugins.
See
https://docs.gradle.org/7.5.1/userguide/command_line_interface.html#sec:command_line_warnings
Execution optimizations have been disabled for 1 invalid unit(s) of work during
this build to ensure correctness.
Please consult deprecation warnings for more details.
BUILD FAILED in 19m 36s
160 actionable tasks: 107 executed, 47 from cache, 6 up-to-date
Publishing build scan...
https://gradle.com/s/fbdxe4eabhb6c
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]
