You are viewing a plain text version of this content. The canonical link for it is here.
Posted to builds@beam.apache.org by Apache Jenkins Server <je...@builds.apache.org> on 2023/07/21 22:50:19 UTC
Build failed in Jenkins: beam_PostCommit_Python_Examples_Flink #2112
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: builds-unsubscribe@beam.apache.org
For additional commands, e-mail: builds-help@beam.apache.org
Jenkins build is back to normal : beam_PostCommit_Python_Examples_Flink #2113
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/2113/display/redirect>
---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscribe@beam.apache.org
For additional commands, e-mail: builds-help@beam.apache.org