You are viewing a plain text version of this content. The canonical link for it is here.
Posted to builds@beam.apache.org by Apache Jenkins Server <je...@builds.apache.org> on 2020/01/24 02:37:22 UTC
Build failed in Jenkins: beam_PostCommit_Go_VR_Flink #2233
See <https://builds.apache.org/job/beam_PostCommit_Go_VR_Flink/2233/display/redirect?page=changes>
Changes:
[bhulette] [BEAM-9072] [SQL] Primitive types should fall through (#10681)
------------------------------------------
[...truncated 296.88 KB...]
[flink-runner-job-invoker] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Web frontend listening at http://localhost:39501.
[mini-cluster-io-thread-1] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - http://localhost:39501 was granted leadership with leaderSessionID=dc6b0dc3-b73c-40b4-bc60-05bcbde9e671
[mini-cluster-io-thread-1] INFO org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService - Received confirmation of leadership for leader http://localhost:39501 , session=dc6b0dc3-b73c-40b4-bc60-05bcbde9e671
[flink-runner-job-invoker] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Starting RPC endpoint for org.apache.flink.runtime.resourcemanager.StandaloneResourceManager at akka://flink/user/resourcemanager .
[flink-runner-job-invoker] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Starting RPC endpoint for org.apache.flink.runtime.dispatcher.StandaloneDispatcher at akka://flink/user/dispatcher .
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService - Proposing leadership to contender org.apache.flink.runtime.dispatcher.StandaloneDispatcher@22488c @ akka://flink/user/dispatcher
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService - Proposing leadership to contender org.apache.flink.runtime.resourcemanager.StandaloneResourceManager@63983e9 @ akka://flink/user/resourcemanager
[flink-runner-job-invoker] INFO org.apache.flink.runtime.minicluster.MiniCluster - Flink Mini Cluster started successfully
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Dispatcher akka://flink/user/dispatcher was granted leadership with fencing token c6541b20-aa80-45bc-af27-c35ebdfc7d02
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - ResourceManager akka://flink/user/resourcemanager was granted leadership with fencing token b86faf34925a2fe89ec2d9b4f9be42e2
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Recovering all persisted jobs.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerImpl - Starting the SlotManager.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService - Received confirmation of leadership for leader akka://flink/user/dispatcher , session=c6541b20-aa80-45bc-af27-c35ebdfc7d02
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService - Received confirmation of leadership for leader akka://flink/user/resourcemanager , session=9ec2d9b4-f9be-42e2-b86f-af34925a2fe8
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Connecting to ResourceManager akka://flink/user/resourcemanager(b86faf34925a2fe89ec2d9b4f9be42e2).
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Resolved ResourceManager address, beginning registration
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Registration at ResourceManager attempt 1 (timeout=100ms)
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Registering TaskManager with ResourceID e9e8266c-9f8a-4132-8079-d591032b3496 (akka://flink/user/taskmanager_4) at ResourceManager
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Successful registration at resource manager akka://flink/user/resourcemanager under registration id 699c1b926da248727d3f08598f7fd7a0.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Received JobGraph submission 3789068e3f7601ab700dade39b538053 (go0job0301579833015508140793-jenkins-0124023015-2fefe133).
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Submitting job 3789068e3f7601ab700dade39b538053 (go0job0301579833015508140793-jenkins-0124023015-2fefe133).
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Starting RPC endpoint for org.apache.flink.runtime.jobmaster.JobMaster at akka://flink/user/jobmanager_5 .
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.jobmaster.JobMaster - Initializing job go0job0301579833015508140793-jenkins-0124023015-2fefe133 (3789068e3f7601ab700dade39b538053).
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.jobmaster.JobMaster - Using restart strategy NoRestartStrategy for go0job0301579833015508140793-jenkins-0124023015-2fefe133 (3789068e3f7601ab700dade39b538053).
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Job recovers via failover strategy: full graph restart
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.jobmaster.JobMaster - Running initialization on master for job go0job0301579833015508140793-jenkins-0124023015-2fefe133 (3789068e3f7601ab700dade39b538053).
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.jobmaster.JobMaster - Successfully ran initialization on master in 2 ms.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService - Proposing leadership to contender org.apache.flink.runtime.jobmaster.JobManagerRunner@2652fc @ akka://flink/user/jobmanager_5
[mini-cluster-io-thread-10] INFO org.apache.flink.runtime.jobmaster.JobManagerRunner - JobManager runner for job go0job0301579833015508140793-jenkins-0124023015-2fefe133 (3789068e3f7601ab700dade39b538053) was granted leadership with session id 0b5b4534-6382-441f-bedd-13544faf5a45 at akka://flink/user/jobmanager_5.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.jobmaster.JobMaster - Starting execution of job go0job0301579833015508140793-jenkins-0124023015-2fefe133 (3789068e3f7601ab700dade39b538053) under job master id bedd13544faf5a450b5b45346382441f.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Job go0job0301579833015508140793-jenkins-0124023015-2fefe133 (3789068e3f7601ab700dade39b538053) switched from state CREATED to RUNNING.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSource (Impulse) (1/1) (fa310765545c679ec5d0fe31677c7e8e) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl - Cannot serve slot request, no ResourceManager connected. Adding as pending request [SlotRequestId{c5571c6a30cd54b11525336d2e93d1c8}]
[jobmanager-future-thread-1] INFO org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService - Received confirmation of leadership for leader akka://flink/user/jobmanager_5 , session=0b5b4534-6382-441f-bedd-13544faf5a45
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.jobmaster.JobMaster - Connecting to ResourceManager akka://flink/user/resourcemanager(b86faf34925a2fe89ec2d9b4f9be42e2)
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.jobmaster.JobMaster - Resolved ResourceManager address, beginning registration
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.jobmaster.JobMaster - Registration at ResourceManager attempt 1 (timeout=100ms)
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Registering job manager bedd13544faf5a450b5b45346382441f@akka://flink/user/jobmanager_5 for job 3789068e3f7601ab700dade39b538053.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Registered job manager bedd13544faf5a450b5b45346382441f@akka://flink/user/jobmanager_5 for job 3789068e3f7601ab700dade39b538053.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.jobmaster.JobMaster - JobManager successfully registered at ResourceManager, leader id: b86faf34925a2fe89ec2d9b4f9be42e2.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl - Requesting new slot [SlotRequestId{c5571c6a30cd54b11525336d2e93d1c8}] and profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=-1, nativeMemoryInMB=-1, networkMemoryInMB=-1, managedMemoryInMB=-1} from resource manager.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=-1, nativeMemoryInMB=-1, networkMemoryInMB=-1, managedMemoryInMB=-1} for job 3789068e3f7601ab700dade39b538053 with allocation id ba0a1e4d96e21153b4e8ce1ec953dbf2.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Receive slot request ba0a1e4d96e21153b4e8ce1ec953dbf2 for job 3789068e3f7601ab700dade39b538053 from resource manager with leader id b86faf34925a2fe89ec2d9b4f9be42e2.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Allocated slot for ba0a1e4d96e21153b4e8ce1ec953dbf2.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Add job 3789068e3f7601ab700dade39b538053 for job leader monitoring.
[mini-cluster-io-thread-13] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Try to register at job manager akka://flink/user/jobmanager_5 with leader id 0b5b4534-6382-441f-bedd-13544faf5a45.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Resolved JobManager address, beginning registration
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Registration at JobManager attempt 1 (timeout=100ms)
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Successful registration at job manager akka://flink/user/jobmanager_5 for job 3789068e3f7601ab700dade39b538053.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Establish JobManager connection for job 3789068e3f7601ab700dade39b538053.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Offer reserved slots to the leader of job 3789068e3f7601ab700dade39b538053.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSource (Impulse) (1/1) (fa310765545c679ec5d0fe31677c7e8e) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSource (Impulse) (1/1) (attempt #0) to e9e8266c-9f8a-4132-8079-d591032b3496 @ localhost (dataPort=-1)
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSource (Impulse) (1/1).
[DataSource (Impulse) (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - DataSource (Impulse) (1/1) (fa310765545c679ec5d0fe31677c7e8e) switched from CREATED to DEPLOYING.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Activate slot ba0a1e4d96e21153b4e8ce1ec953dbf2.
[DataSource (Impulse) (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSource (Impulse) (1/1) (fa310765545c679ec5d0fe31677c7e8e) [DEPLOYING]
[DataSource (Impulse) (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSource (Impulse) (1/1) (fa310765545c679ec5d0fe31677c7e8e) [DEPLOYING].
[DataSource (Impulse) (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSource (Impulse) (1/1) (fa310765545c679ec5d0fe31677c7e8e) [DEPLOYING].
[DataSource (Impulse) (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - DataSource (Impulse) (1/1) (fa310765545c679ec5d0fe31677c7e8e) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSource (Impulse) (1/1) (fa310765545c679ec5d0fe31677c7e8e) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [5]github.com/apache/beam/sdks/go/test/vendor/github.com/apache/beam/sdks/go/{pkg, test}) (1/1) (4aecd45553d0bab076c97c20ad3b40a7) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [5]github.com/apache/beam/sdks/go/test/vendor/github.com/apache/beam/sdks/go/{pkg, test}) (1/1) (4aecd45553d0bab076c97c20ad3b40a7) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying MapPartition (MapPartition at [5]github.com/apache/beam/sdks/go/test/vendor/github.com/apache/beam/sdks/go/{pkg, test}) (1/1) (attempt #0) to e9e8266c-9f8a-4132-8079-d591032b3496 @ localhost (dataPort=-1)
[DataSource (Impulse) (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - DataSource (Impulse) (1/1) (fa310765545c679ec5d0fe31677c7e8e) switched from RUNNING to FINISHED.
[DataSource (Impulse) (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSource (Impulse) (1/1) (fa310765545c679ec5d0fe31677c7e8e).
[DataSource (Impulse) (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSource (Impulse) (1/1) (fa310765545c679ec5d0fe31677c7e8e) [FINISHED]
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task MapPartition (MapPartition at [5]github.com/apache/beam/sdks/go/test/vendor/github.com/apache/beam/sdks/go/{pkg, test}) (1/1).
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSource (Impulse) fa310765545c679ec5d0fe31677c7e8e.
[MapPartition (MapPartition at [5]github.com/apache/beam/sdks/go/test/vendor/github.com/apache/beam/sdks/go/{pkg, test}) (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at [5]github.com/apache/beam/sdks/go/test/vendor/github.com/apache/beam/sdks/go/{pkg, test}) (1/1) (4aecd45553d0bab076c97c20ad3b40a7) switched from CREATED to DEPLOYING.
[MapPartition (MapPartition at [5]github.com/apache/beam/sdks/go/test/vendor/github.com/apache/beam/sdks/go/{pkg, test}) (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task MapPartition (MapPartition at [5]github.com/apache/beam/sdks/go/test/vendor/github.com/apache/beam/sdks/go/{pkg, test}) (1/1) (4aecd45553d0bab076c97c20ad3b40a7) [DEPLOYING]
[MapPartition (MapPartition at [5]github.com/apache/beam/sdks/go/test/vendor/github.com/apache/beam/sdks/go/{pkg, test}) (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task MapPartition (MapPartition at [5]github.com/apache/beam/sdks/go/test/vendor/github.com/apache/beam/sdks/go/{pkg, test}) (1/1) (4aecd45553d0bab076c97c20ad3b40a7) [DEPLOYING].
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSource (Impulse) (1/1) (fa310765545c679ec5d0fe31677c7e8e) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at [5]github.com/apache/beam/sdks/go/test/vendor/github.com/apache/beam/sdks/go/{pkg, test}) (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: MapPartition (MapPartition at [5]github.com/apache/beam/sdks/go/test/vendor/github.com/apache/beam/sdks/go/{pkg, test}) (1/1) (4aecd45553d0bab076c97c20ad3b40a7) [DEPLOYING].
[MapPartition (MapPartition at [5]github.com/apache/beam/sdks/go/test/vendor/github.com/apache/beam/sdks/go/{pkg, test}) (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at [5]github.com/apache/beam/sdks/go/test/vendor/github.com/apache/beam/sdks/go/{pkg, test}) (1/1) (4aecd45553d0bab076c97c20ad3b40a7) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [5]github.com/apache/beam/sdks/go/test/vendor/github.com/apache/beam/sdks/go/{pkg, test}) (1/1) (4aecd45553d0bab076c97c20ad3b40a7) switched from DEPLOYING to RUNNING.
[MapPartition (MapPartition at [5]github.com/apache/beam/sdks/go/test/vendor/github.com/apache/beam/sdks/go/{pkg, test}) (1/1)] WARN org.apache.flink.metrics.MetricGroup - The operator name MapPartition (MapPartition at [5]github.com/apache/beam/sdks/go/test/vendor/github.com/apache/beam/sdks/go/{pkg, test}) exceeded the 80 characters length limit and was truncated.
[grpc-default-executor-0] INFO org.apache.beam.runners.fnexecution.artifact.AbstractArtifactRetrievalService - GetManifest for /tmp/beam-artifact-staging/go-job-3-1579833015508140793_df3136b1-0799-4fb7-9a55-13d3a6a68584/MANIFEST
[grpc-default-executor-0] INFO org.apache.beam.runners.fnexecution.artifact.AbstractArtifactRetrievalService - Manifest at /tmp/beam-artifact-staging/go-job-3-1579833015508140793_df3136b1-0799-4fb7-9a55-13d3a6a68584/MANIFEST has 1 artifact locations
[grpc-default-executor-0] INFO org.apache.beam.runners.fnexecution.artifact.AbstractArtifactRetrievalService - GetManifest for /tmp/beam-artifact-staging/go-job-3-1579833015508140793_df3136b1-0799-4fb7-9a55-13d3a6a68584/MANIFEST -> 1 artifacts
[grpc-default-executor-1] INFO org.apache.beam.runners.fnexecution.logging.GrpcLoggingService - Beam Fn Logging client connected.
[grpc-default-executor-0] INFO org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService - Beam Fn Control client connected with id 7-1
[grpc-default-executor-0] INFO /home/jenkins/jenkins-slave/workspace/beam_PostCommit_Go_VR_Flink/src/sdks/go/test/.gogradle/project_gopath/src/github.com/apache/beam/sdks/go/test/vendor/github.com/apache/beam/sdks/go/pkg/beam/core/runtime/harness/harness.go:317 - Connecting via grpc @ localhost:43433 ...
[grpc-default-executor-0] INFO /home/jenkins/jenkins-slave/workspace/beam_PostCommit_Go_VR_Flink/src/sdks/go/test/.gogradle/project_gopath/src/github.com/apache/beam/sdks/go/test/vendor/github.com/apache/beam/sdks/go/pkg/beam/core/runtime/harness/harness.go:317 - Connecting via grpc @ localhost:45713 ...
[grpc-default-executor-0] INFO /home/jenkins/jenkins-slave/workspace/beam_PostCommit_Go_VR_Flink/src/sdks/go/test/.gogradle/project_gopath/src/github.com/apache/beam/sdks/go/test/vendor/github.com/apache/beam/sdks/go/pkg/beam/core/runtime/harness/harness.go:317 - Connecting via grpc @ localhost:43025 ...
[grpc-default-executor-0] INFO org.apache.beam.runners.fnexecution.data.GrpcDataService - Beam Fn Data client connected.
[grpc-default-executor-1] INFO /home/jenkins/jenkins-slave/workspace/beam_PostCommit_Go_VR_Flink/src/sdks/go/test/.gogradle/project_gopath/src/github.com/apache/beam/sdks/go/test/vendor/github.com/apache/beam/sdks/go/pkg/beam/core/runtime/exec/datasource.go:210 - DataSource: 1 elements in 4066053 ns
[grpc-default-executor-1] INFO /home/jenkins/jenkins-slave/workspace/beam_PostCommit_Go_VR_Flink/src/sdks/go/test/.gogradle/project_gopath/src/github.com/apache/beam/sdks/go/test/vendor/github.com/apache/beam/sdks/go/pkg/beam/core/runtime/exec/datasink.go:84 - DataSink: 1 elements in 3470034 ns
[grpc-default-executor-2] INFO /home/jenkins/jenkins-slave/workspace/beam_PostCommit_Go_VR_Flink/src/sdks/go/test/.gogradle/project_gopath/src/github.com/apache/beam/sdks/go/test/vendor/github.com/apache/beam/sdks/go/pkg/beam/core/runtime/exec/datasink.go:84 - DataSink: 1 elements in 3500946 ns
[grpc-default-executor-2] INFO /home/jenkins/jenkins-slave/workspace/beam_PostCommit_Go_VR_Flink/src/sdks/go/test/.gogradle/project_gopath/src/github.com/apache/beam/sdks/go/test/vendor/github.com/apache/beam/sdks/go/pkg/beam/core/runtime/exec/datasink.go:84 - DataSink: 1 elements in 3508311 ns
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN FlatMap (FlatMap at ExtractOutput[2]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CoGBK'2) -> Map (Key Extractor) (1/1) (c3a553961c03d7c030540ce9de5b5541) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN FlatMap (FlatMap at ExtractOutput[2]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CoGBK'2) -> Map (Key Extractor) (1/1) (c3a553961c03d7c030540ce9de5b5541) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying CHAIN FlatMap (FlatMap at ExtractOutput[2]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CoGBK'2) -> Map (Key Extractor) (1/1) (attempt #0) to e9e8266c-9f8a-4132-8079-d591032b3496 @ localhost (dataPort=-1)
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CoGBK'1) -> Map (Key Extractor) (1/1) (039fcd8c1a8d62cc6f33633b071eaf27) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CoGBK'1) -> Map (Key Extractor) (1/1) (039fcd8c1a8d62cc6f33633b071eaf27) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CoGBK'1) -> Map (Key Extractor) (1/1) (attempt #0) to e9e8266c-9f8a-4132-8079-d591032b3496 @ localhost (dataPort=-1)
[MapPartition (MapPartition at [5]github.com/apache/beam/sdks/go/test/vendor/github.com/apache/beam/sdks/go/{pkg, test}) (1/1)] INFO org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory - Closing environment urn: "beam:env:docker:v1"
payload: "\n<us.gcr.io/apache-beam-testing/jenkins/go_sdk:20200124-022751"
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task CHAIN FlatMap (FlatMap at ExtractOutput[2]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CoGBK'2) -> Map (Key Extractor) (1/1).
[CHAIN FlatMap (FlatMap at ExtractOutput[2]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CoGBK'2) -> Map (Key Extractor) (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN FlatMap (FlatMap at ExtractOutput[2]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CoGBK'2) -> Map (Key Extractor) (1/1) (c3a553961c03d7c030540ce9de5b5541) switched from CREATED to DEPLOYING.
[CHAIN FlatMap (FlatMap at ExtractOutput[2]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CoGBK'2) -> Map (Key Extractor) (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task CHAIN FlatMap (FlatMap at ExtractOutput[2]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CoGBK'2) -> Map (Key Extractor) (1/1) (c3a553961c03d7c030540ce9de5b5541) [DEPLOYING]
[CHAIN FlatMap (FlatMap at ExtractOutput[2]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CoGBK'2) -> Map (Key Extractor) (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task CHAIN FlatMap (FlatMap at ExtractOutput[2]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CoGBK'2) -> Map (Key Extractor) (1/1) (c3a553961c03d7c030540ce9de5b5541) [DEPLOYING].
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CoGBK) -> Map (Key Extractor) (1/1) (1ff3dfb461db6a0f3ada1299577dbb15) switched from CREATED to SCHEDULED.
[MapPartition (MapPartition at [5]github.com/apache/beam/sdks/go/test/vendor/github.com/apache/beam/sdks/go/{pkg, test}) (1/1)] INFO org.apache.beam.runners.fnexecution.logging.GrpcLoggingService - 1 Beam Fn Logging clients still connected during shutdown.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CoGBK) -> Map (Key Extractor) (1/1) (1ff3dfb461db6a0f3ada1299577dbb15) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying CHAIN FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CoGBK) -> Map (Key Extractor) (1/1) (attempt #0) to e9e8266c-9f8a-4132-8079-d591032b3496 @ localhost (dataPort=-1)
[CHAIN FlatMap (FlatMap at ExtractOutput[2]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CoGBK'2) -> Map (Key Extractor) (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: CHAIN FlatMap (FlatMap at ExtractOutput[2]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CoGBK'2) -> Map (Key Extractor) (1/1) (c3a553961c03d7c030540ce9de5b5541) [DEPLOYING].
[CHAIN FlatMap (FlatMap at ExtractOutput[2]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CoGBK'2) -> Map (Key Extractor) (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN FlatMap (FlatMap at ExtractOutput[2]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CoGBK'2) -> Map (Key Extractor) (1/1) (c3a553961c03d7c030540ce9de5b5541) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN FlatMap (FlatMap at ExtractOutput[2]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CoGBK'2) -> Map (Key Extractor) (1/1) (c3a553961c03d7c030540ce9de5b5541) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CoGBK'1) -> Map (Key Extractor) (1/1).
[CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CoGBK'1) -> Map (Key Extractor) (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CoGBK'1) -> Map (Key Extractor) (1/1) (039fcd8c1a8d62cc6f33633b071eaf27) switched from CREATED to DEPLOYING.
[CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CoGBK'1) -> Map (Key Extractor) (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CoGBK'1) -> Map (Key Extractor) (1/1) (039fcd8c1a8d62cc6f33633b071eaf27) [DEPLOYING]
[CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CoGBK'1) -> Map (Key Extractor) (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CoGBK'1) -> Map (Key Extractor) (1/1) (039fcd8c1a8d62cc6f33633b071eaf27) [DEPLOYING].
[CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CoGBK'1) -> Map (Key Extractor) (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CoGBK'1) -> Map (Key Extractor) (1/1) (039fcd8c1a8d62cc6f33633b071eaf27) [DEPLOYING].
[CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CoGBK'1) -> Map (Key Extractor) (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CoGBK'1) -> Map (Key Extractor) (1/1) (039fcd8c1a8d62cc6f33633b071eaf27) switched from DEPLOYING to RUNNING.
[MapPartition (MapPartition at [5]github.com/apache/beam/sdks/go/test/vendor/github.com/apache/beam/sdks/go/{pkg, test}) (1/1)] WARN org.apache.beam.sdk.fn.data.BeamFnDataGrpcMultiplexer - Hanged up for unknown endpoint.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CoGBK'1) -> Map (Key Extractor) (1/1) (039fcd8c1a8d62cc6f33633b071eaf27) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task CHAIN FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CoGBK) -> Map (Key Extractor) (1/1).
[CHAIN FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CoGBK) -> Map (Key Extractor) (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CoGBK) -> Map (Key Extractor) (1/1) (1ff3dfb461db6a0f3ada1299577dbb15) switched from CREATED to DEPLOYING.
[CHAIN FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CoGBK) -> Map (Key Extractor) (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task CHAIN FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CoGBK) -> Map (Key Extractor) (1/1) (1ff3dfb461db6a0f3ada1299577dbb15) [DEPLOYING]
[CHAIN FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CoGBK) -> Map (Key Extractor) (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task CHAIN FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CoGBK) -> Map (Key Extractor) (1/1) (1ff3dfb461db6a0f3ada1299577dbb15) [DEPLOYING].
[CHAIN FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CoGBK) -> Map (Key Extractor) (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: CHAIN FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CoGBK) -> Map (Key Extractor) (1/1) (1ff3dfb461db6a0f3ada1299577dbb15) [DEPLOYING].
[CHAIN FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CoGBK) -> Map (Key Extractor) (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CoGBK) -> Map (Key Extractor) (1/1) (1ff3dfb461db6a0f3ada1299577dbb15) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CoGBK) -> Map (Key Extractor) (1/1) (1ff3dfb461db6a0f3ada1299577dbb15) switched from DEPLOYING to RUNNING.
[MapPartition (MapPartition at [5]github.com/apache/beam/sdks/go/test/vendor/github.com/apache/beam/sdks/go/{pkg, test}) (1/1)] INFO org.apache.beam.runners.fnexecution.environment.DockerContainerEnvironment - Closing Docker container 624487e71655454223023ad63df2ee3d4469e9cca6b76339a2ee61d50c0fa8af. Logs:
2020/01/24 02:30:18 Initializing Go harness: /opt/apache/beam/boot --id=7-1 --logging_endpoint=localhost:45713 --artifact_endpoint=localhost:44497 --provision_endpoint=localhost:38251 --control_endpoint=localhost:43433
Worker exited successfully!
Failed to send message: EOF
severity:WARN timestamp:<seconds:1579833019 nanos:89069998 > message:"forcing DataChannel[localhost:43025] reconnection on port {localhost:43025} due to rpc error: code = Canceled desc = Multiplexer hanging up" instruction_id:"2" log_location:"/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Go_VR_Flink/src/sdks/go/test/.gogradle/project_gopath/src/github.com/apache/beam/sdks/go/test/vendor/github.com/apache/beam/sdks/go/pkg/beam/core/runtime/harness/datamgr.go:119" Remote logging failed: EOF. Retrying in 5 sec ...
[MapPartition (MapPartition at [5]github.com/apache/beam/sdks/go/test/vendor/github.com/apache/beam/sdks/go/{pkg, test}) (1/1)] WARN org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory - Error cleaning up servers urn: "beam:env:docker:v1"
payload: "\n<us.gcr.io/apache-beam-testing/jenkins/go_sdk:20200124-022751"
java.io.IOException: Received exit code 1 for command 'docker rm 624487e71655454223023ad63df2ee3d4469e9cca6b76339a2ee61d50c0fa8af'. stderr: Error: No such container: 624487e71655454223023ad63df2ee3d4469e9cca6b76339a2ee61d50c0fa8af
at org.apache.beam.runners.fnexecution.environment.DockerCommand.runShortCommand(DockerCommand.java:234)
at org.apache.beam.runners.fnexecution.environment.DockerCommand.runShortCommand(DockerCommand.java:168)
at org.apache.beam.runners.fnexecution.environment.DockerCommand.removeContainer(DockerCommand.java:163)
at org.apache.beam.runners.fnexecution.environment.DockerContainerEnvironment.close(DockerContainerEnvironment.java:95)
at org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory$WrappedSdkHarnessClient.$closeResource(DefaultJobBundleFactory.java:481)
at org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory$WrappedSdkHarnessClient.close(DefaultJobBundleFactory.java:481)
at org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory$WrappedSdkHarnessClient.unref(DefaultJobBundleFactory.java:496)
at org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory$WrappedSdkHarnessClient.access$1800(DefaultJobBundleFactory.java:436)
at org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory.lambda$createEnvironmentCaches$3(DefaultJobBundleFactory.java:168)
at org.apache.beam.vendor.guava.v26_0_jre.com.google.common.cache.LocalCache.processPendingNotifications(LocalCache.java:1809)
at org.apache.beam.vendor.guava.v26_0_jre.com.google.common.cache.LocalCache$Segment.runUnlockedCleanup(LocalCache.java:3462)
at org.apache.beam.vendor.guava.v26_0_jre.com.google.common.cache.LocalCache$Segment.postWriteCleanup(LocalCache.java:3438)
at org.apache.beam.vendor.guava.v26_0_jre.com.google.common.cache.LocalCache$Segment.clear(LocalCache.java:3215)
at org.apache.beam.vendor.guava.v26_0_jre.com.google.common.cache.LocalCache.clear(LocalCache.java:4270)
at org.apache.beam.vendor.guava.v26_0_jre.com.google.common.cache.LocalCache$LocalManualCache.invalidateAll(LocalCache.java:4909)
at org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory.close(DefaultJobBundleFactory.java:258)
at org.apache.beam.runners.fnexecution.control.DefaultExecutableStageContext.close(DefaultExecutableStageContext.java:43)
at org.apache.beam.runners.fnexecution.control.ReferenceCountingExecutableStageContextFactory$WrappedContext.closeActual(ReferenceCountingExecutableStageContextFactory.java:208)
at org.apache.beam.runners.fnexecution.control.ReferenceCountingExecutableStageContextFactory$WrappedContext.access$200(ReferenceCountingExecutableStageContextFactory.java:184)
at org.apache.beam.runners.fnexecution.control.ReferenceCountingExecutableStageContextFactory.release(ReferenceCountingExecutableStageContextFactory.java:173)
at org.apache.beam.runners.fnexecution.control.ReferenceCountingExecutableStageContextFactory.scheduleRelease(ReferenceCountingExecutableStageContextFactory.java:132)
at org.apache.beam.runners.fnexecution.control.ReferenceCountingExecutableStageContextFactory.access$300(ReferenceCountingExecutableStageContextFactory.java:44)
at org.apache.beam.runners.fnexecution.control.ReferenceCountingExecutableStageContextFactory$WrappedContext.close(ReferenceCountingExecutableStageContextFactory.java:204)
at org.apache.beam.runners.flink.translation.functions.FlinkExecutableStageFunction.$closeResource(FlinkExecutableStageFunction.java:204)
at org.apache.beam.runners.flink.translation.functions.FlinkExecutableStageFunction.close(FlinkExecutableStageFunction.java:291)
at org.apache.flink.api.common.functions.util.FunctionUtils.closeFunction(FunctionUtils.java:43)
at org.apache.flink.runtime.operators.BatchTask.run(BatchTask.java:508)
at org.apache.flink.runtime.operators.BatchTask.invoke(BatchTask.java:369)
at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:705)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:530)
at java.lang.Thread.run(Thread.java:748)
[MapPartition (MapPartition at [5]github.com/apache/beam/sdks/go/test/vendor/github.com/apache/beam/sdks/go/{pkg, test}) (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at [5]github.com/apache/beam/sdks/go/test/vendor/github.com/apache/beam/sdks/go/{pkg, test}) (1/1) (4aecd45553d0bab076c97c20ad3b40a7) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at [5]github.com/apache/beam/sdks/go/test/vendor/github.com/apache/beam/sdks/go/{pkg, test}) (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for MapPartition (MapPartition at [5]github.com/apache/beam/sdks/go/test/vendor/github.com/apache/beam/sdks/go/{pkg, test}) (1/1) (4aecd45553d0bab076c97c20ad3b40a7).
[MapPartition (MapPartition at [5]github.com/apache/beam/sdks/go/test/vendor/github.com/apache/beam/sdks/go/{pkg, test}) (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task MapPartition (MapPartition at [5]github.com/apache/beam/sdks/go/test/vendor/github.com/apache/beam/sdks/go/{pkg, test}) (1/1) (4aecd45553d0bab076c97c20ad3b40a7) [FINISHED]
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task MapPartition (MapPartition at [5]github.com/apache/beam/sdks/go/test/vendor/github.com/apache/beam/sdks/go/{pkg, test}) 4aecd45553d0bab076c97c20ad3b40a7.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce (GroupReduce at CoGBK'2) (1/1) (a2746bd7873da8bf9b614c90f868eee0) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce (GroupReduce at CoGBK'2) (1/1) (a2746bd7873da8bf9b614c90f868eee0) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying GroupReduce (GroupReduce at CoGBK'2) (1/1) (attempt #0) to e9e8266c-9f8a-4132-8079-d591032b3496 @ localhost (dataPort=-1)
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce (GroupReduce at CoGBK) (1/1) (1280253d7293a7c8492ec8899381cf53) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce (GroupReduce at CoGBK) (1/1) (1280253d7293a7c8492ec8899381cf53) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying GroupReduce (GroupReduce at CoGBK) (1/1) (attempt #0) to e9e8266c-9f8a-4132-8079-d591032b3496 @ localhost (dataPort=-1)
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task GroupReduce (GroupReduce at CoGBK'2) (1/1).
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce (GroupReduce at CoGBK'1) (1/1) (cc35191474ed88548e1e6e5c06c31cab) switched from CREATED to SCHEDULED.
[GroupReduce (GroupReduce at CoGBK'2) (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - GroupReduce (GroupReduce at CoGBK'2) (1/1) (a2746bd7873da8bf9b614c90f868eee0) switched from CREATED to DEPLOYING.
[GroupReduce (GroupReduce at CoGBK'2) (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task GroupReduce (GroupReduce at CoGBK'2) (1/1) (a2746bd7873da8bf9b614c90f868eee0) [DEPLOYING]
[GroupReduce (GroupReduce at CoGBK'2) (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task GroupReduce (GroupReduce at CoGBK'2) (1/1) (a2746bd7873da8bf9b614c90f868eee0) [DEPLOYING].
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce (GroupReduce at CoGBK'1) (1/1) (cc35191474ed88548e1e6e5c06c31cab) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying GroupReduce (GroupReduce at CoGBK'1) (1/1) (attempt #0) to e9e8266c-9f8a-4132-8079-d591032b3496 @ localhost (dataPort=-1)
[GroupReduce (GroupReduce at CoGBK'2) (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: GroupReduce (GroupReduce at CoGBK'2) (1/1) (a2746bd7873da8bf9b614c90f868eee0) [DEPLOYING].
[GroupReduce (GroupReduce at CoGBK'2) (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - GroupReduce (GroupReduce at CoGBK'2) (1/1) (a2746bd7873da8bf9b614c90f868eee0) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task GroupReduce (GroupReduce at CoGBK) (1/1).
[GroupReduce (GroupReduce at CoGBK) (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - GroupReduce (GroupReduce at CoGBK) (1/1) (1280253d7293a7c8492ec8899381cf53) switched from CREATED to DEPLOYING.
[GroupReduce (GroupReduce at CoGBK) (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task GroupReduce (GroupReduce at CoGBK) (1/1) (1280253d7293a7c8492ec8899381cf53) [DEPLOYING]
[GroupReduce (GroupReduce at CoGBK) (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task GroupReduce (GroupReduce at CoGBK) (1/1) (1280253d7293a7c8492ec8899381cf53) [DEPLOYING].
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [5]github.com/apache/beam/sdks/go/test/vendor/github.com/apache/beam/sdks/go/{pkg, test}) (1/1) (4aecd45553d0bab076c97c20ad3b40a7) switched from RUNNING to FINISHED.
[GroupReduce (GroupReduce at CoGBK) (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: GroupReduce (GroupReduce at CoGBK) (1/1) (1280253d7293a7c8492ec8899381cf53) [DEPLOYING].
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task GroupReduce (GroupReduce at CoGBK'1) (1/1).
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce (GroupReduce at CoGBK'2) (1/1) (a2746bd7873da8bf9b614c90f868eee0) switched from DEPLOYING to RUNNING.
[GroupReduce (GroupReduce at CoGBK'1) (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - GroupReduce (GroupReduce at CoGBK'1) (1/1) (cc35191474ed88548e1e6e5c06c31cab) switched from CREATED to DEPLOYING.
[GroupReduce (GroupReduce at CoGBK'1) (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task GroupReduce (GroupReduce at CoGBK'1) (1/1) (cc35191474ed88548e1e6e5c06c31cab) [DEPLOYING]
[GroupReduce (GroupReduce at CoGBK'1) (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task GroupReduce (GroupReduce at CoGBK'1) (1/1) (cc35191474ed88548e1e6e5c06c31cab) [DEPLOYING].
[GroupReduce (GroupReduce at CoGBK) (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - GroupReduce (GroupReduce at CoGBK) (1/1) (1280253d7293a7c8492ec8899381cf53) switched from DEPLOYING to RUNNING.
[GroupReduce (GroupReduce at CoGBK'1) (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: GroupReduce (GroupReduce at CoGBK'1) (1/1) (cc35191474ed88548e1e6e5c06c31cab) [DEPLOYING].
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce (GroupReduce at CoGBK) (1/1) (1280253d7293a7c8492ec8899381cf53) switched from DEPLOYING to RUNNING.
[GroupReduce (GroupReduce at CoGBK'1) (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - GroupReduce (GroupReduce at CoGBK'1) (1/1) (cc35191474ed88548e1e6e5c06c31cab) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce (GroupReduce at CoGBK'1) (1/1) (cc35191474ed88548e1e6e5c06c31cab) switched from DEPLOYING to RUNNING.
[CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CoGBK'1) -> Map (Key Extractor) (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CoGBK'1) -> Map (Key Extractor) (1/1) (039fcd8c1a8d62cc6f33633b071eaf27) switched from RUNNING to FINISHED.
[CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CoGBK'1) -> Map (Key Extractor) (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CoGBK'1) -> Map (Key Extractor) (1/1) (039fcd8c1a8d62cc6f33633b071eaf27).
FATAL: command execution failed
java.io.IOException: Backing channel 'JNLP4-connect connection from 165.171.154.104.bc.googleusercontent.com/104.154.171.165:56854' is disconnected.
at hudson.remoting.RemoteInvocationHandler.channelOrFail(RemoteInvocationHandler.java:214)
at hudson.remoting.RemoteInvocationHandler.invoke(RemoteInvocationHandler.java:283)
at com.sun.proxy.$Proxy145.isAlive(Unknown Source)
at hudson.Launcher$RemoteLauncher$ProcImpl.isAlive(Launcher.java:1150)
at hudson.Launcher$RemoteLauncher$ProcImpl.join(Launcher.java:1142)
at hudson.Launcher$ProcStarter.join(Launcher.java:470)
at hudson.plugins.gradle.Gradle.perform(Gradle.java:317)
at hudson.tasks.BuildStepMonitor$1.perform(BuildStepMonitor.java:20)
at hudson.model.AbstractBuild$AbstractBuildExecution.perform(AbstractBuild.java:741)
at hudson.model.Build$BuildExecution.build(Build.java:206)
at hudson.model.Build$BuildExecution.doRun(Build.java:163)
at hudson.model.AbstractBuild$AbstractBuildExecution.run(AbstractBuild.java:504)
at hudson.model.Run.execute(Run.java:1815)
at hudson.model.FreeStyleBuild.run(FreeStyleBuild.java:43)
at hudson.model.ResourceController.execute(ResourceController.java:97)
at hudson.model.Executor.run(Executor.java:429)
Caused by: java.nio.channels.ClosedChannelException
at org.jenkinsci.remoting.protocol.impl.ChannelApplicationLayer.onReadClosed(ChannelApplicationLayer.java:209)
at org.jenkinsci.remoting.protocol.ApplicationLayer.onRecvClosed(ApplicationLayer.java:222)
at org.jenkinsci.remoting.protocol.ProtocolStack$Ptr.onRecvClosed(ProtocolStack.java:816)
at org.jenkinsci.remoting.protocol.FilterLayer.onRecvClosed(FilterLayer.java:287)
at org.jenkinsci.remoting.protocol.impl.SSLEngineFilterLayer.onRecvClosed(SSLEngineFilterLayer.java:181)
at org.jenkinsci.remoting.protocol.impl.SSLEngineFilterLayer.switchToNoSecure(SSLEngineFilterLayer.java:283)
at org.jenkinsci.remoting.protocol.impl.SSLEngineFilterLayer.processWrite(SSLEngineFilterLayer.java:503)
at org.jenkinsci.remoting.protocol.impl.SSLEngineFilterLayer.processQueuedWrites(SSLEngineFilterLayer.java:248)
at org.jenkinsci.remoting.protocol.impl.SSLEngineFilterLayer.doSend(SSLEngineFilterLayer.java:200)
at org.jenkinsci.remoting.protocol.impl.SSLEngineFilterLayer.doCloseSend(SSLEngineFilterLayer.java:213)
at org.jenkinsci.remoting.protocol.ProtocolStack$Ptr.doCloseSend(ProtocolStack.java:784)
at org.jenkinsci.remoting.protocol.ApplicationLayer.doCloseWrite(ApplicationLayer.java:173)
at org.jenkinsci.remoting.protocol.impl.ChannelApplicationLayer$ByteBufferCommandTransport.closeWrite(ChannelApplicationLayer.java:314)
at hudson.remoting.Channel.close(Channel.java:1452)
at hudson.remoting.Channel.close(Channel.java:1405)
at hudson.slaves.SlaveComputer.closeChannel(SlaveComputer.java:847)
at hudson.slaves.SlaveComputer.access$800(SlaveComputer.java:108)
at hudson.slaves.SlaveComputer$3.run(SlaveComputer.java:756)
at jenkins.util.ContextResettingExecutorService$1.run(ContextResettingExecutorService.java:28)
at jenkins.security.ImpersonatingExecutorService$1.run(ImpersonatingExecutorService.java:59)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
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)
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
ERROR: apache-beam-jenkins-12 is offline; cannot locate JDK 1.8 (latest)
---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscribe@beam.apache.org
For additional commands, e-mail: builds-help@beam.apache.org
Jenkins build is back to normal : beam_PostCommit_Go_VR_Flink #2234
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Go_VR_Flink/2234/display/redirect>
---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscribe@beam.apache.org
For additional commands, e-mail: builds-help@beam.apache.org