See
<https://ci-beam.apache.org/job/beam_PreCommit_Portable_Python_Cron/5695/display/redirect?page=changes>
Changes:
[Moritz Mack] [Spark Dataset runner] Enable projection pushdown for Spark
dataset
[noreply] Fix dependency mismatch in Playground Java runner (#24059)
------------------------------------------
[...truncated 2.14 MB...]
INFO:apache_beam.utils.subprocess_server:Nov 09, 2022 4:45:11 PM
org.apache.flink.runtime.taskmanager.Task doRun
INFO:apache_beam.utils.subprocess_server:INFO: Freeing task resources for
GroupAndSum/GroupByKey -> [3]{GroupAndSum, Format, Write} (2/2)#0
(77463a4d507fad26275e3753aaacca12).
INFO:apache_beam.utils.subprocess_server:Nov 09, 2022 4:45:11 PM
org.apache.flink.runtime.taskmanager.Task transitionState
INFO:apache_beam.utils.subprocess_server:INFO: GroupAndSum/GroupByKey ->
[3]{GroupAndSum, Format, Write} (1/2)#0 (7e0e7e7f8b0e3558f884cb4e46ca3eb3)
switched from RUNNING to FINISHED.
INFO:apache_beam.utils.subprocess_server:Nov 09, 2022 4:45:11 PM
org.apache.flink.runtime.taskmanager.Task doRun
INFO:apache_beam.utils.subprocess_server:INFO: Freeing task resources for
GroupAndSum/GroupByKey -> [3]{GroupAndSum, Format, Write} (1/2)#0
(7e0e7e7f8b0e3558f884cb4e46ca3eb3).
INFO:apache_beam.utils.subprocess_server:Nov 09, 2022 4:45:11 PM
org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO:apache_beam.utils.subprocess_server:INFO: Un-registering task and sending
final execution state FINISHED to JobManager for task GroupAndSum/GroupByKey ->
[3]{GroupAndSum, Format, Write} (1/2)#0 7e0e7e7f8b0e3558f884cb4e46ca3eb3.
INFO:apache_beam.utils.subprocess_server:Nov 09, 2022 4:45:11 PM
org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO:apache_beam.utils.subprocess_server:INFO: Un-registering task and sending
final execution state FINISHED to JobManager for task GroupAndSum/GroupByKey ->
[3]{GroupAndSum, Format, Write} (2/2)#0 77463a4d507fad26275e3753aaacca12.
INFO:apache_beam.utils.subprocess_server:Nov 09, 2022 4:45:11 PM
org.apache.flink.runtime.executiongraph.Execution transitionState
INFO:apache_beam.utils.subprocess_server:INFO: GroupAndSum/GroupByKey ->
[3]{GroupAndSum, Format, Write} (1/2) (7e0e7e7f8b0e3558f884cb4e46ca3eb3)
switched from RUNNING to FINISHED.
INFO:apache_beam.utils.subprocess_server:Nov 09, 2022 4:45:11 PM
org.apache.flink.runtime.executiongraph.Execution transitionState
INFO:apache_beam.utils.subprocess_server:INFO: GroupAndSum/GroupByKey ->
[3]{GroupAndSum, Format, Write} (2/2) (77463a4d507fad26275e3753aaacca12)
switched from RUNNING to FINISHED.
INFO:apache_beam.utils.subprocess_server:Nov 09, 2022 4:45:11 PM
org.apache.flink.runtime.taskmanager.Task transitionState
INFO:apache_beam.utils.subprocess_server:INFO:
[2]Write/Write/WriteImpl/{WriteBundles, Pair} -> ToKeyedWorkItem (2/2)#0
(6ebae96ae99fa0dfec892551114ae8d5) switched from RUNNING to FINISHED.
INFO:apache_beam.utils.subprocess_server:Nov 09, 2022 4:45:11 PM
org.apache.flink.runtime.taskmanager.Task doRun
INFO:apache_beam.utils.subprocess_server:INFO: Freeing task resources for
[2]Write/Write/WriteImpl/{WriteBundles, Pair} -> ToKeyedWorkItem (2/2)#0
(6ebae96ae99fa0dfec892551114ae8d5).
INFO:apache_beam.utils.subprocess_server:Nov 09, 2022 4:45:11 PM
org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO:apache_beam.utils.subprocess_server:INFO: Un-registering task and sending
final execution state FINISHED to JobManager for task
[2]Write/Write/WriteImpl/{WriteBundles, Pair} -> ToKeyedWorkItem (2/2)#0
6ebae96ae99fa0dfec892551114ae8d5.
INFO:apache_beam.utils.subprocess_server:Nov 09, 2022 4:45:11 PM
org.apache.flink.runtime.executiongraph.Execution transitionState
INFO:apache_beam.utils.subprocess_server:INFO:
[2]Write/Write/WriteImpl/{WriteBundles, Pair} -> ToKeyedWorkItem (2/2)
(6ebae96ae99fa0dfec892551114ae8d5) switched from RUNNING to FINISHED.
INFO:apache_beam.utils.subprocess_server:Nov 09, 2022 4:45:11 PM
org.apache.flink.runtime.taskmanager.Task transitionState
INFO:apache_beam.utils.subprocess_server:INFO:
[2]Write/Write/WriteImpl/{WriteBundles, Pair} -> ToKeyedWorkItem (1/2)#0
(28e06812b75b9d54974073adf77b1cd5) switched from RUNNING to FINISHED.
INFO:apache_beam.utils.subprocess_server:Nov 09, 2022 4:45:11 PM
org.apache.flink.runtime.taskmanager.Task doRun
INFO:apache_beam.utils.subprocess_server:INFO: Freeing task resources for
[2]Write/Write/WriteImpl/{WriteBundles, Pair} -> ToKeyedWorkItem (1/2)#0
(28e06812b75b9d54974073adf77b1cd5).
INFO:apache_beam.utils.subprocess_server:Nov 09, 2022 4:45:11 PM
org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO:apache_beam.utils.subprocess_server:INFO: Un-registering task and sending
final execution state FINISHED to JobManager for task
[2]Write/Write/WriteImpl/{WriteBundles, Pair} -> ToKeyedWorkItem (1/2)#0
28e06812b75b9d54974073adf77b1cd5.
INFO:apache_beam.utils.subprocess_server:Nov 09, 2022 4:45:11 PM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor
INFO:apache_beam.utils.subprocess_server:INFO: getProcessBundleDescriptor
request with id 1-14
INFO:apache_beam.utils.subprocess_server:Nov 09, 2022 4:45:11 PM
org.apache.flink.runtime.taskmanager.Task transitionState
INFO:apache_beam.utils.subprocess_server:INFO: Write/Write/WriteImpl/GroupByKey
-> [1]Write/Write/WriteImpl/Extract -> (Map -> ToKeyedWorkItem, Map ->
ToKeyedWorkItem) (2/2)#0 (b7633015552fab29eb6bd005b1c566a4) switched from
RUNNING to FINISHED.
INFO:apache_beam.utils.subprocess_server:Nov 09, 2022 4:45:11 PM
org.apache.flink.runtime.taskmanager.Task doRun
INFO:apache_beam.utils.subprocess_server:INFO: Freeing task resources for
Write/Write/WriteImpl/GroupByKey -> [1]Write/Write/WriteImpl/Extract -> (Map ->
ToKeyedWorkItem, Map -> ToKeyedWorkItem) (2/2)#0
(b7633015552fab29eb6bd005b1c566a4).
INFO:apache_beam.utils.subprocess_server:Nov 09, 2022 4:45:11 PM
org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO:apache_beam.utils.subprocess_server:INFO: Un-registering task and sending
final execution state FINISHED to JobManager for task
Write/Write/WriteImpl/GroupByKey -> [1]Write/Write/WriteImpl/Extract -> (Map ->
ToKeyedWorkItem, Map -> ToKeyedWorkItem) (2/2)#0
b7633015552fab29eb6bd005b1c566a4.
INFO:apache_beam.utils.subprocess_server:Nov 09, 2022 4:45:11 PM
org.apache.flink.runtime.executiongraph.Execution transitionState
INFO:apache_beam.utils.subprocess_server:INFO:
[2]Write/Write/WriteImpl/{WriteBundles, Pair} -> ToKeyedWorkItem (1/2)
(28e06812b75b9d54974073adf77b1cd5) switched from RUNNING to FINISHED.
INFO:apache_beam.utils.subprocess_server:Nov 09, 2022 4:45:11 PM
org.apache.flink.runtime.executiongraph.Execution transitionState
INFO:apache_beam.utils.subprocess_server:INFO: Write/Write/WriteImpl/GroupByKey
-> [1]Write/Write/WriteImpl/Extract -> (Map -> ToKeyedWorkItem, Map ->
ToKeyedWorkItem) (2/2) (b7633015552fab29eb6bd005b1c566a4) switched from RUNNING
to FINISHED.
INFO:apache_beam.utils.subprocess_server:Nov 09, 2022 4:45:11 PM
org.apache.flink.api.java.typeutils.runtime.kryo.KryoSerializer getKryoInstance
INFO:apache_beam.utils.subprocess_server:INFO: Kryo serializer scala extensions
are not available.
INFO:apache_beam.utils.subprocess_server:Nov 09, 2022 4:45:11 PM
org.apache.flink.api.java.typeutils.runtime.kryo.KryoSerializer getKryoInstance
INFO:apache_beam.utils.subprocess_server:INFO: Kryo serializer scala extensions
are not available.
INFO:apache_beam.utils.subprocess_server:Nov 09, 2022 4:45:11 PM
org.apache.flink.runtime.blob.AbstractBlobCache close
INFO:apache_beam.utils.subprocess_server:INFO: Shutting down BLOB cache
INFO:apache_beam.utils.subprocess_server:Nov 09, 2022 4:45:11 PM
org.apache.flink.runtime.taskmanager.Task transitionState
INFO:apache_beam.utils.subprocess_server:INFO:
ref_AppliedPTransform_Write-Write-WriteImpl-PreFinalize_29-python_side_input1
-> Map (1/2)#0 (6de28633b675fe691fc1360274e97e7a) switched from RUNNING to
FINISHED.
INFO:apache_beam.utils.subprocess_server:Nov 09, 2022 4:45:11 PM
org.apache.flink.runtime.taskmanager.Task doRun
INFO:apache_beam.utils.subprocess_server:INFO: Freeing task resources for
ref_AppliedPTransform_Write-Write-WriteImpl-PreFinalize_29-python_side_input1
-> Map (1/2)#0 (6de28633b675fe691fc1360274e97e7a).
INFO:apache_beam.utils.subprocess_server:Nov 09, 2022 4:45:11 PM
org.apache.flink.runtime.taskmanager.Task transitionState
INFO:apache_beam.utils.subprocess_server:INFO:
ref_AppliedPTransform_Write-Write-WriteImpl-PreFinalize_29-python_side_input1
-> Map (2/2)#0 (a3573355fe7c5841b66f9fc030641942) switched from RUNNING to
FINISHED.
INFO:apache_beam.utils.subprocess_server:Nov 09, 2022 4:45:11 PM
org.apache.flink.runtime.taskmanager.Task doRun
INFO:apache_beam.utils.subprocess_server:INFO: Freeing task resources for
ref_AppliedPTransform_Write-Write-WriteImpl-PreFinalize_29-python_side_input1
-> Map (2/2)#0 (a3573355fe7c5841b66f9fc030641942).
INFO:apache_beam.utils.subprocess_server:Nov 09, 2022 4:45:11 PM
org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO:apache_beam.utils.subprocess_server:INFO: Un-registering task and sending
final execution state FINISHED to JobManager for task
ref_AppliedPTransform_Write-Write-WriteImpl-PreFinalize_29-python_side_input1
-> Map (1/2)#0 6de28633b675fe691fc1360274e97e7a.
INFO:apache_beam.utils.subprocess_server:Nov 09, 2022 4:45:11 PM
org.apache.flink.runtime.taskmanager.Task transitionState
INFO:apache_beam.utils.subprocess_server:INFO:
ref_AppliedPTransform_Write-Write-WriteImpl-FinalizeWrite_30-python_side_input1
-> Map (1/2)#0 (4b5cfd1c621d697277fee5cbd114b497) switched from RUNNING to
FINISHED.
INFO:apache_beam.utils.subprocess_server:Nov 09, 2022 4:45:11 PM
org.apache.flink.runtime.taskmanager.Task doRun
INFO:apache_beam.utils.subprocess_server:INFO: Freeing task resources for
ref_AppliedPTransform_Write-Write-WriteImpl-FinalizeWrite_30-python_side_input1
-> Map (1/2)#0 (4b5cfd1c621d697277fee5cbd114b497).
INFO:apache_beam.utils.subprocess_server:Nov 09, 2022 4:45:11 PM
org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO:apache_beam.utils.subprocess_server:INFO: Un-registering task and sending
final execution state FINISHED to JobManager for task
ref_AppliedPTransform_Write-Write-WriteImpl-PreFinalize_29-python_side_input1
-> Map (2/2)#0 a3573355fe7c5841b66f9fc030641942.
INFO:apache_beam.utils.subprocess_server:Nov 09, 2022 4:45:11 PM
org.apache.flink.runtime.executiongraph.Execution transitionState
INFO:apache_beam.utils.subprocess_server:INFO:
ref_AppliedPTransform_Write-Write-WriteImpl-PreFinalize_29-python_side_input1
-> Map (1/2) (6de28633b675fe691fc1360274e97e7a) switched from RUNNING to
FINISHED.
INFO:apache_beam.utils.subprocess_server:Nov 09, 2022 4:45:11 PM
org.apache.flink.runtime.taskmanager.Task transitionState
INFO:apache_beam.utils.subprocess_server:INFO: Write/Write/WriteImpl/GroupByKey
-> [1]Write/Write/WriteImpl/Extract -> (Map -> ToKeyedWorkItem, Map ->
ToKeyedWorkItem) (1/2)#0 (179048bf4fb0b63852426d1acd7a6b22) switched from
RUNNING to FINISHED.
INFO:apache_beam.utils.subprocess_server:Nov 09, 2022 4:45:11 PM
org.apache.flink.runtime.taskmanager.Task transitionState
INFO:apache_beam.utils.subprocess_server:INFO:
ref_AppliedPTransform_Write-Write-WriteImpl-FinalizeWrite_30-python_side_input1
-> Map (2/2)#0 (26b8adc16b6d5455d02fd4e085b26cda) switched from RUNNING to
FINISHED.
INFO:apache_beam.utils.subprocess_server:Nov 09, 2022 4:45:11 PM
org.apache.flink.runtime.taskmanager.Task doRun
INFO:apache_beam.utils.subprocess_server:INFO: Freeing task resources for
ref_AppliedPTransform_Write-Write-WriteImpl-FinalizeWrite_30-python_side_input1
-> Map (2/2)#0 (26b8adc16b6d5455d02fd4e085b26cda).
INFO:apache_beam.utils.subprocess_server:Nov 09, 2022 4:45:11 PM
org.apache.flink.runtime.taskmanager.Task doRun
INFO:apache_beam.utils.subprocess_server:INFO: Freeing task resources for
Write/Write/WriteImpl/GroupByKey -> [1]Write/Write/WriteImpl/Extract -> (Map ->
ToKeyedWorkItem, Map -> ToKeyedWorkItem) (1/2)#0
(179048bf4fb0b63852426d1acd7a6b22).
INFO:apache_beam.utils.subprocess_server:Nov 09, 2022 4:45:11 PM
org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO:apache_beam.utils.subprocess_server:INFO: Un-registering task and sending
final execution state FINISHED to JobManager for task
ref_AppliedPTransform_Write-Write-WriteImpl-FinalizeWrite_30-python_side_input1
-> Map (1/2)#0 4b5cfd1c621d697277fee5cbd114b497.
INFO:apache_beam.utils.subprocess_server:Nov 09, 2022 4:45:12 PM
org.apache.flink.runtime.io.disk.FileChannelManagerImpl lambda$getFileCloser$0
INFO:apache_beam.utils.subprocess_server:INFO: FileChannelManager removed spill
file directory /tmp/flink-netty-shuffle-a754afc9-75ad-4c1e-a3e4-3f901f6795a4
INFO:apache_beam.utils.subprocess_server:Nov 09, 2022 4:45:12 PM
org.apache.flink.runtime.executiongraph.Execution transitionState
INFO:apache_beam.utils.subprocess_server:INFO:
ref_AppliedPTransform_Write-Write-WriteImpl-PreFinalize_29-python_side_input1
-> Map (2/2) (a3573355fe7c5841b66f9fc030641942) switched from RUNNING to
FINISHED.
INFO:apache_beam.utils.subprocess_server:Nov 09, 2022 4:45:12 PM
org.apache.flink.runtime.executiongraph.Execution transitionState
INFO:apache_beam.utils.subprocess_server:INFO:
ref_AppliedPTransform_Write-Write-WriteImpl-FinalizeWrite_30-python_side_input1
-> Map (1/2) (4b5cfd1c621d697277fee5cbd114b497) switched from RUNNING to
FINISHED.
INFO:apache_beam.utils.subprocess_server:Nov 09, 2022 4:45:12 PM
org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO:apache_beam.utils.subprocess_server:INFO: Un-registering task and sending
final execution state FINISHED to JobManager for task
ref_AppliedPTransform_Write-Write-WriteImpl-FinalizeWrite_30-python_side_input1
-> Map (2/2)#0 26b8adc16b6d5455d02fd4e085b26cda.
INFO:apache_beam.utils.subprocess_server:Nov 09, 2022 4:45:12 PM
org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO:apache_beam.utils.subprocess_server:INFO: Un-registering task and sending
final execution state FINISHED to JobManager for task
Write/Write/WriteImpl/GroupByKey -> [1]Write/Write/WriteImpl/Extract -> (Map ->
ToKeyedWorkItem, Map -> ToKeyedWorkItem) (1/2)#0
179048bf4fb0b63852426d1acd7a6b22.
INFO:apache_beam.utils.subprocess_server:Nov 09, 2022 4:45:12 PM
org.apache.flink.runtime.executiongraph.Execution transitionState
INFO:apache_beam.utils.subprocess_server:INFO:
ref_AppliedPTransform_Write-Write-WriteImpl-FinalizeWrite_30-python_side_input1
-> Map (2/2) (26b8adc16b6d5455d02fd4e085b26cda) switched from RUNNING to
FINISHED.
INFO:apache_beam.utils.subprocess_server:Nov 09, 2022 4:45:12 PM
org.apache.flink.runtime.executiongraph.Execution transitionState
INFO:apache_beam.utils.subprocess_server:INFO: Write/Write/WriteImpl/GroupByKey
-> [1]Write/Write/WriteImpl/Extract -> (Map -> ToKeyedWorkItem, Map ->
ToKeyedWorkItem) (1/2) (179048bf4fb0b63852426d1acd7a6b22) switched from RUNNING
to FINISHED.
INFO:apache_beam.utils.subprocess_server:Nov 09, 2022 4:45:12 PM
org.apache.flink.runtime.blob.AbstractBlobCache close
INFO:apache_beam.utils.subprocess_server:INFO: Shutting down BLOB cache
INFO:apache_beam.utils.subprocess_server:Nov 09, 2022 4:45:12 PM
org.apache.flink.runtime.state.TaskExecutorStateChangelogStoragesManager
shutdown
INFO:apache_beam.utils.subprocess_server:INFO: Shutting down
TaskExecutorStateChangelogStoragesManager.
INFO:apache_beam.utils.subprocess_server:Nov 09, 2022 4:45:12 PM
org.apache.flink.runtime.io.disk.FileChannelManagerImpl lambda$getFileCloser$0
INFO:apache_beam.utils.subprocess_server:INFO: FileChannelManager removed spill
file directory /tmp/flink-io-a66178a1-f22c-4d14-9995-e10ddc22aeba
INFO:apache_beam.utils.subprocess_server:Nov 09, 2022 4:45:12 PM
org.apache.flink.runtime.filecache.FileCache shutdown
INFO:apache_beam.utils.subprocess_server:INFO: removed file cache directory
/tmp/flink-dist-cache-4fb1f894-2c2c-4ebc-8f65-9ec73143144c
INFO:apache_beam.utils.subprocess_server:Nov 09, 2022 4:45:12 PM
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager shutdown
INFO:apache_beam.utils.subprocess_server:INFO: Shutting down
TaskExecutorLocalStateStoresManager.
Exception in thread wait_until_finish_read:
Traceback (most recent call last):
Exception in thread read_state:
Traceback (most recent call last):
File "/usr/lib/python3.10/threading.py", line 1009, in _bootstrap_inner
Exception in thread run_worker_1-1:
Traceback (most recent call last):
Traceback (most recent call last):
File "/usr/lib/python3.10/runpy.py", line 196, in _run_module_as_main
self.run()
File "/usr/lib/python3.10/threading.py", line 946, in run
File "/usr/lib/python3.10/threading.py", line 1009, in _bootstrap_inner
ERROR:apache_beam.runners.worker.data_plane:Failed to read inputs in the data
plane.
Traceback (most recent call last):
File
"<https://ci-beam.apache.org/job/beam_PreCommit_Portable_Python_Cron/ws/src/build/gradleenv/-1720702907/lib/python3.10/site-packages/apache_beam/runners/worker/data_plane.py";,>
line 654, in _read_inputs
for elements in elements_iterator:
File
"<https://ci-beam.apache.org/job/beam_PreCommit_Portable_Python_Cron/ws/src/build/gradleenv/-1720702907/lib/python3.10/site-packages/grpc/_channel.py";,>
line 426, in __next__
return self._next()
File
"<https://ci-beam.apache.org/job/beam_PreCommit_Portable_Python_Cron/ws/src/build/gradleenv/-1720702907/lib/python3.10/site-packages/grpc/_channel.py";,>
line 826, in _next
raise self
grpc._channel._MultiThreadedRendezvous: <_MultiThreadedRendezvous of RPC that
terminated with:
status = StatusCode.UNAVAILABLE
details = "Connection reset by peer"
debug_error_string = "UNKNOWN:Error received from peer
ipv6:%5B::1%5D:34047 {created_time:"2022-11-09T16:45:12.465339199+00:00",
grpc_status:14, grpc_message:"Connection reset by peer"}"
>
File "/usr/lib/python3.10/threading.py", line 1009, in _bootstrap_inner
self.run()
File "/usr/lib/python3.10/threading.py", line 946, in run
return _run_code(code, main_globals, None,
File "/usr/lib/python3.10/runpy.py", line 86, in _run_code
self._target(*self._args, **self._kwargs)
File
"<https://ci-beam.apache.org/job/beam_PreCommit_Portable_Python_Cron/ws/src/build/gradleenv/-1720702907/lib/python3.10/site-packages/apache_beam/runners/portability/portable_runner.py";,>
line 572, in read_messages
self.run()
Exception in thread read_grpc_client_inputs:
Traceback (most recent call last):
exec(code, run_globals)
File
"<https://ci-beam.apache.org/job/beam_PreCommit_Portable_Python_Cron/ws/src/build/gradleenv/-1720702907/lib/python3.10/site-packages/apache_beam/examples/wordcount.py";,>
line 111, in <module>
File "/usr/lib/python3.10/threading.py", line 1009, in _bootstrap_inner
for message in self._message_stream:
File
"<https://ci-beam.apache.org/job/beam_PreCommit_Portable_Python_Cron/ws/src/build/gradleenv/-1720702907/lib/python3.10/site-packages/grpc/_channel.py";,>
line 426, in __next__
File "/usr/lib/python3.10/threading.py", line 946, in run
run()
self._target(*self._args, **self._kwargs)
File
"<https://ci-beam.apache.org/job/beam_PreCommit_Portable_Python_Cron/ws/src/build/gradleenv/-1720702907/lib/python3.10/site-packages/apache_beam/runners/worker/sdk_worker.py";,>
line 1006, in pull_responses
self._target(*self._args, **self._kwargs)
File
"<https://ci-beam.apache.org/job/beam_PreCommit_Portable_Python_Cron/ws/src/build/gradleenv/-1720702907/lib/python3.10/site-packages/apache_beam/examples/wordcount.py";,>
line 87, in run
File
"<https://ci-beam.apache.org/job/beam_PreCommit_Portable_Python_Cron/ws/src/build/gradleenv/-1720702907/lib/python3.10/site-packages/apache_beam/runners/worker/sdk_worker.py";,>
line 254, in run
return self._next()
for response in responses:
with beam.Pipeline(options=pipeline_options) as p:
File
"<https://ci-beam.apache.org/job/beam_PreCommit_Portable_Python_Cron/ws/src/build/gradleenv/-1720702907/lib/python3.10/site-packages/apache_beam/pipeline.py";,>
line 598, in __exit__
self.run()
File "/usr/lib/python3.10/threading.py", line 946, in run
File
"<https://ci-beam.apache.org/job/beam_PreCommit_Portable_Python_Cron/ws/src/build/gradleenv/-1720702907/lib/python3.10/site-packages/grpc/_channel.py";,>
line 426, in __next__
File
"<https://ci-beam.apache.org/job/beam_PreCommit_Portable_Python_Cron/ws/src/build/gradleenv/-1720702907/lib/python3.10/site-packages/grpc/_channel.py";,>
line 826, in _next
for work_request in self._control_stub.Control(get_responses()):
File
"<https://ci-beam.apache.org/job/beam_PreCommit_Portable_Python_Cron/ws/src/build/gradleenv/-1720702907/lib/python3.10/site-packages/grpc/_channel.py";,>
line 426, in __next__
self._target(*self._args, **self._kwargs)
File
"<https://ci-beam.apache.org/job/beam_PreCommit_Portable_Python_Cron/ws/src/build/gradleenv/-1720702907/lib/python3.10/site-packages/apache_beam/runners/worker/data_plane.py";,>
line 671, in <lambda>
return self._next()
File
"<https://ci-beam.apache.org/job/beam_PreCommit_Portable_Python_Cron/ws/src/build/gradleenv/-1720702907/lib/python3.10/site-packages/grpc/_channel.py";,>
line 826, in _next
return self._next()
raise self
File
"<https://ci-beam.apache.org/job/beam_PreCommit_Portable_Python_Cron/ws/src/build/gradleenv/-1720702907/lib/python3.10/site-packages/grpc/_channel.py";,>
line 826, in _next
grpc._channel._MultiThreadedRendezvous: <_MultiThreadedRendezvous of RPC that
terminated with:
status = StatusCode.UNAVAILABLE
details = "Socket closed"
debug_error_string = "UNKNOWN:Error received from peer
ipv6:%5B::1%5D:36735 {created_time:"2022-11-09T16:45:12.46562778+00:00",
grpc_status:14, grpc_message:"Socket closed"}"
>
raise self
target=lambda: self._read_inputs(elements_iterator),
File
"<https://ci-beam.apache.org/job/beam_PreCommit_Portable_Python_Cron/ws/src/build/gradleenv/-1720702907/lib/python3.10/site-packages/apache_beam/runners/worker/data_plane.py";,>
line 654, in _read_inputs
self.result.wait_until_finish()
grpc._channel._MultiThreadedRendezvous: <_MultiThreadedRendezvous of RPC that
terminated with:
status = StatusCode.UNAVAILABLE
details = "Connection reset by peer"
debug_error_string = "UNKNOWN:Error received from peer
ipv6:%5B::1%5D:33961 {grpc_message:"Connection reset by peer", grpc_status:14,
created_time:"2022-11-09T16:45:12.465341265+00:00"}"
>
raise self
grpc._channel._MultiThreadedRendezvous: <_MultiThreadedRendezvous of RPC that
terminated with:
status = StatusCode.UNAVAILABLE
details = "Connection reset by peer"
debug_error_string = "UNKNOWN:Error received from peer
ipv6:%5B::1%5D:44333 {grpc_message:"Connection reset by peer", grpc_status:14,
created_time:"2022-11-09T16:45:12.465352667+00:00"}"
>
File
"<https://ci-beam.apache.org/job/beam_PreCommit_Portable_Python_Cron/ws/src/build/gradleenv/-1720702907/lib/python3.10/site-packages/apache_beam/runners/portability/portable_runner.py";,>
line 607, in wait_until_finish
for elements in elements_iterator:
File
"<https://ci-beam.apache.org/job/beam_PreCommit_Portable_Python_Cron/ws/src/build/gradleenv/-1720702907/lib/python3.10/site-packages/grpc/_channel.py";,>
line 426, in __next__
raise self._runtime_exception
return self._next()
File
"<https://ci-beam.apache.org/job/beam_PreCommit_Portable_Python_Cron/ws/src/build/gradleenv/-1720702907/lib/python3.10/site-packages/apache_beam/runners/portability/portable_runner.py";,>
line 613, in _observe_state
File
"<https://ci-beam.apache.org/job/beam_PreCommit_Portable_Python_Cron/ws/src/build/gradleenv/-1720702907/lib/python3.10/site-packages/grpc/_channel.py";,>
line 826, in _next
for state_response in self._state_stream:
raise self
File
"<https://ci-beam.apache.org/job/beam_PreCommit_Portable_Python_Cron/ws/src/build/gradleenv/-1720702907/lib/python3.10/site-packages/grpc/_channel.py";,>
line 426, in __next__
grpc._channel._MultiThreadedRendezvous: <_MultiThreadedRendezvous of RPC that
terminated with:
status = StatusCode.UNAVAILABLE
details = "Connection reset by peer"
debug_error_string = "UNKNOWN:Error received from peer
ipv6:%5B::1%5D:34047 {created_time:"2022-11-09T16:45:12.465339199+00:00",
grpc_status:14, grpc_message:"Connection reset by peer"}"
>
return self._next()
File
"<https://ci-beam.apache.org/job/beam_PreCommit_Portable_Python_Cron/ws/src/build/gradleenv/-1720702907/lib/python3.10/site-packages/grpc/_channel.py";,>
line 826, in _next
raise self
grpc._channel._MultiThreadedRendezvous: <_MultiThreadedRendezvous of RPC that
terminated with:
status = StatusCode.UNAVAILABLE
details = "Socket closed"
debug_error_string = "UNKNOWN:Error received from peer
ipv6:%5B::1%5D:36735 {grpc_message:"Socket closed", grpc_status:14,
created_time:"2022-11-09T16:45:12.465607082+00:00"}"
>
Terminated
The message received from the daemon indicates that the daemon has disappeared.
Build request sent: Build{id=a695ef2d-ed56-4f34-b8d5-102d15f7d2cd,
currentDir=<https://ci-beam.apache.org/job/beam_PreCommit_Portable_Python_Cron/ws/src}>
Attempting to read last messages from the daemon log...
Daemon pid: 2380506
log file: /home/jenkins/.gradle/daemon/7.5.1/daemon-2380506.out.log
----- Last 20 lines from daemon log file - daemon-2380506.out.log -----
File
"<https://ci-beam.apache.org/job/beam_PreCommit_Portable_Python_Cron/ws/src/build/gradleenv/-1720702907/lib/python3.10/site-packages/apache_beam/runners/portability/portable_runner.py";,>
line 613, in _observe_state
File
"<https://ci-beam.apache.org/job/beam_PreCommit_Portable_Python_Cron/ws/src/build/gradleenv/-1720702907/lib/python3.10/site-packages/grpc/_channel.py";,>
line 826, in _next
for state_response in self._state_stream:
raise self
File
"<https://ci-beam.apache.org/job/beam_PreCommit_Portable_Python_Cron/ws/src/build/gradleenv/-1720702907/lib/python3.10/site-packages/grpc/_channel.py";,>
line 426, in __next__
grpc._channel._MultiThreadedRendezvous: <_MultiThreadedRendezvous of RPC that
terminated with:
status = StatusCode.UNAVAILABLE
details = "Connection reset by peer"
debug_error_string = "UNKNOWN:Error received from peer
ipv6:%5B::1%5D:34047 {created_time:"2022-11-09T16:45:12.465339199+00:00",
grpc_status:14, grpc_message:"Connection reset by peer"}"
>
return self._next()
File
"<https://ci-beam.apache.org/job/beam_PreCommit_Portable_Python_Cron/ws/src/build/gradleenv/-1720702907/lib/python3.10/site-packages/grpc/_channel.py";,>
line 826, in _next
raise self
grpc._channel._MultiThreadedRendezvous: <_MultiThreadedRendezvous of RPC that
terminated with:
status = StatusCode.UNAVAILABLE
details = "Socket closed"
debug_error_string = "UNKNOWN:Error received from peer
ipv6:%5B::1%5D:36735 {grpc_message:"Socket closed", grpc_status:14,
created_time:"2022-11-09T16:45:12.465607082+00:00"}"
>
Terminated
Daemon vm is shutting down... The daemon has exited normally or was terminated
in response to a user interrupt.
----- End of the daemon log -----
FAILURE: Build failed with an exception.
* What went wrong:
Gradle build daemon disappeared unexpectedly (it may have been killed or may
have crashed)
* Try:
> Run with --stacktrace option to get the stack trace.
> Run with --info or --debug option to get more log output.
> Run with --scan to get full insights.
* Get more help at https://help.gradle.org
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]
