See
<https://ci-beam.apache.org/job/beam_PostCommit_Go_VR_Flink/6164/display/redirect?page=changes>
Changes:
[noreply] [BEAM-13015] Update the SDK harness grouping table to be memory
bounded
[noreply] [BEAM-13982] Added output of logging for python E2E pytests (#17637)
[noreply] [BEAM-14473] Throw error if using globally windowed, unbounded side
[noreply] [BEAM-14440] Add basic fuzz tests to the coders package (#17587)
[noreply] [BEAM-14035 ] Implement BigQuerySchema Read/Write TransformProvider
------------------------------------------
[...truncated 39.53 MB...]
}, {
"urn": "beam:metric:pardo_execution_time:finish_bundle_msecs:v1",
"type": "beam:metrics:sum_int64:v1",
"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"
}
}]
}
}
May 16, 2022 7:23:13 PM
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool
releaseSlots
INFO: Releasing slot [714dd904063f386592caca4441fb1267].
May 16, 2022 7:23:13 PM
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool
releaseSlots
INFO: Releasing slot [b6078eb0289bbfc3f4c6e5bb15a90df8].
May 16, 2022 7:23:13 PM
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool
releaseSlots
INFO: Releasing slot [66c9a9c63fc44322c2300ff26f6fb7c1].
May 16, 2022 7:23:13 PM
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool
releaseSlots
INFO: Releasing slot [25cbd18f0b412112fa4355f39e6000e0].
May 16, 2022 7:23:13 PM
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool
releaseSlots
INFO: Releasing slot [0387a7a4316cc64095ceb4b3a98038fa].
May 16, 2022 7:23:13 PM
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool
releaseSlots
INFO: Releasing slot [8c567861e53de10cbba8b05e8de94791].
May 16, 2022 7:23:13 PM
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool
releaseSlots
INFO: Releasing slot [7705b2ea6976632359e23caaee76bcef].
May 16, 2022 7:23:13 PM
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool
releaseSlots
INFO: Releasing slot [317c3b3145e5058d798c6c56c6d199c2].
May 16, 2022 7:23:13 PM
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool
releaseSlots
INFO: Releasing slot [0a661f3dd3d38bf65f776ded2d2a8801].
May 16, 2022 7:23:13 PM
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool
releaseSlots
INFO: Releasing slot [0507fd00b6bee2fd692d57983f87f8c4].
May 16, 2022 7:23:13 PM
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool
releaseSlots
INFO: Releasing slot [c9ee850123bf1315ffe1d76622df9e2e].
May 16, 2022 7:23:13 PM
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool
releaseSlots
INFO: Releasing slot [34d14e19d2d699d67e6cd9dec2c241ac].
May 16, 2022 7:23:13 PM
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool
releaseSlots
INFO: Releasing slot [1c1ca759738621c74144a296530c508e].
May 16, 2022 7:23:13 PM
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool
releaseSlots
INFO: Releasing slot [e3423f8305e22c6b69ae92658098d44e].
May 16, 2022 7:23:13 PM
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool
releaseSlots
INFO: Releasing slot [2356854407007a934a8b17c3d3742088].
May 16, 2022 7:23:13 PM
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool
releaseSlots
INFO: Releasing slot [fb5c835767016dc1bc0f7aa7db213537].
May 16, 2022 7:23:13 PM
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool
releaseSlots
INFO: Releasing slot [bdca2eb5eb597e18f7a92982bfd729da].
May 16, 2022 7:23:13 PM
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool
releaseSlots
INFO: Releasing slot [e88b7f2f2624dffa303ae0524faf2c85].
May 16, 2022 7:23:13 PM
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool
releaseSlots
INFO: Releasing slot [01f385e5b969f618e4be1d4a1ec8f442].
May 16, 2022 7:23:13 PM
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool
releaseSlots
INFO: Releasing slot [a4edb6f5cc7bcc048e00657d318a3caa].
May 16, 2022 7:23:13 PM
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool
releaseSlots
INFO: Releasing slot [b895d933e11d3061022158432ad58eb1].
May 16, 2022 7:23:13 PM
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool
releaseSlots
INFO: Releasing slot [d26353e25debb38d240897f5b367c321].
May 16, 2022 7:23:13 PM
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool
releaseSlots
INFO: Releasing slot [7f7ddcb2319ea9a4832e155829af8db2].
May 16, 2022 7:23:13 PM org.apache.flink.runtime.jobmaster.JobMaster
dissolveResourceManagerConnection
INFO: Close ResourceManager connection b3c6241fb74112cd6bd0e932a2609fbf:
Stopping JobMaster for job
'go0testemitpardoaftergbk-jenkins-0516192302-605fdd1'
(5b8ae4aaf1a04d32b34a1ea463fcec6d).
May 16, 2022 7:23:13 PM
org.apache.flink.runtime.resourcemanager.ResourceManager
closeJobManagerConnection
INFO: Disconnect job manager
902b4790ae279c9046569906160241b3@akka://flink/user/rpc/jobmanager_147 for job
5b8ae4aaf1a04d32b34a1ea463fcec6d from the resource manager.
May 16, 2022 7:23:13 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=403.142mb
(422725542 bytes), networkMemory=89.043mb (93368854 bytes)}, allocationId:
b6078eb0289bbfc3f4c6e5bb15a90df8, jobId: 5b8ae4aaf1a04d32b34a1ea463fcec6d).
May 16, 2022 7:23:13 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=403.142mb
(422725542 bytes), networkMemory=89.043mb (93368854 bytes)}, allocationId:
66c9a9c63fc44322c2300ff26f6fb7c1, jobId: 5b8ae4aaf1a04d32b34a1ea463fcec6d).
May 16, 2022 7:23:13 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=403.142mb
(422725542 bytes), networkMemory=89.043mb (93368854 bytes)}, allocationId:
25cbd18f0b412112fa4355f39e6000e0, jobId: 5b8ae4aaf1a04d32b34a1ea463fcec6d).
May 16, 2022 7:23:13 PM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:0, state:ALLOCATED, resource profile:
ResourceProfile{taskHeapMemory=44.522gb (47804853381 bytes),
taskOffHeapMemory=44.522gb (47804853381 bytes), managedMemory=403.142mb
(422725542 bytes), networkMemory=89.043mb (93368854 bytes)}, allocationId:
0387a7a4316cc64095ceb4b3a98038fa, jobId: 5b8ae4aaf1a04d32b34a1ea463fcec6d).
May 16, 2022 7:23:13 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=403.142mb
(422725542 bytes), networkMemory=89.043mb (93368854 bytes)}, allocationId:
8c567861e53de10cbba8b05e8de94791, jobId: 5b8ae4aaf1a04d32b34a1ea463fcec6d).
May 16, 2022 7:23:13 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=403.142mb
(422725542 bytes), networkMemory=89.043mb (93368854 bytes)}, allocationId:
7705b2ea6976632359e23caaee76bcef, jobId: 5b8ae4aaf1a04d32b34a1ea463fcec6d).
May 16, 2022 7:23:13 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=403.142mb
(422725542 bytes), networkMemory=89.043mb (93368854 bytes)}, allocationId:
317c3b3145e5058d798c6c56c6d199c2, jobId: 5b8ae4aaf1a04d32b34a1ea463fcec6d).
May 16, 2022 7:23:13 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=403.142mb
(422725542 bytes), networkMemory=89.043mb (93368854 bytes)}, allocationId:
0a661f3dd3d38bf65f776ded2d2a8801, jobId: 5b8ae4aaf1a04d32b34a1ea463fcec6d).
May 16, 2022 7:23:13 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=403.142mb
(422725542 bytes), networkMemory=89.043mb (93368854 bytes)}, allocationId:
0507fd00b6bee2fd692d57983f87f8c4, jobId: 5b8ae4aaf1a04d32b34a1ea463fcec6d).
May 16, 2022 7:23:13 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=403.142mb
(422725542 bytes), networkMemory=89.043mb (93368854 bytes)}, allocationId:
c9ee850123bf1315ffe1d76622df9e2e, jobId: 5b8ae4aaf1a04d32b34a1ea463fcec6d).
May 16, 2022 7:23:13 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=403.142mb
(422725542 bytes), networkMemory=89.043mb (93368854 bytes)}, allocationId:
34d14e19d2d699d67e6cd9dec2c241ac, jobId: 5b8ae4aaf1a04d32b34a1ea463fcec6d).
May 16, 2022 7:23:13 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=403.142mb
(422725542 bytes), networkMemory=89.043mb (93368854 bytes)}, allocationId:
1c1ca759738621c74144a296530c508e, jobId: 5b8ae4aaf1a04d32b34a1ea463fcec6d).
May 16, 2022 7:23:13 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=403.142mb
(422725542 bytes), networkMemory=89.043mb (93368854 bytes)}, allocationId:
e3423f8305e22c6b69ae92658098d44e, jobId: 5b8ae4aaf1a04d32b34a1ea463fcec6d).
May 16, 2022 7:23:13 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=403.142mb
(422725542 bytes), networkMemory=89.043mb (93368854 bytes)}, allocationId:
2356854407007a934a8b17c3d3742088, jobId: 5b8ae4aaf1a04d32b34a1ea463fcec6d).
May 16, 2022 7:23:13 PM
org.apache.beam.runners.jobsubmission.InMemoryJobService lambda$run$0
WARNING: Failed to remove job staging directory for token
go-testemitpardoaftergbk_56a9b356-298a-49c6-a059-9e23b4e8e089.
java.io.FileNotFoundException: No files found for spec:
/tmp/beam-artifact-staging/0831f5f98019924ed9c0fab87b0f06bd7a55e8b65b5ef065ae8325972f111628/*
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:748)
May 16, 2022 7:23:13 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=403.142mb
(422725542 bytes), networkMemory=89.043mb (93368854 bytes)}, allocationId:
fb5c835767016dc1bc0f7aa7db213537, jobId: 5b8ae4aaf1a04d32b34a1ea463fcec6d).
May 16, 2022 7:23:13 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=403.142mb
(422725542 bytes), networkMemory=89.043mb (93368854 bytes)}, allocationId:
bdca2eb5eb597e18f7a92982bfd729da, jobId: 5b8ae4aaf1a04d32b34a1ea463fcec6d).
May 16, 2022 7:23:13 PM org.apache.flink.runtime.webmonitor.WebMonitorEndpoint
lambda$shutDownInternal$5
INFO: Removing cache directory /tmp/flink-web-ui
May 16, 2022 7:23:13 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=403.142mb
(422725542 bytes), networkMemory=89.043mb (93368854 bytes)}, allocationId:
e88b7f2f2624dffa303ae0524faf2c85, jobId: 5b8ae4aaf1a04d32b34a1ea463fcec6d).
May 16, 2022 7:23:13 PM org.apache.flink.runtime.rest.RestServerEndpoint
lambda$closeAsync$1
INFO: Shut down complete.
May 16, 2022 7:23:13 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=403.142mb
(422725542 bytes), networkMemory=89.043mb (93368854 bytes)}, allocationId:
01f385e5b969f618e4be1d4a1ec8f442, jobId: 5b8ae4aaf1a04d32b34a1ea463fcec6d).
May 16, 2022 7:23:13 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=403.142mb
(422725542 bytes), networkMemory=89.043mb (93368854 bytes)}, allocationId:
a4edb6f5cc7bcc048e00657d318a3caa, jobId: 5b8ae4aaf1a04d32b34a1ea463fcec6d).
May 16, 2022 7:23:13 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=403.142mb
(422725542 bytes), networkMemory=89.043mb (93368854 bytes)}, allocationId:
b895d933e11d3061022158432ad58eb1, jobId: 5b8ae4aaf1a04d32b34a1ea463fcec6d).
May 16, 2022 7:23:13 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=403.142mb
(422725542 bytes), networkMemory=89.043mb (93368854 bytes)}, allocationId:
d26353e25debb38d240897f5b367c321, jobId: 5b8ae4aaf1a04d32b34a1ea463fcec6d).
May 16, 2022 7:23:13 PM
org.apache.flink.runtime.resourcemanager.ResourceManager deregisterApplication
INFO: Shut down cluster because application is in CANCELED, diagnostics
DispatcherResourceManagerComponent has been closed..
May 16, 2022 7:23:13 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=403.142mb
(422725542 bytes), networkMemory=89.043mb (93368854 bytes)}, allocationId:
7f7ddcb2319ea9a4832e155829af8db2, jobId: 5b8ae4aaf1a04d32b34a1ea463fcec6d).
May 16, 2022 7:23:13 PM
org.apache.flink.runtime.entrypoint.component.DispatcherResourceManagerComponent
closeAsyncInternal
INFO: Closing components.
May 16, 2022 7:23:13 PM
org.apache.flink.runtime.dispatcher.runner.AbstractDispatcherLeaderProcess
closeInternal
INFO: Stopping SessionDispatcherLeaderProcess.
May 16, 2022 7:23:13 PM
org.apache.flink.runtime.resourcemanager.ResourceManagerServiceImpl closeAsync
INFO: Stopping resource manager service.
May 16, 2022 7:23:13 PM org.apache.flink.runtime.dispatcher.Dispatcher onStop
INFO: Stopping dispatcher akka://flink/user/rpc/dispatcher_145.
May 16, 2022 7:23:13 PM
org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager
close
INFO: Closing the slot manager.
May 16, 2022 7:23:13 PM org.apache.flink.runtime.dispatcher.Dispatcher
terminateRunningJobs
INFO: Stopping all currently running jobs of dispatcher
akka://flink/user/rpc/dispatcher_145.
May 16, 2022 7:23:13 PM
org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager
suspend
INFO: Suspending the slot manager.
2022/05/16 19:23:13 Job state: DONE
May 16, 2022 7:23:13 PM
org.apache.beam.runners.jobsubmission.InMemoryJobService getJobMetrics
INFO: Getting job metrics for
go0testemitpardoaftergbk-jenkins-0516192302-605fdd1_9d3dec5f-0587-4a51-8a97-6f2052b175f6
May 16, 2022 7:23:13 PM
org.apache.beam.runners.jobsubmission.InMemoryJobService getJobMetrics
INFO: Finished getting job metrics for
go0testemitpardoaftergbk-jenkins-0516192302-605fdd1_9d3dec5f-0587-4a51-8a97-6f2052b175f6
May 16, 2022 7:23:13 PM
org.apache.flink.runtime.taskexecutor.TaskExecutor$JobLeaderListenerImpl
jobManagerLostLeadership
INFO: JobManager for job 5b8ae4aaf1a04d32b34a1ea463fcec6d with leader id
902b4790ae279c9046569906160241b3 lost leadership.
May 16, 2022 7:23:13 PM
org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService stop
INFO: Stop job leader service.
May 16, 2022 7:23:13 PM
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager shutdown
INFO: Shutting down TaskExecutorLocalStateStoresManager.
May 16, 2022 7:23:13 PM org.apache.flink.runtime.io.disk.FileChannelManagerImpl
lambda$getFileCloser$0
INFO: FileChannelManager removed spill file directory
/tmp/flink-io-6e6cc1bb-612f-400b-921b-517cddb15ed3
May 16, 2022 7:23:13 PM
org.apache.flink.runtime.io.network.NettyShuffleEnvironment close
INFO: Shutting down the network environment and its components.
May 16, 2022 7:23:13 PM org.apache.flink.runtime.dispatcher.Dispatcher
lambda$onStop$0
INFO: Stopped dispatcher akka://flink/user/rpc/dispatcher_145.
--- PASS: TestEmitParDoAfterGBK (13.22s)
PASS
May 16, 2022 7:23:13 PM org.apache.flink.runtime.io.disk.FileChannelManagerImpl
lambda$getFileCloser$0
INFO: FileChannelManager removed spill file directory
/tmp/flink-netty-shuffle-ef3d1c74-d8bb-403f-a493-6ba8a623d0fb
May 16, 2022 7:23:13 PM org.apache.flink.runtime.taskexecutor.KvStateService
shutdown
INFO: Shutting down the kvState service and its components.
May 16, 2022 7:23:13 PM
org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService stop
INFO: Stop job leader service.
May 16, 2022 7:23:13 PM org.apache.flink.runtime.filecache.FileCache shutdown
INFO: removed file cache directory
/tmp/flink-dist-cache-b3c6d79d-f963-4039-83ae-4df52c460271
May 16, 2022 7:23:13 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
handleOnStopException
INFO: Stopped TaskExecutor akka://flink/user/rpc/taskmanager_144.
May 16, 2022 7:23:13 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService
stopService
INFO: Stopping Akka RPC service.
ok github.com/apache/beam/sdks/v2/go/test/regression 122.327s
FAIL
> 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: 70
* 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.
> 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 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.4/userguide/command_line_interface.html#sec:command_line_warnings
Execution optimizations have been disabled for 2 invalid unit(s) of work during
this build to ensure correctness.
Please consult deprecation warnings for more details.
BUILD FAILED in 34m 39s
169 actionable tasks: 146 executed, 16 from cache, 7 up-to-date
Publishing build scan...
https://gradle.com/s/n7mervihuj4qu
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]
