See 
<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/1719/display/redirect?page=changes>

Changes:

[noreply] Add outputs to notebook (#26269)


------------------------------------------
[...truncated 31.78 MB...]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInRemotePerSecond'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 2]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInLocal'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 2, 
Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInLocalPerSecond'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 2, 
Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInLocal'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 2]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInLocalPerSecond'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 2]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInRemote'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 2, 
Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInRemotePerSecond'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 2, 
Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInRemote'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 2]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInRemotePerSecond'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 2]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInLocal'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 2, 
Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInLocalPerSecond'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 2, 
Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInLocal'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 2]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInLocalPerSecond'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 2]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInRemote'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 2, 
Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInRemotePerSecond'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 2, 
Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInRemote'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 2]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInRemotePerSecond'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 2]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInLocal'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 2, 
Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInLocalPerSecond'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 2, 
Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInLocal'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 2]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInLocalPerSecond'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 2]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInRemote'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 2, 
Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInRemotePerSecond'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 2, 
Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInRemote'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 2]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInRemotePerSecond'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 2]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInLocal'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 2, 
Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInLocalPerSecond'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 2, 
Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInLocal'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 2]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInLocalPerSecond'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 2]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInRemote'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 2, 
Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInRemotePerSecond'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 2, 
Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInRemote'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 2]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInRemotePerSecond'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 2]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInLocal'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 2, 
Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInLocalPerSecond'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 2, 
Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInLocal'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 2]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInLocalPerSecond'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 2]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInRemote'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 2, 
Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInRemotePerSecond'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 2, 
Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInRemote'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 2]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInRemotePerSecond'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 2]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInLocal'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 3, 
Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInLocalPerSecond'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 3, 
Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInLocal'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 3]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInLocalPerSecond'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 3]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInRemote'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 3, 
Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInRemotePerSecond'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 3, 
Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInRemote'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 3]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInRemotePerSecond'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 3]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInLocal'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 3, 
Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInLocalPerSecond'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 3, 
Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInLocal'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 3]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInLocalPerSecond'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 3]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInRemote'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 3, 
Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInRemotePerSecond'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 3, 
Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInRemote'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 3]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInRemotePerSecond'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 3]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInLocal'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 3, 
Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInLocalPerSecond'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 3, 
Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInLocal'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 3]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInLocalPerSecond'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 3]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInRemote'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 3, 
Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInRemotePerSecond'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 3, 
Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInRemote'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 3]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInRemotePerSecond'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 3]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInLocal'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 3, 
Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInLocalPerSecond'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 3, 
Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInLocal'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 3]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInLocalPerSecond'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 3]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInRemote'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 3, 
Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInRemotePerSecond'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 3, 
Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInRemote'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 3]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInRemotePerSecond'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 3]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInLocal'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 3, 
Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInLocalPerSecond'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 3, 
Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInLocal'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 3]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInLocalPerSecond'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 3]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInRemote'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 3, 
Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInRemotePerSecond'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 3, 
Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInRemote'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 3]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInRemotePerSecond'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 3]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInLocal'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 3, 
Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInLocalPerSecond'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 3, 
Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInLocal'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 3]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInLocalPerSecond'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 3]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInRemote'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 3, 
Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInRemotePerSecond'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 3, 
Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInRemote'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 3]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:31 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInRemotePerSecond'. Metric will not be reported.[, taskmanager, 
afbb5623-6193-43ea-9b22-961c1d2306c0, BeamApp-jenkins-0414155809-24b19542, 
MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite), 3]

> Task :sdks:python:test-suites:portable:py311:flinkExamples
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:16 PM software.amazon.awssdk.regions.internal.util.EC2MetadataUtils 
getItems
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Unable to retrieve the requested metadata.
WARNING  root:subprocess_server.py:95 Waiting for grpc channel to be ready at 
localhost:40319.
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:17 PM org.apache.beam.runners.jobsubmission.JobServerDriver 
createArtifactStagingService
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: 
ArtifactStagingService started on localhost:34607
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:17 PM org.apache.beam.runners.jobsubmission.JobServerDriver 
createExpansionService
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: 
Java ExpansionService started on localhost:36695
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:17 PM org.apache.beam.runners.jobsubmission.JobServerDriver 
createJobServer
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: 
JobService started on localhost:40319
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:17 PM org.apache.beam.runners.jobsubmission.JobServerDriver run
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: Job 
server now running, terminate with Ctrl+C
WARNING  root:subprocess_server.py:95 Waiting for grpc channel to be ready at 
localhost:40319.
WARNING  root:subprocess_server.py:95 Waiting for grpc channel to be ready at 
localhost:40319.
WARNING  root:subprocess_server.py:95 Waiting for grpc channel to be ready at 
localhost:40319.
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:23 PM 
org.apache.beam.runners.fnexecution.artifact.ArtifactStagingService$2 onNext
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: 
Staging artifacts for job_479cdfc0-024f-415f-b981-edd1b93fdaa4.
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:23 PM 
org.apache.beam.runners.fnexecution.artifact.ArtifactStagingService$2 
resolveNextEnvironment
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: 
Resolving artifacts for 
job_479cdfc0-024f-415f-b981-edd1b93fdaa4.ref_Environment_default_environment_1.
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:23 PM 
org.apache.beam.runners.fnexecution.artifact.ArtifactStagingService$2 onNext
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: 
Getting 0 artifacts for job_479cdfc0-024f-415f-b981-edd1b93fdaa4.null.
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:23 PM 
org.apache.beam.runners.fnexecution.artifact.ArtifactStagingService$2 
finishStaging
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: 
Artifacts fully staged for job_479cdfc0-024f-415f-b981-edd1b93fdaa4.
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:24 PM org.apache.beam.runners.flink.FlinkJobInvoker invokeWithExecutor
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: 
Invoking job 
BeamApp-jenkins-0414155823-93352346_a341fc9a-9acd-4d98-9072-40e1e83ff5b2 with 
pipeline runner org.apache.beam.runners.flink.FlinkPipelineRunner@ebc94d
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:25 PM org.apache.beam.runners.jobsubmission.JobInvocation start
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: 
Starting job invocation 
BeamApp-jenkins-0414155823-93352346_a341fc9a-9acd-4d98-9072-40e1e83ff5b2
INFO     apache_beam.runners.portability.portable_runner:portable_runner.py:459 
Environment "LOOPBACK" has started a component necessary for the execution. Be 
sure to run the pipeline using
  with Pipeline() as p:
    p.apply(..)
This ensures that the pipeline finishes before this program exits.
INFO     apache_beam.runners.portability.portable_runner:portable_runner.py:588 
Job state changed to STOPPED
INFO     apache_beam.runners.portability.portable_runner:portable_runner.py:588 
Job state changed to STARTING
INFO     apache_beam.runners.portability.portable_runner:portable_runner.py:588 
Job state changed to RUNNING
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:26 PM org.apache.beam.runners.flink.FlinkExecutionEnvironments 
createBatchExecutionEnvironment
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: 
Creating a Batch Execution Environment.
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:27 PM software.amazon.awssdk.regions.internal.util.EC2MetadataUtils 
getItems
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Unable to retrieve the requested metadata.
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 14, 
2023 3:58:29 PM org.apache.flink.api.java.utils.PlanGenerator 
logTypeRegistrationDetails
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: The 
job has 0 registered types and 0 default Kryo serializers
FATAL: command execution failed
java.io.IOException: Backing channel 'apache-beam-jenkins-12' is disconnected.
        at 
hudson.remoting.RemoteInvocationHandler.channelOrFail(RemoteInvocationHandler.java:215)
        at 
hudson.remoting.RemoteInvocationHandler.invoke(RemoteInvocationHandler.java:285)
        at com.sun.proxy.$Proxy143.isAlive(Unknown Source)
        at hudson.Launcher$RemoteLauncher$ProcImpl.isAlive(Launcher.java:1215)
        at hudson.Launcher$RemoteLauncher$ProcImpl.join(Launcher.java:1207)
        at hudson.Launcher$ProcStarter.join(Launcher.java:524)
        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:814)
        at hudson.model.Build$BuildExecution.build(Build.java:199)
        at hudson.model.Build$BuildExecution.doRun(Build.java:164)
        at 
hudson.model.AbstractBuild$AbstractBuildExecution.run(AbstractBuild.java:522)
        at hudson.model.Run.execute(Run.java:1896)
        at hudson.model.FreeStyleBuild.run(FreeStyleBuild.java:44)
        at hudson.model.ResourceController.execute(ResourceController.java:101)
        at hudson.model.Executor.run(Executor.java:442)
Caused by: java.io.IOException: Pipe closed after 0 cycles
        at 
org.apache.sshd.common.channel.ChannelPipedInputStream.read(ChannelPipedInputStream.java:126)
        at 
org.apache.sshd.common.channel.ChannelPipedInputStream.read(ChannelPipedInputStream.java:105)
        at 
hudson.remoting.FlightRecorderInputStream.read(FlightRecorderInputStream.java:94)
        at 
hudson.remoting.ChunkedInputStream.readHeader(ChunkedInputStream.java:75)
        at 
hudson.remoting.ChunkedInputStream.readUntilBreak(ChunkedInputStream.java:105)
        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-12 is offline; cannot locate jdk_1.8_latest

---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to