See
<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/2112/display/redirect>
Changes:
------------------------------------------
[...truncated 43.59 MB...]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49:28 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_fe34a766-69b4-4a11-8d3d-dbd2a7779b46.null.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49:28 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_fe34a766-69b4-4a11-8d3d-dbd2a7779b46.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49:29 PM org.apache.beam.runners.flink.FlinkJobInvoker invokeWithExecutor
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Invoking job
BeamApp-jenkins-0721214929-7edc54ac_f8d13eb2-09ed-4d29-9f18-e04a382511ac with
pipeline runner org.apache.beam.runners.flink.FlinkPipelineRunner@743153d6
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49:30 PM org.apache.beam.runners.jobsubmission.JobInvocation start
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Starting job invocation
BeamApp-jenkins-0721214929-7edc54ac_f8d13eb2-09ed-4d29-9f18-e04a382511ac
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 Jul 21,
2023 9:49:30 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 Jul 21,
2023 9:49:30 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 Jul 21,
2023 9:49:31 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
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49:32 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 Jul 21,
2023 9:49:33 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 Jul 21,
2023 9:49:34 PM org.apache.hadoop.util.NativeCodeLoader <clinit>
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Unable to load native-hadoop library for your platform... using builtin-java
classes where applicable
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49:35 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 Jul 21,
2023 9:49:35 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 Jul 21,
2023 9:49:35 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 Jul 21,
2023 9:49: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 [3]read
table/{FilesToRemoveImpulse, MapFilesToRemove}) exceeded the 80 characters
length limit and was truncated.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49: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 [3]read
table/{FilesToRemoveImpulse, MapFilesToRemove}) exceeded the 80 characters
length limit and was truncated.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49: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 [3]read
table/{FilesToRemoveImpulse, MapFilesToRemove}) exceeded the 80 characters
length limit and was truncated.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49: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 [3]read
table/{FilesToRemoveImpulse, MapFilesToRemove}) exceeded the 80 characters
length limit and was truncated.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49: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 [3]read
table/{FilesToRemoveImpulse, MapFilesToRemove}) exceeded the 80 characters
length limit and was truncated.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49: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 [3]read
table/{FilesToRemoveImpulse, MapFilesToRemove}) exceeded the 80 characters
length limit and was truncated.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49: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 [3]read
table/{FilesToRemoveImpulse, MapFilesToRemove}) exceeded the 80 characters
length limit and was truncated.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49: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 [3]read
table/{FilesToRemoveImpulse, MapFilesToRemove}) exceeded the 80 characters
length limit and was truncated.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49: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 [3]read
table/{FilesToRemoveImpulse, MapFilesToRemove}) exceeded the 80 characters
length limit and was truncated.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49: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 [3]read
table/{FilesToRemoveImpulse, MapFilesToRemove}) exceeded the 80 characters
length limit and was truncated.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49: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 [3]read
table/{FilesToRemoveImpulse, MapFilesToRemove}) exceeded the 80 characters
length limit and was truncated.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49: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 [3]read
table/{FilesToRemoveImpulse, MapFilesToRemove}) exceeded the 80 characters
length limit and was truncated.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49: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 [3]read
table/{FilesToRemoveImpulse, MapFilesToRemove}) exceeded the 80 characters
length limit and was truncated.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49: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 [3]read
table/{FilesToRemoveImpulse, MapFilesToRemove}) exceeded the 80 characters
length limit and was truncated.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49: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 [3]read
table/{FilesToRemoveImpulse, MapFilesToRemove}) exceeded the 80 characters
length limit and was truncated.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49: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 [3]read
table/{FilesToRemoveImpulse, MapFilesToRemove}) exceeded the 80 characters
length limit and was truncated.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49: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 [3]read table/Read/{Map(<lambda
at iobase.py:911>), SDFBoundedSourceReader}) exceeded the 80 characters length
limit and was truncated.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49: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 [3]read table/Read/{Map(<lambda
at iobase.py:911>), SDFBoundedSourceReader}) exceeded the 80 characters length
limit and was truncated.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49: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 [3]read table/Read/{Map(<lambda
at iobase.py:911>), SDFBoundedSourceReader}) exceeded the 80 characters length
limit and was truncated.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49: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 [3]read table/Read/{Map(<lambda
at iobase.py:911>), SDFBoundedSourceReader}) exceeded the 80 characters length
limit and was truncated.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49: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 [3]read table/Read/{Map(<lambda
at iobase.py:911>), SDFBoundedSourceReader}) exceeded the 80 characters length
limit and was truncated.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49: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 [3]read table/Read/{Map(<lambda
at iobase.py:911>), SDFBoundedSourceReader}) exceeded the 80 characters length
limit and was truncated.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49: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 [3]read table/Read/{Map(<lambda
at iobase.py:911>), SDFBoundedSourceReader}) exceeded the 80 characters length
limit and was truncated.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49: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 [3]read table/Read/{Map(<lambda
at iobase.py:911>), SDFBoundedSourceReader}) exceeded the 80 characters length
limit and was truncated.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49: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 [3]read table/Read/{Map(<lambda
at iobase.py:911>), SDFBoundedSourceReader}) exceeded the 80 characters length
limit and was truncated.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49: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 [3]read table/Read/{Map(<lambda
at iobase.py:911>), SDFBoundedSourceReader}) exceeded the 80 characters length
limit and was truncated.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49: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 [3]read table/Read/{Map(<lambda
at iobase.py:911>), SDFBoundedSourceReader}) exceeded the 80 characters length
limit and was truncated.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49: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 [3]read table/Read/{Map(<lambda
at iobase.py:911>), SDFBoundedSourceReader}) exceeded the 80 characters length
limit and was truncated.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49: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 [3]read table/Read/{Map(<lambda
at iobase.py:911>), SDFBoundedSourceReader}) exceeded the 80 characters length
limit and was truncated.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49: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 [3]read table/Read/{Map(<lambda
at iobase.py:911>), SDFBoundedSourceReader}) exceeded the 80 characters length
limit and was truncated.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49: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 [3]read table/Read/{Map(<lambda
at iobase.py:911>), SDFBoundedSourceReader}) exceeded the 80 characters length
limit and was truncated.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49: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 [3]read table/Read/{Map(<lambda
at iobase.py:911>), SDFBoundedSourceReader}) exceeded the 80 characters length
limit and was truncated.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49: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 [13]{read table, assign
timestamp, set schema, daily windows, BatchElements(daily), ToPCollection(df) -
gs:}) exceeded the 80 characters length limit and was truncated.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49: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 [13]{read table, assign
timestamp, set schema, daily windows, BatchElements(daily), ToPCollection(df) -
gs:}) exceeded the 80 characters length limit and was truncated.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49: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 [13]{read table, assign
timestamp, set schema, daily windows, BatchElements(daily), ToPCollection(df) -
gs:}) exceeded the 80 characters length limit and was truncated.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49: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 [13]{read table, assign
timestamp, set schema, daily windows, BatchElements(daily), ToPCollection(df) -
gs:}) exceeded the 80 characters length limit and was truncated.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49: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 [13]{read table, assign
timestamp, set schema, daily windows, BatchElements(daily), ToPCollection(df) -
gs:}) exceeded the 80 characters length limit and was truncated.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49: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 [13]{read table, assign
timestamp, set schema, daily windows, BatchElements(daily), ToPCollection(df) -
gs:}) exceeded the 80 characters length limit and was truncated.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49: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 [13]{read table, assign
timestamp, set schema, daily windows, BatchElements(daily), ToPCollection(df) -
gs:}) exceeded the 80 characters length limit and was truncated.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49: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 [13]{read table, assign
timestamp, set schema, daily windows, BatchElements(daily), ToPCollection(df) -
gs:}) exceeded the 80 characters length limit and was truncated.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49: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 [13]{read table, assign
timestamp, set schema, daily windows, BatchElements(daily), ToPCollection(df) -
gs:}) exceeded the 80 characters length limit and was truncated.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49: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 [13]{read table, assign
timestamp, set schema, daily windows, BatchElements(daily), ToPCollection(df) -
gs:}) exceeded the 80 characters length limit and was truncated.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49: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 [13]{read table, assign
timestamp, set schema, daily windows, BatchElements(daily), ToPCollection(df) -
gs:}) exceeded the 80 characters length limit and was truncated.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49: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 [13]{read table, assign
timestamp, set schema, daily windows, BatchElements(daily), ToPCollection(df) -
gs:}) exceeded the 80 characters length limit and was truncated.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49: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 [13]{read table, assign
timestamp, set schema, daily windows, BatchElements(daily), ToPCollection(df) -
gs:}) exceeded the 80 characters length limit and was truncated.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49: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 [13]{read table, assign
timestamp, set schema, daily windows, BatchElements(daily), ToPCollection(df) -
gs:}) exceeded the 80 characters length limit and was truncated.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49: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 [13]{read table, assign
timestamp, set schema, daily windows, BatchElements(daily), ToPCollection(df) -
gs:}) exceeded the 80 characters length limit and was truncated.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49: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 [13]{read table, assign
timestamp, set schema, daily windows, BatchElements(daily), ToPCollection(df) -
gs:}) exceeded the 80 characters length limit and was truncated.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49:37 PM org.apache.flink.runtime.metrics.groups.TaskMetricGroup
getOrAddOperator
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
The operator name GroupCombine (GroupCombine at GroupCombine: ToPCollection(df)
-
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-f7d3e751-66f7-41a9-b42d-330e7d516880/output.csv/[ComputedExpression[apply_DataFrame_140420201334032]]:140418797469072/CoGroupByKey/CoGroupByKeyImpl/GroupByKey)
exceeded the 80 characters length limit and was truncated.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49:37 PM org.apache.flink.runtime.metrics.groups.TaskMetricGroup
getOrAddOperator
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
The operator name GroupCombine (GroupCombine at GroupCombine: ToPCollection(df)
-
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-f7d3e751-66f7-41a9-b42d-330e7d516880/output.csv/[ComputedExpression[apply_DataFrame_140420201334032]]:140418797469072/CoGroupByKey/CoGroupByKeyImpl/GroupByKey)
exceeded the 80 characters length limit and was truncated.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49:37 PM org.apache.flink.runtime.metrics.groups.TaskMetricGroup
getOrAddOperator
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
The operator name GroupCombine (GroupCombine at GroupCombine: ToPCollection(df)
-
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-f7d3e751-66f7-41a9-b42d-330e7d516880/output.csv/[ComputedExpression[apply_DataFrame_140420201334032]]:140418797469072/CoGroupByKey/CoGroupByKeyImpl/GroupByKey)
exceeded the 80 characters length limit and was truncated.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49:37 PM org.apache.flink.runtime.metrics.groups.TaskMetricGroup
getOrAddOperator
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
The operator name GroupCombine (GroupCombine at GroupCombine: ToPCollection(df)
-
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-f7d3e751-66f7-41a9-b42d-330e7d516880/output.csv/[ComputedExpression[apply_DataFrame_140420201334032]]:140418797469072/CoGroupByKey/CoGroupByKeyImpl/GroupByKey)
exceeded the 80 characters length limit and was truncated.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49:37 PM org.apache.flink.runtime.metrics.groups.TaskMetricGroup
getOrAddOperator
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
The operator name GroupCombine (GroupCombine at GroupCombine: ToPCollection(df)
-
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-f7d3e751-66f7-41a9-b42d-330e7d516880/output.csv/[ComputedExpression[apply_DataFrame_140420201334032]]:140418797469072/CoGroupByKey/CoGroupByKeyImpl/GroupByKey)
exceeded the 80 characters length limit and was truncated.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49:37 PM org.apache.flink.runtime.metrics.groups.TaskMetricGroup
getOrAddOperator
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
The operator name GroupCombine (GroupCombine at GroupCombine: ToPCollection(df)
-
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-f7d3e751-66f7-41a9-b42d-330e7d516880/output.csv/[ComputedExpression[apply_DataFrame_140420201334032]]:140418797469072/CoGroupByKey/CoGroupByKeyImpl/GroupByKey)
exceeded the 80 characters length limit and was truncated.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49:37 PM org.apache.flink.runtime.metrics.groups.TaskMetricGroup
getOrAddOperator
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
The operator name GroupCombine (GroupCombine at GroupCombine: ToPCollection(df)
-
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-f7d3e751-66f7-41a9-b42d-330e7d516880/output.csv/[ComputedExpression[apply_DataFrame_140420201334032]]:140418797469072/CoGroupByKey/CoGroupByKeyImpl/GroupByKey)
exceeded the 80 characters length limit and was truncated.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49:37 PM org.apache.flink.runtime.metrics.groups.TaskMetricGroup
getOrAddOperator
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
The operator name GroupCombine (GroupCombine at GroupCombine: ToPCollection(df)
-
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-f7d3e751-66f7-41a9-b42d-330e7d516880/output.csv/[ComputedExpression[apply_DataFrame_140420201334032]]:140418797469072/CoGroupByKey/CoGroupByKeyImpl/GroupByKey)
exceeded the 80 characters length limit and was truncated.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49:37 PM org.apache.flink.runtime.metrics.groups.TaskMetricGroup
getOrAddOperator
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
The operator name GroupCombine (GroupCombine at GroupCombine: ToPCollection(df)
-
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-f7d3e751-66f7-41a9-b42d-330e7d516880/output.csv/[ComputedExpression[apply_DataFrame_140420201334032]]:140418797469072/CoGroupByKey/CoGroupByKeyImpl/GroupByKey)
exceeded the 80 characters length limit and was truncated.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49:37 PM org.apache.flink.runtime.metrics.groups.TaskMetricGroup
getOrAddOperator
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
The operator name GroupCombine (GroupCombine at GroupCombine: ToPCollection(df)
-
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-f7d3e751-66f7-41a9-b42d-330e7d516880/output.csv/[ComputedExpression[apply_DataFrame_140420201334032]]:140418797469072/CoGroupByKey/CoGroupByKeyImpl/GroupByKey)
exceeded the 80 characters length limit and was truncated.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49:37 PM org.apache.flink.runtime.metrics.groups.TaskMetricGroup
getOrAddOperator
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
The operator name GroupCombine (GroupCombine at GroupCombine: ToPCollection(df)
-
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-f7d3e751-66f7-41a9-b42d-330e7d516880/output.csv/[ComputedExpression[apply_DataFrame_140420201334032]]:140418797469072/CoGroupByKey/CoGroupByKeyImpl/GroupByKey)
exceeded the 80 characters length limit and was truncated.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49:37 PM org.apache.flink.runtime.metrics.groups.TaskMetricGroup
getOrAddOperator
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
The operator name GroupCombine (GroupCombine at GroupCombine: ToPCollection(df)
-
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-f7d3e751-66f7-41a9-b42d-330e7d516880/output.csv/[ComputedExpression[apply_DataFrame_140420201334032]]:140418797469072/CoGroupByKey/CoGroupByKeyImpl/GroupByKey)
exceeded the 80 characters length limit and was truncated.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49:37 PM org.apache.flink.runtime.metrics.groups.TaskMetricGroup
getOrAddOperator
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
The operator name GroupReduce (GroupReduce at ToPCollection(df) -
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-f7d3e751-66f7-41a9-b42d-330e7d516880/output.csv/[ComputedExpression[apply_DataFrame_140420201334032]]:140418797469072/CoGroupByKey/CoGroupByKeyImpl/GroupByKey)
exceeded the 80 characters length limit and was truncated.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49:37 PM org.apache.flink.runtime.metrics.groups.TaskMetricGroup
getOrAddOperator
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
The operator name GroupReduce (GroupReduce at ToPCollection(df) -
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-f7d3e751-66f7-41a9-b42d-330e7d516880/output.csv/[ComputedExpression[apply_DataFrame_140420201334032]]:140418797469072/CoGroupByKey/CoGroupByKeyImpl/GroupByKey)
exceeded the 80 characters length limit and was truncated.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49:37 PM org.apache.flink.runtime.metrics.groups.TaskMetricGroup
getOrAddOperator
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
The operator name GroupCombine (GroupCombine at GroupCombine: ToPCollection(df)
-
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-f7d3e751-66f7-41a9-b42d-330e7d516880/output.csv/[ComputedExpression[apply_DataFrame_140420201334032]]:140418797469072/CoGroupByKey/CoGroupByKeyImpl/GroupByKey)
exceeded the 80 characters length limit and was truncated.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49:37 PM org.apache.flink.runtime.metrics.groups.TaskMetricGroup
getOrAddOperator
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
The operator name GroupReduce (GroupReduce at ToPCollection(df) -
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-f7d3e751-66f7-41a9-b42d-330e7d516880/output.csv/[ComputedExpression[apply_DataFrame_140420201334032]]:140418797469072/CoGroupByKey/CoGroupByKeyImpl/GroupByKey)
exceeded the 80 characters length limit and was truncated.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49:37 PM org.apache.flink.runtime.metrics.groups.TaskMetricGroup
getOrAddOperator
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
The operator name GroupReduce (GroupReduce at ToPCollection(df) -
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-f7d3e751-66f7-41a9-b42d-330e7d516880/output.csv/[ComputedExpression[apply_DataFrame_140420201334032]]:140418797469072/CoGroupByKey/CoGroupByKeyImpl/GroupByKey)
exceeded the 80 characters length limit and was truncated.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49:37 PM org.apache.flink.runtime.metrics.groups.TaskMetricGroup
getOrAddOperator
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
The operator name GroupReduce (GroupReduce at ToPCollection(df) -
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-f7d3e751-66f7-41a9-b42d-330e7d516880/output.csv/[ComputedExpression[apply_DataFrame_140420201334032]]:140418797469072/CoGroupByKey/CoGroupByKeyImpl/GroupByKey)
exceeded the 80 characters length limit and was truncated.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49:37 PM org.apache.flink.runtime.metrics.groups.TaskMetricGroup
getOrAddOperator
> Task :sdks:python:test-suites:portable:py38:flinkExamples
INFO apache_beam.runners.worker.worker_pool_main:worker_pool_main.py:113
Listening for workers at localhost:40593
INFO
apache_beam.runners.portability.fn_api_runner.translations:translations.py:710
==================== <function pack_combiners at 0x7f535e011dc0>
====================
INFO
apache_beam.runners.portability.fn_api_runner.translations:translations.py:710
==================== <function lift_combiners at 0x7f535e011e50>
====================
INFO
apache_beam.runners.portability.fn_api_runner.translations:translations.py:710
==================== <function sort_stages at 0x7f535e0125e0>
====================
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.50.0-SNAPSHOT.jar'
'--flink-master' '[auto]' '--artifacts-dir'
'/tmp/beam-temp34chl38n/artifactsw81oxx03' '--job-port' '52803'
'--artifact-port' '0' '--expansion-port' '0']
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49: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 Jul 21,
2023 9:49:30 PM org.apache.beam.runners.jobsubmission.JobServerDriver
createArtifactStagingService
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
ArtifactStagingService started on localhost:34631
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49:30 PM org.apache.beam.runners.jobsubmission.JobServerDriver
createExpansionService
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Java ExpansionService started on localhost:38163
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49:30 PM org.apache.beam.runners.jobsubmission.JobServerDriver
createJobServer
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
JobService started on localhost:52803
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49: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:52803.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49: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_6c2b539d-6401-4c83-8e0e-84200cebd91a.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49: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_6c2b539d-6401-4c83-8e0e-84200cebd91a.ref_Environment_default_environment_1.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49: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_6c2b539d-6401-4c83-8e0e-84200cebd91a.null.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49: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_6c2b539d-6401-4c83-8e0e-84200cebd91a.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49:33 PM org.apache.beam.runners.flink.FlinkJobInvoker invokeWithExecutor
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Invoking job
BeamApp-jenkins-0721214932-7ecc9064_a7db71ea-3799-4b85-af9a-32e73e7f2ba0 with
pipeline runner org.apache.beam.runners.flink.FlinkPipelineRunner@12ec1686
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49:33 PM org.apache.beam.runners.jobsubmission.JobInvocation start
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Starting job invocation
BeamApp-jenkins-0721214932-7ecc9064_a7db71ea-3799-4b85-af9a-32e73e7f2ba0
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 Jul 21,
2023 9:49:33 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 Jul 21,
2023 9:49:33 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 Jul 21,
2023 9:49:34 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
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jul 21,
2023 9:49:36 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 Jul 21,
2023 9:49:36 PM akka.event.slf4j.Slf4jLogger$$anonfun$receive$1 applyOrElse
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Slf4jLogger started
> Task :sdks:python:test-suites:portable:py311:flinkExamples
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
The operator name GroupReduce (GroupReduce at ToPCollection(df) -
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-f7d3e751-66f7-41a9-b42d-330e7d516880/output.csv/[ComputedExpression[apply_DataFrame_140420201334032]]:140418797469072/CoGroupByKey/CoGroupByKeyImpl/GroupByKey)
exceeded the 80 characters length limit and was truncated.
FATAL: command execution failed
hudson.remoting.ChannelClosedException: Channel
"hudson.remoting.Channel@6154c3da:apache-beam-jenkins-10": Remote call on
apache-beam-jenkins-10 failed. The channel is closing down or has closed down
at hudson.remoting.Channel.call(Channel.java:993)
at
hudson.remoting.RemoteInvocationHandler.invoke(RemoteInvocationHandler.java:285)
at com.sun.proxy.$Proxy147.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-10 is offline; cannot locate jdk_1.8_latest
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
