See 
<https://ci-beam.apache.org/job/beam_PostCommit_Python39/1504/display/redirect>

Changes:


------------------------------------------
[...truncated 10.41 MB...]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: 
Slf4jLogger started
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Feb 24, 
2023 12:24:13 PM akka.event.slf4j.Slf4jLogger$$anonfun$receive$1 applyOrElse
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: 
Slf4jLogger started
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Feb 24, 
2023 12:24:13 PM org.apache.flink.configuration.Configuration loggingFallback
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: 
Config uses fallback configuration key 'akka.ask.timeout' instead of key 
'taskmanager.slot.timeout'
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Feb 24, 
2023 12:24:13 PM 
org.apache.flink.runtime.webmonitor.WebMonitorUtils$LogFileLocation find
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
Log file environment variable 'log.file' is not set.
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Feb 24, 
2023 12:24:13 PM 
org.apache.flink.runtime.webmonitor.WebMonitorUtils$LogFileLocation find
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: 
JobManager log files are unavailable in the web dashboard. Log file location 
not found in environment variable 'log.file' or configuration key 
'web.log.path'.
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Feb 24, 
2023 12:24:14 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 Feb 24, 
2023 12:24:14 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 Feb 24, 
2023 12:24:14 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 Feb 24, 
2023 12:24:14 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 Feb 24, 
2023 12:24:14 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 Feb 24, 
2023 12:24:14 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 Feb 24, 
2023 12:24:14 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 Feb 24, 
2023 12:24:14 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 Feb 24, 
2023 12:24:14 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 Feb 24, 
2023 12:24:14 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 Feb 24, 
2023 12:24:14 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 Feb 24, 
2023 12:24:14 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 Feb 24, 
2023 12:24:14 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 Feb 24, 
2023 12:24:14 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 Feb 24, 
2023 12:24:14 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 Feb 24, 
2023 12:24:14 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 Feb 24, 
2023 12:24:14 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 Feb 24, 
2023 12:24:14 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 Feb 24, 
2023 12:24:14 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 Feb 24, 
2023 12:24:14 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 Feb 24, 
2023 12:24:14 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 Feb 24, 
2023 12:24:14 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 Feb 24, 
2023 12:24:14 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 Feb 24, 
2023 12:24:14 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 Feb 24, 
2023 12:24:14 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 Feb 24, 
2023 12:24:14 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 Feb 24, 
2023 12:24:14 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 Feb 24, 
2023 12:24:14 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 Feb 24, 
2023 12:24:14 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 Feb 24, 
2023 12:24:14 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 Feb 24, 
2023 12:24:14 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 Feb 24, 
2023 12:24:14 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 Feb 24, 
2023 12:24:14 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 
[3]ReadFromKafka/KafkaIO.Read/KafkaIO.Read.ReadFromKafkaViaUnbounded/Read(KafkaUnboundedSource)/Create/Read(CreateSource)/{ParDo(OutputSingleSource),
 ParDo(BoundedSourceAsSDFWrapper)}) exceeded the 80 characters length limit and 
was truncated.
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Feb 24, 
2023 12:24:14 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 
[3]ReadFromKafka/KafkaIO.Read/KafkaIO.Read.ReadFromKafkaViaUnbounded/Read(KafkaUnboundedSource)/Create/Read(CreateSource)/{ParDo(OutputSingleSource),
 ParDo(BoundedSourceAsSDFWrapper)}) exceeded the 80 characters length limit and 
was truncated.
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Feb 24, 
2023 12:24:14 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 
[3]ReadFromKafka/KafkaIO.Read/KafkaIO.Read.ReadFromKafkaViaUnbounded/Read(KafkaUnboundedSource)/Create/Read(CreateSource)/{ParDo(OutputSingleSource),
 ParDo(BoundedSourceAsSDFWrapper)}) exceeded the 80 characters length limit and 
was truncated.
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Feb 24, 
2023 12:24:14 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 
[3]ReadFromKafka/KafkaIO.Read/KafkaIO.Read.ReadFromKafkaViaUnbounded/Read(KafkaUnboundedSource)/Create/Read(CreateSource)/{ParDo(OutputSingleSource),
 ParDo(BoundedSourceAsSDFWrapper)}) exceeded the 80 characters length limit and 
was truncated.
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Feb 24, 
2023 12:24:14 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 
[3]ReadFromKafka/KafkaIO.Read/KafkaIO.Read.ReadFromKafkaViaUnbounded/Read(KafkaUnboundedSource)/Create/Read(CreateSource)/{ParDo(OutputSingleSource),
 ParDo(BoundedSourceAsSDFWrapper)}) exceeded the 80 characters length limit and 
was truncated.
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Feb 24, 
2023 12:24:14 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 
[3]ReadFromKafka/KafkaIO.Read/KafkaIO.Read.ReadFromKafkaViaUnbounded/Read(KafkaUnboundedSource)/Create/Read(CreateSource)/{ParDo(OutputSingleSource),
 ParDo(BoundedSourceAsSDFWrapper)}) exceeded the 80 characters length limit and 
was truncated.
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Feb 24, 
2023 12:24:14 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 
[3]ReadFromKafka/KafkaIO.Read/KafkaIO.Read.ReadFromKafkaViaUnbounded/Read(KafkaUnboundedSource)/Create/Read(CreateSource)/{ParDo(OutputSingleSource),
 ParDo(BoundedSourceAsSDFWrapper)}) exceeded the 80 characters length limit and 
was truncated.
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Feb 24, 
2023 12:24:14 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 
[3]ReadFromKafka/KafkaIO.Read/KafkaIO.Read.ReadFromKafkaViaUnbounded/Read(KafkaUnboundedSource)/Create/Read(CreateSource)/{ParDo(OutputSingleSource),
 ParDo(BoundedSourceAsSDFWrapper)}) exceeded the 80 characters length limit and 
was truncated.
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Feb 24, 
2023 12:24:14 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 
[3]ReadFromKafka/KafkaIO.Read/KafkaIO.Read.ReadFromKafkaViaUnbounded/Read(KafkaUnboundedSource)/Create/Read(CreateSource)/{ParDo(OutputSingleSource),
 ParDo(BoundedSourceAsSDFWrapper)}) exceeded the 80 characters length limit and 
was truncated.
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Feb 24, 
2023 12:24:14 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 
[3]ReadFromKafka/KafkaIO.Read/KafkaIO.Read.ReadFromKafkaViaUnbounded/Read(KafkaUnboundedSource)/Create/Read(CreateSource)/{ParDo(OutputSingleSource),
 ParDo(BoundedSourceAsSDFWrapper)}) exceeded the 80 characters length limit and 
was truncated.
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Feb 24, 
2023 12:24:14 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 
[3]ReadFromKafka/KafkaIO.Read/KafkaIO.Read.ReadFromKafkaViaUnbounded/Read(KafkaUnboundedSource)/Create/Read(CreateSource)/{ParDo(OutputSingleSource),
 ParDo(BoundedSourceAsSDFWrapper)}) exceeded the 80 characters length limit and 
was truncated.
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Feb 24, 
2023 12:24:14 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 Feb 24, 
2023 12:24:14 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 Feb 24, 
2023 12:24:14 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 
[3]ReadFromKafka/KafkaIO.Read/KafkaIO.Read.ReadFromKafkaViaUnbounded/Read(KafkaUnboundedSource)/Create/Read(CreateSource)/{ParDo(OutputSingleSource),
 ParDo(BoundedSourceAsSDFWrapper)}) exceeded the 80 characters length limit and 
was truncated.
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Feb 24, 
2023 12:24:14 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 
[3]ReadFromKafka/KafkaIO.Read/KafkaIO.Read.ReadFromKafkaViaUnbounded/Read(KafkaUnboundedSource)/Create/Read(CreateSource)/{ParDo(OutputSingleSource),
 ParDo(BoundedSourceAsSDFWrapper)}) exceeded the 80 characters length limit and 
was truncated.
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Feb 24, 
2023 12:24:14 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 Feb 24, 
2023 12:24:14 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 Feb 24, 
2023 12:24:14 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 
[3]ReadFromKafka/KafkaIO.Read/KafkaIO.Read.ReadFromKafkaViaUnbounded/Read(KafkaUnboundedSource)/Create/Read(CreateSource)/{ParDo(OutputSingleSource),
 ParDo(BoundedSourceAsSDFWrapper)}) exceeded the 80 characters length limit and 
was truncated.
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Feb 24, 
2023 12:24:14 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 
[3]ReadFromKafka/KafkaIO.Read/KafkaIO.Read.ReadFromKafkaViaUnbounded/Read(KafkaUnboundedSource)/Create/Read(CreateSource)/{ParDo(OutputSingleSource),
 ParDo(BoundedSourceAsSDFWrapper)}) exceeded the 80 characters length limit and 
was truncated.
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Feb 24, 
2023 12:24:14 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 Feb 24, 
2023 12:24:14 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 Feb 24, 
2023 12:24:14 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 Feb 24, 
2023 12:24:14 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 Feb 24, 
2023 12:24:14 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 
[3]ReadFromKafka/KafkaIO.Read/KafkaIO.Read.ReadFromKafkaViaUnbounded/Read(KafkaUnboundedSource)/Create/Read(CreateSource)/{ParDo(OutputSingleSource),
 ParDo(BoundedSourceAsSDFWrapper)}) exceeded the 80 characters length limit and 
was truncated.
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Feb 24, 
2023 12:24:14 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 Feb 24, 
2023 12:24:14 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 Feb 24, 
2023 12:24:14 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 Feb 24, 
2023 12:24:14 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 
[3]ReadFromKafka/KafkaIO.Read/KafkaIO.Read.ReadFromKafkaViaUnbounded/Read(KafkaUnboundedSource)/{Create,
 Split, Reshuffle}) exceeded the 80 characters length limit and was truncated.
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Feb 24, 
2023 12:24:14 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 
[3]ReadFromKafka/KafkaIO.Read/KafkaIO.Read.ReadFromKafkaViaUnbounded/Read(KafkaUnboundedSource)/{Create,
 Split, Reshuffle}) exceeded the 80 characters length limit and was truncated.
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Feb 24, 
2023 12:24:14 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 Feb 24, 
2023 12:24:14 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 Feb 24, 
2023 12:24:14 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 Feb 24, 
2023 12:24:14 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 
[3]ReadFromKafka/KafkaIO.Read/KafkaIO.Read.ReadFromKafkaViaUnbounded/Read(KafkaUnboundedSource)/{Create,
 Split, Reshuffle}) exceeded the 80 characters length limit and was truncated.
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Feb 24, 
2023 12:24:14 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 
[3]ReadFromKafka/KafkaIO.Read/KafkaIO.Read.ReadFromKafkaViaUnbounded/Read(KafkaUnboundedSource)/{Create,
 Split, Reshuffle}) exceeded the 80 characters length limit and was truncated.
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Feb 24, 
2023 12:24:14 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 Feb 24, 
2023 12:24:14 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 Feb 24, 
2023 12:24:14 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 
[3]ReadFromKafka/KafkaIO.Read/KafkaIO.Read.ReadFromKafkaViaUnbounded/Read(KafkaUnboundedSource)/{Create,
 Split, Reshuffle}) exceeded the 80 characters length limit and was truncated.
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Feb 24, 
2023 12:24:14 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 
[3]ReadFromKafka/KafkaIO.Read/KafkaIO.Read.ReadFromKafkaViaUnbounded/Read(KafkaUnboundedSource)/{Create,
 Split, Reshuffle}) exceeded the 80 characters length limit and was truncated.
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Feb 24, 
2023 12:24:14 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 
[3]ReadFromKafka/KafkaIO.Read/KafkaIO.Read.ReadFromKafkaViaUnbounded/Read(KafkaUnboundedSource)/{Create,
 Split, Reshuffle}) exceeded the 80 characters length limit and was truncated.
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Feb 24, 
2023 12:24:14 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 
[3]ReadFromKafka/KafkaIO.Read/KafkaIO.Read.ReadFromKafkaViaUnbounded/Read(KafkaUnboundedSource)/{Create,
 Split, Reshuffle}) exceeded the 80 characters length limit and was truncated.
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Feb 24, 
2023 12:24:14 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 
[3]ReadFromKafka/KafkaIO.Read/KafkaIO.Read.ReadFromKafkaViaUnbounded/Read(KafkaUnboundedSource)/{Create,
 Split, Reshuffle}) exceeded the 80 characters length limit and was truncated.
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Feb 24, 
2023 12:24:14 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 
[3]ReadFromKafka/KafkaIO.Read/KafkaIO.Read.ReadFromKafkaViaUnbounded/Read(KafkaUnboundedSource)/{Create,
 Split, Reshuffle}) exceeded the 80 characters length limit and was truncated.
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Feb 24, 
2023 12:24:14 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 
[3]ReadFromKafka/KafkaIO.Read/KafkaIO.Read.ReadFromKafkaViaUnbounded/Read(KafkaUnboundedSource)/{Create,
 Split, Reshuffle}) exceeded the 80 characters length limit and was truncated.
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Feb 24, 
2023 12:24:14 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 
[3]ReadFromKafka/KafkaIO.Read/KafkaIO.Read.ReadFromKafkaViaUnbounded/Read(KafkaUnboundedSource)/{Create,
 Split, Reshuffle}) exceeded the 80 characters length limit and was truncated.
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Feb 24, 
2023 12:24:14 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 
[3]ReadFromKafka/KafkaIO.Read/KafkaIO.Read.ReadFromKafkaViaUnbounded/Read(KafkaUnboundedSource)/{Create,
 Split, Reshuffle}) exceeded the 80 characters length limit and was truncated.
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Feb 24, 
2023 12:24:14 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 
[3]ReadFromKafka/KafkaIO.Read/KafkaIO.Read.ReadFromKafkaViaUnbounded/Read(KafkaUnboundedSource)/{Create,
 Split, Reshuffle}) exceeded the 80 characters length limit and was truncated.
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Feb 24, 
2023 12:24:14 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 
[3]ReadFromKafka/KafkaIO.Read/KafkaIO.Read.ReadFromKafkaViaUnbounded/Read(KafkaUnboundedSource)/{Create,
 Split, Reshuffle}) exceeded the 80 characters length limit and was truncated.
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Feb 24, 
2023 12:24:14 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 
[3]ReadFromKafka/KafkaIO.Read/KafkaIO.Read.ReadFromKafkaViaUnbounded/Read(KafkaUnboundedSource)/{Create,
 Split, Reshuffle}) exceeded the 80 characters length limit and was truncated.
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Feb 24, 
2023 12:24:15 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 [4]ReadFromKafka/{KafkaIO.Read, 
Remove Kafka Metadata}) exceeded the 80 characters length limit and was 
truncated.
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Feb 24, 
2023 12:24:15 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 [4]ReadFromKafka/{KafkaIO.Read, 
Remove Kafka Metadata}) exceeded the 80 characters length limit and was 
truncated.
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Feb 24, 
2023 12:24:15 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 [4]ReadFromKafka/{KafkaIO.Read, 
Remove Kafka Metadata}) exceeded the 80 characters length limit and was 
truncated.
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Feb 24, 
2023 12:24:15 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 [4]ReadFromKafka/{KafkaIO.Read, 
Remove Kafka Metadata}) exceeded the 80 characters length limit and was 
truncated.
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Feb 24, 
2023 12:24:15 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 [4]ReadFromKafka/{KafkaIO.Read, 
Remove Kafka Metadata}) exceeded the 80 characters length limit and was 
truncated.
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Feb 24, 
2023 12:24:15 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 [4]ReadFromKafka/{KafkaIO.Read, 
Remove Kafka Metadata}) exceeded the 80 characters length limit and was 
truncated.
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Feb 24, 
2023 12:24:15 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 [4]ReadFromKafka/{KafkaIO.Read, 
Remove Kafka Metadata}) exceeded the 80 characters length limit and was 
truncated.
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Feb 24, 
2023 12:24:15 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 [4]ReadFromKafka/{KafkaIO.Read, 
Remove Kafka Metadata}) exceeded the 80 characters length limit and was 
truncated.
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Feb 24, 
2023 12:24:15 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 [4]ReadFromKafka/{KafkaIO.Read, 
Remove Kafka Metadata}) exceeded the 80 characters length limit and was 
truncated.
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Feb 24, 
2023 12:24:15 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 [4]ReadFromKafka/{KafkaIO.Read, 
Remove Kafka Metadata}) exceeded the 80 characters length limit and was 
truncated.
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Feb 24, 
2023 12:24:15 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 [4]ReadFromKafka/{KafkaIO.Read, 
Remove Kafka Metadata}) exceeded the 80 characters length limit and was 
truncated.
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Feb 24, 
2023 12:24:15 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 [4]ReadFromKafka/{KafkaIO.Read, 
Remove Kafka Metadata}) exceeded the 80 characters length limit and was 
truncated.
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Feb 24, 
2023 12:24:15 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 [4]ReadFromKafka/{KafkaIO.Read, 
Remove Kafka Metadata}) exceeded the 80 characters length limit and was 
truncated.
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Feb 24, 
2023 12:24:15 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 [4]ReadFromKafka/{KafkaIO.Read, 
Remove Kafka Metadata}) exceeded the 80 characters length limit and was 
truncated.
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Feb 24, 
2023 12:24:15 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 [4]ReadFromKafka/{KafkaIO.Read, 
Remove Kafka Metadata}) exceeded the 80 characters length limit and was 
truncated.
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Feb 24, 
2023 12:24:15 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 [4]ReadFromKafka/{KafkaIO.Read, 
Remove Kafka Metadata}) exceeded the 80 characters length limit and was 
truncated.
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Feb 24, 
2023 12:24:15 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 
[4]assert_that/{WindowInto(WindowIntoFn), ToVoidKey, Group}) exceeded the 80 
characters length limit and was truncated.
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Feb 24, 
2023 12:24:15 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 
[4]assert_that/{WindowInto(WindowIntoFn), ToVoidKey, Group}) exceeded the 80 
characters length limit and was truncated.
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Feb 24, 
2023 12:24:15 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 
[4]assert_that/{WindowInto(WindowIntoFn), ToVoidKey, Group}) exceeded the 80 
characters length limit and was truncated.
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Feb 24, 
2023 12:24:15 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 
[4]assert_that/{WindowInto(WindowIntoFn), ToVoidKey, Group}) exceeded the 80 
characters length limit and was truncated.
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Feb 24, 
2023 12:24:15 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 
[4]assert_that/{WindowInto(WindowIntoFn), ToVoidKey, Group}) exceeded the 80 
characters length limit and was truncated.
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Feb 24, 
2023 12:24:15 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 
[4]assert_that/{WindowInto(WindowIntoFn), ToVoidKey, Group}) exceeded the 80 
characters length limit and was truncated.
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Feb 24, 
2023 12:24:15 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 
[4]assert_that/{WindowInto(WindowIntoFn), ToVoidKey, Group}) exceeded the 80 
characters length limit and was truncated.
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Feb 24, 
2023 12:24:15 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 
[4]assert_that/{WindowInto(WindowIntoFn), ToVoidKey, Group}) exceeded the 80 
characters length limit and was truncated.
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Feb 24, 
2023 12:24:15 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 
[4]assert_that/{WindowInto(WindowIntoFn), ToVoidKey, Group}) exceeded the 80 
characters length limit and was truncated.
FATAL: command execution failed
java.io.IOException: Backing channel 'apache-beam-jenkins-6' 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:317)
        at hudson.tasks.BuildStepMonitor$1.perform(BuildStepMonitor.java:20)
        at 
hudson.model.AbstractBuild$AbstractBuildExecution.perform(AbstractBuild.java:814)
        at hudson.model.Build$BuildExecution.build(Build.java:199)
        at hudson.model.Build$BuildExecution.doRun(Build.java:164)
        at 
hudson.model.AbstractBuild$AbstractBuildExecution.run(AbstractBuild.java:522)
        at hudson.model.Run.execute(Run.java:1896)
        at hudson.model.FreeStyleBuild.run(FreeStyleBuild.java:44)
        at hudson.model.ResourceController.execute(ResourceController.java:101)
        at hudson.model.Executor.run(Executor.java:442)
Caused by: java.io.IOException: Pipe closed after 0 cycles
        at 
org.apache.sshd.common.channel.ChannelPipedInputStream.read(ChannelPipedInputStream.java:126)
        at 
org.apache.sshd.common.channel.ChannelPipedInputStream.read(ChannelPipedInputStream.java:105)
        at 
hudson.remoting.FlightRecorderInputStream.read(FlightRecorderInputStream.java:94)
        at 
hudson.remoting.ChunkedInputStream.readHeader(ChunkedInputStream.java:75)
        at 
hudson.remoting.ChunkedInputStream.readUntilBreak(ChunkedInputStream.java:105)
        at 
hudson.remoting.ChunkedCommandTransport.readBlock(ChunkedCommandTransport.java:39)
        at 
hudson.remoting.AbstractSynchronousByteArrayCommandTransport.read(AbstractSynchronousByteArrayCommandTransport.java:34)
        at 
hudson.remoting.SynchronousCommandTransport$ReaderThread.run(SynchronousCommandTransport.java:61)
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
ERROR: apache-beam-jenkins-6 is offline; cannot locate jdk_1.8_latest


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


Reply via email to