See
<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/1995/display/redirect?page=changes>
Changes:
[noreply] Fixes naming conflict with "Tour of Beam" (#27206)
------------------------------------------
[...truncated 39.98 MB...]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBuffersInRemotePerSecond'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 8]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBytesInLocal'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 8, Shuffle, Netty, Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBytesInLocalPerSecond'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 8, Shuffle, Netty, Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBytesInLocal'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 8]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBytesInLocalPerSecond'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 8]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBytesInRemote'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 8, Shuffle, Netty, Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBytesInRemotePerSecond'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 8, Shuffle, Netty, Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBytesInRemote'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 8]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBytesInRemotePerSecond'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 8]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBuffersInLocal'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 8, Shuffle, Netty, Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBuffersInLocalPerSecond'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 8, Shuffle, Netty, Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBuffersInLocal'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 8]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBuffersInLocalPerSecond'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 8]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBuffersInRemote'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 8, Shuffle, Netty, Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBuffersInRemotePerSecond'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 8, Shuffle, Netty, Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBuffersInRemote'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 8]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBuffersInRemotePerSecond'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 8]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBytesInLocal'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 9, Shuffle, Netty, Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBytesInLocalPerSecond'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 9, Shuffle, Netty, Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBytesInLocal'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 9]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBytesInLocalPerSecond'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 9]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBytesInRemote'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 9, Shuffle, Netty, Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBytesInRemotePerSecond'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 9, Shuffle, Netty, Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBytesInRemote'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 9]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBytesInRemotePerSecond'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 9]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBuffersInLocal'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 9, Shuffle, Netty, Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBuffersInLocalPerSecond'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 9, Shuffle, Netty, Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBuffersInLocal'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 9]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBuffersInLocalPerSecond'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 9]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBuffersInRemote'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 9, Shuffle, Netty, Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBuffersInRemotePerSecond'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 9, Shuffle, Netty, Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBuffersInRemote'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 9]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBuffersInRemotePerSecond'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 9]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBytesInLocal'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 9, Shuffle, Netty, Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBytesInLocalPerSecond'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 9, Shuffle, Netty, Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBytesInLocal'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 9]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBytesInLocalPerSecond'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 9]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBytesInRemote'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 9, Shuffle, Netty, Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBytesInRemotePerSecond'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 9, Shuffle, Netty, Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBytesInRemote'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 9]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBytesInRemotePerSecond'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 9]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBuffersInLocal'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 9, Shuffle, Netty, Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBuffersInLocalPerSecond'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 9, Shuffle, Netty, Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBuffersInLocal'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 9]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBuffersInLocalPerSecond'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 9]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBuffersInRemote'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 9, Shuffle, Netty, Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBuffersInRemotePerSecond'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 9, Shuffle, Netty, Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBuffersInRemote'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 9]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBuffersInRemotePerSecond'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 9]
INFO apache_beam.runners.worker.sdk_worker:sdk_worker.py:195 Control
channel established.
INFO apache_beam.runners.worker.sdk_worker:sdk_worker.py:243 Initializing
SDKHarness with unbounded number of workers.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBytesInLocal'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 10, Shuffle, Netty, Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBytesInLocalPerSecond'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 10, Shuffle, Netty, Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBytesInLocal'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 10]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBytesInLocalPerSecond'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 10]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBytesInRemote'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 10, Shuffle, Netty, Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBytesInRemotePerSecond'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 10, Shuffle, Netty, Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBytesInRemote'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 10]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBytesInRemotePerSecond'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 10]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBuffersInLocal'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 10, Shuffle, Netty, Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBuffersInLocalPerSecond'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 10, Shuffle, Netty, Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBuffersInLocal'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 10]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBuffersInLocalPerSecond'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 10]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBuffersInRemote'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 10, Shuffle, Netty, Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBuffersInRemotePerSecond'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 10, Shuffle, Netty, Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBuffersInRemote'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 10]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBuffersInRemotePerSecond'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 10]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBytesInLocal'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 10, Shuffle, Netty, Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBytesInLocalPerSecond'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 10, Shuffle, Netty, Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBytesInLocal'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 10]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBytesInLocalPerSecond'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 10]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBytesInRemote'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 10, Shuffle, Netty, Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBytesInRemotePerSecond'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 10, Shuffle, Netty, Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBytesInRemote'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 10]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBytesInRemotePerSecond'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 10]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBuffersInLocal'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 10, Shuffle, Netty, Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBuffersInLocalPerSecond'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 10, Shuffle, Netty, Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBuffersInLocal'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 10]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBuffersInLocalPerSecond'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 10]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBuffersInRemote'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 10, Shuffle, Netty, Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBuffersInRemotePerSecond'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 10, Shuffle, Netty, Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBuffersInRemote'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 10]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBuffersInRemotePerSecond'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 10]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
control
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Beam Fn Control client connected with id 4-1
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBytesInLocal'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 11, Shuffle, Netty, Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBytesInLocalPerSecond'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 11, Shuffle, Netty, Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBytesInLocal'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 11]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBytesInLocalPerSecond'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 11]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBytesInRemote'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 11, Shuffle, Netty, Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBytesInRemotePerSecond'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 11, Shuffle, Netty, Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBytesInRemote'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 11]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBytesInRemotePerSecond'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 11]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBuffersInLocal'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 11, Shuffle, Netty, Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBuffersInLocalPerSecond'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 11, Shuffle, Netty, Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBuffersInLocal'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 11]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBuffersInLocalPerSecond'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 11]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBuffersInRemote'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 11, Shuffle, Netty, Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBuffersInRemotePerSecond'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 11, Shuffle, Netty, Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBuffersInRemote'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 11]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBuffersInRemotePerSecond'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 11]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBytesInLocal'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 11, Shuffle, Netty, Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBytesInLocalPerSecond'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 11, Shuffle, Netty, Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBytesInLocal'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 11]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBytesInLocalPerSecond'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 11]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBytesInRemote'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 11, Shuffle, Netty, Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBytesInRemotePerSecond'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 11, Shuffle, Netty, Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBytesInRemote'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 11]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBytesInRemotePerSecond'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 11]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBuffersInLocal'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/PreFinalize)
-> FlatMap (FlatMap at ExtractOutput[0]), 11, Shuffle, Netty, Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jun 22,
2023 4:27:47 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Name collision: Group already contains a Metric with the name
'numBuffersInLocalPerSecond'. Metric will not be reported.[, taskmanager,
946cc6ce-456a-44b1-86aa-06062458ce0a, BeamApp-jenkins-0622162651-a970df52,
CHAIN MapPartition (MapPartition at [1]WriteFATAL: command execution failed
java.io.IOException: Backing channel 'apache-beam-jenkins-5' is disconnected.
at
hudson.remoting.RemoteInvocationHandler.channelOrFail(RemoteInvocationHandler.java:215)
at
hudson.remoting.RemoteInvocationHandler.invoke(RemoteInvocationHandler.java:285)
at com.sun.proxy.$Proxy141.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:814)
at hudson.model.Build$BuildExecution.build(Build.java:199)
at hudson.model.Build$BuildExecution.doRun(Build.java:164)
at
hudson.model.AbstractBuild$AbstractBuildExecution.run(AbstractBuild.java:522)
at hudson.model.Run.execute(Run.java:1896)
at hudson.model.FreeStyleBuild.run(FreeStyleBuild.java:44)
at hudson.model.ResourceController.execute(ResourceController.java:101)
at hudson.model.Executor.run(Executor.java:442)
Caused by: 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$CloseCommand.<init>(Channel.java:1304)
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)
... 2 more
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
ERROR: apache-beam-jenkins-5 is offline; cannot locate jdk_1.8_latest
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]