See
<https://builds.apache.org/job/beam_PostCommit_Python36/1656/display/redirect?page=changes>
Changes:
[daniel.o.programmer] [BEAM-3301] (Go SDK) Adding restriction plumbing to graph
construction.
[github] Merge pull request #10766: [BEAM-4461] Add Selected.flattenedSchema
------------------------------------------
[...truncated 1.76 MB...]
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - FlatMap (FlatMap at
ExtractOutput[1]) (6/16) (19ba532c8e356e82ed7d9fa26274db18) switched from
CREATED to SCHEDULED.
[MapPartition (MapPartition at [6]{read, assert_that}) (1/16)] INFO
org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at
[6]{read, assert_that}) (1/16) (902fdcd54afde5edd4c98eeb0a158de4) switched from
RUNNING to FINISHED.
[MapPartition (MapPartition at [6]{read, assert_that}) (1/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
MapPartition (MapPartition at [6]{read, assert_that}) (1/16)
(902fdcd54afde5edd4c98eeb0a158de4).
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - FlatMap (FlatMap at
ExtractOutput[1]) (6/16) (19ba532c8e356e82ed7d9fa26274db18) switched from
SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying FlatMap
(FlatMap at ExtractOutput[1]) (6/16) (attempt #0) to
dd40b6cc-0451-41a8-87c3-1ba00ec1bcae @ localhost (dataPort=-1)
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - FlatMap (FlatMap at
ExtractOutput[0]) (6/16) (1b07c2856e0c17cf2c4ee3446d62bc50) switched from
CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - FlatMap (FlatMap at
ExtractOutput[0]) (6/16) (1b07c2856e0c17cf2c4ee3446d62bc50) switched from
SCHEDULED to DEPLOYING.
[MapPartition (MapPartition at [6]{read, assert_that}) (16/16)] INFO
org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at
[6]{read, assert_that}) (16/16) (01abcbda51fd1da626a5ae38750cce7a) switched
from RUNNING to FINISHED.
[MapPartition (MapPartition at [6]{read, assert_that}) (16/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
MapPartition (MapPartition at [6]{read, assert_that}) (16/16)
(01abcbda51fd1da626a5ae38750cce7a).
[MapPartition (MapPartition at [6]{read, assert_that}) (2/16)] INFO
org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at
[6]{read, assert_that}) (2/16) (95318d9b3cd2d8f1f4fb4a31b34d19a1) switched from
RUNNING to FINISHED.
[MapPartition (MapPartition at [6]{read, assert_that}) (2/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
MapPartition (MapPartition at [6]{read, assert_that}) (2/16)
(95318d9b3cd2d8f1f4fb4a31b34d19a1).
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying FlatMap
(FlatMap at ExtractOutput[0]) (6/16) (attempt #0) to
dd40b6cc-0451-41a8-87c3-1ba00ec1bcae @ localhost (dataPort=-1)
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task FlatMap
(FlatMap at ExtractOutput[1]) (15/16).
[FlatMap (FlatMap at ExtractOutput[1]) (12/16)] INFO
org.apache.flink.runtime.taskmanager.Task - FlatMap (FlatMap at
ExtractOutput[1]) (12/16) (9b8a2a876f92cff313312a15c50a03bc) switched from
RUNNING to FINISHED.
[FlatMap (FlatMap at ExtractOutput[1]) (12/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for FlatMap
(FlatMap at ExtractOutput[1]) (12/16) (9b8a2a876f92cff313312a15c50a03bc).
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - FlatMap (FlatMap at
ExtractOutput[1]) (1/16) (3b86feb6c3ae750c0d00eeaeacf6a8c8) switched from
CREATED to SCHEDULED.
[FlatMap (FlatMap at ExtractOutput[0]) (10/16)] INFO
org.apache.flink.runtime.taskmanager.Task - FlatMap (FlatMap at
ExtractOutput[0]) (10/16) (6e480e84f96870d77bca62d60879ec94) switched from
RUNNING to FINISHED.
[FlatMap (FlatMap at ExtractOutput[0]) (10/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for FlatMap
(FlatMap at ExtractOutput[0]) (10/16) (6e480e84f96870d77bca62d60879ec94).
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - FlatMap (FlatMap at
ExtractOutput[1]) (1/16) (3b86feb6c3ae750c0d00eeaeacf6a8c8) switched from
SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying FlatMap
(FlatMap at ExtractOutput[1]) (1/16) (attempt #0) to
dd40b6cc-0451-41a8-87c3-1ba00ec1bcae @ localhost (dataPort=-1)
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - FlatMap (FlatMap at
ExtractOutput[0]) (1/16) (383292ba70fcc85d30cfec67d6a767ca) switched from
CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - FlatMap (FlatMap at
ExtractOutput[0]) (1/16) (383292ba70fcc85d30cfec67d6a767ca) switched from
SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying FlatMap
(FlatMap at ExtractOutput[0]) (1/16) (attempt #0) to
dd40b6cc-0451-41a8-87c3-1ba00ec1bcae @ localhost (dataPort=-1)
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - FlatMap (FlatMap at
ExtractOutput[1]) (16/16) (da01a637d96ccc85b71519d10d41ade1) switched from
CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task FlatMap
(FlatMap at ExtractOutput[0]) (15/16).
[FlatMap (FlatMap at ExtractOutput[0]) (15/16)] INFO
org.apache.flink.runtime.taskmanager.Task - FlatMap (FlatMap at
ExtractOutput[0]) (15/16) (b3a73065596951bb74b85682d998b3cc) switched from
CREATED to DEPLOYING.
[FlatMap (FlatMap at ExtractOutput[0]) (15/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak
safety net for task FlatMap (FlatMap at ExtractOutput[0]) (15/16)
(b3a73065596951bb74b85682d998b3cc) [DEPLOYING]
[FlatMap (FlatMap at ExtractOutput[0]) (15/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task FlatMap
(FlatMap at ExtractOutput[0]) (15/16) (b3a73065596951bb74b85682d998b3cc)
[DEPLOYING].
[FlatMap (FlatMap at ExtractOutput[1]) (15/16)] INFO
org.apache.flink.runtime.taskmanager.Task - FlatMap (FlatMap at
ExtractOutput[1]) (15/16) (83311ed10f57f80f81c025366f86bd27) switched from
CREATED to DEPLOYING.
[FlatMap (FlatMap at ExtractOutput[1]) (15/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak
safety net for task FlatMap (FlatMap at ExtractOutput[1]) (15/16)
(83311ed10f57f80f81c025366f86bd27) [DEPLOYING]
[FlatMap (FlatMap at ExtractOutput[0]) (15/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Registering task at network:
FlatMap (FlatMap at ExtractOutput[0]) (15/16)
(b3a73065596951bb74b85682d998b3cc) [DEPLOYING].
[FlatMap (FlatMap at ExtractOutput[1]) (15/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task FlatMap
(FlatMap at ExtractOutput[1]) (15/16) (83311ed10f57f80f81c025366f86bd27)
[DEPLOYING].
[FlatMap (FlatMap at ExtractOutput[0]) (15/16)] INFO
org.apache.flink.runtime.taskmanager.Task - FlatMap (FlatMap at
ExtractOutput[0]) (15/16) (b3a73065596951bb74b85682d998b3cc) switched from
DEPLOYING to RUNNING.
[FlatMap (FlatMap at ExtractOutput[1]) (15/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Registering task at network:
FlatMap (FlatMap at ExtractOutput[1]) (15/16)
(83311ed10f57f80f81c025366f86bd27) [DEPLOYING].
[FlatMap (FlatMap at ExtractOutput[1]) (15/16)] INFO
org.apache.flink.runtime.taskmanager.Task - FlatMap (FlatMap at
ExtractOutput[1]) (15/16) (83311ed10f57f80f81c025366f86bd27) switched from
DEPLOYING to RUNNING.
[FlatMap (FlatMap at ExtractOutput[0]) (15/16)] INFO
org.apache.flink.runtime.taskmanager.Task - FlatMap (FlatMap at
ExtractOutput[0]) (15/16) (b3a73065596951bb74b85682d998b3cc) switched from
RUNNING to FINISHED.
[FlatMap (FlatMap at ExtractOutput[0]) (15/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for FlatMap
(FlatMap at ExtractOutput[0]) (15/16) (b3a73065596951bb74b85682d998b3cc).
[FlatMap (FlatMap at ExtractOutput[1]) (15/16)] INFO
org.apache.flink.runtime.taskmanager.Task - FlatMap (FlatMap at
ExtractOutput[1]) (15/16) (83311ed10f57f80f81c025366f86bd27) switched from
RUNNING to FINISHED.
[FlatMap (FlatMap at ExtractOutput[1]) (15/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for FlatMap
(FlatMap at ExtractOutput[1]) (15/16) (83311ed10f57f80f81c025366f86bd27).
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - FlatMap (FlatMap at
ExtractOutput[1]) (16/16) (da01a637d96ccc85b71519d10d41ade1) switched from
SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying FlatMap
(FlatMap at ExtractOutput[1]) (16/16) (attempt #0) to
dd40b6cc-0451-41a8-87c3-1ba00ec1bcae @ localhost (dataPort=-1)
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - FlatMap (FlatMap at
ExtractOutput[0]) (16/16) (7f8d57cef6b254a9566205cc72895c95) switched from
CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - FlatMap (FlatMap at
ExtractOutput[0]) (16/16) (7f8d57cef6b254a9566205cc72895c95) switched from
SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying FlatMap
(FlatMap at ExtractOutput[0]) (16/16) (attempt #0) to
dd40b6cc-0451-41a8-87c3-1ba00ec1bcae @ localhost (dataPort=-1)
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - FlatMap (FlatMap at
ExtractOutput[1]) (2/16) (e28e865b6a7224dcd6d013fa9d94c978) switched from
CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - FlatMap (FlatMap at
ExtractOutput[1]) (2/16) (e28e865b6a7224dcd6d013fa9d94c978) switched from
SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying FlatMap
(FlatMap at ExtractOutput[1]) (2/16) (attempt #0) to
dd40b6cc-0451-41a8-87c3-1ba00ec1bcae @ localhost (dataPort=-1)
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - FlatMap (FlatMap at
ExtractOutput[0]) (2/16) (56cd0e03e6a69b783f1f82a4d188f37d) switched from
CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - FlatMap (FlatMap at
ExtractOutput[0]) (2/16) (56cd0e03e6a69b783f1f82a4d188f37d) switched from
SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying FlatMap
(FlatMap at ExtractOutput[0]) (2/16) (attempt #0) to
dd40b6cc-0451-41a8-87c3-1ba00ec1bcae @ localhost (dataPort=-1)
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - FlatMap (FlatMap at
ExtractOutput[0]) (15/16) (b3a73065596951bb74b85682d998b3cc) switched from
DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - FlatMap (FlatMap at
ExtractOutput[1]) (15/16) (83311ed10f57f80f81c025366f86bd27) switched from
DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task FlatMap
(FlatMap at ExtractOutput[1]) (8/16).
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task FlatMap
(FlatMap at ExtractOutput[0]) (8/16).
[FlatMap (FlatMap at ExtractOutput[1]) (8/16)] INFO
org.apache.flink.runtime.taskmanager.Task - FlatMap (FlatMap at
ExtractOutput[1]) (8/16) (f6bfb242237eab8d22fbd517a647bee4) switched from
CREATED to DEPLOYING.
[FlatMap (FlatMap at ExtractOutput[1]) (8/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak
safety net for task FlatMap (FlatMap at ExtractOutput[1]) (8/16)
(f6bfb242237eab8d22fbd517a647bee4) [DEPLOYING]
[FlatMap (FlatMap at ExtractOutput[1]) (8/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task FlatMap
(FlatMap at ExtractOutput[1]) (8/16) (f6bfb242237eab8d22fbd517a647bee4)
[DEPLOYING].
[FlatMap (FlatMap at ExtractOutput[1]) (8/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Registering task at network:
FlatMap (FlatMap at ExtractOutput[1]) (8/16) (f6bfb242237eab8d22fbd517a647bee4)
[DEPLOYING].
[FlatMap (FlatMap at ExtractOutput[1]) (8/16)] INFO
org.apache.flink.runtime.taskmanager.Task - FlatMap (FlatMap at
ExtractOutput[1]) (8/16) (f6bfb242237eab8d22fbd517a647bee4) switched from
DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - FlatMap (FlatMap at
ExtractOutput[1]) (8/16) (f6bfb242237eab8d22fbd517a647bee4) switched from
DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task FlatMap
(FlatMap at ExtractOutput[1]) (13/16).
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task FlatMap
(FlatMap at ExtractOutput[0]) (13/16).
[FlatMap (FlatMap at ExtractOutput[1]) (8/16)] INFO
org.apache.flink.runtime.taskmanager.Task - FlatMap (FlatMap at
ExtractOutput[1]) (8/16) (f6bfb242237eab8d22fbd517a647bee4) switched from
RUNNING to FINISHED.
[FlatMap (FlatMap at ExtractOutput[1]) (8/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for FlatMap
(FlatMap at ExtractOutput[1]) (8/16) (f6bfb242237eab8d22fbd517a647bee4).
[FlatMap (FlatMap at ExtractOutput[0]) (8/16)] INFO
org.apache.flink.runtime.taskmanager.Task - FlatMap (FlatMap at
ExtractOutput[0]) (8/16) (86047ffd4d9713cf5d9eaea253de80b2) switched from
CREATED to DEPLOYING.
[FlatMap (FlatMap at ExtractOutput[1]) (13/16)] INFO
org.apache.flink.runtime.taskmanager.Task - FlatMap (FlatMap at
ExtractOutput[1]) (13/16) (88e88fcd5155fed78d6cab988b1eac8f) switched from
CREATED to DEPLOYING.
[FlatMap (FlatMap at ExtractOutput[0]) (8/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak
safety net for task FlatMap (FlatMap at ExtractOutput[0]) (8/16)
(86047ffd4d9713cf5d9eaea253de80b2) [DEPLOYING]
[FlatMap (FlatMap at ExtractOutput[1]) (13/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak
safety net for task FlatMap (FlatMap at ExtractOutput[1]) (13/16)
(88e88fcd5155fed78d6cab988b1eac8f) [DEPLOYING]
[FlatMap (FlatMap at ExtractOutput[0]) (13/16)] INFO
org.apache.flink.runtime.taskmanager.Task - FlatMap (FlatMap at
ExtractOutput[0]) (13/16) (502b67a230c48b634ff4b642ffab3a92) switched from
CREATED to DEPLOYING.
[FlatMap (FlatMap at ExtractOutput[1]) (13/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task FlatMap
(FlatMap at ExtractOutput[1]) (13/16) (88e88fcd5155fed78d6cab988b1eac8f)
[DEPLOYING].
[FlatMap (FlatMap at ExtractOutput[0]) (13/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak
safety net for task FlatMap (FlatMap at ExtractOutput[0]) (13/16)
(502b67a230c48b634ff4b642ffab3a92) [DEPLOYING]
[FlatMap (FlatMap at ExtractOutput[0]) (8/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task FlatMap
(FlatMap at ExtractOutput[0]) (8/16) (86047ffd4d9713cf5d9eaea253de80b2)
[DEPLOYING].
[FlatMap (FlatMap at ExtractOutput[0]) (13/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task FlatMap
(FlatMap at ExtractOutput[0]) (13/16) (502b67a230c48b634ff4b642ffab3a92)
[DEPLOYING].
[FlatMap (FlatMap at ExtractOutput[0]) (8/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Registering task at network:
FlatMap (FlatMap at ExtractOutput[0]) (8/16) (86047ffd4d9713cf5d9eaea253de80b2)
[DEPLOYING].
[FlatMap (FlatMap at ExtractOutput[0]) (13/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Registering task at network:
FlatMap (FlatMap at ExtractOutput[0]) (13/16)
(502b67a230c48b634ff4b642ffab3a92) [DEPLOYING].
[FlatMap (FlatMap at ExtractOutput[1]) (13/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Registering task at network:
FlatMap (FlatMap at ExtractOutput[1]) (13/16)
(88e88fcd5155fed78d6cab988b1eac8f) [DEPLOYING].
[FlatMap (FlatMap at ExtractOutput[0]) (13/16)] INFO
org.apache.flink.runtime.taskmanager.Task - FlatMap (FlatMap at
ExtractOutput[0]) (13/16) (502b67a230c48b634ff4b642ffab3a92) switched from
DEPLOYING to RUNNING.
[FlatMap (FlatMap at ExtractOutput[0]) (8/16)] INFO
org.apache.flink.runtime.taskmanager.Task - FlatMap (FlatMap at
ExtractOutput[0]) (8/16) (86047ffd4d9713cf5d9eaea253de80b2) switched from
DEPLOYING to RUNNING.
[FlatMap (FlatMap at ExtractOutput[1]) (13/16)] INFO
org.apache.flink.runtime.taskmanager.Task - FlatMap (FlatMap at
ExtractOutput[1]) (13/16) (88e88fcd5155fed78d6cab988b1eac8f) switched from
DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - FlatMap (FlatMap at
ExtractOutput[0]) (13/16) (502b67a230c48b634ff4b642ffab3a92) switched from
DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - FlatMap (FlatMap at
ExtractOutput[0]) (8/16) (86047ffd4d9713cf5d9eaea253de80b2) switched from
DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - FlatMap (FlatMap at
ExtractOutput[1]) (13/16) (88e88fcd5155fed78d6cab988b1eac8f) switched from
DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task FlatMap
(FlatMap at ExtractOutput[1]) (14/16).
[FlatMap (FlatMap at ExtractOutput[1]) (14/16)] INFO
org.apache.flink.runtime.taskmanager.Task - FlatMap (FlatMap at
ExtractOutput[1]) (14/16) (54540df9c3f721681985d2af53caed72) switched from
CREATED to DEPLOYING.
[FlatMap (FlatMap at ExtractOutput[1]) (14/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak
safety net for task FlatMap (FlatMap at ExtractOutput[1]) (14/16)
(54540df9c3f721681985d2af53caed72) [DEPLOYING]
[FlatMap (FlatMap at ExtractOutput[1]) (14/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task FlatMap
(FlatMap at ExtractOutput[1]) (14/16) (54540df9c3f721681985d2af53caed72)
[DEPLOYING].
[FlatMap (FlatMap at ExtractOutput[1]) (14/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Registering task at network:
FlatMap (FlatMap at ExtractOutput[1]) (14/16)
(54540df9c3f721681985d2af53caed72) [DEPLOYING].
[FlatMap (FlatMap at ExtractOutput[1]) (14/16)] INFO
org.apache.flink.runtime.taskmanager.Task - FlatMap (FlatMap at
ExtractOutput[1]) (14/16) (54540df9c3f721681985d2af53caed72) switched from
DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - FlatMap (FlatMap at
ExtractOutput[1]) (14/16) (54540df9c3f721681985d2af53caed72) switched from
DEPLOYING to RUNNING.
[FlatMap (FlatMap at ExtractOutput[0]) (13/16)] INFO
org.apache.flink.runtime.taskmanager.Task - FlatMap (FlatMap at
ExtractOutput[0]) (13/16) (502b67a230c48b634ff4b642ffab3a92) switched from
RUNNING to FINISHED.
[FlatMap (FlatMap at ExtractOutput[0]) (13/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for FlatMap
(FlatMap at ExtractOutput[0]) (13/16) (502b67a230c48b634ff4b642ffab3a92).
[FlatMap (FlatMap at ExtractOutput[0]) (8/16)] INFO
org.apache.flink.runtime.taskmanager.Task - FlatMap (FlatMap at
ExtractOutput[0]) (8/16) (86047ffd4d9713cf5d9eaea253de80b2) switched from
RUNNING to FINISHED.
[FlatMap (FlatMap at ExtractOutput[0]) (8/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for FlatMap
(FlatMap at ExtractOutput[0]) (8/16) (86047ffd4d9713cf5d9eaea253de80b2).
[FlatMap (FlatMap at ExtractOutput[1]) (13/16)] INFO
org.apache.flink.runtime.taskmanager.Task - FlatMap (FlatMap at
ExtractOutput[1]) (13/16) (88e88fcd5155fed78d6cab988b1eac8f) switched from
RUNNING to FINISHED.
[FlatMap (FlatMap at ExtractOutput[1]) (13/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for FlatMap
(FlatMap at ExtractOutput[1]) (13/16) (88e88fcd5155fed78d6cab988b1eac8f).
[FlatMap (FlatMap at ExtractOutput[1]) (14/16)] INFO
org.apache.flink.runtime.taskmanager.Task - FlatMap (FlatMap at
ExtractOutput[1]) (14/16) (54540df9c3f721681985d2af53caed72) switched from
RUNNING to FINISHED.
[FlatMap (FlatMap at ExtractOutput[1]) (14/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for FlatMap
(FlatMap at ExtractOutput[1]) (14/16) (54540df9c3f721681985d2af53caed72).
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task FlatMap
(FlatMap at ExtractOutput[0]) (14/16).
[FlatMap (FlatMap at ExtractOutput[0]) (14/16)] INFO
org.apache.flink.runtime.taskmanager.Task - FlatMap (FlatMap at
ExtractOutput[0]) (14/16) (8be7f90e1bc1d4f84cc533a0b5279cf1) switched from
CREATED to DEPLOYING.
[FlatMap (FlatMap at ExtractOutput[0]) (14/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak
safety net for task FlatMap (FlatMap at ExtractOutput[0]) (14/16)
(8be7f90e1bc1d4f84cc533a0b5279cf1) [DEPLOYING]
[FlatMap (FlatMap at ExtractOutput[0]) (14/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task FlatMap
(FlatMap at ExtractOutput[0]) (14/16) (8be7f90e1bc1d4f84cc533a0b5279cf1)
[DEPLOYING].
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task FlatMap
(FlatMap at ExtractOutput[1]) (9/16).
[FlatMap (FlatMap at ExtractOutput[0]) (14/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Registering task at network:
FlatMap (FlatMap at ExtractOutput[0]) (14/16)
(8be7f90e1bc1d4f84cc533a0b5279cf1) [DEPLOYING].
[FlatMap (FlatMap at ExtractOutput[0]) (14/16)] INFO
org.apache.flink.runtime.taskmanager.Task - FlatMap (FlatMap at
ExtractOutput[0]) (14/16) (8be7f90e1bc1d4f84cc533a0b5279cf1) switched from
DEPLOYING to RUNNING.
[FlatMap (FlatMap at ExtractOutput[1]) (9/16)] INFO
org.apache.flink.runtime.taskmanager.Task - FlatMap (FlatMap at
ExtractOutput[1]) (9/16) (eb079c2d2d8b28b86f0fb93b5aecc56b) switched from
CREATED to DEPLOYING.
[FlatMap (FlatMap at ExtractOutput[1]) (9/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak
safety net for task FlatMap (FlatMap at ExtractOutput[1]) (9/16)
(eb079c2d2d8b28b86f0fb93b5aecc56b) [DEPLOYING]
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - FlatMap (FlatMap at
ExtractOutput[0]) (14/16) (8be7f90e1bc1d4f84cc533a0b5279cf1) switched from
DEPLOYING to RUNNING.
[FlatMap (FlatMap at ExtractOutput[1]) (9/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task FlatMap
(FlatMap at ExtractOutput[1]) (9/16) (eb079c2d2d8b28b86f0fb93b5aecc56b)
[DEPLOYING].
[FlatMap (FlatMap at ExtractOutput[1]) (9/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Registering task at network:
FlatMap (FlatMap at ExtractOutput[1]) (9/16) (eb079c2d2d8b28b86f0fb93b5aecc56b)
[DEPLOYING].
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task FlatMap
(FlatMap at ExtractOutput[0]) (9/16).
[FlatMap (FlatMap at ExtractOutput[1]) (9/16)] INFO
org.apache.flink.runtime.taskmanager.Task - FlatMap (FlatMap at
ExtractOutput[1]) (9/16) (eb079c2d2d8b28b86f0fb93b5aecc56b) switched from
DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - FlatMap (FlatMap at
ExtractOutput[1]) (9/16) (eb079c2d2d8b28b86f0fb93b5aecc56b) switched from
DEPLOYING to RUNNING.
[FlatMap (FlatMap at ExtractOutput[0]) (9/16)] INFO
org.apache.flink.runtime.taskmanager.Task - FlatMap (FlatMap at
ExtractOutput[0]) (9/16) (8585829b967a0f3bb80ac2747429dd23) switched from
CREATED to DEPLOYING.
[FlatMap (FlatMap at ExtractOutput[0]) (9/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak
safety net for task FlatMap (FlatMap at ExtractOutput[0]) (9/16)
(8585829b967a0f3bb80ac2747429dd23) [DEPLOYING]
[FlatMap (FlatMap at ExtractOutput[0]) (9/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task FlatMap
(FlatMap at ExtractOutput[0]) (9/16) (8585829b967a0f3bb80ac2747429dd23)
[DEPLOYING].
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task FlatMap
(FlatMap at ExtractOutput[1]) (6/16).
[FlatMap (FlatMap at ExtractOutput[0]) (9/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Registering task at network:
FlatMap (FlatMap at ExtractOutput[0]) (9/16) (8585829b967a0f3bb80ac2747429dd23)
[DEPLOYING].
[FlatMap (FlatMap at ExtractOutput[0]) (9/16)] INFO
org.apache.flink.runtime.taskmanager.Task - FlatMap (FlatMap at
ExtractOutput[0]) (9/16) (8585829b967a0f3bb80ac2747429dd23) switched from
DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - FlatMap (FlatMap at
ExtractOutput[0]) (9/16) (8585829b967a0f3bb80ac2747429dd23) switched from
DEPLOYING to RUNNING.
[FlatMap (FlatMap at ExtractOutput[1]) (6/16)] INFO
org.apache.flink.runtime.taskmanager.Task - FlatMap (FlatMap at
ExtractOutput[1]) (6/16) (19ba532c8e356e82ed7d9fa26274db18) switched from
CREATED to DEPLOYING.
[FlatMap (FlatMap at ExtractOutput[1]) (6/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak
safety net for task FlatMap (FlatMap at ExtractOutput[1]) (6/16)
(19ba532c8e356e82ed7d9fa26274db18) [DEPLOYING]
[FlatMap (FlatMap at ExtractOutput[1]) (6/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task FlatMap
(FlatMap at ExtractOutput[1]) (6/16) (19ba532c8e356e82ed7d9fa26274db18)
[DEPLOYING].
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task FlatMap
(FlatMap at ExtractOutput[0]) (6/16).
[FlatMap (FlatMap at ExtractOutput[1]) (6/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Registering task at network:
FlatMap (FlatMap at ExtractOutput[1]) (6/16) (19ba532c8e356e82ed7d9fa26274db18)
[DEPLOYING].
[FlatMap (FlatMap at ExtractOutput[1]) (6/16)] INFO
org.apache.flink.runtime.taskmanager.Task - FlatMap (FlatMap at
ExtractOutput[1]) (6/16) (19ba532c8e356e82ed7d9fa26274db18) switched from
DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - FlatMap (FlatMap at
ExtractOutput[1]) (6/16) (19ba532c8e356e82ed7d9fa26274db18) switched from
DEPLOYING to RUNNING.
[FlatMap (FlatMap at ExtractOutput[0]) (14/16)] INFO
org.apache.flink.runtime.taskmanager.Task - FlatMap (FlatMap at
ExtractOutput[0]) (14/16) (8be7f90e1bc1d4f84cc533a0b5279cf1) switched from
RUNNING to FINISHED.
[FlatMap (FlatMap at ExtractOutput[0]) (14/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for FlatMap
(FlatMap at ExtractOutput[0]) (14/16) (8be7f90e1bc1d4f84cc533a0b5279cf1).
[FlatMap (FlatMap at ExtractOutput[1]) (9/16)] INFO
org.apache.flink.runtime.taskmanager.Task - FlatMap (FlatMap at
ExtractOutput[1]) (9/16) (eb079c2d2d8b28b86f0fb93b5aecc56b) switched from
RUNNING to FINISHED.
[FlatMap (FlatMap at ExtractOutput[1]) (9/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for FlatMap
(FlatMap at ExtractOutput[1]) (9/16) (eb079c2d2d8b28b86f0fb93b5aecc56b).
[FlatMap (FlatMap at ExtractOutput[0]) (9/16)] INFO
org.apache.flink.runtime.taskmanager.Task - FlatMap (FlatMap at
ExtractOutput[0]) (9/16) (8585829b967a0f3bb80ac2747429dd23) switched from
RUNNING to FINISHED.
[FlatMap (FlatMap at ExtractOutput[0]) (9/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for FlatMap
(FlatMap at ExtractOutput[0]) (9/16) (8585829b967a0f3bb80ac2747429dd23).
[FlatMap (FlatMap at ExtractOutput[1]) (6/16)] INFO
org.apache.flink.runtime.taskmanager.Task - FlatMap (FlatMap at
ExtractOutput[1]) (6/16) (19ba532c8e356e82ed7d9fa26274db18) switched from
RUNNING to FINISHED.
[FlatMap (FlatMap at ExtractOutput[1]) (6/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for FlatMap
(FlatMap at ExtractOutput[1]) (6/16) (19ba532c8e356e82ed7d9fa26274db18).
[FlatMap (FlatMap at ExtractOutput[0]) (6/16)] INFO
org.apache.flink.runtime.taskmanager.Task - FlatMap (FlatMap at
ExtractOutput[0]) (6/16) (1b07c2856e0c17cf2c4ee3446d62bc50) switched from
CREATED to DEPLOYING.
[FlatMap (FlatMap at ExtractOutput[0]) (6/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak
safety net for task FlatMap (FlatMap at ExtractOutput[0]) (6/16)
(1b07c2856e0c17cf2c4ee3446d62bc50) [DEPLOYING]
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task FlatMap
(FlatMap at ExtractOutput[1]) (1/16).
[FlatMap (FlatMap at ExtractOutput[0]) (6/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task FlatMap
(FlatMap at ExtractOutput[0]) (6/16) (1b07c2856e0c17cf2c4ee3446d62bc50)
[DEPLOYING].
[FlatMap (FlatMap at ExtractOutput[0]) (6/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Registering task at network:
FlatMap (FlatMap at ExtractOutput[0]) (6/16) (1b07c2856e0c17cf2c4ee3446d62bc50)
[DEPLOYING].
[FlatMap (FlatMap at ExtractOutput[0]) (6/16)] INFO
org.apache.flink.runtime.taskmanager.Task - FlatMap (FlatMap at
ExtractOutput[0]) (6/16) (1b07c2856e0c17cf2c4ee3446d62bc50) switched from
DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - FlatMap (FlatMap at
ExtractOutput[0]) (6/16) (1b07c2856e0c17cf2c4ee3446d62bc50) switched from
DEPLOYING to RUNNING.
[FlatMap (FlatMap at ExtractOutput[1]) (1/16)] INFO
org.apache.flink.runtime.taskmanager.Task - FlatMap (FlatMap at
ExtractOutput[1]) (1/16) (3b86feb6c3ae750c0d00eeaeacf6a8c8) switched from
CREATED to DEPLOYING.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task FlatMap
(FlatMap at ExtractOutput[0]) (1/16).
[FlatMap (FlatMap at ExtractOutput[1]) (1/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak
safety net for task FlatMap (FlatMap at ExtractOutput[1]) (1/16)
(3b86feb6c3ae750c0d00eeaeacf6a8c8) [DEPLOYING]
[FlatMap (FlatMap at ExtractOutput[1]) (1/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task FlatMap
(FlatMap at ExtractOutput[1]) (1/16) (3b86feb6c3ae750c0d00eeaeacf6a8c8)
[DEPLOYING].
[FlatMap (FlatMap at ExtractOutput[1]) (1/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Registering task at network:
FlatMap (FlatMap at ExtractOutput[1]) (1/16) (3b86feb6c3ae750c0d00eeaeacf6a8c8)
[DEPLOYING].
[FlatMap (FlatMap at ExtractOutput[1]) (1/16)] INFO
org.apache.flink.runtime.taskmanager.Task - FlatMap (FlatMap at
ExtractOutput[1]) (1/16) (3b86feb6c3ae750c0d00eeaeacf6a8c8) switched from
DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - FlatMap (FlatMap at
ExtractOutput[1]) (1/16) (3b86feb6c3ae750c0d00eeaeacf6a8c8) switched from
DEPLOYING to RUNNING.
[FlatMap (FlatMap at ExtractOutput[0]) (1/16)] INFO
org.apache.flink.runtime.taskmanager.Task - FlatMap (FlatMap at
ExtractOutput[0]) (1/16) (383292ba70fcc85d30cfec67d6a767ca) switched from
CREATED to DEPLOYING.
[FlatMap (FlatMap at ExtractOutput[0]) (1/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak
safety net for task FlatMap (FlatMap at ExtractOutput[0]) (1/16)
(383292ba70fcc85d30cfec67d6a767ca) [DEPLOYING]
[FlatMap (FlatMap at ExtractOutput[0]) (1/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task FlatMap
(FlatMap at ExtractOutput[0]) (1/16) (383292ba70fcc85d30cfec67d6a767ca)
[DEPLOYING].
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task FlatMap
(FlatMap at ExtractOutput[1]) (16/16).
[FlatMap (FlatMap at ExtractOutput[0]) (1/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Registering task at network:
FlatMap (FlatMap at ExtractOutput[0]) (1/16) (383292ba70fcc85d30cfec67d6a767ca)
[DEPLOYING].
[FlatMap (FlatMap at ExtractOutput[0]) (1/16)] INFO
org.apache.flink.runtime.taskmanager.Task - FlatMap (FlatMap at
ExtractOutput[0]) (1/16) (383292ba70fcc85d30cfec67d6a767ca) switched from
DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - FlatMap (FlatMap at
ExtractOutput[0]) (1/16) (383292ba70fcc85d30cfec67d6a767ca) switched from
DEPLOYING to RUNNING.
[FlatMap (FlatMap at ExtractOutput[0]) (6/16)] INFO
org.apache.flink.runtime.taskmanager.Task - FlatMap (FlatMap at
ExtractOutput[0]) (6/16) (1b07c2856e0c17cf2c4ee3446d62bc50) switched from
RUNNING to FINISHED.
[FlatMap (FlatMap at ExtractOutput[0]) (6/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for FlatMap
(FlatMap at ExtractOutput[0]) (6/16) (1b07c2856e0c17cf2c4ee3446d62bc50).
[FlatMap (FlatMap at ExtractOutput[1]) (1/16)] INFO
org.apache.flink.runtime.taskmanager.Task - FlatMap (FlatMap at
ExtractOutput[1]) (1/16) (3b86feb6c3ae750c0d00eeaeacf6a8c8) switched from
RUNNING to FINISHED.
[FlatMap (FlatMap at ExtractOutput[1]) (1/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for FlatMap
(FlatMap at ExtractOutput[1]) (1/16) (3b86feb6c3ae750c0d00eeaeacf6a8c8).
[FlatMap (FlatMap at ExtractOutput[1]) (16/16)] INFO
org.apache.flink.runtime.taskmanager.Task - FlatMap (FlatMap at
ExtractOutput[1]) (16/16) (da01a637d96ccc85b71519d10d41ade1) switched from
CREATED to DEPLOYING.
[FlatMap (FlatMap at ExtractOutput[1]) (16/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak
safety net for task FlatMap (FlatMap at ExtractOutput[1]) (16/16)
(da01a637d96ccc85b71519d10d41ade1) [DEPLOYING]
[FlatMap (FlatMap at ExtractOutput[1]) (16/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task FlatMap
(FlatMap at ExtractOutput[1]) (16/16) (da01a637d96ccc85b71519d10d41ade1)
[DEPLOYING].
[FlatMap (FlatMap at ExtractOutput[0]) (1/16)] INFO
org.apache.flink.runtime.taskmanager.Task - FlatMap (FlatMap at
ExtractOutput[0]) (1/16) (383292ba70fcc85d30cfec67d6a767ca) switched from
RUNNING to FINISHED.
[FlatMap (FlatMap at ExtractOutput[0]) (1/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for FlatMap
(FlatMap at ExtractOutput[0]) (1/16) (383292ba70fcc85d30cfec67d6a767ca).
[FlatMap (FlatMap at ExtractOutput[1]) (16/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Registering task at network:
FlatMap (FlatMap at ExtractOutput[1]) (16/16)
(da01a637d96ccc85b71519d10d41ade1) [DEPLOYING].
[FlatMap (FlatMap at ExtractOutput[1]) (16/16)] INFO
org.apache.flink.runtime.taskmanager.Task - FlatMap (FlatMap at
ExtractOutput[1]) (16/16) (da01a637d96ccc85b71519d10d41ade1) switched from
DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - FlatMap (FlatMap at
ExtractOutput[1]) (16/16) (da01a637d96ccc85b71519d10d41ade1) switched from
DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task FlatMap
(FlatMap at ExtractOutput[0]) (16/16).
[FlatMap (FlatMap at ExtractOutput[0]) (16/16)] INFO
org.apache.flink.runtime.taskmanager.Task - FlatMap (FlatMap at
ExtractOutput[0]) (16/16) (7f8d57cef6b254a9566205cc72895c95) switched from
CREATED to DEPLOYING.
[FlatMap (FlatMap at ExtractOutput[0]) (16/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak
safety net for task FlatMap (FlatMap at ExtractOutput[0]) (16/16)
(7f8d57cef6b254a9566205cc72895c95) [DEPLOYING]
[FlatMap (FlatMap at ExtractOutput[0]) (16/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task FlatMap
(FlatMap at ExtractOutput[0]) (16/16) (7f8d57cef6b254a9566205cc72895c95)
[DEPLOYING].
[FlatMap (FlatMap at ExtractOutput[0]) (16/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Registering task at network:
FlatMap (FlatMap at ExtractOutput[0]) (16/16)
(7f8d57cef6b254a9566205cc72895c95) [DEPLOYING].
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task FlatMap
(FlatMap at ExtractOutput[1]) (2/16).
[FlatMap (FlatMap at ExtractOutput[0]) (16/16)] INFO
org.apache.flink.runtime.taskmanager.Task - FlatMap (FlatMap at
ExtractOutput[0]) (16/16) (7f8d57cef6b254a9566205cc72895c95) switched from
DEPLOYING to RUNNING.
[FlatMap (FlatMap at ExtractOutput[1]) (2/16)] INFO
org.apache.flink.runtime.taskmanager.Task - FlatMap (FlatMap at
ExtractOutput[1]) (2/16) (e28e865b6a7224dcd6d013fa9d94c978) switched from
CREATED to DEPLOYING.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - FlatMap (FlatMap at
ExtractOutput[0]) (16/16) (7f8d57cef6b254a9566205cc72895c95) switched from
DEPLOYING to RUNNING.
[FlatMap (FlatMap at ExtractOutput[1]) (2/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak
safety net for task FlatMap (FlatMap at ExtractOutput[1]) (2/16)
(e28e865b6a7224dcd6d013fa9d94c978) [DEPLOYING]
[FlatMap (FlatMap at ExtractOutput[1]) (2/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task FlatMap
(FlatMap at ExtractOutput[1]) (2/16) (e28e865b6a7224dcd6d013fa9d94c978)
[DEPLOYING].
[FlatMap (FlatMap at ExtractOutput[1]) (16/16)] INFO
org.apache.flink.runtime.taskmanager.Task - FlatMap (FlatMap at
ExtractOutput[1]) (16/16) (da01a637d96ccc85b71519d10d41ade1) switched from
RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task FlatMap
(FlatMap at ExtractOutput[0]) (2/16).
[FlatMap (FlatMap at ExtractOutput[1]) (16/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for FlatMap
(FlatMap at ExtractOutput[1]) (16/16) (da01a637d96ccc85b71519d10d41ade1).
[FlatMap (FlatMap at ExtractOutput[1]) (2/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Registering task at network:
FlatMap (FlatMap at ExtractOutput[1]) (2/16) (e28e865b6a7224dcd6d013fa9d94c978)
[DEPLOYING].
[FlatMap (FlatMap at ExtractOutput[1]) (2/16)] INFO
org.apache.flink.runtime.taskmanager.Task - FlatMap (FlatMap at
ExtractOutput[1]) (2/16) (e28e865b6a7224dcd6d013fa9d94c978) switched from
DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - FlatMap (FlatMap at
ExtractOutput[1]) (2/16) (e28e865b6a7224dcd6d013fa9d94c978) switched from
DEPLOYING to RUNNING.
[FlatMap (FlatMap at ExtractOutput[0]) (16/16)] INFO
org.apache.flink.runtime.taskmanager.Task - FlatMap (FlatMap at
ExtractOutput[0]) (16/16) (7f8d57cef6b254a9566205cc72895c95) switched from
RUNNING to FINISHED.
[FlatMap (FlatMap at ExtractOutput[0]) (16/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for FlatMap
(FlatMap at ExtractOutput[0]) (16/16) (7f8d57cef6b254a9566205cc72895c95).
[FlatMap (FlatMap at ExtractOutput[1]) (2/16)] INFO
org.apache.flink.runtime.taskmanager.Task - FlatMap (FlatMap at
ExtractOutput[1]) (2/16) (e28e865b6a7224dcd6d013fa9d94c978) switched from
RUNNING to FINISHED.
[FlatMap (FlatMap at ExtractOutput[1]) (2/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for FlatMap
(FlatMap at ExtractOutput[1]) (2/16) (e28e865b6a7224dcd6d013fa9d94c978).
[FlatMap (FlatMap at ExtractOutput[0]) (2/16)] INFO
org.apache.flink.runtime.taskmanager.Task - FlatMap (FlatMap at
ExtractOutput[0]) (2/16) (56cd0e03e6a69b783f1f82a4d188f37d) switched from
CREATED to DEPLOYING.
[FlatMap (FlatMap at ExtractOutput[0]) (2/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak
safety net for task FlatMap (FlatMap at ExtractOutput[0]) (2/16)
(56cd0e03e6a69b783f1f82a4d188f37d) [DEPLOYING]
[FlatMap (FlatMap at ExtractOutput[0]) (2/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task FlatMap
(FlatMap at ExtractOutput[0]) (2/16) (56cd0e03e6a69b783f1f82a4d188f37d)
[DEPLOYING].
[FlatMap (FlatMap at ExtractOutput[0]) (2/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Registering task at network:
FlatMap (FlatMap at ExtractOutput[0]) (2/16) (56cd0e03e6a69b783f1f82a4d188f37d)
[DEPLOYING].
[FlatMap (FlatMap at ExtractOutput[0]) (2/16)] INFO
org.apache.flink.runtime.taskmanager.Task - FlatMap (FlatMap at
ExtractOutput[0]) (2/16) (56cd0e03e6a69b783f1f82a4d188f37d) switched from
DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - FlatMap (FlatMap at
ExtractOutput[0]) (2/16) (56cd0e03e6a69b783f1f82a4d188f37d) switched from
DEPLOYING to RUNNING.
[FlatMap (FlatMap at ExtractOutput[0]) (2/16)] INFO
org.apache.flink.runtime.taskmanager.Task - FlatMap (FlatMap at
ExtractOutput[0]) (2/16) (56cd0e03e6a69b783f1f82a4d188f37d) switched from
RUNNING to FINISHED.
[FlatMap (FlatMap at ExtractOutput[0]) (2/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for FlatMap
(FlatMap at ExtractOutput[0]) (2/16) (56cd0e03e6a69b783f1f82a4d188f37d).
OpenJDK 64-Bit Server VM warning: INFO: os::commit_memory(0x0000000686d00000,
172490752, 0) failed; error='Cannot allocate memory' (errno=12)
#
# There is insufficient memory for the Java Runtime Environment to continue.
# Native memory allocation (mmap) failed to map 172490752 bytes for committing
reserved memory.
# An error report file with more information is saved as:
#
/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Python36/src/sdks/python/hs_err_pid11922.log
FATAL: command execution failed
java.io.IOException: Backing channel 'JNLP4-connect connection from
192.194.239.35.bc.googleusercontent.com/35.239.194.192:44120' is disconnected.
at
hudson.remoting.RemoteInvocationHandler.channelOrFail(RemoteInvocationHandler.java:214)
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-7 is offline; cannot locate JDK 1.8 (latest)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
