See
<https://builds.apache.org/job/beam_PostCommit_Python2/1672/display/redirect?page=changes>
Changes:
[robertwb] [BEAM-9266] Remove unused fields from provisioning API.
[robertwb] Remove one more reference to provision resources.
[robertwb] Reject unsupported WindowFns and Window types.
[alex] [BEAM-9241] Fix inconsistent proto nullability
[github] [BEAM-9268] SpannerIO: Add more documentation and warnings for unknown
------------------------------------------
[...truncated 1.69 MB...]
[CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine
(GroupCombine at GroupCombine: assert_that/Group/GroupByKey) -> Map (Key
Extractor) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN
Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: assert_that/Group/GroupByKey) -> Map (Key Extractor) (15/16)
(af8f53f9d26a0cbf9b905110ba7396f7) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN Filter
(UnionFixFilter) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: assert_that/Group/GroupByKey) -> Map (Key Extractor) (15/16)
(af8f53f9d26a0cbf9b905110ba7396f7) switched from DEPLOYING to RUNNING.
[CHAIN MapPartition (MapPartition at
[2]read/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:2646>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (4/16)] INFO
org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at
[2]read/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:2646>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (4/16)
(2b0ec810798db0475263c1762f757076) switched from RUNNING to FINISHED.
[CHAIN MapPartition (MapPartition at
[2]read/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:2646>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (4/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for CHAIN
MapPartition (MapPartition at
[2]read/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:2646>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (4/16)
(2b0ec810798db0475263c1762f757076).
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [1]read/_PassThroughThenCleanup/ParDo(RemoveJsonFiles)) (4/16)
(e197cf5de25b38366fa4c30b4b521c68) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [1]read/_PassThroughThenCleanup/ParDo(RemoveJsonFiles)) (4/16)
(e197cf5de25b38366fa4c30b4b521c68) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying MapPartition
(MapPartition at [1]read/_PassThroughThenCleanup/ParDo(RemoveJsonFiles)) (4/16)
(attempt #0) to 273bf175-ee2a-4d1b-9304-f050801ccffe @ localhost (dataPort=-1)
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task MapPartition
(MapPartition at [1]read/_PassThroughThenCleanup/ParDo(RemoveJsonFiles)) (4/16).
[MapPartition (MapPartition at
[1]read/_PassThroughThenCleanup/ParDo(RemoveJsonFiles)) (4/16)] INFO
org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at
[1]read/_PassThroughThenCleanup/ParDo(RemoveJsonFiles)) (4/16)
(e197cf5de25b38366fa4c30b4b521c68) switched from CREATED to DEPLOYING.
[MapPartition (MapPartition at
[1]read/_PassThroughThenCleanup/ParDo(RemoveJsonFiles)) (4/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak
safety net for task MapPartition (MapPartition at
[1]read/_PassThroughThenCleanup/ParDo(RemoveJsonFiles)) (4/16)
(e197cf5de25b38366fa4c30b4b521c68) [DEPLOYING]
[MapPartition (MapPartition at
[1]read/_PassThroughThenCleanup/ParDo(RemoveJsonFiles)) (4/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task
MapPartition (MapPartition at
[1]read/_PassThroughThenCleanup/ParDo(RemoveJsonFiles)) (4/16)
(e197cf5de25b38366fa4c30b4b521c68) [DEPLOYING].
[MapPartition (MapPartition at
[1]read/_PassThroughThenCleanup/ParDo(RemoveJsonFiles)) (4/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Registering task at network:
MapPartition (MapPartition at
[1]read/_PassThroughThenCleanup/ParDo(RemoveJsonFiles)) (4/16)
(e197cf5de25b38366fa4c30b4b521c68) [DEPLOYING].
[MapPartition (MapPartition at
[1]read/_PassThroughThenCleanup/ParDo(RemoveJsonFiles)) (4/16)] INFO
org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at
[1]read/_PassThroughThenCleanup/ParDo(RemoveJsonFiles)) (4/16)
(e197cf5de25b38366fa4c30b4b521c68) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [1]read/_PassThroughThenCleanup/ParDo(RemoveJsonFiles)) (4/16)
(e197cf5de25b38366fa4c30b4b521c68) switched from DEPLOYING to RUNNING.
[MapPartition (MapPartition at
[1]read/_PassThroughThenCleanup/ParDo(RemoveJsonFiles)) (4/16)] WARN
org.apache.flink.metrics.MetricGroup - The operator name MapPartition
(MapPartition at [1]read/_PassThroughThenCleanup/ParDo(RemoveJsonFiles))
exceeded the 80 characters length limit and was truncated.
[CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) -> FlatMap
(FlatMap at ExtractOutput[0]) (14/16)] INFO
org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at
[4]assert_that/{Create, Group}) -> FlatMap (FlatMap at ExtractOutput[0])
(14/16) (25c5720a269d141080a84c7a09899690) switched from RUNNING to FINISHED.
[CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) -> FlatMap
(FlatMap at ExtractOutput[0]) (14/16)] 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]) (14/16) (25c5720a269d141080a84c7a09899690).
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN Filter
(UnionFixFilter) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: assert_that/Group/GroupByKey) -> Map (Key Extractor) (14/16)
(7dfb284d4847ff65e1922e132312efe4) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN Filter
(UnionFixFilter) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: assert_that/Group/GroupByKey) -> Map (Key Extractor) (14/16)
(7dfb284d4847ff65e1922e132312efe4) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying CHAIN Filter
(UnionFixFilter) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: assert_that/Group/GroupByKey) -> Map (Key Extractor) (14/16)
(attempt #0) to 273bf175-ee2a-4d1b-9304-f050801ccffe @ localhost (dataPort=-1)
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task CHAIN Filter
(UnionFixFilter) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: assert_that/Group/GroupByKey) -> Map (Key Extractor) (14/16).
[CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine
(GroupCombine at GroupCombine: assert_that/Group/GroupByKey) -> Map (Key
Extractor) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN
Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: assert_that/Group/GroupByKey) -> Map (Key Extractor) (14/16)
(7dfb284d4847ff65e1922e132312efe4) switched from CREATED to DEPLOYING.
[CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine
(GroupCombine at GroupCombine: assert_that/Group/GroupByKey) -> Map (Key
Extractor) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating
FileSystem stream leak safety net for task CHAIN Filter (UnionFixFilter) -> Map
(Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
assert_that/Group/GroupByKey) -> Map (Key Extractor) (14/16)
(7dfb284d4847ff65e1922e132312efe4) [DEPLOYING]
[CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine
(GroupCombine at GroupCombine: assert_that/Group/GroupByKey) -> Map (Key
Extractor) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading
JAR files for task CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) ->
GroupCombine (GroupCombine at GroupCombine: assert_that/Group/GroupByKey) ->
Map (Key Extractor) (14/16) (7dfb284d4847ff65e1922e132312efe4) [DEPLOYING].
[CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine
(GroupCombine at GroupCombine: assert_that/Group/GroupByKey) -> Map (Key
Extractor) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Registering task at network: CHAIN Filter (UnionFixFilter) -> Map (Key
Extractor) -> GroupCombine (GroupCombine at GroupCombine:
assert_that/Group/GroupByKey) -> Map (Key Extractor) (14/16)
(7dfb284d4847ff65e1922e132312efe4) [DEPLOYING].
[CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine
(GroupCombine at GroupCombine: assert_that/Group/GroupByKey) -> Map (Key
Extractor) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN
Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: assert_that/Group/GroupByKey) -> Map (Key Extractor) (14/16)
(7dfb284d4847ff65e1922e132312efe4) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN Filter
(UnionFixFilter) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: assert_that/Group/GroupByKey) -> Map (Key Extractor) (14/16)
(7dfb284d4847ff65e1922e132312efe4) switched from DEPLOYING to RUNNING.
[CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) -> FlatMap
(FlatMap at ExtractOutput[0]) (14/16)] 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]) (14/16)
(25c5720a269d141080a84c7a09899690) [FINISHED]
[CHAIN MapPartition (MapPartition at
[2]read/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:2646>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (4/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task CHAIN MapPartition (MapPartition at
[2]read/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:2646>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (4/16)
(2b0ec810798db0475263c1762f757076) [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 CHAIN
MapPartition (MapPartition at
[2]read/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:2646>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0])
2b0ec810798db0475263c1762f757076.
[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 CHAIN
MapPartition (MapPartition at [4]assert_that/{Create, Group}) -> FlatMap
(FlatMap at ExtractOutput[0]) 25c5720a269d141080a84c7a09899690.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition
(MapPartition at [2]read/_PassThroughThenCleanup/Create/{FlatMap(<lambda at
core.py:2646>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (4/16)
(2b0ec810798db0475263c1762f757076) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition
(MapPartition at [4]assert_that/{Create, Group}) -> FlatMap (FlatMap at
ExtractOutput[0]) (14/16) (25c5720a269d141080a84c7a09899690) switched from
RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [1]read/_PassThroughThenCleanup/ParDo(RemoveJsonFiles))
(16/16) (f823d3509330945db8263394a0863190) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [1]read/_PassThroughThenCleanup/ParDo(RemoveJsonFiles))
(16/16) (f823d3509330945db8263394a0863190) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying MapPartition
(MapPartition at [1]read/_PassThroughThenCleanup/ParDo(RemoveJsonFiles))
(16/16) (attempt #0) to 273bf175-ee2a-4d1b-9304-f050801ccffe @ localhost
(dataPort=-1)
[CHAIN MapPartition (MapPartition at
[2]read/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:2646>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (16/16)] INFO
org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at
[2]read/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:2646>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (16/16)
(cb6815ad78a2dc31aee5039edc6f56b1) switched from RUNNING to FINISHED.
[CHAIN MapPartition (MapPartition at
[2]read/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:2646>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (16/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for CHAIN
MapPartition (MapPartition at
[2]read/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:2646>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (16/16)
(cb6815ad78a2dc31aee5039edc6f56b1).
[CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) -> FlatMap
(FlatMap at ExtractOutput[0]) (6/16)] INFO
org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at
[4]assert_that/{Create, Group}) -> FlatMap (FlatMap at ExtractOutput[0]) (6/16)
(87213c626a106e6bead586fde81959d8) switched from RUNNING to FINISHED.
[CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) -> FlatMap
(FlatMap at ExtractOutput[0]) (6/16)] 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]) (6/16) (87213c626a106e6bead586fde81959d8).
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN Filter
(UnionFixFilter) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: assert_that/Group/GroupByKey) -> Map (Key Extractor) (6/16)
(4b603e50d03d19fc49042a2372dce3c8) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN Filter
(UnionFixFilter) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: assert_that/Group/GroupByKey) -> Map (Key Extractor) (6/16)
(4b603e50d03d19fc49042a2372dce3c8) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying CHAIN Filter
(UnionFixFilter) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: assert_that/Group/GroupByKey) -> Map (Key Extractor) (6/16)
(attempt #0) to 273bf175-ee2a-4d1b-9304-f050801ccffe @ localhost (dataPort=-1)
[CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) -> FlatMap
(FlatMap at ExtractOutput[0]) (6/16)] 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]) (6/16)
(87213c626a106e6bead586fde81959d8) [FINISHED]
[CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) -> FlatMap
(FlatMap at ExtractOutput[0]) (15/16)] 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]) (15/16)
(3f6c94044e8da169031c7c42116cb86f) [FINISHED]
[CHAIN MapPartition (MapPartition at
[2]read/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:2646>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (16/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task CHAIN MapPartition (MapPartition at
[2]read/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:2646>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (16/16)
(cb6815ad78a2dc31aee5039edc6f56b1) [FINISHED]
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task MapPartition
(MapPartition at [1]read/_PassThroughThenCleanup/ParDo(RemoveJsonFiles))
(16/16).
[MapPartition (MapPartition at
[1]read/_PassThroughThenCleanup/ParDo(RemoveJsonFiles)) (16/16)] INFO
org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at
[1]read/_PassThroughThenCleanup/ParDo(RemoveJsonFiles)) (16/16)
(f823d3509330945db8263394a0863190) switched from CREATED to DEPLOYING.
[MapPartition (MapPartition at
[1]read/_PassThroughThenCleanup/ParDo(RemoveJsonFiles)) (16/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak
safety net for task MapPartition (MapPartition at
[1]read/_PassThroughThenCleanup/ParDo(RemoveJsonFiles)) (16/16)
(f823d3509330945db8263394a0863190) [DEPLOYING]
[MapPartition (MapPartition at
[1]read/_PassThroughThenCleanup/ParDo(RemoveJsonFiles)) (16/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task
MapPartition (MapPartition at
[1]read/_PassThroughThenCleanup/ParDo(RemoveJsonFiles)) (16/16)
(f823d3509330945db8263394a0863190) [DEPLOYING].
[MapPartition (MapPartition at
[1]read/_PassThroughThenCleanup/ParDo(RemoveJsonFiles)) (16/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Registering task at network:
MapPartition (MapPartition at
[1]read/_PassThroughThenCleanup/ParDo(RemoveJsonFiles)) (16/16)
(f823d3509330945db8263394a0863190) [DEPLOYING].
[MapPartition (MapPartition at
[1]read/_PassThroughThenCleanup/ParDo(RemoveJsonFiles)) (16/16)] INFO
org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at
[1]read/_PassThroughThenCleanup/ParDo(RemoveJsonFiles)) (16/16)
(f823d3509330945db8263394a0863190) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [1]read/_PassThroughThenCleanup/ParDo(RemoveJsonFiles))
(16/16) (f823d3509330945db8263394a0863190) switched from DEPLOYING to RUNNING.
[MapPartition (MapPartition at
[1]read/_PassThroughThenCleanup/ParDo(RemoveJsonFiles)) (16/16)] WARN
org.apache.flink.metrics.MetricGroup - The operator name MapPartition
(MapPartition at [1]read/_PassThroughThenCleanup/ParDo(RemoveJsonFiles))
exceeded the 80 characters length limit and was truncated.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task CHAIN Filter
(UnionFixFilter) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: assert_that/Group/GroupByKey) -> Map (Key Extractor) (6/16).
[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 CHAIN
MapPartition (MapPartition at [4]assert_that/{Create, Group}) -> FlatMap
(FlatMap at ExtractOutput[0]) 87213c626a106e6bead586fde81959d8.
[CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine
(GroupCombine at GroupCombine: assert_that/Group/GroupByKey) -> Map (Key
Extractor) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN
Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: assert_that/Group/GroupByKey) -> Map (Key Extractor) (6/16)
(4b603e50d03d19fc49042a2372dce3c8) switched from CREATED to DEPLOYING.
[CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine
(GroupCombine at GroupCombine: assert_that/Group/GroupByKey) -> Map (Key
Extractor) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating
FileSystem stream leak safety net for task CHAIN Filter (UnionFixFilter) -> Map
(Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
assert_that/Group/GroupByKey) -> Map (Key Extractor) (6/16)
(4b603e50d03d19fc49042a2372dce3c8) [DEPLOYING]
[CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine
(GroupCombine at GroupCombine: assert_that/Group/GroupByKey) -> Map (Key
Extractor) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR
files for task CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) ->
GroupCombine (GroupCombine at GroupCombine: assert_that/Group/GroupByKey) ->
Map (Key Extractor) (6/16) (4b603e50d03d19fc49042a2372dce3c8) [DEPLOYING].
[CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine
(GroupCombine at GroupCombine: assert_that/Group/GroupByKey) -> Map (Key
Extractor) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering
task at network: CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) ->
GroupCombine (GroupCombine at GroupCombine: assert_that/Group/GroupByKey) ->
Map (Key Extractor) (6/16) (4b603e50d03d19fc49042a2372dce3c8) [DEPLOYING].
[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 CHAIN
MapPartition (MapPartition at [4]assert_that/{Create, Group}) -> FlatMap
(FlatMap at ExtractOutput[0]) 3f6c94044e8da169031c7c42116cb86f.
[CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine
(GroupCombine at GroupCombine: assert_that/Group/GroupByKey) -> Map (Key
Extractor) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN
Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: assert_that/Group/GroupByKey) -> Map (Key Extractor) (6/16)
(4b603e50d03d19fc49042a2372dce3c8) switched from DEPLOYING to RUNNING.
[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 CHAIN
MapPartition (MapPartition at
[2]read/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:2646>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0])
cb6815ad78a2dc31aee5039edc6f56b1.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition
(MapPartition at [4]assert_that/{Create, Group}) -> FlatMap (FlatMap at
ExtractOutput[0]) (6/16) (87213c626a106e6bead586fde81959d8) switched from
RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN Filter
(UnionFixFilter) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: assert_that/Group/GroupByKey) -> Map (Key Extractor) (6/16)
(4b603e50d03d19fc49042a2372dce3c8) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition
(MapPartition at [4]assert_that/{Create, Group}) -> FlatMap (FlatMap at
ExtractOutput[0]) (15/16) (3f6c94044e8da169031c7c42116cb86f) switched from
RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition
(MapPartition at [2]read/_PassThroughThenCleanup/Create/{FlatMap(<lambda at
core.py:2646>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (16/16)
(cb6815ad78a2dc31aee5039edc6f56b1) switched from RUNNING to FINISHED.
[CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) -> FlatMap
(FlatMap at ExtractOutput[0]) (16/16)] INFO
org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at
[4]assert_that/{Create, Group}) -> FlatMap (FlatMap at ExtractOutput[0])
(16/16) (249744e774ed833f9e733b5a32f0bf0f) switched from RUNNING to FINISHED.
[CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) -> FlatMap
(FlatMap at ExtractOutput[0]) (16/16)] 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]) (16/16) (249744e774ed833f9e733b5a32f0bf0f).
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN Filter
(UnionFixFilter) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: assert_that/Group/GroupByKey) -> Map (Key Extractor) (16/16)
(279aa25f2f3e3e250e1ec3af2cf7e4dc) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN Filter
(UnionFixFilter) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: assert_that/Group/GroupByKey) -> Map (Key Extractor) (16/16)
(279aa25f2f3e3e250e1ec3af2cf7e4dc) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying CHAIN Filter
(UnionFixFilter) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: assert_that/Group/GroupByKey) -> Map (Key Extractor) (16/16)
(attempt #0) to 273bf175-ee2a-4d1b-9304-f050801ccffe @ localhost (dataPort=-1)
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task CHAIN Filter
(UnionFixFilter) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: assert_that/Group/GroupByKey) -> Map (Key Extractor) (16/16).
[CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine
(GroupCombine at GroupCombine: assert_that/Group/GroupByKey) -> Map (Key
Extractor) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN
Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: assert_that/Group/GroupByKey) -> Map (Key Extractor) (16/16)
(279aa25f2f3e3e250e1ec3af2cf7e4dc) switched from CREATED to DEPLOYING.
[CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine
(GroupCombine at GroupCombine: assert_that/Group/GroupByKey) -> Map (Key
Extractor) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating
FileSystem stream leak safety net for task CHAIN Filter (UnionFixFilter) -> Map
(Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
assert_that/Group/GroupByKey) -> Map (Key Extractor) (16/16)
(279aa25f2f3e3e250e1ec3af2cf7e4dc) [DEPLOYING]
[CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine
(GroupCombine at GroupCombine: assert_that/Group/GroupByKey) -> Map (Key
Extractor) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading
JAR files for task CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) ->
GroupCombine (GroupCombine at GroupCombine: assert_that/Group/GroupByKey) ->
Map (Key Extractor) (16/16) (279aa25f2f3e3e250e1ec3af2cf7e4dc) [DEPLOYING].
[CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine
(GroupCombine at GroupCombine: assert_that/Group/GroupByKey) -> Map (Key
Extractor) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Registering task at network: CHAIN Filter (UnionFixFilter) -> Map (Key
Extractor) -> GroupCombine (GroupCombine at GroupCombine:
assert_that/Group/GroupByKey) -> Map (Key Extractor) (16/16)
(279aa25f2f3e3e250e1ec3af2cf7e4dc) [DEPLOYING].
[CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine
(GroupCombine at GroupCombine: assert_that/Group/GroupByKey) -> Map (Key
Extractor) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN
Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: assert_that/Group/GroupByKey) -> Map (Key Extractor) (16/16)
(279aa25f2f3e3e250e1ec3af2cf7e4dc) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN Filter
(UnionFixFilter) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: assert_that/Group/GroupByKey) -> Map (Key Extractor) (16/16)
(279aa25f2f3e3e250e1ec3af2cf7e4dc) switched from DEPLOYING to RUNNING.
[CHAIN MapPartition (MapPartition at
[2]read/Read/_SDFBoundedSourceWrapper/ParDo(SDFBoundedSourceDoFn)/{PairWithRestriction0,
SplitAndSize0}) -> FlatMap (FlatMap at ExtractOutput[0]) (10/16)] INFO
org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at
[2]read/Read/_SDFBoundedSourceWrapper/ParDo(SDFBoundedSourceDoFn)/{PairWithRestriction0,
SplitAndSize0}) -> FlatMap (FlatMap at ExtractOutput[0]) (10/16)
(a22af975fe0e2095a848d249652d5b88) switched from RUNNING to FINISHED.
[CHAIN MapPartition (MapPartition at
[2]read/Read/_SDFBoundedSourceWrapper/ParDo(SDFBoundedSourceDoFn)/{PairWithRestriction0,
SplitAndSize0}) -> FlatMap (FlatMap at ExtractOutput[0]) (10/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for CHAIN
MapPartition (MapPartition at
[2]read/Read/_SDFBoundedSourceWrapper/ParDo(SDFBoundedSourceDoFn)/{PairWithRestriction0,
SplitAndSize0}) -> FlatMap (FlatMap at ExtractOutput[0]) (10/16)
(a22af975fe0e2095a848d249652d5b88).
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [6]{read, assert_that}) (10/16)
(5b737ff318c036eafb9de385a8fc2057) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [6]{read, assert_that}) (10/16)
(5b737ff318c036eafb9de385a8fc2057) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying MapPartition
(MapPartition at [6]{read, assert_that}) (10/16) (attempt #0) to
273bf175-ee2a-4d1b-9304-f050801ccffe @ localhost (dataPort=-1)
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task MapPartition
(MapPartition at [6]{read, assert_that}) (10/16).
[MapPartition (MapPartition at [6]{read, assert_that}) (10/16)] INFO
org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at
[6]{read, assert_that}) (10/16) (5b737ff318c036eafb9de385a8fc2057) switched
from CREATED to DEPLOYING.
[MapPartition (MapPartition at [6]{read, assert_that}) (10/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak
safety net for task MapPartition (MapPartition at [6]{read, assert_that})
(10/16) (5b737ff318c036eafb9de385a8fc2057) [DEPLOYING]
[MapPartition (MapPartition at [6]{read, assert_that}) (10/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task
MapPartition (MapPartition at [6]{read, assert_that}) (10/16)
(5b737ff318c036eafb9de385a8fc2057) [DEPLOYING].
[MapPartition (MapPartition at [6]{read, assert_that}) (10/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Registering task at network:
MapPartition (MapPartition at [6]{read, assert_that}) (10/16)
(5b737ff318c036eafb9de385a8fc2057) [DEPLOYING].
[MapPartition (MapPartition at [6]{read, assert_that}) (10/16)] INFO
org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at
[6]{read, assert_that}) (10/16) (5b737ff318c036eafb9de385a8fc2057) switched
from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [6]{read, assert_that}) (10/16)
(5b737ff318c036eafb9de385a8fc2057) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN Filter
(UnionFixFilter) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: assert_that/Group/GroupByKey) -> Map (Key Extractor) (13/16)
(8d23587aac96cbfbd328218cf5bd6670) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN Filter
(UnionFixFilter) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: assert_that/Group/GroupByKey) -> Map (Key Extractor) (13/16)
(8d23587aac96cbfbd328218cf5bd6670) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying CHAIN Filter
(UnionFixFilter) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: assert_that/Group/GroupByKey) -> Map (Key Extractor) (13/16)
(attempt #0) to 273bf175-ee2a-4d1b-9304-f050801ccffe @ localhost (dataPort=-1)
[CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) -> FlatMap
(FlatMap at ExtractOutput[0]) (13/16)] INFO
org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at
[4]assert_that/{Create, Group}) -> FlatMap (FlatMap at ExtractOutput[0])
(13/16) (a5b482198c8cb316af7eecdad392c241) switched from RUNNING to FINISHED.
[CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) -> FlatMap
(FlatMap at ExtractOutput[0]) (13/16)] 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]) (13/16) (a5b482198c8cb316af7eecdad392c241).
[CHAIN MapPartition (MapPartition at
[2]read/Read/_SDFBoundedSourceWrapper/ParDo(SDFBoundedSourceDoFn)/{PairWithRestriction0,
SplitAndSize0}) -> FlatMap (FlatMap at ExtractOutput[0]) (11/16)] INFO
org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at
[2]read/Read/_SDFBoundedSourceWrapper/ParDo(SDFBoundedSourceDoFn)/{PairWithRestriction0,
SplitAndSize0}) -> FlatMap (FlatMap at ExtractOutput[0]) (11/16)
(7a765b0c15570627d98bb189c8d967eb) switched from RUNNING to FINISHED.
[CHAIN MapPartition (MapPartition at
[2]read/Read/_SDFBoundedSourceWrapper/ParDo(SDFBoundedSourceDoFn)/{PairWithRestriction0,
SplitAndSize0}) -> FlatMap (FlatMap at ExtractOutput[0]) (11/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for CHAIN
MapPartition (MapPartition at
[2]read/Read/_SDFBoundedSourceWrapper/ParDo(SDFBoundedSourceDoFn)/{PairWithRestriction0,
SplitAndSize0}) -> FlatMap (FlatMap at ExtractOutput[0]) (11/16)
(7a765b0c15570627d98bb189c8d967eb).
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [6]{read, assert_that}) (11/16)
(0886c7922c6bd2fd91313082ae429446) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [6]{read, assert_that}) (11/16)
(0886c7922c6bd2fd91313082ae429446) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying MapPartition
(MapPartition at [6]{read, assert_that}) (11/16) (attempt #0) to
273bf175-ee2a-4d1b-9304-f050801ccffe @ localhost (dataPort=-1)
[CHAIN MapPartition (MapPartition at
[2]read/Read/_SDFBoundedSourceWrapper/ParDo(SDFBoundedSourceDoFn)/{PairWithRestriction0,
SplitAndSize0}) -> FlatMap (FlatMap at ExtractOutput[0]) (8/16)] INFO
org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at
[2]read/Read/_SDFBoundedSourceWrapper/ParDo(SDFBoundedSourceDoFn)/{PairWithRestriction0,
SplitAndSize0}) -> FlatMap (FlatMap at ExtractOutput[0]) (8/16)
(622e2d3eb928a34c5cd6a1253ccae6dc) switched from RUNNING to FINISHED.
[CHAIN MapPartition (MapPartition at
[2]read/Read/_SDFBoundedSourceWrapper/ParDo(SDFBoundedSourceDoFn)/{PairWithRestriction0,
SplitAndSize0}) -> FlatMap (FlatMap at ExtractOutput[0]) (8/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for CHAIN
MapPartition (MapPartition at
[2]read/Read/_SDFBoundedSourceWrapper/ParDo(SDFBoundedSourceDoFn)/{PairWithRestriction0,
SplitAndSize0}) -> FlatMap (FlatMap at ExtractOutput[0]) (8/16)
(622e2d3eb928a34c5cd6a1253ccae6dc).
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [6]{read, assert_that}) (8/16)
(9f9873cb3b0eadb5addb9003e4cce321) switched from CREATED to SCHEDULED.
[CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) -> FlatMap
(FlatMap at ExtractOutput[0]) (11/16)] INFO
org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at
[4]assert_that/{Create, Group}) -> FlatMap (FlatMap at ExtractOutput[0])
(11/16) (da79c84756df1f603cbaed83743c9b3c) switched from RUNNING to FINISHED.
[CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) -> FlatMap
(FlatMap at ExtractOutput[0]) (11/16)] 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]) (11/16) (da79c84756df1f603cbaed83743c9b3c).
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [6]{read, assert_that}) (8/16)
(9f9873cb3b0eadb5addb9003e4cce321) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying MapPartition
(MapPartition at [6]{read, assert_that}) (8/16) (attempt #0) to
273bf175-ee2a-4d1b-9304-f050801ccffe @ localhost (dataPort=-1)
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN Filter
(UnionFixFilter) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: assert_that/Group/GroupByKey) -> Map (Key Extractor) (11/16)
(d537f4533a4c5414c166f35792c3bd52) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN Filter
(UnionFixFilter) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: assert_that/Group/GroupByKey) -> Map (Key Extractor) (11/16)
(d537f4533a4c5414c166f35792c3bd52) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying CHAIN Filter
(UnionFixFilter) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: assert_that/Group/GroupByKey) -> Map (Key Extractor) (11/16)
(attempt #0) to 273bf175-ee2a-4d1b-9304-f050801ccffe @ localhost (dataPort=-1)
[CHAIN MapPartition (MapPartition at
[2]read/Read/_SDFBoundedSourceWrapper/ParDo(SDFBoundedSourceDoFn)/{PairWithRestriction0,
SplitAndSize0}) -> FlatMap (FlatMap at ExtractOutput[0]) (12/16)] INFO
org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at
[2]read/Read/_SDFBoundedSourceWrapper/ParDo(SDFBoundedSourceDoFn)/{PairWithRestriction0,
SplitAndSize0}) -> FlatMap (FlatMap at ExtractOutput[0]) (12/16)
(7350e6800d8acbbe339145cb9715dea3) switched from RUNNING to FINISHED.
[CHAIN MapPartition (MapPartition at
[2]read/Read/_SDFBoundedSourceWrapper/ParDo(SDFBoundedSourceDoFn)/{PairWithRestriction0,
SplitAndSize0}) -> FlatMap (FlatMap at ExtractOutput[0]) (12/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for CHAIN
MapPartition (MapPartition at
[2]read/Read/_SDFBoundedSourceWrapper/ParDo(SDFBoundedSourceDoFn)/{PairWithRestriction0,
SplitAndSize0}) -> FlatMap (FlatMap at ExtractOutput[0]) (12/16)
(7350e6800d8acbbe339145cb9715dea3).
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [6]{read, assert_that}) (12/16)
(be3b4b9b79d1e61e574ca11bce544a27) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [6]{read, assert_that}) (12/16)
(be3b4b9b79d1e61e574ca11bce544a27) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying MapPartition
(MapPartition at [6]{read, assert_that}) (12/16) (attempt #0) to
273bf175-ee2a-4d1b-9304-f050801ccffe @ localhost (dataPort=-1)
[CHAIN MapPartition (MapPartition at
[2]read/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:2646>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (13/16)] INFO
org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at
[2]read/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:2646>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (13/16)
(cc1b490bf3b31997f036703be52587ff) switched from RUNNING to FINISHED.
[CHAIN MapPartition (MapPartition at
[2]read/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:2646>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (13/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for CHAIN
MapPartition (MapPartition at
[2]read/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:2646>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (13/16)
(cc1b490bf3b31997f036703be52587ff).
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [1]read/_PassThroughThenCleanup/ParDo(RemoveJsonFiles))
(13/16) (da3c56a7ad2bf587e2501039a862ad7a) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [1]read/_PassThroughThenCleanup/ParDo(RemoveJsonFiles))
(13/16) (da3c56a7ad2bf587e2501039a862ad7a) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying MapPartition
(MapPartition at [1]read/_PassThroughThenCleanup/ParDo(RemoveJsonFiles))
(13/16) (attempt #0) to 273bf175-ee2a-4d1b-9304-f050801ccffe @ localhost
(dataPort=-1)
[CHAIN MapPartition (MapPartition at
[2]read/Read/_SDFBoundedSourceWrapper/ParDo(SDFBoundedSourceDoFn)/{PairWithRestriction0,
SplitAndSize0}) -> FlatMap (FlatMap at ExtractOutput[0]) (5/16)] INFO
org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at
[2]read/Read/_SDFBoundedSourceWrapper/ParDo(SDFBoundedSourceDoFn)/{PairWithRestriction0,
SplitAndSize0}) -> FlatMap (FlatMap at ExtractOutput[0]) (5/16)
(191de26221d646b62a9ddfdae1a316d4) switched from RUNNING to FINISHED.
[CHAIN MapPartition (MapPartition at
[2]read/Read/_SDFBoundedSourceWrapper/ParDo(SDFBoundedSourceDoFn)/{PairWithRestriction0,
SplitAndSize0}) -> FlatMap (FlatMap at ExtractOutput[0]) (5/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for CHAIN
MapPartition (MapPartition at
[2]read/Read/_SDFBoundedSourceWrapper/ParDo(SDFBoundedSourceDoFn)/{PairWithRestriction0,
SplitAndSize0}) -> FlatMap (FlatMap at ExtractOutput[0]) (5/16)
(191de26221d646b62a9ddfdae1a316d4).
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [6]{read, assert_that}) (5/16)
(936282643eb7caa4c93e87c587c19e69) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [6]{read, assert_that}) (5/16)
(936282643eb7caa4c93e87c587c19e69) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying MapPartition
(MapPartition at [6]{read, assert_that}) (5/16) (attempt #0) to
273bf175-ee2a-4d1b-9304-f050801ccffe @ localhost (dataPort=-1)
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task CHAIN Filter
(UnionFixFilter) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: assert_that/Group/GroupByKey) -> Map (Key Extractor) (13/16).
[CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine
(GroupCombine at GroupCombine: assert_that/Group/GroupByKey) -> Map (Key
Extractor) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN
Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: assert_that/Group/GroupByKey) -> Map (Key Extractor) (13/16)
(8d23587aac96cbfbd328218cf5bd6670) switched from CREATED to DEPLOYING.
[CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine
(GroupCombine at GroupCombine: assert_that/Group/GroupByKey) -> Map (Key
Extractor) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating
FileSystem stream leak safety net for task CHAIN Filter (UnionFixFilter) -> Map
(Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
assert_that/Group/GroupByKey) -> Map (Key Extractor) (13/16)
(8d23587aac96cbfbd328218cf5bd6670) [DEPLOYING]
[CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine
(GroupCombine at GroupCombine: assert_that/Group/GroupByKey) -> Map (Key
Extractor) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading
JAR files for task CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) ->
GroupCombine (GroupCombine at GroupCombine: assert_that/Group/GroupByKey) ->
Map (Key Extractor) (13/16) (8d23587aac96cbfbd328218cf5bd6670) [DEPLOYING].
[CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine
(GroupCombine at GroupCombine: assert_that/Group/GroupByKey) -> Map (Key
Extractor) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Registering task at network: CHAIN Filter (UnionFixFilter) -> Map (Key
Extractor) -> GroupCombine (GroupCombine at GroupCombine:
assert_that/Group/GroupByKey) -> Map (Key Extractor) (13/16)
(8d23587aac96cbfbd328218cf5bd6670) [DEPLOYING].
[CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine
(GroupCombine at GroupCombine: assert_that/Group/GroupByKey) -> Map (Key
Extractor) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN
Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: assert_that/Group/GroupByKey) -> Map (Key Extractor) (13/16)
(8d23587aac96cbfbd328218cf5bd6670) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task MapPartition
(MapPartition at [6]{read, assert_that}) (11/16).
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN Filter
(UnionFixFilter) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: assert_that/Group/GroupByKey) -> Map (Key Extractor) (13/16)
(8d23587aac96cbfbd328218cf5bd6670) switched from DEPLOYING to RUNNING.
[MapPartition (MapPartition at [6]{read, assert_that}) (11/16)] INFO
org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at
[6]{read, assert_that}) (11/16) (0886c7922c6bd2fd91313082ae429446) switched
from CREATED to DEPLOYING.
[MapPartition (MapPartition at [6]{read, assert_that}) (11/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak
safety net for task MapPartition (MapPartition at [6]{read, assert_that})
(11/16) (0886c7922c6bd2fd91313082ae429446) [DEPLOYING]
[MapPartition (MapPartition at [6]{read, assert_that}) (11/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task
MapPartition (MapPartition at [6]{read, assert_that}) (11/16)
(0886c7922c6bd2fd91313082ae429446) [DEPLOYING].
[MapPartition (MapPartition at [6]{read, assert_that}) (11/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Registering task at network:
MapPartition (MapPartition at [6]{read, assert_that}) (11/16)
(0886c7922c6bd2fd91313082ae429446) [DEPLOYING].
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task MapPartition
(MapPartition at [6]{read, assert_that}) (8/16).
[MapPartition (MapPartition at [6]{read, assert_that}) (11/16)] INFO
org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at
[6]{read, assert_that}) (11/16) (0886c7922c6bd2fd91313082ae429446) switched
from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [6]{read, assert_that}) (11/16)
(0886c7922c6bd2fd91313082ae429446) switched from DEPLOYING to RUNNING.
[MapPartition (MapPartition at [6]{read, assert_that}) (8/16)] INFO
org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at
[6]{read, assert_that}) (8/16) (9f9873cb3b0eadb5addb9003e4cce321) switched from
CREATED to DEPLOYING.
[MapPartition (MapPartition at [6]{read, assert_that}) (8/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak
safety net for task MapPartition (MapPartition at [6]{read, assert_that})
(8/16) (9f9873cb3b0eadb5addb9003e4cce321) [DEPLOYING]
[MapPartition (MapPartition at [6]{read, assert_that}) (8/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task
MapPartition (MapPartition at [6]{read, assert_that}) (8/16)
(9f9873cb3b0eadb5addb9003e4cce321) [DEPLOYING].
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task CHAIN Filter
(UnionFixFilter) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: assert_that/Group/GroupByKey) -> Map (Key Extractor) (11/16).
[MapPartition (MapPartition at [6]{read, assert_that}) (8/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Registering task at network:
MapPartition (MapPartition at [6]{read, assert_that}) (8/16)
(9f9873cb3b0eadb5addb9003e4cce321) [DEPLOYING].
[MapPartition (MapPartition at [6]{read, assert_that}) (8/16)] INFO
org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at
[6]{read, assert_that}) (8/16) (9f9873cb3b0eadb5addb9003e4cce321) switched from
DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [6]{read, assert_that}) (8/16)
(9f9873cb3b0eadb5addb9003e4cce321) switched from DEPLOYING to RUNNING.
[CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine
(GroupCombine at GroupCombine: assert_that/Group/GroupByKey) -> Map (Key
Extractor) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN
Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: assert_that/Group/GroupByKey) -> Map (Key Extractor) (11/16)
(d537f4533a4c5414c166f35792c3bd52) switched from CREATED to DEPLOYING.
[CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine
(GroupCombine at GroupCombine: assert_that/Group/GroupByKey) -> Map (Key
Extractor) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating
FileSystem stream leak safety net for task CHAIN Filter (UnionFixFilter) -> Map
(Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
assert_that/Group/GroupByKey) -> Map (Key Extractor) (11/16)
(d537f4533a4c5414c166f35792c3bd52) [DEPLOYING]
[CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine
(GroupCombine at GroupCombine: assert_that/Group/GroupByKey) -> Map (Key
Extractor) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading
JAR files for task CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) ->
GroupCombine (GroupCombine at GroupCombine: assert_that/Group/GroupByKey) ->
Map (Key Extractor) (11/16) (d537f4533a4c5414c166f35792c3bd52) [DEPLOYING].
[CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine
(GroupCombine at GroupCombine: assert_that/Group/GroupByKey) -> Map (Key
Extractor) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Registering task at network: CHAIN Filter (UnionFixFilter) -> Map (Key
Extractor) -> GroupCombine (GroupCombine at GroupCombine:
assert_that/Group/GroupByKey) -> Map (Key Extractor) (11/16)
(d537f4533a4c5414c166f35792c3bd52) [DEPLOYING].
[CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine
(GroupCombine at GroupCombine: assert_that/Group/GroupByKey) -> Map (Key
Extractor) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN
Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: assert_that/Group/GroupByKey) -> Map (Key Extractor) (11/16)
(d537f4533a4c5414c166f35792c3bd52) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task MapPartition
(MapPartition at [6]{read, assert_that}) (12/16).
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN Filter
(UnionFixFilter) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: assert_that/Group/GroupByKey) -> Map (Key Extractor) (11/16)
(d537f4533a4c5414c166f35792c3bd52) switched from DEPLOYING to RUNNING.
[MapPartition (MapPartition at [6]{read, assert_that}) (12/16)] INFO
org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at
[6]{read, assert_that}) (12/16) (be3b4b9b79d1e61e574ca11bce544a27) switched
from CREATED to DEPLOYING.
[MapPartition (MapPartition at [6]{read, assert_that}) (12/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak
safety net for task MapPartition (MapPartition at [6]{read, assert_that})
(12/16) (be3b4b9b79d1e61e574ca11bce544a27) [DEPLOYING]
[MapPartition (MapPartition at [6]{read, assert_that}) (12/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task
MapPartition (MapPartition at [6]{read, assert_that}) (12/16)
(be3b4b9b79d1e61e574ca11bce544a27) [DEPLOYING].
[MapPartition (MapPartition at [6]{read, assert_that}) (12/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Registering task at network:
MapPartition (MapPartition at [6]{read, assert_that}) (12/16)
(be3b4b9b79d1e61e574ca11bce544a27) [DEPLOYING].
[MapPartition (MapPartition at [6]{read, assert_that}) (12/16)] INFO
org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at
[6]{read, assert_that}) (12/16) (be3b4b9b79d1e61e574ca11bce544a27) switched
from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [6]{read, assert_that}) (12/16)
(be3b4b9b79d1e61e574ca11bce544a27) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task MapPartition
(MapPartition at [1]read/_PassThroughThenCleanup/ParDo(RemoveJsonFiles))
(13/16).
[MapPartition (MapPartition at
[1]read/_PassThroughThenCleanup/ParDo(RemoveJsonFiles)) (13/16)] INFO
org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at
[1]read/_PassThroughThenCleanup/ParDo(RemoveJsonFiles)) (13/16)
(da3c56a7ad2bf587e2501039a862ad7a) switched from CREATED to DEPLOYING.
[MapPartition (MapPartition at
[1]read/_PassThroughThenCleanup/ParDo(RemoveJsonFiles)) (13/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak
safety net for task MapPartition (MapPartition at
[1]read/_PassThroughThenCleanup/ParDo(RemoveJsonFiles)) (13/16)
(da3c56a7ad2bf587e2501039a862ad7a) [DEPLOYING]
[MapPartition (MapPartition at
[1]read/_PassThroughThenCleanup/ParDo(RemoveJsonFiles)) (13/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task
MapPartition (MapPartition at
[1]read/_PassThroughThenCleanup/ParDo(RemoveJsonFiles)) (13/16)
(da3c56a7ad2bf587e2501039a862ad7a) [DEPLOYING].
[MapPartition (MapPartition at
[1]read/_PassThroughThenCleanup/ParDo(RemoveJsonFiles)) (13/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Registering task at network:
MapPartition (MapPartition at
[1]read/_PassThroughThenCleanup/ParDo(RemoveJsonFiles)) (13/16)
(da3c56a7ad2bf587e2501039a862ad7a) [DEPLOYING].
[MapPartition (MapPartition at
[1]read/_PassThroughThenCleanup/ParDo(RemoveJsonFiles)) (13/16)] INFO
org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at
[1]read/_PassThroughThenCleanup/ParDo(RemoveJsonFiles)) (13/16)
(da3c56a7ad2bf587e2501039a862ad7a) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [1]read/_PassThroughThenCleanup/ParDo(RemoveJsonFiles))
(13/16) (da3c56a7ad2bf587e2501039a862ad7a) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task MapPartition
(MapPartition at [6]{read, assert_that}) (5/16).
[MapPartition (MapPartition at
[1]read/_PassThroughThenCleanup/ParDo(RemoveJsonFiles)) (13/16)] WARN
org.apache.flink.metrics.MetricGroup - The operator name MapPartition
(MapPartition at [1]read/_PassThroughThenCleanup/ParDo(RemoveJsonFiles))
exceeded the 80 characters length limit and was truncated.
[MapPartition (MapPartition at [6]{read, assert_that}) (5/16)] INFO
org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at
[6]{read, assert_that}) (5/16) (936282643eb7caa4c93e87c587c19e69) switched from
CREATED to DEPLOYING.
[MapPartition (MapPartition at [6]{read, assert_that}) (5/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak
safety net for task MapPartition (MapPartition at [6]{read, assert_that})
(5/16) (936282643eb7caa4c93e87c587c19e69) [DEPLOYING]
[MapPartition (MapPartition at [6]{read, assert_that}) (5/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task
MapPartition (MapPartition at [6]{read, assert_that}) (5/16)
(936282643eb7caa4c93e87c587c19e69) [DEPLOYING].
[MapPartition (MapPartition at [6]{read, assert_that}) (5/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Registering task at network:
MapPartition (MapPartition at [6]{read, assert_that}) (5/16)
(936282643eb7caa4c93e87c587c19e69) [DEPLOYING].
[MapPartition (MapPartition at [6]{read, assert_that}) (5/16)] INFO
org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at
[6]{read, assert_that}) (5/16) (936282643eb7caa4c93e87c587c19e69) switched from
DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [6]{read, assert_that}) (5/16)
(936282643eb7caa4c93e87c587c19e69) switched from DEPLOYING to RUNNING.
[CHAIN MapPartition (MapPartition at
[2]read/Read/_SDFBoundedSourceWrapper/ParDo(SDFBoundedSourceDoFn)/{PairWithRestriction0,
SplitAndSize0}) -> FlatMap (FlatMap at ExtractOutput[0]) (3/16)] INFO
org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at
[2]read/Read/_SDFBoundedSourceWrapper/ParDo(SDFBoundedSourceDoFn)/{PairWithRestriction0,
SplitAndSize0}) -> FlatMap (FlatMap at ExtractOutput[0]) (3/16)
(6eda51f6be6792af971decd0fea182a2) switched from RUNNING to FINISHED.
[CHAIN MapPartition (MapPartition at
[2]read/Read/_SDFBoundedSourceWrapper/ParDo(SDFBoundedSourceDoFn)/{PairWithRestriction0,
SplitAndSize0}) -> FlatMap (FlatMap at ExtractOutput[0]) (3/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for CHAIN
MapPartition (MapPartition at
[2]read/Read/_SDFBoundedSourceWrapper/ParDo(SDFBoundedSourceDoFn)/{PairWithRestriction0,
SplitAndSize0}) -> FlatMap (FlatMap at ExtractOutput[0]) (3/16)
(6eda51f6be6792af971decd0fea182a2).
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [6]{read, assert_that}) (3/16)
(4e5416e5243d4e40a9266851fae2c335) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [6]{read, assert_that}) (3/16)
(4e5416e5243d4e40a9266851fae2c335) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying MapPartition
(MapPartition at [6]{read, assert_that}) (3/16) (attempt #0) to
273bf175-ee2a-4d1b-9304-f050801ccffe @ localhost (dataPort=-1)
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task MapPartition
(MapPartition at [6]{read, assert_that}) (3/16).
[MapPartition (MapPartition at [6]{read, assert_that}) (3/16)] INFO
org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at
[6]{read, assert_that}) (3/16) (4e5416e5243d4e40a9266851fae2c335) switched from
CREATED to DEPLOYING.
[MapPartition (MapPartition at [6]{read, assert_that}) (3/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak
safety net for task MapPartition (MapPartition at [6]{read, assert_that})
(3/16) (4e5416e5243d4e40a9266851fae2c335) [DEPLOYING]
[MapPartition (MapPartition at [6]{read, assert_that}) (3/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task
MapPartition (MapPartition at [6]{read, assert_that}) (3/16)
(4e5416e5243d4e40a9266851fae2c335) [DEPLOYING].
[MapPartition (MapPartition at [6]{read, assert_that}) (3/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Registering task at network:
MapPartition (MapPartition at [6]{read, assert_that}) (3/16)
(4e5416e5243d4e40a9266851fae2c335) [DEPLOYING].
[MapPartition (MapPartition at [6]{read, assert_that}) (3/16)] INFO
org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at
[6]{read, assert_that}) (3/16) (4e5416e5243d4e40a9266851fae2c335) switched from
DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [6]{read, assert_that}) (3/16)
(4e5416e5243d4e40a9266851fae2c335) switched from DEPLOYING to RUNNING.
[CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) -> FlatMap
(FlatMap at ExtractOutput[0]) (8/16)] INFO
org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at
[4]assert_that/{Create, Group}) -> FlatMap (FlatMap at ExtractOutput[0]) (8/16)
(96d39d3425b964e901c83e199e731718) switched from RUNNING to FINISHED.
[CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) -> FlatMap
(FlatMap at ExtractOutput[0]) (8/16)] 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]) (8/16) (96d39d3425b964e901c83e199e731718).
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN Filter
(UnionFixFilter) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: assert_that/Group/GroupByKey) -> Map (Key Extractor) (8/16)
(e4ba8957e3ac670b7cdc02fc5351cc80) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN Filter
(UnionFixFilter) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: assert_that/Group/GroupByKey) -> Map (Key Extractor) (8/16)
(e4ba8957e3ac670b7cdc02fc5351cc80) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying CHAIN Filter
(UnionFixFilter) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: assert_that/Group/GroupByKey) -> Map (Key Extractor) (8/16)
(attempt #0) to 273bf175-ee2a-4d1b-9304-f050801ccffe @ localhost (dataPort=-1)
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task CHAIN Filter
(UnionFixFilter) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: assert_that/Group/GroupByKey) -> Map (Key Extractor) (8/16).
[CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine
(GroupCombine at GroupCombine: assert_that/Group/GroupByKey) -> Map (Key
Extractor) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN
Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: assert_that/Group/GroupByKey) -> Map (Key Extractor) (8/16)
(e4ba8957e3ac670b7cdc02fc5351cc80) switched from CREATED to DEPLOYING.
[CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine
(GroupCombine at GroupCombine: assert_that/Group/GroupByKey) -> Map (Key
Extractor) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating
FileSystem stream leak safety net for task CHAIN Filter (UnionFixFilter) -> Map
(Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
assert_that/Group/GroupByKey) -> Map (Key Extractor) (8/16)
(e4ba8957e3ac670b7cdc02fc5351cc80) [DEPLOYING]
[CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine
(GroupCombine at GroupCombine: assert_that/Group/GroupByKey) -> Map (Key
Extractor) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR
files for task CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) ->
GroupCombine (GroupCombine at GroupCombine: assert_that/Group/GroupByKey) ->
Map (Key Extractor) (8/16) (e4ba8957e3ac670b7cdc02fc5351cc80) [DEPLOYING].
[CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine
(GroupCombine at GroupCombine: assert_that/Group/GroupByKey) -> Map (Key
Extractor) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering
task at network: CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) ->
GroupCombine (GroupCombine at GroupCombine: assert_that/Group/GroupByKey) ->
Map (Key Extractor) (8/16) (e4ba8957e3ac670b7cdc02fc5351cc80) [DEPLOYING].
[CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine
(GroupCombine at GroupCombine: assert_that/Group/GroupByKey) -> Map (Key
Extractor) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN
Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: assert_that/Group/GroupByKey) -> Map (Key Extractor) (8/16)
(e4ba8957e3ac670b7cdc02fc5351cc80) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN Filter
(UnionFixFilter) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: assert_that/Group/GroupByKey) -> Map (Key Extractor) (8/16)
(e4ba8957e3ac670b7cdc02fc5351cc80) switched from DEPLOYING to RUNNING.
OpenJDK 64-Bit Server VM warning: INFO: os::commit_memory(0x000000063f700000,
959447040, 0) failed; error='Cannot allocate memory' (errno=12)
#
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]
