See
<https://ci-beam.apache.org/job/beam_PostCommit_Python36/4950/display/redirect?page=changes>
Changes:
[noreply] Minor: Add 2.38.0 section to CHANGES.md (#16804)
------------------------------------------
[...truncated 28.57 MB...]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:18 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSink (DiscardingOutput) (14/16)#0 (dd783930b1ed185fd8bab1b2d4d2c628)
switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:18 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Received task DataSink (DiscardingOutput) (16/16)#0
(14feaca5259459a384f136cd018ce452), deploy into slot with allocation id
cb540384f980d6da23425e3aea9e1968.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:18 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSink (DiscardingOutput) (14/16) (dd783930b1ed185fd8bab1b2d4d2c628) switched
from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:18 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSink (DiscardingOutput) (15/16)#0 (a4cf02654bceb4627a9cb3d71fd30edf)
switched from CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:18 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Loading JAR files for task DataSink (DiscardingOutput) (15/16)#0
(a4cf02654bceb4627a9cb3d71fd30edf) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:18 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSink (DiscardingOutput) (15/16)#0 (a4cf02654bceb4627a9cb3d71fd30edf)
switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:18 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSink (DiscardingOutput) (15/16)#0 (a4cf02654bceb4627a9cb3d71fd30edf)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:18 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSink (DiscardingOutput) (15/16) (a4cf02654bceb4627a9cb3d71fd30edf) switched
from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:18 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSink (DiscardingOutput) (14/16)#0 (dd783930b1ed185fd8bab1b2d4d2c628)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:18 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSink (DiscardingOutput) (15/16) (a4cf02654bceb4627a9cb3d71fd30edf) switched
from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:18 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSink (DiscardingOutput) (14/16) (dd783930b1ed185fd8bab1b2d4d2c628) switched
from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:18 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory
createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO:
The AWS S3 Beam extension was included in this build, but the awsRegion flag
was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:18 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory
createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO:
The AWS S3 Beam extension was included in this build, but the awsRegion flag
was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:18 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Activate slot b7bbd9c54c7e0d26404f6437fa9aa604.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:18 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Activate slot b96056c207d15d959be1080e7c6cb0a4.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:18 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Activate slot b14af902e3a3b78ab8544d24eeb1fc82.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:18 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Activate slot f8e0a540f8ebd49ad4fc362767a96020.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:18 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Activate slot cb540384f980d6da23425e3aea9e1968.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:18 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Activate slot 64d10e5b14d4f3484619828be4a2c629.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:18 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Activate slot d66e392c0b38f3ba49f2e32e7bedb8a1.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:18 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Activate slot edfdae7d8d23d9984a2ad14c3380a54c.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:18 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Activate slot 3225538121ba6d70bbcd5ceb49de0c67.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:18 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Activate slot 69792d6aae7bbaf5dc1e5c36fed938bd.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:18 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Activate slot b2e464a31eb57d5175a81b45fb8f8576.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:18 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Activate slot 77605e85f5983ef54817217f105c5545.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:18 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Activate slot ea61e7af5f167b4f31cc6c9bc6b32d69.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:18 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Activate slot 676063c744d7f95f81b7cf2670439147.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:18 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Activate slot 747a550cdd295384f4e985e44ecdb105.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:18 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Activate slot 3319fdf2773497bd6c911a1e00032a70.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:18 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSink (DiscardingOutput) (16/16)#0 (14feaca5259459a384f136cd018ce452)
switched from CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:18 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Loading JAR files for task DataSink (DiscardingOutput) (16/16)#0
(14feaca5259459a384f136cd018ce452) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:18 PM 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 DataSource (Impulse) (7/16)#0 4ca69e82c84507168d0e9a21659c3862.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:18 PM 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 DataSource (Impulse) (9/16)#0 9da21717b3f02140b16bf4079b1700df.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:18 PM 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 DataSource (Impulse) (8/16)#0 97448cc58b9c1564b2b3d6a402bc6d13.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:18 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSource (Impulse) (7/16) (4ca69e82c84507168d0e9a21659c3862) switched from
RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:18 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSource (Impulse) (9/16) (9da21717b3f02140b16bf4079b1700df) switched from
RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:18 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSink (DiscardingOutput) (16/16)#0 (14feaca5259459a384f136cd018ce452)
switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:18 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSink (DiscardingOutput) (16/16)#0 (14feaca5259459a384f136cd018ce452)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:18 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSink (DiscardingOutput) (16/16) (14feaca5259459a384f136cd018ce452) switched
from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:18 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSink (DiscardingOutput) (16/16) (14feaca5259459a384f136cd018ce452) switched
from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:18 PM 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 DataSource (Impulse) (6/16)#0 90ca9d699687d52c3c56f9a15404ad83.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:18 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSource (Impulse) (8/16) (97448cc58b9c1564b2b3d6a402bc6d13) switched from
RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:18 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory
createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO:
The AWS S3 Beam extension was included in this build, but the awsRegion flag
was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:18 PM 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 DataSource (Impulse) (3/16)#0 997e4d8062d69faf51fdc65e704722c4.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:18 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSource (Impulse) (6/16) (90ca9d699687d52c3c56f9a15404ad83) switched from
RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:18 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSource (Impulse) (3/16) (997e4d8062d69faf51fdc65e704722c4) switched from
RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:18 PM 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 DataSource (Impulse) (1/16)#0 2a76fdf240dfb9ca5f90235e2334a622.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:18 PM 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 DataSource (Impulse) (5/16)#0 8fea03df41768f07e0dc90a6d9126664.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:18 PM 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 DataSource (Impulse) (2/16)#0 33580459cc940dec6db9f22ed87b327d.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:18 PM 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 DataSource (Impulse) (4/16)#0 9bd3635bba4bfc70d9b45bbac9219d62.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:18 PM 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 DataSource (Impulse) (10/16)#0 c5689722f2f2d2c10128b818fc304f46.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:18 PM 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 DataSource (Impulse) (11/16)#0 eba3b5fc92523191bc80ff6ad1a39d44.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:18 PM 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 DataSource (Impulse) (12/16)#0 50f12829c3d8e3cf691c5c68aa51ccd5.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:18 PM 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 DataSource (Impulse) (13/16)#0 b95bb4c3b618f736da5113addbc944bb.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:18 PM 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 DataSource (Impulse) (14/16)#0 3a82fbf7a297987e48b509931cde107e.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:18 PM 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 DataSource (Impulse) (15/16)#0 b6d4b0b3f8f25d024c5775079a557cb4.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:18 PM 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 DataSource (Impulse) (16/16)#0 dfb3399df6dd02a22c626ba77cf8b382.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:18 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSource (Impulse) (1/16) (2a76fdf240dfb9ca5f90235e2334a622) switched from
RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:18 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSource (Impulse) (5/16) (8fea03df41768f07e0dc90a6d9126664) switched from
RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:18 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSource (Impulse) (2/16) (33580459cc940dec6db9f22ed87b327d) switched from
RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:18 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSource (Impulse) (4/16) (9bd3635bba4bfc70d9b45bbac9219d62) switched from
RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:18 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSource (Impulse) (10/16) (c5689722f2f2d2c10128b818fc304f46) switched from
RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:18 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSource (Impulse) (11/16) (eba3b5fc92523191bc80ff6ad1a39d44) switched from
RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:18 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSource (Impulse) (12/16) (50f12829c3d8e3cf691c5c68aa51ccd5) switched from
RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:18 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSource (Impulse) (13/16) (b95bb4c3b618f736da5113addbc944bb) switched from
RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:18 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSource (Impulse) (14/16) (3a82fbf7a297987e48b509931cde107e) switched from
RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:18 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSource (Impulse) (15/16) (b6d4b0b3f8f25d024c5775079a557cb4) switched from
RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:18 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSource (Impulse) (16/16) (dfb3399df6dd02a22c626ba77cf8b382) switched from
RUNNING to FINISHED.'
INFO apache_beam.runners.worker.statecache:statecache.py:172 Creating state
cache with size 0
INFO apache_beam.runners.worker.sdk_worker:sdk_worker.py:164 Creating
insecure control channel for localhost:34199.
INFO apache_beam.runners.worker.sdk_worker:sdk_worker.py:172 Control
channel established.
INFO apache_beam.runners.worker.sdk_worker:sdk_worker.py:215 Initializing
SDKHarness with unbounded number of workers.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:19 PM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
control'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Beam Fn Control client connected with id 1-1'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:19 PM org.apache.beam.runners.fnexecution.environment.DockerCommand
runImage'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b"WARNING: Unable to pull docker image apache/beam_java8_sdk:2.38.0.dev, cause:
Received exit code 1 for command 'docker pull
apache/beam_java8_sdk:2.38.0.dev'. stderr: Error response from daemon: manifest
for apache/beam_java8_sdk:2.38.0.dev not found"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:19 PM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
getProcessBundleDescriptor request with id 1-16'
INFO apache_beam.runners.worker.sdk_worker:sdk_worker.py:807 Creating
insecure state channel for localhost:34831.
INFO apache_beam.runners.worker.sdk_worker:sdk_worker.py:814 State channel
established.
INFO apache_beam.runners.worker.data_plane:data_plane.py:750 Creating
client data channel for localhost:37723
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:19 PM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
getProcessBundleDescriptor request with id 1-20'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:19 PM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
getProcessBundleDescriptor request with id 1-7'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:19 PM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
getProcessBundleDescriptor request with id 1-34'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:19 PM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
getProcessBundleDescriptor request with id 1-4'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:19 PM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
getProcessBundleDescriptor request with id 1-28'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:19 PM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
getProcessBundleDescriptor request with id 1-10'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:19 PM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
getProcessBundleDescriptor request with id 1-18'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:19 PM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
getProcessBundleDescriptor request with id 1-11'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:19 PM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
getProcessBundleDescriptor request with id 1-19'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:19 PM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
getProcessBundleDescriptor request with id 1-17'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:19 PM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
getProcessBundleDescriptor request with id 1-15'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:19 PM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
getProcessBundleDescriptor request with id 1-25'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:19 PM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
getProcessBundleDescriptor request with id 1-32'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:19 PM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
getProcessBundleDescriptor request with id 1-21'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:19 PM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
getProcessBundleDescriptor request with id 1-22'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:19 PM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
getProcessBundleDescriptor request with id 1-3'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:19 PM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
getProcessBundleDescriptor request with id 1-31'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:19 PM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
getProcessBundleDescriptor request with id 1-5'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:19 PM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
getProcessBundleDescriptor request with id 1-33'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:19 PM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
getProcessBundleDescriptor request with id 1-26'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:19 PM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
getProcessBundleDescriptor request with id 1-6'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:19 PM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
getProcessBundleDescriptor request with id 1-27'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:19 PM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
getProcessBundleDescriptor request with id 1-14'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:19 PM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
getProcessBundleDescriptor request with id 1-8'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:19 PM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
getProcessBundleDescriptor request with id 1-12'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:19 PM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
getProcessBundleDescriptor request with id 1-9'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:19 PM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
getProcessBundleDescriptor request with id 1-30'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:19 PM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
getProcessBundleDescriptor request with id 1-29'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:19 PM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
getProcessBundleDescriptor request with id 1-23'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:19 PM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
getProcessBundleDescriptor request with id 1-13'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:19 PM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
getProcessBundleDescriptor request with id 1-24'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:19 PM org.apache.beam.runners.fnexecution.data.GrpcDataService data'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Beam Fn Data client connected.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:19 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [1]Create/FlatMap(<lambda at
core.py:3228>)) -> FlatMap (FlatMap at ExtractOutput[0]) (4/16)#0
(7e71f476f993ab0e313b643ae5c78032) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:19 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Freeing task resources for CHAIN MapPartition (MapPartition at
[1]Create/FlatMap(<lambda at core.py:3228>)) -> FlatMap (FlatMap at
ExtractOutput[0]) (4/16)#0 (7e71f476f993ab0e313b643ae5c78032).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:19 PM 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 CHAIN MapPartition (MapPartition at [1]Create/FlatMap(<lambda at
core.py:3228>)) -> FlatMap (FlatMap at ExtractOutput[0]) (4/16)#0
7e71f476f993ab0e313b643ae5c78032.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 10,
2022 6:15:19 PM org.apache.flink.runtime.taskmanager.Task
transitionState'FATAL: command execution failed
java.io.IOException: Backing channel 'apache-beam-jenkins-11' is disconnected.
at
hudson.remoting.RemoteInvocationHandler.channelOrFail(RemoteInvocationHandler.java:216)
at
hudson.remoting.RemoteInvocationHandler.invoke(RemoteInvocationHandler.java:286)
at com.sun.proxy.$Proxy133.isAlive(Unknown Source)
at hudson.Launcher$RemoteLauncher$ProcImpl.isAlive(Launcher.java:1211)
at hudson.Launcher$RemoteLauncher$ProcImpl.join(Launcher.java:1203)
at hudson.Launcher$ProcStarter.join(Launcher.java:523)
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:803)
at hudson.model.Build$BuildExecution.build(Build.java:197)
at hudson.model.Build$BuildExecution.doRun(Build.java:163)
at
hudson.model.AbstractBuild$AbstractBuildExecution.run(AbstractBuild.java:513)
at hudson.model.Run.execute(Run.java:1906)
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.io.IOException: Pipe closed after 0 cycles
at
org.apache.sshd.common.channel.ChannelPipedInputStream.read(ChannelPipedInputStream.java:118)
at
org.apache.sshd.common.channel.ChannelPipedInputStream.read(ChannelPipedInputStream.java:101)
at
hudson.remoting.FlightRecorderInputStream.read(FlightRecorderInputStream.java:93)
at
hudson.remoting.ChunkedInputStream.readHeader(ChunkedInputStream.java:74)
at
hudson.remoting.ChunkedInputStream.readUntilBreak(ChunkedInputStream.java:104)
at
hudson.remoting.ChunkedCommandTransport.readBlock(ChunkedCommandTransport.java:39)
at
hudson.remoting.AbstractSynchronousByteArrayCommandTransport.read(AbstractSynchronousByteArrayCommandTransport.java:34)
at
hudson.remoting.SynchronousCommandTransport$ReaderThread.run(SynchronousCommandTransport.java:61)
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
ERROR: apache-beam-jenkins-11 is offline; cannot locate jdk_1.8_latest
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
