Build failed in Jenkins: beam_PostCommit_Python_Examples_Flink #2813

[Apache Jenkins Server]

See 
<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/2813/display/redirect>

Changes:


------------------------------------------
[...truncated 73.10 MB...]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInRemote'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 2, Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInRemotePerSecond'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 2, Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInRemote'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 2]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInRemotePerSecond'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 2]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInLocal'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 2, Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInLocalPerSecond'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 2, Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInLocal'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 2]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInLocalPerSecond'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 2]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInRemote'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 2, Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInRemotePerSecond'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 2, Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInRemote'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 2]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInRemotePerSecond'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 2]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInLocal'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 3, Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInLocalPerSecond'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 3, Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInLocal'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 3]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInLocalPerSecond'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 3]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInRemote'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 3, Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInRemotePerSecond'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 3, Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInRemote'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 3]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInRemotePerSecond'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 3]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInLocal'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 3, Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInLocalPerSecond'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 3, Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInLocal'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 3]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInLocalPerSecond'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 3]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInRemote'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 3, Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInRemotePerSecond'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 3, Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInRemote'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 3]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInRemotePerSecond'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 3]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInLocal'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 4, Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInLocalPerSecond'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 4, Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInLocal'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 4]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInLocalPerSecond'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 4]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInRemote'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 4, Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInRemotePerSecond'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 4, Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInRemote'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 4]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInRemotePerSecond'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 4]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInLocal'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 4, Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInLocalPerSecond'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 4, Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInLocal'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 4]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInLocalPerSecond'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 4]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInRemote'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 4, Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInRemotePerSecond'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 4, Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInRemote'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 4]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInRemotePerSecond'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 4]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInLocal'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 5, Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInLocalPerSecond'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 5, Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInLocal'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 5]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInLocalPerSecond'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 5]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInRemote'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 5, Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInRemotePerSecond'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 5, Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInRemote'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 5]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInRemotePerSecond'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 5]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInLocal'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 5, Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInLocalPerSecond'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 5, Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInLocal'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 5]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInLocalPerSecond'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 5]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInRemote'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 5, Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInRemotePerSecond'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 5, Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInRemote'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 5]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInRemotePerSecond'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 5]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInLocal'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 6, Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInLocalPerSecond'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 6, Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInLocal'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 6]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInLocalPerSecond'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 6]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInRemote'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 6, Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInRemotePerSecond'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 6, Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInRemote'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 6]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInRemotePerSecond'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 6]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInLocal'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 6, Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInLocalPerSecond'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 6, Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInLocal'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 6]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInLocalPerSecond'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 6]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInRemote'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 6, Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInRemotePerSecond'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 6, Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInRemote'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 6]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInRemotePerSecond'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 6]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInLocal'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 7, Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInLocalPerSecond'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 7, Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInLocal'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 7]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInLocalPerSecond'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 7]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInRemote'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 7, Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInRemotePerSecond'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 7, Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInRemote'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 7]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInRemotePerSecond'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 7]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInLocal'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 7, Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInLocalPerSecond'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 7, Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInLocal'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 7]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInLocalPerSecond'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 7]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInRemote'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 7, Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInRemotePerSecond'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 7, Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInRemote'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 7]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInRemotePerSecond'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 7]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInLocal'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 8, Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInLocalPerSecond'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 8, Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInLocal'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 8]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInLocalPerSecond'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 8]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInRemote'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 8, Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInRemotePerSecond'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 8, Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInRemote'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 8]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBytesInRemotePerSecond'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 8]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInLocal'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 8, Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInLocalPerSecond'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 8, Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInLocal'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 8]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInLocalPerSecond'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 8]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInRemote'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 8, Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInRemotePerSecond'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 8, Shuffle, Netty, Input]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING: 
Name collision: Group already contains a Metric with the name 
'numBuffersInRemote'. Metric will not be reported.[, taskmanager, 
08222069-1228-48cb-a6c2-770f8454103f, BeamApp-jenkins-0118160218-be42406d, 
CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: WriteToPandas(df) - 
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-d236d735-21e0-4ea5-aa25-c5a0b4967e69/output.csv/WriteToFiles/GroupTempFilesByDestination)
 -> Map (Key Extractor), 8]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 18, 
2024 4:02:52 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup 
addMetric

+++++++++++++++++++++++++++++++++++ Timeout ++++++++++++++++++++++++++++++++++++
FATAL: command execution failed
java.io.IOException: Backing channel 'apache-beam-jenkins-15' is disconnected.
        at 
hudson.remoting.RemoteInvocationHandler.channelOrFail(RemoteInvocationHandler.java:215)
        at 
hudson.remoting.RemoteInvocationHandler.invoke(RemoteInvocationHandler.java:285)
        at com.sun.proxy.$Proxy208.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:321)
        at hudson.tasks.BuildStepMonitor$1.perform(BuildStepMonitor.java:20)
        at 
hudson.model.AbstractBuild$AbstractBuildExecution.perform(AbstractBuild.java:818)
        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:526)
        at hudson.model.Run.execute(Run.java:1900)
        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: hudson.remoting.Channel$OrderlyShutdown: Command Close created at
        at hudson.remoting.Channel$CloseCommand.execute(Channel.java:1313)
        at hudson.remoting.Channel$1.handle(Channel.java:606)
        at 
hudson.remoting.SynchronousCommandTransport$ReaderThread.run(SynchronousCommandTransport.java:81)
Caused by: Command Close created at
        at hudson.remoting.Command.<init>(Command.java:70)
        at hudson.remoting.Channel$CloseCommand.<init>(Channel.java:1306)
        at hudson.remoting.Channel.close(Channel.java:1480)
        at hudson.remoting.Channel.close(Channel.java:1447)
        at hudson.remoting.Channel$CloseCommand.execute(Channel.java:1312)
        at hudson.remoting.Channel$1.handle(Channel.java:606)
        at 
hudson.remoting.SynchronousCommandTransport$ReaderThread.run(SynchronousCommandTransport.java:81)
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
ERROR: apache-beam-jenkins-15 is offline; cannot locate jdk_1.8_latest

---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscr...@beam.apache.org
For additional commands, e-mail: builds-h...@beam.apache.org