You are viewing a plain text version of this content. The canonical link for it is here.

Posted to builds@beam.apache.org by Apache Jenkins Server <je...@builds.apache.org> on 2024/01/18 17:36:01 UTC

Build failed in Jenkins: beam_PostCommit_Python_Examples_Flink #2813

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-unsubscribe@beam.apache.org
For additional commands, e-mail: builds-help@beam.apache.org

Jenkins build is back to normal : beam_PostCommit_Python_Examples_Flink #2815

Posted by Apache Jenkins Server <je...@builds.apache.org>.

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


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

Build failed in Jenkins: beam_PostCommit_Python_Examples_Flink #2814

Posted by Apache Jenkins Server <je...@builds.apache.org>.

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

Changes:


------------------------------------------
Started by timer
Running as SYSTEM
[EnvInject] - Loading node environment variables.
Building remotely on apache-beam-jenkins-15 (beam) in workspace /home/jenkins/jenkins-slave/workspace/beam_PostCommit_Python_Examples_Flink
The recommended git tool is: NONE
No credentials specified
Wiping out workspace first.
FATAL: hudson.remoting.Channel$OrderlyShutdown: Command Close created at
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)
Caused: hudson.remoting.Channel$OrderlyShutdown
Also:   hudson.remoting.Channel$CallSiteStackTrace: Remote call to apache-beam-jenkins-15
		at hudson.remoting.Channel.attachCallSiteStackTrace(Channel.java:1784)
		at hudson.remoting.Request.call(Request.java:199)
		at hudson.remoting.Channel.call(Channel.java:999)
		at hudson.FilePath.act(FilePath.java:1192)
		at hudson.FilePath.act(FilePath.java:1181)
		at hudson.FilePath.deleteContents(FilePath.java:1451)
		at hudson.plugins.git.extensions.impl.WipeWorkspace.beforeCheckout(WipeWorkspace.java:30)
		at hudson.plugins.git.GitSCM.checkout(GitSCM.java:1306)
		at hudson.scm.SCM.checkout(SCM.java:540)
		at hudson.model.AbstractProject.checkout(AbstractProject.java:1240)
		at hudson.model.AbstractBuild$AbstractBuildExecution.defaultCheckout(AbstractBuild.java:649)
		at jenkins.scm.SCMCheckoutStrategy.checkout(SCMCheckoutStrategy.java:85)
		at hudson.model.AbstractBuild$AbstractBuildExecution.run(AbstractBuild.java:521)
		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: hudson.remoting.RequestAbortedException
	at hudson.remoting.Request.abort(Request.java:346)
	at hudson.remoting.Channel.terminate(Channel.java:1080)
	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)
ERROR: apache-beam-jenkins-15 is offline; cannot locate jdk_1.8_latest

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