See
<https://builds.apache.org/job/beam_PostCommit_PortableJar_Flink/1335/display/redirect>
Changes:
------------------------------------------
[...truncated 183.59 KB...]
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition
(MapPartition at [6]{Create, Map(<lambda at <string>:20>), assert_that}) ->
FlatMap (FlatMap at ExtractOutput[0]) (1/1) (48d36c11675486638e07e14b43206603)
switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition
(MapPartition at [6]{Create, Map(<lambda at <string>:20>), assert_that}) ->
FlatMap (FlatMap at ExtractOutput[0]) (1/1) (48d36c11675486638e07e14b43206603)
switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying CHAIN
MapPartition (MapPartition at [6]{Create, Map(<lambda at <string>:20>),
assert_that}) -> FlatMap (FlatMap at ExtractOutput[0]) (1/1) (attempt #0) to
a17a21eb-f38b-4dd5-b2be-c5b3a7f496a1 @ localhost (dataPort=-1)
[flink-akka.actor.default-dispatcher-10] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task CHAIN
MapPartition (MapPartition at [6]{Create, Map(<lambda at <string>:20>),
assert_that}) -> FlatMap (FlatMap at ExtractOutput[0]) (1/1).
[CHAIN MapPartition (MapPartition at [6]{Create, Map(<lambda at <string>:20>),
assert_that}) -> FlatMap (FlatMap at ExtractOutput[0]) (1/1)] INFO
org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at
[6]{Create, Map(<lambda at <string>:20>), assert_that}) -> FlatMap (FlatMap at
ExtractOutput[0]) (1/1) (48d36c11675486638e07e14b43206603) switched from
CREATED to DEPLOYING.
[CHAIN MapPartition (MapPartition at [6]{Create, Map(<lambda at <string>:20>),
assert_that}) -> FlatMap (FlatMap at ExtractOutput[0]) (1/1)] INFO
org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak
safety net for task CHAIN MapPartition (MapPartition at [6]{Create, Map(<lambda
at <string>:20>), assert_that}) -> FlatMap (FlatMap at ExtractOutput[0]) (1/1)
(48d36c11675486638e07e14b43206603) [DEPLOYING]
[CHAIN MapPartition (MapPartition at [6]{Create, Map(<lambda at <string>:20>),
assert_that}) -> FlatMap (FlatMap at ExtractOutput[0]) (1/1)] INFO
org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task CHAIN
MapPartition (MapPartition at [6]{Create, Map(<lambda at <string>:20>),
assert_that}) -> FlatMap (FlatMap at ExtractOutput[0]) (1/1)
(48d36c11675486638e07e14b43206603) [DEPLOYING].
[CHAIN MapPartition (MapPartition at [6]{Create, Map(<lambda at <string>:20>),
assert_that}) -> FlatMap (FlatMap at ExtractOutput[0]) (1/1)] INFO
org.apache.flink.runtime.taskmanager.Task - Registering task at network: CHAIN
MapPartition (MapPartition at [6]{Create, Map(<lambda at <string>:20>),
assert_that}) -> FlatMap (FlatMap at ExtractOutput[0]) (1/1)
(48d36c11675486638e07e14b43206603) [DEPLOYING].
[CHAIN MapPartition (MapPartition at [6]{Create, Map(<lambda at <string>:20>),
assert_that}) -> FlatMap (FlatMap at ExtractOutput[0]) (1/1)] INFO
org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at
[6]{Create, Map(<lambda at <string>:20>), assert_that}) -> FlatMap (FlatMap at
ExtractOutput[0]) (1/1) (48d36c11675486638e07e14b43206603) switched from
DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition
(MapPartition at [6]{Create, Map(<lambda at <string>:20>), assert_that}) ->
FlatMap (FlatMap at ExtractOutput[0]) (1/1) (48d36c11675486638e07e14b43206603)
switched from DEPLOYING to RUNNING.
[CHAIN MapPartition (MapPartition at [6]{Create, Map(<lambda at <string>:20>),
assert_that}) -> FlatMap (FlatMap at ExtractOutput[0]) (1/1)] WARN
org.apache.flink.metrics.MetricGroup - The operator name MapPartition
(MapPartition at [6]{Create, Map(<lambda at <string>:20>), assert_that})
exceeded the 80 characters length limit and was truncated.
[CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) -> FlatMap
(FlatMap at ExtractOutput[0]) (1/1)] INFO
org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at
[4]assert_that/{Create, Group}) -> FlatMap (FlatMap at ExtractOutput[0]) (1/1)
(dbbbc5785b89dc7ecd6d964107dca34d) switched from RUNNING to FINISHED.
[CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) -> FlatMap
(FlatMap at ExtractOutput[0]) (1/1)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for CHAIN
MapPartition (MapPartition at [4]assert_that/{Create, Group}) -> FlatMap
(FlatMap at ExtractOutput[0]) (1/1) (dbbbc5785b89dc7ecd6d964107dca34d).
[CHAIN MapPartition (MapPartition at [1]Create/FlatMap(<lambda at
core.py:2646>)) -> FlatMap (FlatMap at ExtractOutput[0]) (1/1)] INFO
org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at
[1]Create/FlatMap(<lambda at core.py:2646>)) -> FlatMap (FlatMap at
ExtractOutput[0]) (1/1) (43ef7d457921ae94839e2522ad80b292) switched from
RUNNING to FINISHED.
[CHAIN MapPartition (MapPartition at [1]Create/FlatMap(<lambda at
core.py:2646>)) -> FlatMap (FlatMap at ExtractOutput[0]) (1/1)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for CHAIN
MapPartition (MapPartition at [1]Create/FlatMap(<lambda at core.py:2646>)) ->
FlatMap (FlatMap at ExtractOutput[0]) (1/1) (43ef7d457921ae94839e2522ad80b292).
[CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) -> FlatMap
(FlatMap at ExtractOutput[0]) (1/1)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task CHAIN MapPartition (MapPartition at [4]assert_that/{Create,
Group}) -> FlatMap (FlatMap at ExtractOutput[0]) (1/1)
(dbbbc5785b89dc7ecd6d964107dca34d) [FINISHED]
[CHAIN MapPartition (MapPartition at [1]Create/FlatMap(<lambda at
core.py:2646>)) -> FlatMap (FlatMap at ExtractOutput[0]) (1/1)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task CHAIN MapPartition (MapPartition at [1]Create/FlatMap(<lambda
at core.py:2646>)) -> FlatMap (FlatMap at ExtractOutput[0]) (1/1)
(43ef7d457921ae94839e2522ad80b292) [FINISHED]
[Partition (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Partition
(1/1) (26c98d16deb7e86df04313657f5a0508) switched from RUNNING to FINISHED.
[Partition (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for Partition (1/1) (26c98d16deb7e86df04313657f5a0508).
[Partition (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all
FileSystem streams are closed for task Partition (1/1)
(26c98d16deb7e86df04313657f5a0508) [FINISHED]
[flink-akka.actor.default-dispatcher-10] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task CHAIN
MapPartition (MapPartition at [4]assert_that/{Create, Group}) -> FlatMap
(FlatMap at ExtractOutput[0]) dbbbc5785b89dc7ecd6d964107dca34d.
[flink-akka.actor.default-dispatcher-10] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task CHAIN
MapPartition (MapPartition at [1]Create/FlatMap(<lambda at core.py:2646>)) ->
FlatMap (FlatMap at ExtractOutput[0]) 43ef7d457921ae94839e2522ad80b292.
[flink-akka.actor.default-dispatcher-10] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task Partition
26c98d16deb7e86df04313657f5a0508.
[CHAIN MapPartition (MapPartition at [6]{Create, Map(<lambda at <string>:20>),
assert_that}) -> FlatMap (FlatMap at ExtractOutput[0]) (1/1)] INFO
org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory - Closing
environment urn: "beam:env:docker:v1"
payload: "\n#apachebeam/python3.6_sdk:2.20.0.dev"
[CHAIN MapPartition (MapPartition at [6]{Create, Map(<lambda at <string>:20>),
assert_that}) -> FlatMap (FlatMap at ExtractOutput[0]) (1/1)] INFO
org.apache.beam.runners.fnexecution.logging.GrpcLoggingService - 1 Beam Fn
Logging clients still connected during shutdown.
[CHAIN MapPartition (MapPartition at [6]{Create, Map(<lambda at <string>:20>),
assert_that}) -> FlatMap (FlatMap at ExtractOutput[0]) (1/1)] WARN
org.apache.beam.sdk.fn.data.BeamFnDataGrpcMultiplexer - Hanged up for unknown
endpoint.
[CHAIN MapPartition (MapPartition at [6]{Create, Map(<lambda at <string>:20>),
assert_that}) -> FlatMap (FlatMap at ExtractOutput[0]) (1/1)] INFO
org.apache.beam.runners.fnexecution.environment.DockerContainerEnvironment -
Closing Docker container
36ef64623bb6637366dbb152525cf0912d6fc07176768e76929711f15ded3b4b. Logs:
2020/02/10 18:15:34 Initializing python harness: /opt/apache/beam/boot --id=1-1
--logging_endpoint=localhost:40491 --artifact_endpoint=localhost:41707
--provision_endpoint=localhost:38401 --control_endpoint=localhost:41895
2020/02/10 18:15:35 Installing setup packages ...
2020/02/10 18:15:35 Found artifact: pickled_main_session
2020/02/10 18:15:35 Executing: python -m
apache_beam.runners.worker.sdk_worker_main
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition
(MapPartition at [4]assert_that/{Create, Group}) -> FlatMap (FlatMap at
ExtractOutput[0]) (1/1) (dbbbc5785b89dc7ecd6d964107dca34d) switched from
RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition
(MapPartition at [1]Create/FlatMap(<lambda at core.py:2646>)) -> FlatMap
(FlatMap at ExtractOutput[0]) (1/1) (43ef7d457921ae94839e2522ad80b292) switched
from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Partition (1/1)
(26c98d16deb7e86df04313657f5a0508) switched from RUNNING to FINISHED.
[CHAIN MapPartition (MapPartition at [6]{Create, Map(<lambda at <string>:20>),
assert_that}) -> FlatMap (FlatMap at ExtractOutput[0]) (1/1)] WARN
org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory - Error
cleaning up servers urn: "beam:env:docker:v1"
payload: "\n#apachebeam/python3.6_sdk:2.20.0.dev"
java.io.IOException: Received exit code 1 for command 'docker rm
36ef64623bb6637366dbb152525cf0912d6fc07176768e76929711f15ded3b4b'. stderr:
Error: No such container:
36ef64623bb6637366dbb152525cf0912d6fc07176768e76929711f15ded3b4b
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:478)
at
org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory$WrappedSdkHarnessClient.close(DefaultJobBundleFactory.java:478)
at
org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory$WrappedSdkHarnessClient.unref(DefaultJobBundleFactory.java:493)
at
org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory$WrappedSdkHarnessClient.access$1600(DefaultJobBundleFactory.java:431)
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)
[CHAIN MapPartition (MapPartition at [6]{Create, Map(<lambda at <string>:20>),
assert_that}) -> FlatMap (FlatMap at ExtractOutput[0]) (1/1)] INFO
org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at
[6]{Create, Map(<lambda at <string>:20>), assert_that}) -> FlatMap (FlatMap at
ExtractOutput[0]) (1/1) (48d36c11675486638e07e14b43206603) switched from
RUNNING to FINISHED.
[CHAIN MapPartition (MapPartition at [6]{Create, Map(<lambda at <string>:20>),
assert_that}) -> FlatMap (FlatMap at ExtractOutput[0]) (1/1)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for CHAIN
MapPartition (MapPartition at [6]{Create, Map(<lambda at <string>:20>),
assert_that}) -> FlatMap (FlatMap at ExtractOutput[0]) (1/1)
(48d36c11675486638e07e14b43206603).
[CHAIN MapPartition (MapPartition at [6]{Create, Map(<lambda at <string>:20>),
assert_that}) -> FlatMap (FlatMap at ExtractOutput[0]) (1/1)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task CHAIN MapPartition (MapPartition at [6]{Create, Map(<lambda at
<string>:20>), assert_that}) -> FlatMap (FlatMap at ExtractOutput[0]) (1/1)
(48d36c11675486638e07e14b43206603) [FINISHED]
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task CHAIN
MapPartition (MapPartition at [6]{Create, Map(<lambda at <string>:20>),
assert_that}) -> FlatMap (FlatMap at ExtractOutput[0])
48d36c11675486638e07e14b43206603.
[flink-akka.actor.default-dispatcher-10] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition
(MapPartition at [6]{Create, Map(<lambda at <string>:20>), assert_that}) ->
FlatMap (FlatMap at ExtractOutput[0]) (1/1) (48d36c11675486638e07e14b43206603)
switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-10] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce
(GroupReduce at assert_that/Group/GroupByKey) (1/1)
(4d391603e17e8a0a8928267fb3cfaa56) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-10] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce
(GroupReduce at assert_that/Group/GroupByKey) (1/1)
(4d391603e17e8a0a8928267fb3cfaa56) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-10] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying GroupReduce
(GroupReduce at assert_that/Group/GroupByKey) (1/1) (attempt #0) to
a17a21eb-f38b-4dd5-b2be-c5b3a7f496a1 @ localhost (dataPort=-1)
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task GroupReduce
(GroupReduce at assert_that/Group/GroupByKey) (1/1).
[GroupReduce (GroupReduce at assert_that/Group/GroupByKey) (1/1)] INFO
org.apache.flink.runtime.taskmanager.Task - GroupReduce (GroupReduce at
assert_that/Group/GroupByKey) (1/1) (4d391603e17e8a0a8928267fb3cfaa56) switched
from CREATED to DEPLOYING.
[GroupReduce (GroupReduce at assert_that/Group/GroupByKey) (1/1)] INFO
org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak
safety net for task GroupReduce (GroupReduce at assert_that/Group/GroupByKey)
(1/1) (4d391603e17e8a0a8928267fb3cfaa56) [DEPLOYING]
[GroupReduce (GroupReduce at assert_that/Group/GroupByKey) (1/1)] INFO
org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task
GroupReduce (GroupReduce at assert_that/Group/GroupByKey) (1/1)
(4d391603e17e8a0a8928267fb3cfaa56) [DEPLOYING].
[GroupReduce (GroupReduce at assert_that/Group/GroupByKey) (1/1)] INFO
org.apache.flink.runtime.taskmanager.Task - Registering task at network:
GroupReduce (GroupReduce at assert_that/Group/GroupByKey) (1/1)
(4d391603e17e8a0a8928267fb3cfaa56) [DEPLOYING].
[GroupReduce (GroupReduce at assert_that/Group/GroupByKey) (1/1)] INFO
org.apache.flink.runtime.taskmanager.Task - GroupReduce (GroupReduce at
assert_that/Group/GroupByKey) (1/1) (4d391603e17e8a0a8928267fb3cfaa56) switched
from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce
(GroupReduce at assert_that/Group/GroupByKey) (1/1)
(4d391603e17e8a0a8928267fb3cfaa56) switched from DEPLOYING to RUNNING.
[CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine
(GroupCombine at GroupCombine: assert_that/Group/GroupByKey) -> Map (Key
Extractor) (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN Filter
(UnionFixFilter) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: assert_that/Group/GroupByKey) -> Map (Key Extractor) (1/1)
(b18f7a5a79053b3b8d32ef162e059e43) switched from RUNNING to FINISHED.
[CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine
(GroupCombine at GroupCombine: assert_that/Group/GroupByKey) -> Map (Key
Extractor) (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) ->
GroupCombine (GroupCombine at GroupCombine: assert_that/Group/GroupByKey) ->
Map (Key Extractor) (1/1) (b18f7a5a79053b3b8d32ef162e059e43).
[CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine
(GroupCombine at GroupCombine: assert_that/Group/GroupByKey) -> Map (Key
Extractor) (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all
FileSystem streams are closed for task CHAIN Filter (UnionFixFilter) -> Map
(Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
assert_that/Group/GroupByKey) -> Map (Key Extractor) (1/1)
(b18f7a5a79053b3b8d32ef162e059e43) [FINISHED]
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task CHAIN Filter
(UnionFixFilter) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: assert_that/Group/GroupByKey) -> Map (Key Extractor)
b18f7a5a79053b3b8d32ef162e059e43.
[flink-akka.actor.default-dispatcher-10] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN Filter
(UnionFixFilter) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: assert_that/Group/GroupByKey) -> Map (Key Extractor) (1/1)
(b18f7a5a79053b3b8d32ef162e059e43) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-10] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [3]assert_that/{Group, Unkey, Match}) (1/1)
(82ca52888d10b1d1a7834d967f993b8e) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-10] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [3]assert_that/{Group, Unkey, Match}) (1/1)
(82ca52888d10b1d1a7834d967f993b8e) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-10] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying MapPartition
(MapPartition at [3]assert_that/{Group, Unkey, Match}) (1/1) (attempt #0) to
a17a21eb-f38b-4dd5-b2be-c5b3a7f496a1 @ localhost (dataPort=-1)
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task MapPartition
(MapPartition at [3]assert_that/{Group, Unkey, Match}) (1/1).
[MapPartition (MapPartition at [3]assert_that/{Group, Unkey, Match}) (1/1)]
INFO org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at
[3]assert_that/{Group, Unkey, Match}) (1/1) (82ca52888d10b1d1a7834d967f993b8e)
switched from CREATED to DEPLOYING.
[MapPartition (MapPartition at [3]assert_that/{Group, Unkey, Match}) (1/1)]
INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream
leak safety net for task MapPartition (MapPartition at [3]assert_that/{Group,
Unkey, Match}) (1/1) (82ca52888d10b1d1a7834d967f993b8e) [DEPLOYING]
[MapPartition (MapPartition at [3]assert_that/{Group, Unkey, Match}) (1/1)]
INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task
MapPartition (MapPartition at [3]assert_that/{Group, Unkey, Match}) (1/1)
(82ca52888d10b1d1a7834d967f993b8e) [DEPLOYING].
[MapPartition (MapPartition at [3]assert_that/{Group, Unkey, Match}) (1/1)]
INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network:
MapPartition (MapPartition at [3]assert_that/{Group, Unkey, Match}) (1/1)
(82ca52888d10b1d1a7834d967f993b8e) [DEPLOYING].
[MapPartition (MapPartition at [3]assert_that/{Group, Unkey, Match}) (1/1)]
INFO org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at
[3]assert_that/{Group, Unkey, Match}) (1/1) (82ca52888d10b1d1a7834d967f993b8e)
switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [3]assert_that/{Group, Unkey, Match}) (1/1)
(82ca52888d10b1d1a7834d967f993b8e) switched from DEPLOYING to RUNNING.
[GroupReduce (GroupReduce at assert_that/Group/GroupByKey) (1/1)] INFO
org.apache.flink.runtime.taskmanager.Task - GroupReduce (GroupReduce at
assert_that/Group/GroupByKey) (1/1) (4d391603e17e8a0a8928267fb3cfaa56) switched
from RUNNING to FINISHED.
[GroupReduce (GroupReduce at assert_that/Group/GroupByKey) (1/1)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
GroupReduce (GroupReduce at assert_that/Group/GroupByKey) (1/1)
(4d391603e17e8a0a8928267fb3cfaa56).
[GroupReduce (GroupReduce at assert_that/Group/GroupByKey) (1/1)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task GroupReduce (GroupReduce at assert_that/Group/GroupByKey) (1/1)
(4d391603e17e8a0a8928267fb3cfaa56) [FINISHED]
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task GroupReduce
(GroupReduce at assert_that/Group/GroupByKey) 4d391603e17e8a0a8928267fb3cfaa56.
[flink-akka.actor.default-dispatcher-12] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce
(GroupReduce at assert_that/Group/GroupByKey) (1/1)
(4d391603e17e8a0a8928267fb3cfaa56) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at [3]assert_that/{Group, Unkey, Match}) (1/1)]
WARN org.apache.beam.runners.fnexecution.environment.DockerCommand - Unable to
pull docker image apachebeam/python3.6_sdk:2.20.0.dev, cause: Received exit
code 1 for command 'docker pull apachebeam/python3.6_sdk:2.20.0.dev'. stderr:
Error response from daemon: manifest for apachebeam/python3.6_sdk:2.20.0.dev
not found
[grpc-default-executor-0] INFO
org.apache.beam.runners.fnexecution.artifact.AbstractArtifactRetrievalService -
GetManifest for BEAM-PIPELINE/pipeline/artifact-manifest.json
[grpc-default-executor-0] INFO
org.apache.beam.runners.fnexecution.artifact.AbstractArtifactRetrievalService -
Manifest at BEAM-PIPELINE/pipeline/artifact-manifest.json has 1 artifact
locations
[grpc-default-executor-0] INFO
org.apache.beam.runners.fnexecution.artifact.AbstractArtifactRetrievalService -
GetManifest for BEAM-PIPELINE/pipeline/artifact-manifest.json -> 1 artifacts
[grpc-default-executor-0] INFO
org.apache.beam.runners.fnexecution.logging.GrpcLoggingService - Beam Fn
Logging client connected.
[grpc-default-executor-0] INFO
/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/sdk_worker_main.py:98
- Logging handler created.
[grpc-default-executor-0] INFO
/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/sdk_worker_main.py:125
- semi_persistent_directory: /tmp
[grpc-default-executor-0] INFO
/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/sdk_worker_main.py:79
- Status HTTP server running at localhost:43733
[grpc-default-executor-0] WARN
/usr/local/lib/python3.6/site-packages/apache_beam/options/pipeline_options.py:290
- Discarding unparseable args: ['--app_name=None',
'--direct_runner_use_stacked_bundle', '--job_server_timeout=60',
'--options_id=1', '--pipeline_type_check',
'--retrieval_service_type=CLASSLOADER']
[grpc-default-executor-0] INFO
/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/sdk_worker_main.py:138
- Python sdk harness started with pipeline_options: {'job_name':
'BeamApp-jenkins-0210181517-4d238882', 'experiments': ['beam_fn_api'],
'save_main_session': True, 'sdk_location': 'container', 'environment_type':
'DOCKER', 'environment_config': 'apachebeam/python3.6_sdk:2.20.0.dev',
'sdk_worker_parallelism': '1', 'environment_cache_millis': '0', 'job_port':
'0', 'artifact_port': '0', 'expansion_port': '0', 'flink_job_server_jar':
'/home/jenkins/jenkins-slave/workspace/beam_PostCommit_PortableJar_Flink/src/runners/flink/1.9/job-server/build/libs/beam-runners-flink-1.9-job-server-2.20.0-SNAPSHOT.jar',
'flink_submit_uber_jar': True}
[grpc-default-executor-0] INFO
/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/statecache.py:154
- Creating state cache with size 0
[grpc-default-executor-0] INFO
/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/sdk_worker.py:94
- Creating insecure control channel for localhost:35549.
[grpc-default-executor-0] INFO
/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/sdk_worker.py:102
- Control channel established.
[grpc-default-executor-0] INFO
/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/sdk_worker.py:136
- Initializing SDKHarness with unbounded number of workers.
[grpc-default-executor-0] INFO
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService -
Beam Fn Control client connected with id 2-1
[grpc-default-executor-0] INFO
/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/sdk_worker.py:590
- Creating insecure state channel for localhost:38503.
[grpc-default-executor-0] INFO
/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/sdk_worker.py:597
- State channel established.
[grpc-default-executor-0] INFO
/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/data_plane.py:525
- Creating client data channel for localhost:43179
[grpc-default-executor-0] INFO
org.apache.beam.runners.fnexecution.data.GrpcDataService - Beam Fn Data client
connected.
[MapPartition (MapPartition at [3]assert_that/{Group, Unkey, Match}) (1/1)]
INFO org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory -
Closing environment urn: "beam:env:docker:v1"
payload: "\n#apachebeam/python3.6_sdk:2.20.0.dev"
[MapPartition (MapPartition at [3]assert_that/{Group, Unkey, Match}) (1/1)]
INFO org.apache.beam.runners.fnexecution.logging.GrpcLoggingService - 1 Beam Fn
Logging clients still connected during shutdown.
[MapPartition (MapPartition at [3]assert_that/{Group, Unkey, Match}) (1/1)]
WARN org.apache.beam.sdk.fn.data.BeamFnDataGrpcMultiplexer - Hanged up for
unknown endpoint.
[MapPartition (MapPartition at [3]assert_that/{Group, Unkey, Match}) (1/1)]
INFO org.apache.beam.runners.fnexecution.environment.DockerContainerEnvironment
- Closing Docker container
3532da95c0a924ac5ba5b980988950052da615b4ca251f847e083d947d79696d. Logs:
2020/02/10 18:16:08 Initializing python harness: /opt/apache/beam/boot --id=2-1
--logging_endpoint=localhost:34015 --artifact_endpoint=localhost:46431
--provision_endpoint=localhost:46587 --control_endpoint=localhost:35549
2020/02/10 18:16:08 Installing setup packages ...
2020/02/10 18:16:08 Found artifact: pickled_main_session
2020/02/10 18:16:08 Executing: python -m
apache_beam.runners.worker.sdk_worker_main
[MapPartition (MapPartition at [3]assert_that/{Group, Unkey, Match}) (1/1)]
WARN org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory -
Error cleaning up servers urn: "beam:env:docker:v1"
payload: "\n#apachebeam/python3.6_sdk:2.20.0.dev"
java.io.IOException: Received exit code 1 for command 'docker rm
3532da95c0a924ac5ba5b980988950052da615b4ca251f847e083d947d79696d'. stderr:
Error: No such container:
3532da95c0a924ac5ba5b980988950052da615b4ca251f847e083d947d79696d
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:478)
at
org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory$WrappedSdkHarnessClient.close(DefaultJobBundleFactory.java:478)
at
org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory$WrappedSdkHarnessClient.unref(DefaultJobBundleFactory.java:493)
at
org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory$WrappedSdkHarnessClient.access$1600(DefaultJobBundleFactory.java:431)
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 [3]assert_that/{Group, Unkey, Match}) (1/1)]
INFO org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at
[3]assert_that/{Group, Unkey, Match}) (1/1) (82ca52888d10b1d1a7834d967f993b8e)
switched from RUNNING to FINISHED.
[MapPartition (MapPartition at [3]assert_that/{Group, Unkey, Match}) (1/1)]
INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
MapPartition (MapPartition at [3]assert_that/{Group, Unkey, Match}) (1/1)
(82ca52888d10b1d1a7834d967f993b8e).
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (1/1) (82346d8608a6951fe765abfaa6c0dcbe) switched from
CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (1/1) (82346d8608a6951fe765abfaa6c0dcbe) switched from
SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink
(DiscardingOutput) (1/1) (attempt #0) to a17a21eb-f38b-4dd5-b2be-c5b3a7f496a1 @
localhost (dataPort=-1)
[MapPartition (MapPartition at [3]assert_that/{Group, Unkey, Match}) (1/1)]
INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem
streams are closed for task MapPartition (MapPartition at
[3]assert_that/{Group, Unkey, Match}) (1/1) (82ca52888d10b1d1a7834d967f993b8e)
[FINISHED]
[flink-akka.actor.default-dispatcher-12] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task MapPartition
(MapPartition at [3]assert_that/{Group, Unkey, Match})
82ca52888d10b1d1a7834d967f993b8e.
[flink-akka.actor.default-dispatcher-12] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(DiscardingOutput) (1/1).
[DataSink (DiscardingOutput) (1/1)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (1/1)
(82346d8608a6951fe765abfaa6c0dcbe) switched from CREATED to DEPLOYING.
[DataSink (DiscardingOutput) (1/1)] INFO
org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak
safety net for task DataSink (DiscardingOutput) (1/1)
(82346d8608a6951fe765abfaa6c0dcbe) [DEPLOYING]
[DataSink (DiscardingOutput) (1/1)] INFO
org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink
(DiscardingOutput) (1/1) (82346d8608a6951fe765abfaa6c0dcbe) [DEPLOYING].
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [3]assert_that/{Group, Unkey, Match}) (1/1)
(82ca52888d10b1d1a7834d967f993b8e) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (1/1)] INFO
org.apache.flink.runtime.taskmanager.Task - Registering task at network:
DataSink (DiscardingOutput) (1/1) (82346d8608a6951fe765abfaa6c0dcbe)
[DEPLOYING].
[DataSink (DiscardingOutput) (1/1)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (1/1)
(82346d8608a6951fe765abfaa6c0dcbe) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-13] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (1/1) (82346d8608a6951fe765abfaa6c0dcbe) switched from
DEPLOYING to RUNNING.
[DataSink (DiscardingOutput) (1/1)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (1/1)
(82346d8608a6951fe765abfaa6c0dcbe) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (1/1)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink
(DiscardingOutput) (1/1) (82346d8608a6951fe765abfaa6c0dcbe).
[DataSink (DiscardingOutput) (1/1)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task DataSink (DiscardingOutput) (1/1)
(82346d8608a6951fe765abfaa6c0dcbe) [FINISHED]
[flink-akka.actor.default-dispatcher-13] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(DiscardingOutput) 82346d8608a6951fe765abfaa6c0dcbe.
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (1/1) (82346d8608a6951fe765abfaa6c0dcbe) switched from
RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Job
BeamApp-jenkins-0210181517-4d238882 (8a9fb2b0875e86d40d2feccb01d6a2ec) switched
from state RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-13] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job
8a9fb2b0875e86d40d2feccb01d6a2ec reached globally terminal state FINISHED.
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job
BeamApp-jenkins-0210181517-4d238882(8a9fb2b0875e86d40d2feccb01d6a2ec).
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl - Suspending SlotPool.
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection
7cc06a80938e968e3d53425b0fde6986: JobManager is shutting down..
[flink-akka.actor.default-dispatcher-13] INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot
TaskSlot(index:0, state:ACTIVE, resource profile:
ResourceProfile{cpuCores=1.7976931348623157E308, heapMemoryInMB=2147483647,
directMemoryInMB=2147483647, nativeMemoryInMB=2147483647,
networkMemoryInMB=2147483647, managedMemoryInMB=16277}, allocationId:
92ebb7804ea0bb4b53e3883533b2a479, jobId: 8a9fb2b0875e86d40d2feccb01d6a2ec).
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl - Stopping SlotPool.
[flink-akka.actor.default-dispatcher-10] INFO
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Disconnect
job manager 9a9e07bc50da109320a6e48c1e054f37@akka://flink/user/jobmanager_1 for
job 8a9fb2b0875e86d40d2feccb01d6a2ec from the resource manager.
[flink-akka.actor.default-dispatcher-13] INFO
org.apache.flink.runtime.taskexecutor.JobLeaderService - Remove job
8a9fb2b0875e86d40d2feccb01d6a2ec from job leader monitoring.
[flink-akka.actor.default-dispatcher-13] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager
connection for job 8a9fb2b0875e86d40d2feccb01d6a2ec.
[flink-akka.actor.default-dispatcher-13] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager
connection for job 8a9fb2b0875e86d40d2feccb01d6a2ec.
[flink-akka.actor.default-dispatcher-13] INFO
org.apache.flink.runtime.taskexecutor.JobLeaderService - Cannot reconnect to
job 8a9fb2b0875e86d40d2feccb01d6a2ec because it is not registered.
FATAL: command execution failed
hudson.remoting.ChannelClosedException: Channel "unknown": Remote call on
JNLP4-connect connection from
165.171.154.104.bc.googleusercontent.com/104.154.171.165:60710 failed. The
channel is closing down or has closed down
at hudson.remoting.Channel.call(Channel.java:950)
at
hudson.remoting.RemoteInvocationHandler.invoke(RemoteInvocationHandler.java:283)
at com.sun.proxy.$Proxy143.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: [email protected]
For additional commands, e-mail: [email protected]
