See
<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/1747/display/redirect?page=changes>
Changes:
[noreply] Pin pandas to <=1.5.3 for Interactive (#26377)
------------------------------------------
[...truncated 43.51 MB...]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 13, Shuffle, Netty,
Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 13, Shuffle, Netty,
Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 13]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 13]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 13, Shuffle, Netty,
Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 13, Shuffle, Netty,
Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 13]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 13]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 13, Shuffle, Netty,
Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 13, Shuffle, Netty,
Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 13]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 13]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 13, Shuffle, Netty,
Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 13, Shuffle, Netty,
Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 13]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 13]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 13, Shuffle, Netty,
Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 13, Shuffle, Netty,
Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 13]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 13]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 PM org.apache.flink.runtime.metrics.groups.TaskMetricGroup
getOrAddOperator
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
The operator name MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)) exceeded the 80
characters length limit and was truncated.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 14, Shuffle, Netty,
Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 14, Shuffle, Netty,
Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 14]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 14]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 14, Shuffle, Netty,
Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 14, Shuffle, Netty,
Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 14]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 14]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 14, Shuffle, Netty,
Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 14, Shuffle, Netty,
Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 14]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 14]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 14, Shuffle, Netty,
Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 14, Shuffle, Netty,
Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 14]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 14]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 14, Shuffle, Netty,
Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 14, Shuffle, Netty,
Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 14]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 14]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 14, Shuffle, Netty,
Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 14, Shuffle, Netty,
Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 14]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 14]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 14, Shuffle, Netty,
Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 14, Shuffle, Netty,
Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 14]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 14]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 14, Shuffle, Netty,
Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 14, Shuffle, Netty,
Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 14]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 14]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 PM org.apache.flink.runtime.metrics.groups.TaskMetricGroup
getOrAddOperator
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
The operator name MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)) exceeded the 80
characters length limit and was truncated.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 15, Shuffle, Netty,
Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 15, Shuffle, Netty,
Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 15]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 15]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 15, Shuffle, Netty,
Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 15, Shuffle, Netty,
Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 15]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 15]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 15, Shuffle, Netty,
Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 15, Shuffle, Netty,
Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 15]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 15]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 15, Shuffle, Netty,
Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 15, Shuffle, Netty,
Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 15]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 15]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 15, Shuffle, Netty,
Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 15, Shuffle, Netty,
Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 15]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 15]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 15, Shuffle, Netty,
Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 15, Shuffle, Netty,
Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 15]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 15]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 15, Shuffle, Netty,
Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 15, Shuffle, Netty,
Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 15]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 15]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 15, Shuffle, Netty,
Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 15, Shuffle, Netty,
Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 15]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 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,
2e155544-e3a2-4fc7-9d95-3203122876e0, BeamApp-jenkins-0421163325-a214d7d1,
MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 15]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:36 PM org.apache.flink.runtime.metrics.groups.TaskMetricGroup
getOrAddOperator
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
The operator name MapPartition (MapPartition at [1]read
table/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)) exceeded the 80
characters length limit and was truncated.
> Task :sdks:python:test-suites:portable:py311:flinkExamples
INFO
apache_beam.runners.portability.fn_api_runner.translations:translations.py:710
==================== <function pack_combiners at 0x7f297556eca0>
====================
INFO
apache_beam.runners.portability.fn_api_runner.translations:translations.py:710
==================== <function lift_combiners at 0x7f297556ed40>
====================
INFO
apache_beam.runners.portability.fn_api_runner.translations:translations.py:710
==================== <function sort_stages at 0x7f297556f560>
====================
INFO apache_beam.utils.subprocess_server:subprocess_server.py:116 Starting
service with ['java' '-jar'
'/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Python_Examples_Flink/src/runners/flink/1.16/job-server/build/libs/beam-runners-flink-1.16-job-server-2.48.0-SNAPSHOT.jar'
'--flink-master' '[auto]' '--artifacts-dir'
'/tmp/beam-temp9pnruifx/artifactsywargpxq' '--job-port' '45919'
'--artifact-port' '0' '--expansion-port' '0']
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:29 PM software.amazon.awssdk.regions.internal.util.EC2MetadataUtils
getItems
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Unable to retrieve the requested metadata.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:29 PM org.apache.beam.runners.jobsubmission.JobServerDriver
createArtifactStagingService
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
ArtifactStagingService started on localhost:34471
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:29 PM org.apache.beam.runners.jobsubmission.JobServerDriver
createExpansionService
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Java ExpansionService started on localhost:38955
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:30 PM org.apache.beam.runners.jobsubmission.JobServerDriver
createJobServer
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
JobService started on localhost:45919
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:30 PM org.apache.beam.runners.jobsubmission.JobServerDriver run
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: Job
server now running, terminate with Ctrl+C
WARNING root:subprocess_server.py:95 Waiting for grpc channel to be ready at
localhost:45919.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:32 PM
org.apache.beam.runners.fnexecution.artifact.ArtifactStagingService$2 onNext
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Staging artifacts for job_438f96e3-740d-40bb-9a93-b05192007f47.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:32 PM
org.apache.beam.runners.fnexecution.artifact.ArtifactStagingService$2
resolveNextEnvironment
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Resolving artifacts for
job_438f96e3-740d-40bb-9a93-b05192007f47.ref_Environment_default_environment_1.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:32 PM
org.apache.beam.runners.fnexecution.artifact.ArtifactStagingService$2 onNext
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Getting 0 artifacts for job_438f96e3-740d-40bb-9a93-b05192007f47.null.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:32 PM
org.apache.beam.runners.fnexecution.artifact.ArtifactStagingService$2
finishStaging
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Artifacts fully staged for job_438f96e3-740d-40bb-9a93-b05192007f47.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:34 PM org.apache.beam.runners.flink.FlinkJobInvoker invokeWithExecutor
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Invoking job
BeamApp-jenkins-0421163333-22221049_d9924e8e-7b85-4a01-a337-78c7e7fec0da with
pipeline runner org.apache.beam.runners.flink.FlinkPipelineRunner@2ea4656e
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:34 PM org.apache.beam.runners.jobsubmission.JobInvocation start
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Starting job invocation
BeamApp-jenkins-0421163333-22221049_d9924e8e-7b85-4a01-a337-78c7e7fec0da
INFO apache_beam.runners.portability.portable_runner:portable_runner.py:459
Environment "LOOPBACK" has started a component necessary for the execution. Be
sure to run the pipeline using
with Pipeline() as p:
p.apply(..)
This ensures that the pipeline finishes before this program exits.
INFO apache_beam.runners.portability.portable_runner:portable_runner.py:588
Job state changed to STOPPED
INFO apache_beam.runners.portability.portable_runner:portable_runner.py:588
Job state changed to STARTING
INFO apache_beam.runners.portability.portable_runner:portable_runner.py:588
Job state changed to RUNNING
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:34 PM org.apache.beam.runners.flink.FlinkExecutionEnvironments
createBatchExecutionEnvironment
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Creating a Batch Execution Environment.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:34 PM software.amazon.awssdk.regions.internal.util.EC2MetadataUtils
getItems
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Unable to retrieve the requested metadata.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Apr 21,
2023 4:33:35 PM org.apache.flink.api.java.utils.PlanGenerator
logTypeRegistrationDetails
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: The
job has 0 registered types and 0 default Kryo serializers
FATAL: command execution failed
java.io.IOException: Backing channel 'apache-beam-jenkins-3' is disconnected.
at
hudson.remoting.RemoteInvocationHandler.channelOrFail(RemoteInvocationHandler.java:215)
at
hudson.remoting.RemoteInvocationHandler.invoke(RemoteInvocationHandler.java:285)
at com.sun.proxy.$Proxy135.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-3 is offline; cannot locate jdk_1.8_latest
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
