See
<https://ci-beam.apache.org/job/beam_PostCommit_Python36/4716/display/redirect>
Changes:
------------------------------------------
[...truncated 48.50 MB...]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task failExternally'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Attempting to fail task externally FlatMap (FlatMap at ExtractOutput[0])
(14/16)#0 (9709b13e1b276c4cad2baa0120f5e302).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task
cancelOrFailAndCancelInvokableInternal'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Task FlatMap (FlatMap at ExtractOutput[0]) (14/16)#0 is already in state
FINISHED'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Un-registering task and sending final execution state FINISHED to JobManager
for task FlatMap (FlatMap at ExtractOutput[0]) (13/16)#0
8a331c766e6ab5ce89355ec805c40f8b.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Un-registering task and sending final execution state FINISHED to JobManager
for task FlatMap (FlatMap at ExtractOutput[0]) (14/16)#0
9709b13e1b276c4cad2baa0120f5e302.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task failExternally'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Attempting to fail task externally FlatMap (FlatMap at ExtractOutput[0])
(15/16)#0 (2520f4e1a0e1e3821850240f332bdb31).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task
cancelOrFailAndCancelInvokableInternal'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Task FlatMap (FlatMap at ExtractOutput[0]) (15/16)#0 is already in state
FINISHED'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task failExternally'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Attempting to fail task externally FlatMap (FlatMap at ExtractOutput[0])
(15/16)#0 (2520f4e1a0e1e3821850240f332bdb31).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task
cancelOrFailAndCancelInvokableInternal'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Task FlatMap (FlatMap at ExtractOutput[0]) (15/16)#0 is already in state
FINISHED'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Un-registering task and sending final execution state FINISHED to JobManager
for task FlatMap (FlatMap at ExtractOutput[0]) (15/16)#0
2520f4e1a0e1e3821850240f332bdb31.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task failExternally'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Attempting to fail task externally FlatMap (FlatMap at ExtractOutput[0])
(16/16)#0 (577f58633a7c4f3934f6a4cda3caaf94).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task
cancelOrFailAndCancelInvokableInternal'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Task FlatMap (FlatMap at ExtractOutput[0]) (16/16)#0 is already in state
FINISHED'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task failExternally'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Attempting to fail task externally FlatMap (FlatMap at ExtractOutput[0])
(16/16)#0 (577f58633a7c4f3934f6a4cda3caaf94).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task
cancelOrFailAndCancelInvokableInternal'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Task FlatMap (FlatMap at ExtractOutput[0]) (16/16)#0 is already in state
FINISHED'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Un-registering task and sending final execution state FINISHED to JobManager
for task FlatMap (FlatMap at ExtractOutput[0]) (16/16)#0
577f58633a7c4f3934f6a4cda3caaf94.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task failExternally'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Attempting to fail task externally CHAIN MapPartition (MapPartition at
[4]assert_that/{Create, Group}) -> FlatMap (FlatMap at ExtractOutput[0])
(1/16)#0 (9078825ae2944b6df70e06dfb21e96b6).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task
cancelOrFailAndCancelInvokableInternal'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Task CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) ->
FlatMap (FlatMap at ExtractOutput[0]) (1/16)#0 is already in state FINISHED'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task failExternally'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Attempting to fail task externally CHAIN MapPartition (MapPartition at
[4]assert_that/{Create, Group}) -> FlatMap (FlatMap at ExtractOutput[0])
(1/16)#0 (9078825ae2944b6df70e06dfb21e96b6).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task
cancelOrFailAndCancelInvokableInternal'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Task CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) ->
FlatMap (FlatMap at ExtractOutput[0]) (1/16)#0 is already in state FINISHED'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task failExternally'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Attempting to fail task externally CHAIN MapPartition (MapPartition at
[4]assert_that/{Create, Group}) -> FlatMap (FlatMap at ExtractOutput[0])
(2/16)#0 (b7a7e6618b6929d86f5227ac8958dfe6).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task
cancelOrFailAndCancelInvokableInternal'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Task CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) ->
FlatMap (FlatMap at ExtractOutput[0]) (2/16)#0 is already in state FINISHED'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task failExternally'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Attempting to fail task externally CHAIN MapPartition (MapPartition at
[4]assert_that/{Create, Group}) -> FlatMap (FlatMap at ExtractOutput[0])
(2/16)#0 (b7a7e6618b6929d86f5227ac8958dfe6).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task
cancelOrFailAndCancelInvokableInternal'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Task CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) ->
FlatMap (FlatMap at ExtractOutput[0]) (2/16)#0 is already in state FINISHED'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task failExternally'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Attempting to fail task externally CHAIN MapPartition (MapPartition at
[4]assert_that/{Create, Group}) -> FlatMap (FlatMap at ExtractOutput[0])
(3/16)#0 (5ef2eeb36d6104c8fc4f63a9c760f42a).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task
cancelOrFailAndCancelInvokableInternal'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Task CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) ->
FlatMap (FlatMap at ExtractOutput[0]) (3/16)#0 is already in state FINISHED'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task failExternally'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Attempting to fail task externally CHAIN MapPartition (MapPartition at
[4]assert_that/{Create, Group}) -> FlatMap (FlatMap at ExtractOutput[0])
(3/16)#0 (5ef2eeb36d6104c8fc4f63a9c760f42a).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task
cancelOrFailAndCancelInvokableInternal'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Task CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) ->
FlatMap (FlatMap at ExtractOutput[0]) (3/16)#0 is already in state FINISHED'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task failExternally'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Attempting to fail task externally CHAIN MapPartition (MapPartition at
[4]assert_that/{Create, Group}) -> FlatMap (FlatMap at ExtractOutput[0])
(4/16)#0 (69519c0e684bab39ce6b12dd95fff274).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task
cancelOrFailAndCancelInvokableInternal'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Task CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) ->
FlatMap (FlatMap at ExtractOutput[0]) (4/16)#0 is already in state FINISHED'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task failExternally'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Attempting to fail task externally CHAIN MapPartition (MapPartition at
[4]assert_that/{Create, Group}) -> FlatMap (FlatMap at ExtractOutput[0])
(4/16)#0 (69519c0e684bab39ce6b12dd95fff274).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task
cancelOrFailAndCancelInvokableInternal'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Task CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) ->
FlatMap (FlatMap at ExtractOutput[0]) (4/16)#0 is already in state FINISHED'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task failExternally'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Attempting to fail task externally CHAIN MapPartition (MapPartition at
[4]assert_that/{Create, Group}) -> FlatMap (FlatMap at ExtractOutput[0])
(5/16)#0 (08a6bfdf2ddfba1f9558c9a18aad5b13).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task
cancelOrFailAndCancelInvokableInternal'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Task CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) ->
FlatMap (FlatMap at ExtractOutput[0]) (5/16)#0 is already in state FINISHED'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task failExternally'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Attempting to fail task externally CHAIN MapPartition (MapPartition at
[4]assert_that/{Create, Group}) -> FlatMap (FlatMap at ExtractOutput[0])
(5/16)#0 (08a6bfdf2ddfba1f9558c9a18aad5b13).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task
cancelOrFailAndCancelInvokableInternal'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Task CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) ->
FlatMap (FlatMap at ExtractOutput[0]) (5/16)#0 is already in state FINISHED'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task failExternally'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Attempting to fail task externally CHAIN MapPartition (MapPartition at
[4]assert_that/{Create, Group}) -> FlatMap (FlatMap at ExtractOutput[0])
(6/16)#0 (90df349ee6df7702c59c61a7dab67e6c).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task
cancelOrFailAndCancelInvokableInternal'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Task CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) ->
FlatMap (FlatMap at ExtractOutput[0]) (6/16)#0 is already in state FINISHED'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task failExternally'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Attempting to fail task externally CHAIN MapPartition (MapPartition at
[4]assert_that/{Create, Group}) -> FlatMap (FlatMap at ExtractOutput[0])
(6/16)#0 (90df349ee6df7702c59c61a7dab67e6c).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task
cancelOrFailAndCancelInvokableInternal'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Task CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) ->
FlatMap (FlatMap at ExtractOutput[0]) (6/16)#0 is already in state FINISHED'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task failExternally'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Attempting to fail task externally CHAIN MapPartition (MapPartition at
[4]assert_that/{Create, Group}) -> FlatMap (FlatMap at ExtractOutput[0])
(7/16)#0 (4021b87935183fd0e0350f3d26e1a2e9).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task
cancelOrFailAndCancelInvokableInternal'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Task CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) ->
FlatMap (FlatMap at ExtractOutput[0]) (7/16)#0 is already in state FINISHED'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task failExternally'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Attempting to fail task externally CHAIN MapPartition (MapPartition at
[4]assert_that/{Create, Group}) -> FlatMap (FlatMap at ExtractOutput[0])
(7/16)#0 (4021b87935183fd0e0350f3d26e1a2e9).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task
cancelOrFailAndCancelInvokableInternal'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Task CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) ->
FlatMap (FlatMap at ExtractOutput[0]) (7/16)#0 is already in state FINISHED'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task failExternally'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Attempting to fail task externally CHAIN MapPartition (MapPartition at
[4]assert_that/{Create, Group}) -> FlatMap (FlatMap at ExtractOutput[0])
(8/16)#0 (1c4f4e30e448a3eef58e06d27e491630).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task
cancelOrFailAndCancelInvokableInternal'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Task CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) ->
FlatMap (FlatMap at ExtractOutput[0]) (8/16)#0 is already in state FINISHED'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task failExternally'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Attempting to fail task externally CHAIN MapPartition (MapPartition at
[4]assert_that/{Create, Group}) -> FlatMap (FlatMap at ExtractOutput[0])
(8/16)#0 (1c4f4e30e448a3eef58e06d27e491630).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task
cancelOrFailAndCancelInvokableInternal'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Task CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) ->
FlatMap (FlatMap at ExtractOutput[0]) (8/16)#0 is already in state FINISHED'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task failExternally'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Attempting to fail task externally CHAIN MapPartition (MapPartition at
[4]assert_that/{Create, Group}) -> FlatMap (FlatMap at ExtractOutput[0])
(9/16)#0 (efae4840a8267a8f739576b7fb399d98).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task
cancelOrFailAndCancelInvokableInternal'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Task CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) ->
FlatMap (FlatMap at ExtractOutput[0]) (9/16)#0 is already in state FINISHED'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task failExternally'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Attempting to fail task externally CHAIN MapPartition (MapPartition at
[4]assert_that/{Create, Group}) -> FlatMap (FlatMap at ExtractOutput[0])
(9/16)#0 (efae4840a8267a8f739576b7fb399d98).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task
cancelOrFailAndCancelInvokableInternal'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Task CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) ->
FlatMap (FlatMap at ExtractOutput[0]) (9/16)#0 is already in state FINISHED'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task failExternally'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Attempting to fail task externally CHAIN MapPartition (MapPartition at
[4]assert_that/{Create, Group}) -> FlatMap (FlatMap at ExtractOutput[0])
(10/16)#0 (2f986243df7f8a4965a2d929f9a2f9d8).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task
cancelOrFailAndCancelInvokableInternal'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Task CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) ->
FlatMap (FlatMap at ExtractOutput[0]) (10/16)#0 is already in state FINISHED'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task failExternally'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Attempting to fail task externally CHAIN MapPartition (MapPartition at
[4]assert_that/{Create, Group}) -> FlatMap (FlatMap at ExtractOutput[0])
(10/16)#0 (2f986243df7f8a4965a2d929f9a2f9d8).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task
cancelOrFailAndCancelInvokableInternal'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Task CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) ->
FlatMap (FlatMap at ExtractOutput[0]) (10/16)#0 is already in state FINISHED'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task failExternally'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Attempting to fail task externally CHAIN MapPartition (MapPartition at
[4]assert_that/{Create, Group}) -> FlatMap (FlatMap at ExtractOutput[0])
(11/16)#0 (c2a68c97410495e51fe1e28fc4607201).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task
cancelOrFailAndCancelInvokableInternal'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Task CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) ->
FlatMap (FlatMap at ExtractOutput[0]) (11/16)#0 is already in state FINISHED'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task failExternally'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Attempting to fail task externally CHAIN MapPartition (MapPartition at
[4]assert_that/{Create, Group}) -> FlatMap (FlatMap at ExtractOutput[0])
(11/16)#0 (c2a68c97410495e51fe1e28fc4607201).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task
cancelOrFailAndCancelInvokableInternal'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Task CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) ->
FlatMap (FlatMap at ExtractOutput[0]) (11/16)#0 is already in state FINISHED'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task failExternally'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Attempting to fail task externally CHAIN MapPartition (MapPartition at
[4]assert_that/{Create, Group}) -> FlatMap (FlatMap at ExtractOutput[0])
(12/16)#0 (a65b4e3d6ef7e276df879002508a99ad).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task
cancelOrFailAndCancelInvokableInternal'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Task CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) ->
FlatMap (FlatMap at ExtractOutput[0]) (12/16)#0 is already in state FINISHED'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task failExternally'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Attempting to fail task externally CHAIN MapPartition (MapPartition at
[4]assert_that/{Create, Group}) -> FlatMap (FlatMap at ExtractOutput[0])
(12/16)#0 (a65b4e3d6ef7e276df879002508a99ad).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task
cancelOrFailAndCancelInvokableInternal'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Task CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) ->
FlatMap (FlatMap at ExtractOutput[0]) (12/16)#0 is already in state FINISHED'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task failExternally'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Attempting to fail task externally CHAIN MapPartition (MapPartition at
[4]assert_that/{Create, Group}) -> FlatMap (FlatMap at ExtractOutput[0])
(14/16)#0 (e92e6be41f9d336989f4cfacd37be8af).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task
cancelOrFailAndCancelInvokableInternal'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Task CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) ->
FlatMap (FlatMap at ExtractOutput[0]) (14/16)#0 is already in state FINISHED'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task failExternally'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Attempting to fail task externally CHAIN MapPartition (MapPartition at
[4]assert_that/{Create, Group}) -> FlatMap (FlatMap at ExtractOutput[0])
(13/16)#0 (f8f6e102e0f58aacf96b1a0a4362c678).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task
cancelOrFailAndCancelInvokableInternal'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Task CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) ->
FlatMap (FlatMap at ExtractOutput[0]) (13/16)#0 is already in state FINISHED'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task failExternally'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Attempting to fail task externally CHAIN MapPartition (MapPartition at
[4]assert_that/{Create, Group}) -> FlatMap (FlatMap at ExtractOutput[0])
(13/16)#0 (f8f6e102e0f58aacf96b1a0a4362c678).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task
cancelOrFailAndCancelInvokableInternal'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Task CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) ->
FlatMap (FlatMap at ExtractOutput[0]) (13/16)#0 is already in state FINISHED'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task failExternally'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Attempting to fail task externally CHAIN MapPartition (MapPartition at
[4]assert_that/{Create, Group}) -> FlatMap (FlatMap at ExtractOutput[0])
(14/16)#0 (e92e6be41f9d336989f4cfacd37be8af).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task
cancelOrFailAndCancelInvokableInternal'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Task CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) ->
FlatMap (FlatMap at ExtractOutput[0]) (14/16)#0 is already in state FINISHED'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task failExternally'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Attempting to fail task externally CHAIN MapPartition (MapPartition at
[4]assert_that/{Create, Group}) -> FlatMap (FlatMap at ExtractOutput[0])
(15/16)#0 (2531ffad8a49f59547f11dabcfcbbb47).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task
cancelOrFailAndCancelInvokableInternal'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Task CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) ->
FlatMap (FlatMap at ExtractOutput[0]) (15/16)#0 is already in state FINISHED'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task failExternally'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Attempting to fail task externally CHAIN MapPartition (MapPartition at
[4]assert_that/{Create, Group}) -> FlatMap (FlatMap at ExtractOutput[0])
(15/16)#0 (2531ffad8a49f59547f11dabcfcbbb47).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task
cancelOrFailAndCancelInvokableInternal'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Task CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) ->
FlatMap (FlatMap at ExtractOutput[0]) (15/16)#0 is already in state FINISHED'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task failExternally'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Attempting to fail task externally CHAIN MapPartition (MapPartition at
[4]assert_that/{Create, Group}) -> FlatMap (FlatMap at ExtractOutput[0])
(16/16)#0 (1b0339e5747e912eaff64607228a7f10).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task
cancelOrFailAndCancelInvokableInternal'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Task CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) ->
FlatMap (FlatMap at ExtractOutput[0]) (16/16)#0 is already in state FINISHED'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task failExternally'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Attempting to fail task externally CHAIN MapPartition (MapPartition at
[4]assert_that/{Create, Group}) -> FlatMap (FlatMap at ExtractOutput[0])
(16/16)#0 (1b0339e5747e912eaff64607228a7f10).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task
cancelOrFailAndCancelInvokableInternal'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Task CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) ->
FlatMap (FlatMap at ExtractOutput[0]) (16/16)#0 is already in state FINISHED'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task failExternally'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Attempting to fail task externally CHAIN Filter (UnionFixFilter) -> Map (Key
Extractor) -> GroupCombine (GroupCombine at GroupCombine:
assert_that/Group/CoGroupByKeyImpl/GroupByKey) -> Map (Key Extractor) (4/16)#0
(60ab7d16c6c52bb2c0a1d8b9e0579bbe).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task
cancelOrFailAndCancelInvokableInternal'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Task CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine
(GroupCombine at GroupCombine: assert_that/Group/CoGroupByKeyImpl/GroupByKey)
-> Map (Key Extractor) (4/16)#0 is already in state FINISHED'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task failExternally'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Attempting to fail task externally CHAIN Filter (UnionFixFilter) -> Map (Key
Extractor) -> GroupCombine (GroupCombine at GroupCombine:
assert_that/Group/CoGroupByKeyImpl/GroupByKey) -> Map (Key Extractor) (4/16)#0
(60ab7d16c6c52bb2c0a1d8b9e0579bbe).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task
cancelOrFailAndCancelInvokableInternal'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Task CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine
(GroupCombine at GroupCombine: assert_that/Group/CoGroupByKeyImpl/GroupByKey)
-> Map (Key Extractor) (4/16)#0 is already in state FINISHED'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task failExternally'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Attempting to fail task externally CHAIN Filter (UnionFixFilter) -> Map (Key
Extractor) -> GroupCombine (GroupCombine at GroupCombine:
assert_that/Group/CoGroupByKeyImpl/GroupByKey) -> Map (Key Extractor) (3/16)#0
(6cb7109d92c90aaca66214d9e5dff7d2).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task
cancelOrFailAndCancelInvokableInternal'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Task CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine
(GroupCombine at GroupCombine: assert_that/Group/CoGroupByKeyImpl/GroupByKey)
-> Map (Key Extractor) (3/16)#0 is already in state FINISHED'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task failExternally'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Attempting to fail task externally CHAIN Filter (UnionFixFilter) -> Map (Key
Extractor) -> GroupCombine (GroupCombine at GroupCombine:
assert_that/Group/CoGroupByKeyImpl/GroupByKey) -> Map (Key Extractor) (3/16)#0
(6cb7109d92c90aaca66214d9e5dff7d2).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task
cancelOrFailAndCancelInvokableInternal'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Task CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine
(GroupCombine at GroupCombine: assert_that/Group/CoGroupByKeyImpl/GroupByKey)
-> Map (Key Extractor) (3/16)#0 is already in state FINISHED'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task failExternally'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Attempting to fail task externally CHAIN Filter (UnionFixFilter) -> Map (Key
Extractor) -> GroupCombine (GroupCombine at GroupCombine:
assert_that/Group/CoGroupByKeyImpl/GroupByKey) -> Map (Key Extractor) (5/16)#0
(497954eb72fd0bde53f30047a3fe1062).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task
cancelOrFailAndCancelInvokableInternal'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Task CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine
(GroupCombine at GroupCombine: assert_that/Group/CoGroupByKeyImpl/GroupByKey)
-> Map (Key Extractor) (5/16)#0 is already in state FINISHED'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task failExternally'
> Task :sdks:python:test-suites:dataflow:py36:postCommitIT
[gw6] [32mPASSED[0m
apache_beam/examples/dataframe/taxiride_it_test.py::TaxirideIT::test_aggregation
apache_beam/examples/dataframe/taxiride_it_test.py::TaxirideIT::test_enrich
> Task :sdks:python:test-suites:portable:py36:postCommitPy36IT
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Attempting to fail task externally CHAIN Filter (UnionFixFilter) -> Map (Key
Extractor) -> GroupCombine (GroupCombine at GroupCombine:
assert_that/Group/CoGroupByKeyImpl/GroupByKey) -> Map (Key Extractor) (5/16)#0
(497954eb72fd0bde53f30047a3fe1062).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task
cancelOrFailAndCancelInvokableInternal'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Task CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine
(GroupCombine at GroupCombine: assert_that/Group/CoGroupByKeyImpl/GroupByKey)
-> Map (Key Extractor) (5/16)#0 is already in state FINISHED'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task failExternally'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Attempting to fail task externally CHAIN Filter (UnionFixFilter) -> Map (Key
Extractor) -> GroupCombine (GroupCombine at GroupCombine:
assert_that/Group/CoGroupByKeyImpl/GroupByKey) -> Map (Key Extractor) (1/16)#0
(5fd8b1e654793da28bef8bc1e176b52a).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task
cancelOrFailAndCancelInvokableInternal'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Task CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine
(GroupCombine at GroupCombine: assert_that/Group/CoGroupByKeyImpl/GroupByKey)
-> Map (Key Extractor) (1/16)#0 is already in state FINISHED'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task failExternally'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Attempting to fail task externally CHAIN Filter (UnionFixFilter) -> Map (Key
Extractor) -> GroupCombine (GroupCombine at GroupCombine:
assert_that/Group/CoGroupByKeyImpl/GroupByKey) -> Map (Key Extractor) (1/16)#0
(5fd8b1e654793da28bef8bc1e176b52a).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task
cancelOrFailAndCancelInvokableInternal'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Task CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine
(GroupCombine at GroupCombine: assert_that/Group/CoGroupByKeyImpl/GroupByKey)
-> Map (Key Extractor) (1/16)#0 is already in state FINISHED'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task failExternally'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Attempting to fail task externally CHAIN Filter (UnionFixFilter) -> Map (Key
Extractor) -> GroupCombine (GroupCombine at GroupCombine:
assert_that/Group/CoGroupByKeyImpl/GroupByKey) -> Map (Key Extractor) (2/16)#0
(f168944e8fc3ab603a48d6eb7c758cb7).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task
cancelOrFailAndCancelInvokableInternal'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Task CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine
(GroupCombine at GroupCombine: assert_that/Group/CoGroupByKeyImpl/GroupByKey)
-> Map (Key Extractor) (2/16)#0 is already in state FINISHED'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task failExternally'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Attempting to fail task externally CHAIN Filter (UnionFixFilter) -> Map (Key
Extractor) -> GroupCombine (GroupCombine at GroupCombine:
assert_that/Group/CoGroupByKeyImpl/GroupByKey) -> Map (Key Extractor) (2/16)#0
(f168944e8fc3ab603a48d6eb7c758cb7).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task
cancelOrFailAndCancelInvokableInternal'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Task CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine
(GroupCombine at GroupCombine: assert_that/Group/CoGroupByKeyImpl/GroupByKey)
-> Map (Key Extractor) (2/16)#0 is already in state FINISHED'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task failExternally'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Attempting to fail task externally CHAIN Filter (UnionFixFilter) -> Map (Key
Extractor) -> GroupCombine (GroupCombine at GroupCombine:
assert_that/Group/CoGroupByKeyImpl/GroupByKey) -> Map (Key Extractor) (6/16)#0
(a31874960462646a40f160da2b9c22f5).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task
cancelOrFailAndCancelInvokableInternal'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Task CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine
(GroupCombine at GroupCombine: assert_that/Group/CoGroupByKeyImpl/GroupByKey)
-> Map (Key Extractor) (6/16)#0 is already in state FINISHED'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task failExternally'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Attempting to fail task externally CHAIN Filter (UnionFixFilter) -> Map (Key
Extractor) -> GroupCombine (GroupCombine at GroupCombine:
assert_that/Group/CoGroupByKeyImpl/GroupByKey) -> Map (Key Extractor) (6/16)#0
(a31874960462646a40f160da2b9c22f5).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task
cancelOrFailAndCancelInvokableInternal'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Task CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine
(GroupCombine at GroupCombine: assert_that/Group/CoGroupByKeyImpl/GroupByKey)
-> Map (Key Extractor) (6/16)#0 is already in state FINISHED'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task failExternally'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Attempting to fail task externally CHAIN Filter (UnionFixFilter) -> Map (Key
Extractor) -> GroupCombine (GroupCombine at GroupCombine:
assert_that/Group/CoGroupByKeyImpl/GroupByKey) -> Map (Key Extractor) (7/16)#0
(9eda3887cec90e3898c5c0a308ee0ff5).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task
cancelOrFailAndCancelInvokableInternal'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Task CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine
(GroupCombine at GroupCombine: assert_that/Group/CoGroupByKeyImpl/GroupByKey)
-> Map (Key Extractor) (7/16)#0 is already in state FINISHED'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task failExternally'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Attempting to fail task externally CHAIN Filter (UnionFixFilter) -> Map (Key
Extractor) -> GroupCombine (GroupCombine at GroupCombine:
assert_that/Group/CoGroupByKeyImpl/GroupByKey) -> Map (Key Extractor) (7/16)#0
(9eda3887cec90e3898c5c0a308ee0ff5).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task
cancelOrFailAndCancelInvokableInternal'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Task CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine
(GroupCombine at GroupCombine: assert_that/Group/CoGroupByKeyImpl/GroupByKey)
-> Map (Key Extractor) (7/16)#0 is already in state FINISHED'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task failExternally'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Attempting to fail task externally CHAIN Filter (UnionFixFilter) -> Map (Key
Extractor) -> GroupCombine (GroupCombine at GroupCombine:
assert_that/Group/CoGroupByKeyImpl/GroupByKey) -> Map (Key Extractor) (8/16)#0
(08df620765ee4ee17af1a0352924e85d).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task
cancelOrFailAndCancelInvokableInternal'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Task CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine
(GroupCombine at GroupCombine: assert_that/Group/CoGroupByKeyImpl/GroupByKey)
-> Map (Key Extractor) (8/16)#0 is already in state FINISHED'
> Task :sdks:python:test-suites:portable:py36:postCommitPy36IT
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Attempting to fail task externally CHAIN Filter (UnionFixFilter) -> Map (Key
Extractor) -> GroupCombine (GroupCombine at GroupCombine:
assert_that/Group/CoGroupByKeyImpl/GroupByKey) -> Map (Key Extractor) (5/16)#0
(497954eb72fd0bde53f30047a3fe1062).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task
cancelOrFailAndCancelInvokableInternal'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Task CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine
(GroupCombine at GroupCombine: assert_that/Group/CoGroupByKeyImpl/GroupByKey)
-> Map (Key Extractor) (5/16)#0 is already in state FINISHED'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task failExternally'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Attempting to fail task externally CHAIN Filter (UnionFixFilter) -> Map (Key
Extractor) -> GroupCombine (GroupCombine at GroupCombine:
assert_that/Group/CoGroupByKeyImpl/GroupByKey) -> Map (Key Extractor) (1/16)#0
(5fd8b1e654793da28bef8bc1e176b52a).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task
cancelOrFailAndCancelInvokableInternal'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Task CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine
(GroupCombine at GroupCombine: assert_that/Group/CoGroupByKeyImpl/GroupByKey)
-> Map (Key Extractor) (1/16)#0 is already in state FINISHED'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task failExternally'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Attempting to fail task externally CHAIN Filter (UnionFixFilter) -> Map (Key
Extractor) -> GroupCombine (GroupCombine at GroupCombine:
assert_that/Group/CoGroupByKeyImpl/GroupByKey) -> Map (Key Extractor) (1/16)#0
(5fd8b1e654793da28bef8bc1e176b52a).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task
cancelOrFailAndCancelInvokableInternal'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Task CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine
(GroupCombine at GroupCombine: assert_that/Group/CoGroupByKeyImpl/GroupByKey)
-> Map (Key Extractor) (1/16)#0 is already in state FINISHED'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task failExternally'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Attempting to fail task externally CHAIN Filter (UnionFixFilter) -> Map (Key
Extractor) -> GroupCombine (GroupCombine at GroupCombine:
assert_that/Group/CoGroupByKeyImpl/GroupByKey) -> Map (Key Extractor) (2/16)#0
(f168944e8fc3ab603a48d6eb7c758cb7).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task
cancelOrFailAndCancelInvokableInternal'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Task CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine
(GroupCombine at GroupCombine: assert_that/Group/CoGroupByKeyImpl/GroupByKey)
-> Map (Key Extractor) (2/16)#0 is already in state FINISHED'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task failExternally'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Attempting to fail task externally CHAIN Filter (UnionFixFilter) -> Map (Key
Extractor) -> GroupCombine (GroupCombine at GroupCombine:
assert_that/Group/CoGroupByKeyImpl/GroupByKey) -> Map (Key Extractor) (2/16)#0
(f168944e8fc3ab603a48d6eb7c758cb7).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task
cancelOrFailAndCancelInvokableInternal'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Task CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine
(GroupCombine at GroupCombine: assert_that/Group/CoGroupByKeyImpl/GroupByKey)
-> Map (Key Extractor) (2/16)#0 is already in state FINISHED'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task failExternally'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Attempting to fail task externally CHAIN Filter (UnionFixFilter) -> Map (Key
Extractor) -> GroupCombine (GroupCombine at GroupCombine:
assert_that/Group/CoGroupByKeyImpl/GroupByKey) -> Map (Key Extractor) (6/16)#0
(a31874960462646a40f160da2b9c22f5).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 6:11:31 AM org.apache.flink.runtime.taskmanager.Task
cancelOrFailAndCancelInvokableInternal'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Task CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine
(GroupCombine at GroupCombine: assert_that/Group/CoGroupByKeyImpl/GroupByKey)
-> Map (Key Extractor) (6/16)#0 is already in state FINISHED'
java.lang.OutOfMemoryError: GC overhead limit exceeded
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
