See <https://ci-beam.apache.org/job/beam_PostCommit_Python37/4892/display/redirect?page=changes>
Changes: [Kenneth Knowles] Disable AfterSynchronizedProcessingTime test on Dataflow [mmack] [BEAM-13563] Introducing common AWS ClientBuilderFactory to unify [noreply] Case studies page improvements (#16702) ------------------------------------------ [...truncated 5.28 MB...] Step 23/31 : COPY target/license_scripts /tmp/license_scripts/ ---> dbfbc5315f7e Step 24/31 : COPY target/LICENSE target/go-licenses/* /opt/apache/beam/third_party_licenses/golang/ ---> 90080489dda1 Step 25/31 : RUN rm /opt/apache/beam/third_party_licenses/golang/LICENSE ---> Running in 893688ccd6d9 Removing intermediate container 893688ccd6d9 ---> 37ef9fb7482f Step 26/31 : COPY target/license_scripts /tmp/license_scripts/ ---> 991a598d8ba4 Step 27/31 : RUN if [ "$pull_licenses" = "true" ] ; then pip install 'pip-licenses<3.0.0' pyyaml tenacity && python /tmp/license_scripts/pull_licenses_py.py ; fi ---> Running in a51fdc2f4230 Collecting pip-licenses<3.0.0 Downloading pip_licenses-2.3.0-py3-none-any.whl (14 kB) Requirement already satisfied: pyyaml in /usr/local/lib/python3.7/site-packages (6.0) Requirement already satisfied: tenacity in /usr/local/lib/python3.7/site-packages (5.1.5) Collecting PTable Downloading PTable-0.9.2.tar.gz (31 kB) Requirement already satisfied: six>=1.9.0 in /usr/local/lib/python3.7/site-packages (from tenacity) (1.16.0) Building wheels for collected packages: PTable Building wheel for PTable (setup.py): started Building wheel for PTable (setup.py): finished with status 'done' Created wheel for PTable: filename=PTable-0.9.2-py3-none-any.whl size=22925 sha256=2cfc2854e2a44ea4c76eec815616afee624027289f882653571d2494e756cad6 Stored in directory: /root/.cache/pip/wheels/33/df/2f/674985b3f8a2de3f96357d1eadef5110f74fa91b3785e52a54 Successfully built PTable Installing collected packages: PTable, pip-licenses Successfully installed PTable-0.9.2 pip-licenses-2.3.0 [91mWARNING: Running pip as the 'root' user can result in broken permissions and conflicting behaviour with the system package manager. It is recommended to use a virtual environment instead: https://pip.pypa.io/warnings/venv [0m[91mWARNING: You are using pip version 21.2.4; however, version 22.0.3 is available. You should consider upgrading via the '/usr/local/bin/python -m pip install --upgrade pip' command. [0m[91mINFO:root:Successfully pulled licenses for 138 dependencies [0mSkip pulling license for bs4 Removing intermediate container a51fdc2f4230 ---> 7bb8015efc85 Step 28/31 : FROM beam ---> f32af9551e49 Step 29/31 : ARG pull_licenses ---> Running in 745b27989c16 Removing intermediate container 745b27989c16 ---> 92dac5df81a6 Step 30/31 : COPY --from=third_party_licenses /opt/apache/beam/third_party_licenses /opt/apache/beam/third_party_licenses ---> b5cf9a98d278 Step 31/31 : RUN if [ "$pull_licenses" != "true" ] ; then rm -rf /opt/apache/beam/third_party_licenses ; fi ---> Running in 4f314db6ca60 Removing intermediate container 4f314db6ca60 ---> 287b4b9fa270 Successfully built 287b4b9fa270 Successfully tagged apache/beam_python3.7_sdk:2.38.0.dev > Task :sdks:python:test-suites:portable:py37:postCommitPy37IT INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:35 PM akka.event.slf4j.Slf4jLogger$$anonfun$receive$1 applyOrElse' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Slf4jLogger started' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:35 PM org.apache.flink.runtime.rpc.akka.AkkaBootstrapTools startActorSystem' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Actor system started at akka://flink' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:35 PM org.apache.flink.runtime.rpc.akka.AkkaBootstrapTools startLocalActorSystem' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Trying to start local actor system' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:35 PM akka.event.slf4j.Slf4jLogger$$anonfun$receive$1 applyOrElse' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Slf4jLogger started' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:35 PM org.apache.flink.runtime.rpc.akka.AkkaBootstrapTools startActorSystem' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Actor system started at akka://flink-metrics' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:35 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService startServer' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Starting RPC endpoint for org.apache.flink.runtime.metrics.dump.MetricQueryService at akka://flink-metrics/user/rpc/MetricQueryService .' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:35 PM org.apache.flink.runtime.minicluster.MiniCluster createHighAvailabilityServices' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Starting high-availability services' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:35 PM org.apache.flink.runtime.blob.BlobServer <init>' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Created BLOB server storage directory /tmp/blobStore-ed033650-b3a8-4fa9-b2d6-3e0dc30686ed' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:35 PM org.apache.flink.runtime.blob.BlobServer <init>' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Started BLOB server at 0.0.0.0:44127 - max concurrent requests: 50 - max backlog: 1000' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:35 PM org.apache.flink.runtime.blob.AbstractBlobCache <init>' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Created BLOB cache storage directory /tmp/blobStore-99b51031-bb2d-4d88-82ba-1172ef8b2fab' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:35 PM org.apache.flink.runtime.blob.AbstractBlobCache <init>' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Created BLOB cache storage directory /tmp/blobStore-210c9032-19e5-423e-98f8-9ca5f5575102' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:35 PM org.apache.flink.runtime.minicluster.MiniCluster startTaskManagers' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Starting 1 TaskManager(s)' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:35 PM org.apache.flink.runtime.taskexecutor.TaskManagerRunner startTaskManager' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Starting TaskManager with ResourceID: 9c9642de-e8ab-44c0-bd6a-684f3ea4402e' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:36 PM org.apache.flink.runtime.taskexecutor.TaskManagerServices checkTempDirs' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: Temporary file directory '/tmp': total 969 GB, usable 809 GB (83.49% usable)" INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:36 PM org.apache.flink.runtime.io.disk.iomanager.IOManager <init>' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Created a new FileChannelManager for spilling of task related data to disk (joins, sorting, ...). Used directories:' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'\t/tmp/flink-io-a65bdb54-0aa1-4ba4-a736-e0f6014a4507' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:36 PM org.apache.flink.runtime.io.network.NettyShuffleServiceFactory createNettyShuffleEnvironment' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Created a new FileChannelManager for storing result partitions of BLOCKING shuffles. Used directories:' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'\t/tmp/flink-netty-shuffle-ab9c871e-8a45-43c6-a86c-67ed8a6efa29' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:36 PM org.apache.flink.runtime.io.network.buffer.NetworkBufferPool <init>' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Allocated 64 MB for network buffer pool (number of memory segments: 2048, bytes per segment: 32768).' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:36 PM org.apache.flink.runtime.io.network.NettyShuffleEnvironment start' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Starting the network environment and its components.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:36 PM org.apache.flink.runtime.taskexecutor.KvStateService start' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Starting the kvState service and its components.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:36 PM org.apache.flink.configuration.Configuration loggingFallback' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: Config uses fallback configuration key 'akka.ask.timeout' instead of key 'taskmanager.slot.timeout'" INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:36 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService startServer' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Starting RPC endpoint for org.apache.flink.runtime.taskexecutor.TaskExecutor at akka://flink/user/rpc/taskmanager_0 .' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:36 PM org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService start' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Start job leader service.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:36 PM org.apache.flink.runtime.filecache.FileCache <init>' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: User file cache uses directory /tmp/flink-dist-cache-872ebc49-0a6a-45ce-9d10-f1732c8c3b43' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:36 PM org.apache.flink.runtime.rest.RestServerEndpoint start' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Starting rest endpoint.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:36 PM org.apache.flink.runtime.webmonitor.WebMonitorUtils$LogFileLocation find' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"WARNING: Log file environment variable 'log.file' is not set." INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:36 PM org.apache.flink.runtime.webmonitor.WebMonitorUtils$LogFileLocation find' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"WARNING: JobManager log files are unavailable in the web dashboard. Log file location not found in environment variable 'log.file' or configuration key 'web.log.path'." INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:36 PM org.apache.flink.runtime.rest.RestServerEndpoint start' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Rest endpoint listening at localhost:36627' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:36 PM org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService updateLeader' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Proposing leadership to contender http://localhost:36627' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:36 PM org.apache.flink.runtime.webmonitor.WebMonitorEndpoint startInternal' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Web frontend listening at http://localhost:36627.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:36 PM org.apache.flink.runtime.webmonitor.WebMonitorEndpoint grantLeadership' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: http://localhost:36627 was granted leadership with leaderSessionID=57d0ceb8-43a5-49d5-9dc8-1220421ba0fd' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:36 PM org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService confirmLeader' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received confirmation of leadership for leader http://localhost:36627 , session=57d0ceb8-43a5-49d5-9dc8-1220421ba0fd' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:36 PM org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService updateLeader' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Proposing leadership to contender LeaderContender: DefaultDispatcherRunner' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:36 PM org.apache.flink.runtime.resourcemanager.ResourceManagerServiceImpl start' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Starting resource manager service.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:36 PM org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService updateLeader' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Proposing leadership to contender LeaderContender: ResourceManagerServiceImpl' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:36 PM org.apache.flink.runtime.dispatcher.runner.DefaultDispatcherRunner lambda$grantLeadership$0' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: DefaultDispatcherRunner was granted leadership with leader id af858122-be6e-45aa-a882-fca2b94dd36d. Creating new DispatcherLeaderProcess.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:36 PM org.apache.flink.runtime.resourcemanager.ResourceManagerServiceImpl lambda$grantLeadership$1' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Resource manager service is granted leadership with session id 9c4939cd-47d1-470a-b087-3360628c2489.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:36 PM org.apache.flink.runtime.minicluster.MiniCluster start' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Flink Mini Cluster started successfully' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:36 PM org.apache.flink.runtime.dispatcher.runner.AbstractDispatcherLeaderProcess startInternal' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Start SessionDispatcherLeaderProcess.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:36 PM org.apache.flink.runtime.dispatcher.runner.SessionDispatcherLeaderProcess recoverJobs' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Recover all persisted job graphs.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:36 PM org.apache.flink.runtime.dispatcher.runner.SessionDispatcherLeaderProcess recoverJobs' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Successfully recovered 0 persisted job graphs.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:36 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService startServer' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Starting RPC endpoint for org.apache.flink.runtime.dispatcher.StandaloneDispatcher at akka://flink/user/rpc/dispatcher_1 .' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:36 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService startServer' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Starting RPC endpoint for org.apache.flink.runtime.resourcemanager.StandaloneResourceManager at akka://flink/user/rpc/resourcemanager_2 .' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:36 PM org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService confirmLeader' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received confirmation of leadership for leader akka://flink/user/rpc/dispatcher_1 , session=af858122-be6e-45aa-a882-fca2b94dd36d' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:36 PM org.apache.flink.runtime.resourcemanager.ResourceManager onStart' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Starting the resource manager.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:36 PM org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService confirmLeader' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received confirmation of leadership for leader akka://flink/user/rpc/resourcemanager_2 , session=9c4939cd-47d1-470a-b087-3360628c2489' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:36 PM org.apache.flink.runtime.taskexecutor.TaskExecutor connectToResourceManager' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Connecting to ResourceManager akka://flink/user/rpc/resourcemanager_2(b0873360628c24899c4939cd47d1470a).' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:36 PM org.apache.flink.runtime.registration.RetryingRegistration lambda$startRegistration$0' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Resolved ResourceManager address, beginning registration' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:36 PM org.apache.flink.runtime.resourcemanager.ResourceManager registerTaskExecutorInternal' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Registering TaskManager with ResourceID 9c9642de-e8ab-44c0-bd6a-684f3ea4402e (akka://flink/user/rpc/taskmanager_0) at ResourceManager' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:36 PM org.apache.flink.runtime.taskexecutor.TaskExecutorToResourceManagerConnection onRegistrationSuccess' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Successful registration at resource manager akka://flink/user/rpc/resourcemanager_2 under registration id e2c8823e35d5cb476cee09df19c5a0d9.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:36 PM org.apache.flink.runtime.dispatcher.Dispatcher submitJob' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: Received JobGraph submission 'BeamApp-jenkins-0217201432-11c89ed1' (8c889482b3d9cebe8d7bab2003a6cb2f)." INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:36 PM org.apache.flink.runtime.dispatcher.Dispatcher internalSubmitJob' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: Submitting job 'BeamApp-jenkins-0217201432-11c89ed1' (8c889482b3d9cebe8d7bab2003a6cb2f)." INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:36 PM org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService updateLeader' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Proposing leadership to contender LeaderContender: JobMasterServiceLeadershipRunner' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:36 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService startServer' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Starting RPC endpoint for org.apache.flink.runtime.jobmaster.JobMaster at akka://flink/user/rpc/jobmanager_3 .' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:36 PM org.apache.flink.runtime.jobmaster.JobMaster <init>' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: Initializing job 'BeamApp-jenkins-0217201432-11c89ed1' (8c889482b3d9cebe8d7bab2003a6cb2f)." INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:36 PM org.apache.flink.runtime.scheduler.DefaultSchedulerFactory createInstance' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Using restart back off time strategy NoRestartBackoffTimeStrategy for BeamApp-jenkins-0217201432-11c89ed1 (8c889482b3d9cebe8d7bab2003a6cb2f).' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:36 PM org.apache.flink.runtime.executiongraph.DefaultExecutionGraphBuilder buildGraph' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Running initialization on master for job BeamApp-jenkins-0217201432-11c89ed1 (8c889482b3d9cebe8d7bab2003a6cb2f).' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:36 PM org.apache.flink.runtime.executiongraph.DefaultExecutionGraphBuilder buildGraph' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Successfully ran initialization on master in 6 ms.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:36 PM org.apache.flink.runtime.scheduler.adapter.DefaultExecutionTopology computePipelinedRegions' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Built 1 pipelined regions in 0 ms' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:36 PM org.apache.flink.runtime.scheduler.DefaultScheduler <init>' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Using failover strategy org.apache.flink.runtime.executiongraph.failover.flip1.RestartPipelinedRegionFailoverStrategy@422f7748 for BeamApp-jenkins-0217201432-11c89ed1 (8c889482b3d9cebe8d7bab2003a6cb2f).' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:36 PM org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService confirmLeader' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received confirmation of leadership for leader akka://flink/user/rpc/jobmanager_3 , session=4f5127fb-9897-48e6-a8e3-7b5f27520494' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:36 PM org.apache.flink.runtime.jobmaster.JobMaster startJobExecution' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: Starting execution of job 'BeamApp-jenkins-0217201432-11c89ed1' (8c889482b3d9cebe8d7bab2003a6cb2f) under job master id a8e37b5f275204944f5127fb989748e6." INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:36 PM org.apache.flink.runtime.scheduler.DefaultScheduler startSchedulingInternal' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Starting scheduling with scheduling strategy [org.apache.flink.runtime.scheduler.strategy.PipelinedRegionSchedulingStrategy]' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:36 PM org.apache.flink.runtime.executiongraph.DefaultExecutionGraph transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Job BeamApp-jenkins-0217201432-11c89ed1 (8c889482b3d9cebe8d7bab2003a6cb2f) switched from state CREATED to RUNNING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:36 PM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: DataSource (Impulse) (1/16) (37cf3038805ebbe7d3ab66e1f96247cd) switched from CREATED to SCHEDULED.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:36 PM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: DataSource (Impulse) (2/16) (0b5793312d19c7cf71074bb2d85e4afa) switched from CREATED to SCHEDULED.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:36 PM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: DataSource (Impulse) (3/16) (f535342fb04d2e8414123cb721d50114) switched from CREATED to SCHEDULED.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:36 PM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: DataSource (Impulse) (4/16) (ed18e73aec2b77c43608e8a62a6d0ba9) switched from CREATED to SCHEDULED.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:36 PM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: DataSource (Impulse) (5/16) (a0a3088e4bc7e7e78410faf7acd063a0) switched from CREATED to SCHEDULED.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:36 PM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: DataSource (Impulse) (6/16) (16fb21c01e362834225f3fa995bbabb1) switched from CREATED to SCHEDULED.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:36 PM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: DataSource (Impulse) (7/16) (f25a3d255d8ba06f8ab5bf41588bb618) switched from CREATED to SCHEDULED.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:36 PM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: DataSource (Impulse) (8/16) (f05c8b7297a455b6cbd9170db8313184) switched from CREATED to SCHEDULED.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:36 PM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: DataSource (Impulse) (9/16) (70153fa74a56628c13cc91b3b27db155) switched from CREATED to SCHEDULED.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:36 PM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: DataSource (Impulse) (10/16) (7f29c5290bdc5c36bd98c3e74b3c8507) switched from CREATED to SCHEDULED.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:36 PM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: DataSource (Impulse) (11/16) (dbe7b42e2bf03945fd58b17634bd12e8) switched from CREATED to SCHEDULED.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:36 PM org.apache.flink.runtime.executiongraph.Execution transitionState' > Task :sdks:python:test-suites:portable:py37:postCommitPy37IT INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:35 PM akka.event.slf4j.Slf4jLogger$$anonfun$receive$1 applyOrElse' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Slf4jLogger started' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:35 PM org.apache.flink.runtime.rpc.akka.AkkaBootstrapTools startActorSystem' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Actor system started at akka://flink' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:35 PM org.apache.flink.runtime.rpc.akka.AkkaBootstrapTools startLocalActorSystem' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Trying to start local actor system' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:35 PM akka.event.slf4j.Slf4jLogger$$anonfun$receive$1 applyOrElse' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Slf4jLogger started' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:35 PM org.apache.flink.runtime.rpc.akka.AkkaBootstrapTools startActorSystem' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Actor system started at akka://flink-metrics' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:35 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService startServer' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Starting RPC endpoint for org.apache.flink.runtime.metrics.dump.MetricQueryService at akka://flink-metrics/user/rpc/MetricQueryService .' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:35 PM org.apache.flink.runtime.minicluster.MiniCluster createHighAvailabilityServices' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Starting high-availability services' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:35 PM org.apache.flink.runtime.blob.BlobServer <init>' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Created BLOB server storage directory /tmp/blobStore-ed033650-b3a8-4fa9-b2d6-3e0dc30686ed' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:35 PM org.apache.flink.runtime.blob.BlobServer <init>' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Started BLOB server at 0.0.0.0:44127 - max concurrent requests: 50 - max backlog: 1000' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:35 PM org.apache.flink.runtime.blob.AbstractBlobCache <init>' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Created BLOB cache storage directory /tmp/blobStore-99b51031-bb2d-4d88-82ba-1172ef8b2fab' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:35 PM org.apache.flink.runtime.blob.AbstractBlobCache <init>' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Created BLOB cache storage directory /tmp/blobStore-210c9032-19e5-423e-98f8-9ca5f5575102' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:35 PM org.apache.flink.runtime.minicluster.MiniCluster startTaskManagers' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Starting 1 TaskManager(s)' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:35 PM org.apache.flink.runtime.taskexecutor.TaskManagerRunner startTaskManager' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Starting TaskManager with ResourceID: 9c9642de-e8ab-44c0-bd6a-684f3ea4402e' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:36 PM org.apache.flink.runtime.taskexecutor.TaskManagerServices checkTempDirs' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: Temporary file directory '/tmp': total 969 GB, usable 809 GB (83.49% usable)" INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17, 2022 8:14:36 PM org.apache.flink.runtime.io.disk.iomanager.IOManager <init>' FAILURE: Build failed with an exception. * What went wrong: GC overhead limit exceeded * Try: > Run with --info or --debug option to get more log output. > Run with --scan to get full insights. * Exception is: java.lang.OutOfMemoryError: GC overhead limit exceeded * Get more help at https://help.gradle.org 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]
