See
<https://ci-beam.apache.org/job/beam_PostCommit_PortableJar_Flink/3994/display/redirect>
Changes:
------------------------------------------
[...truncated 1.16 MB...]
Aug 21, 2021 6:17:34 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine
(GroupCombine at GroupCombine: assert_that/Group/_CoGBKImpl/GroupByKey) -> Map
(Key Extractor) (1/1)#0 (92153f3fc854f06a19ded7c52174e563) switched from
RUNNING to FINISHED.
Aug 21, 2021 6:17:34 PM org.apache.flink.runtime.taskmanager.Task doRun
INFO: Freeing task resources for CHAIN Filter (UnionFixFilter) -> Map (Key
Extractor) -> GroupCombine (GroupCombine at GroupCombine:
assert_that/Group/_CoGBKImpl/GroupByKey) -> Map (Key Extractor) (1/1)#0
(92153f3fc854f06a19ded7c52174e563).
Aug 21, 2021 6:17:34 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task Partition (1/1)#0 a7b52e5f4f2e43c0abd60305eeed39ff.
Aug 21, 2021 6:17:34 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task CHAIN MapPartition (MapPartition at
[1]Create/FlatMap(<lambda at core.py:2965>)) -> FlatMap (FlatMap at
ExtractOutput[0]) (1/1)#0 561632c412457ed42c004f4ed0bdaad0.
Aug 21, 2021 6:17:34 PM
org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder
INFO: The AWS S3 Beam extension was included in this build, but the awsRegion
flag was not specified. If you don't plan to use S3, then ignore this message.
Aug 21, 2021 6:17:34 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task CHAIN MapPartition (MapPartition at [6]{Create, Map(<lambda
at <string>:23>), assert_that}) -> FlatMap (FlatMap at ExtractOutput[0])
(1/1)#0 f712b4455969202948d5a1ff6d8728ca.
Aug 21, 2021 6:17:34 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) ->
GroupCombine (GroupCombine at GroupCombine:
assert_that/Group/_CoGBKImpl/GroupByKey) -> Map (Key Extractor) (1/1)#0
92153f3fc854f06a19ded7c52174e563.
Aug 21, 2021 6:17:34 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: GroupReduce (GroupReduce at assert_that/Group/_CoGBKImpl/GroupByKey)
(1/1)#0 (35651a22489f412922a814ff00a112ec) switched from RUNNING to FINISHED.
Aug 21, 2021 6:17:34 PM org.apache.flink.runtime.taskmanager.Task doRun
INFO: Freeing task resources for GroupReduce (GroupReduce at
assert_that/Group/_CoGBKImpl/GroupByKey) (1/1)#0
(35651a22489f412922a814ff00a112ec).
Aug 21, 2021 6:17:34 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task GroupReduce (GroupReduce at
assert_that/Group/_CoGBKImpl/GroupByKey) (1/1)#0
35651a22489f412922a814ff00a112ec.
Aug 21, 2021 6:17:34 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) ->
FlatMap (FlatMap at ExtractOutput[0]) (1/1) (b0061885d49db1311e5b55184ba2b740)
switched from RUNNING to FINISHED.
Aug 21, 2021 6:17:34 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: Partition (1/1) (a7b52e5f4f2e43c0abd60305eeed39ff) switched from RUNNING
to FINISHED.
Aug 21, 2021 6:17:34 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: CHAIN MapPartition (MapPartition at [1]Create/FlatMap(<lambda at
core.py:2965>)) -> FlatMap (FlatMap at ExtractOutput[0]) (1/1)
(561632c412457ed42c004f4ed0bdaad0) switched from RUNNING to FINISHED.
Aug 21, 2021 6:17:34 PM
org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory$WrappedSdkHarnessClient
unref
INFO: Closing environment urn: "beam:env:docker:v1"
payload: "\n$apache/beam_python3.7_sdk:2.33.0.dev"
capabilities: "beam:coder:bytes:v1"
capabilities: "beam:coder:string_utf8:v1"
capabilities: "beam:coder:kv:v1"
capabilities: "beam:coder:bool:v1"
capabilities: "beam:coder:varint:v1"
capabilities: "beam:coder:double:v1"
capabilities: "beam:coder:iterable:v1"
capabilities: "beam:coder:timer:v1"
capabilities: "beam:coder:interval_window:v1"
capabilities: "beam:coder:length_prefix:v1"
capabilities: "beam:coder:global_window:v1"
capabilities: "beam:coder:windowed_value:v1"
capabilities: "beam:coder:param_windowed_value:v1"
capabilities: "beam:coder:state_backed_iterable:v1"
capabilities: "beam:coder:custom_window:v1"
capabilities: "beam:coder:row:v1"
capabilities: "beam:coder:sharded_key:v1"
capabilities: "beam:protocol:progress_reporting:v0"
capabilities: "beam:protocol:harness_monitoring_infos:v1"
capabilities: "beam:protocol:worker_status:v1"
capabilities: "beam:combinefn:packed_python:v1"
capabilities: "beam:version:sdk_base:apache/beam_python3.7_sdk:2.33.0.dev"
capabilities: "beam:transform:sdf_truncate_sized_restrictions:v1"
capabilities: "beam:transform:to_string:v1"
dependencies {
type_urn: "beam:artifact:type:file:v1"
type_payload:
"\n\253\001classpath://BEAM-PIPELINE/pipeline/artifacts/job-7264b744-0ff7-4acf-80a4-7b2199583542/509d6acc9d3b2a2c5ef066d422297f8481aa62ee0f71043c6530fafe6569f672-pickled_main_session"
role_urn: "beam:artifact:role:staging_to:v1"
role_payload: "\n\024pickled_main_session"
}
Aug 21, 2021 6:17:34 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: CHAIN MapPartition (MapPartition at [6]{Create, Map(<lambda at
<string>:23>), assert_that}) -> FlatMap (FlatMap at ExtractOutput[0]) (1/1)
(f712b4455969202948d5a1ff6d8728ca) switched from RUNNING to FINISHED.
Aug 21, 2021 6:17:34 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine
(GroupCombine at GroupCombine: assert_that/Group/_CoGBKImpl/GroupByKey) -> Map
(Key Extractor) (1/1) (92153f3fc854f06a19ded7c52174e563) switched from RUNNING
to FINISHED.
Aug 21, 2021 6:17:34 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: GroupReduce (GroupReduce at assert_that/Group/_CoGBKImpl/GroupByKey)
(1/1) (35651a22489f412922a814ff00a112ec) switched from RUNNING to FINISHED.
Aug 21, 2021 6:17:34 PM
org.apache.beam.runners.fnexecution.logging.GrpcLoggingService close
INFO: 1 Beam Fn Logging clients still connected during shutdown.
Aug 21, 2021 6:17:34 PM
org.apache.beam.sdk.fn.data.BeamFnDataGrpcMultiplexer$InboundObserver
onCompleted
WARNING: Hanged up for unknown endpoint.
Aug 21, 2021 6:17:34 PM
org.apache.beam.sdk.fn.data.BeamFnDataGrpcMultiplexer$InboundObserver
onCompleted
WARNING: Hanged up for unknown endpoint.
Aug 21, 2021 6:17:35 PM
org.apache.beam.runners.fnexecution.environment.DockerContainerEnvironment close
INFO: Closing Docker container
8b45aa29f71b2b017b045a53976fcc78b4a001090f12ef339c8281aaaf1b374f. Logs:
2021/08/21 18:17:31 Provision info:
pipeline_options:{fields:{key:"beam:option:allow_non_deterministic_key_coders:v1"
value:{bool_value:false}} fields:{key:"beam:option:allow_unsafe_triggers:v1"
value:{bool_value:false}} fields:{key:"beam:option:app_name:v1"
value:{null_value:NULL_VALUE}} fields:{key:"beam:option:artifact_port:v1"
value:{string_value:"0"}} fields:{key:"beam:option:beam_services:v1"
value:{struct_value:{}}} fields:{key:"beam:option:dataflow_endpoint:v1"
value:{string_value:"https://dataflow.googleapis.com"}}
fields:{key:"beam:option:direct_num_workers:v1" value:{string_value:"1"}}
fields:{key:"beam:option:direct_runner_bundle_repeat:v1"
value:{string_value:"0"}}
fields:{key:"beam:option:direct_runner_use_stacked_bundle:v1"
value:{bool_value:true}} fields:{key:"beam:option:direct_running_mode:v1"
value:{string_value:"in_memory"}} fields:{key:"beam:option:dry_run:v1"
value:{bool_value:false}} fields:{key:"beam:option:enable_hot_key_logging:v1"
value:{bool_value:false}} fields:{key:"beam:option:enable_streaming_engine:v1"
value:{bool_value:false}} fields:{key:"beam:option:environment_cache_millis:v1"
value:{string_value:"0"}} fields:{key:"beam:option:environment_options:v1"
value:{list_value:{values:{string_value:"docker_container_image=apache/beam_python3.7_sdk:2.33.0.dev"}}}}
fields:{key:"beam:option:environment_type:v1" value:{string_value:"DOCKER"}}
fields:{key:"beam:option:expansion_port:v1" value:{string_value:"0"}}
fields:{key:"beam:option:experiments:v1"
value:{list_value:{values:{string_value:"beam_fn_api"}}}}
fields:{key:"beam:option:flink_job_server_jar:v1"
value:{string_value:"<https://ci-beam.apache.org/job/beam_PostCommit_PortableJar_Flink/ws/src/runners/flink/1.13/job-server/build/libs/beam-runners-flink-1.13-job-server-2.33.0-SNAPSHOT.jar"}}>
fields:{key:"beam:option:flink_master:v1" value:{string_value:"[auto]"}}
fields:{key:"beam:option:flink_submit_uber_jar:v1" value:{bool_value:true}}
fields:{key:"beam:option:flink_version:v1" value:{string_value:"1.13"}}
fields:{key:"beam:option:hdfs_full_urls:v1" value:{bool_value:false}}
fields:{key:"beam:option:job_name:v1"
value:{string_value:"BeamApp-jenkins-0821181714-bc8cb588"}}
fields:{key:"beam:option:job_port:v1" value:{string_value:"0"}}
fields:{key:"beam:option:job_server_java_launcher:v1"
value:{string_value:"java"}}
fields:{key:"beam:option:job_server_jvm_properties:v1" value:{list_value:{}}}
fields:{key:"beam:option:job_server_timeout:v1" value:{string_value:"60"}}
fields:{key:"beam:option:no_auth:v1" value:{bool_value:false}}
fields:{key:"beam:option:options_id:v1" value:{number_value:1}}
fields:{key:"beam:option:parallelism:v1" value:{string_value:"1"}}
fields:{key:"beam:option:performance_runtime_type_check:v1"
value:{bool_value:false}} fields:{key:"beam:option:pipeline_type_check:v1"
value:{bool_value:true}} fields:{key:"beam:option:profile_cpu:v1"
value:{bool_value:false}} fields:{key:"beam:option:profile_memory:v1"
value:{bool_value:false}} fields:{key:"beam:option:profile_sample_rate:v1"
value:{number_value:1}} fields:{key:"beam:option:resource_hints:v1"
value:{list_value:{}}} fields:{key:"beam:option:runtime_type_check:v1"
value:{bool_value:false}} fields:{key:"beam:option:s3_disable_ssl:v1"
value:{bool_value:false}} fields:{key:"beam:option:save_main_session:v1"
value:{bool_value:true}} fields:{key:"beam:option:sdk_location:v1"
value:{string_value:"container"}}
fields:{key:"beam:option:sdk_worker_parallelism:v1" value:{string_value:"1"}}
fields:{key:"beam:option:spark_master_url:v1" value:{string_value:"local[4]"}}
fields:{key:"beam:option:spark_submit_uber_jar:v1" value:{bool_value:false}}
fields:{key:"beam:option:spark_version:v1" value:{string_value:"2"}}
fields:{key:"beam:option:streaming:v1" value:{bool_value:false}}
fields:{key:"beam:option:type_check_additional:v1" value:{string_value:""}}
fields:{key:"beam:option:type_check_strictness:v1"
value:{string_value:"DEFAULT_TO_ANY"}} fields:{key:"beam:option:update:v1"
value:{bool_value:false}}} retrieval_token:"__no_artifacts_staged__"
logging_endpoint:{url:"localhost:40401"}
artifact_endpoint:{url:"localhost:42571"}
control_endpoint:{url:"localhost:34313"}
dependencies:{type_urn:"beam:artifact:type:file:v1"
type_payload:"\n\xab\x01classpath://BEAM-PIPELINE/pipeline/artifacts/job-7264b744-0ff7-4acf-80a4-7b2199583542/509d6acc9d3b2a2c5ef066d422297f8481aa62ee0f71043c6530fafe6569f672-pickled_main_session"
role_urn:"beam:artifact:role:staging_to:v1"
role_payload:"\n\x14pickled_main_session"}
2021/08/21 18:17:31 Initializing python harness: /opt/apache/beam/boot --id=1-1
--provision_endpoint=localhost:33995
2021/08/21 18:17:32 Downloaded: /tmp/staged/pickled_main_session (sha256:
4c62abc7278376f17fda3a9724a4cc285606a0105d73dd6807b2f158253dd463, size: 2760)
2021/08/21 18:17:32 Found artifact: pickled_main_session
2021/08/21 18:17:32 Installing setup packages ...
2021/08/21 18:17:32 Executing: python -m
apache_beam.runners.worker.sdk_worker_main
2021/08/21 18:17:34 Python exited: <nil>
Aug 21, 2021 6:17:39 PM
org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory$WrappedSdkHarnessClient
close
WARNING: Error cleaning up servers urn: "beam:env:docker:v1"
payload: "\n$apache/beam_python3.7_sdk:2.33.0.dev"
capabilities: "beam:coder:bytes:v1"
capabilities: "beam:coder:string_utf8:v1"
capabilities: "beam:coder:kv:v1"
capabilities: "beam:coder:bool:v1"
capabilities: "beam:coder:varint:v1"
capabilities: "beam:coder:double:v1"
capabilities: "beam:coder:iterable:v1"
capabilities: "beam:coder:timer:v1"
capabilities: "beam:coder:interval_window:v1"
capabilities: "beam:coder:length_prefix:v1"
capabilities: "beam:coder:global_window:v1"
capabilities: "beam:coder:windowed_value:v1"
capabilities: "beam:coder:param_windowed_value:v1"
capabilities: "beam:coder:state_backed_iterable:v1"
capabilities: "beam:coder:custom_window:v1"
capabilities: "beam:coder:row:v1"
capabilities: "beam:coder:sharded_key:v1"
capabilities: "beam:protocol:progress_reporting:v0"
capabilities: "beam:protocol:harness_monitoring_infos:v1"
capabilities: "beam:protocol:worker_status:v1"
capabilities: "beam:combinefn:packed_python:v1"
capabilities: "beam:version:sdk_base:apache/beam_python3.7_sdk:2.33.0.dev"
capabilities: "beam:transform:sdf_truncate_sized_restrictions:v1"
capabilities: "beam:transform:to_string:v1"
dependencies {
type_urn: "beam:artifact:type:file:v1"
type_payload:
"\n\253\001classpath://BEAM-PIPELINE/pipeline/artifacts/job-7264b744-0ff7-4acf-80a4-7b2199583542/509d6acc9d3b2a2c5ef066d422297f8481aa62ee0f71043c6530fafe6569f672-pickled_main_session"
role_urn: "beam:artifact:role:staging_to:v1"
role_payload: "\n\024pickled_main_session"
}
java.io.IOException: Received exit code 1 for command 'docker kill
8b45aa29f71b2b017b045a53976fcc78b4a001090f12ef339c8281aaaf1b374f'. stderr:
Error response from daemon: Cannot kill container:
8b45aa29f71b2b017b045a53976fcc78b4a001090f12ef339c8281aaaf1b374f: Container
8b45aa29f71b2b017b045a53976fcc78b4a001090f12ef339c8281aaaf1b374f is not running
at
org.apache.beam.runners.fnexecution.environment.DockerCommand.runShortCommand(DockerCommand.java:237)
at
org.apache.beam.runners.fnexecution.environment.DockerCommand.runShortCommand(DockerCommand.java:171)
at
org.apache.beam.runners.fnexecution.environment.DockerCommand.killContainer(DockerCommand.java:151)
at
org.apache.beam.runners.fnexecution.environment.DockerContainerEnvironment.close(DockerContainerEnvironment.java:93)
at
org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory$WrappedSdkHarnessClient.$closeResource(DefaultJobBundleFactory.java:642)
at
org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory$WrappedSdkHarnessClient.close(DefaultJobBundleFactory.java:642)
at
org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory$WrappedSdkHarnessClient.unref(DefaultJobBundleFactory.java:658)
at
org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory$WrappedSdkHarnessClient.access$400(DefaultJobBundleFactory.java:589)
at
org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory.lambda$createEnvironmentCaches$3(DefaultJobBundleFactory.java:212)
at
org.apache.beam.vendor.guava.v26_0_jre.com.google.common.cache.LocalCache.processPendingNotifications(LocalCache.java:1809)
at
org.apache.beam.vendor.guava.v26_0_jre.com.google.common.cache.LocalCache$Segment.runUnlockedCleanup(LocalCache.java:3462)
at
org.apache.beam.vendor.guava.v26_0_jre.com.google.common.cache.LocalCache$Segment.postWriteCleanup(LocalCache.java:3438)
at
org.apache.beam.vendor.guava.v26_0_jre.com.google.common.cache.LocalCache$Segment.clear(LocalCache.java:3215)
at
org.apache.beam.vendor.guava.v26_0_jre.com.google.common.cache.LocalCache.clear(LocalCache.java:4270)
at
org.apache.beam.vendor.guava.v26_0_jre.com.google.common.cache.LocalCache$LocalManualCache.invalidateAll(LocalCache.java:4909)
at
org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory.close(DefaultJobBundleFactory.java:319)
at
org.apache.beam.runners.fnexecution.control.DefaultExecutableStageContext.close(DefaultExecutableStageContext.java:43)
at
org.apache.beam.runners.fnexecution.control.ReferenceCountingExecutableStageContextFactory$WrappedContext.closeActual(ReferenceCountingExecutableStageContextFactory.java:212)
at
org.apache.beam.runners.fnexecution.control.ReferenceCountingExecutableStageContextFactory$WrappedContext.access$200(ReferenceCountingExecutableStageContextFactory.java:188)
at
org.apache.beam.runners.fnexecution.control.ReferenceCountingExecutableStageContextFactory.release(ReferenceCountingExecutableStageContextFactory.java:177)
at
org.apache.beam.runners.fnexecution.control.ReferenceCountingExecutableStageContextFactory.scheduleRelease(ReferenceCountingExecutableStageContextFactory.java:136)
at
org.apache.beam.runners.fnexecution.control.ReferenceCountingExecutableStageContextFactory.access$300(ReferenceCountingExecutableStageContextFactory.java:48)
at
org.apache.beam.runners.fnexecution.control.ReferenceCountingExecutableStageContextFactory$WrappedContext.close(ReferenceCountingExecutableStageContextFactory.java:208)
at
org.apache.beam.runners.flink.translation.functions.FlinkExecutableStageFunction.$closeResource(FlinkExecutableStageFunction.java:268)
at
org.apache.beam.runners.flink.translation.functions.FlinkExecutableStageFunction.close(FlinkExecutableStageFunction.java:373)
at
org.apache.flink.api.common.functions.util.FunctionUtils.closeFunction(FunctionUtils.java:41)
at org.apache.flink.runtime.operators.BatchTask.run(BatchTask.java:524)
at
org.apache.flink.runtime.operators.BatchTask.invoke(BatchTask.java:360)
at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:779)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:566)
at java.lang.Thread.run(Thread.java:748)
Aug 21, 2021 6:17:39 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: MapPartition (MapPartition at [4]assert_that/{Group, Unkey, Match})
(1/1)#0 (a16c8d3cb51de1b80e17bc08086c7c81) switched from RUNNING to FINISHED.
Aug 21, 2021 6:17:39 PM org.apache.flink.runtime.taskmanager.Task doRun
INFO: Freeing task resources for MapPartition (MapPartition at
[4]assert_that/{Group, Unkey, Match}) (1/1)#0
(a16c8d3cb51de1b80e17bc08086c7c81).
Aug 21, 2021 6:17:39 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (DiscardingOutput) (1/1)#0 (4c28ef181fc4b8be1b2b02bd9250b47c)
switched from RUNNING to FINISHED.
Aug 21, 2021 6:17:39 PM org.apache.flink.runtime.taskmanager.Task doRun
INFO: Freeing task resources for DataSink (DiscardingOutput) (1/1)#0
(4c28ef181fc4b8be1b2b02bd9250b47c).
Aug 21, 2021 6:17:39 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task MapPartition (MapPartition at [4]assert_that/{Group, Unkey,
Match}) (1/1)#0 a16c8d3cb51de1b80e17bc08086c7c81.
Aug 21, 2021 6:17:39 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task DataSink (DiscardingOutput) (1/1)#0
4c28ef181fc4b8be1b2b02bd9250b47c.
Aug 21, 2021 6:17:39 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: MapPartition (MapPartition at [4]assert_that/{Group, Unkey, Match}) (1/1)
(a16c8d3cb51de1b80e17bc08086c7c81) switched from RUNNING to FINISHED.
Aug 21, 2021 6:17:39 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (DiscardingOutput) (1/1) (4c28ef181fc4b8be1b2b02bd9250b47c)
switched from RUNNING to FINISHED.
Aug 21, 2021 6:17:39 PM
org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager
processResourceRequirements
INFO: Clearing resource requirements of job fbdd0c48ba4d3498a52b59b482647989
Aug 21, 2021 6:17:39 PM
org.apache.flink.runtime.executiongraph.DefaultExecutionGraph transitionState
INFO: Job BeamApp-jenkins-0821181714-bc8cb588
(fbdd0c48ba4d3498a52b59b482647989) switched from state RUNNING to FINISHED.
Aug 21, 2021 6:17:39 PM org.apache.flink.runtime.dispatcher.Dispatcher
jobReachedTerminalState
INFO: Job fbdd0c48ba4d3498a52b59b482647989 reached terminal state FINISHED.
Aug 21, 2021 6:17:39 PM org.apache.flink.runtime.jobmaster.JobMaster onStop
INFO: Stopping the JobMaster for job
BeamApp-jenkins-0821181714-bc8cb588(fbdd0c48ba4d3498a52b59b482647989).
Aug 21, 2021 6:17:39 PM
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool
releaseSlots
INFO: Releasing slot [d328de590f936669e722a7ab47260ef0].
Aug 21, 2021 6:17:39 PM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:0, state:ACTIVE, resource profile:
ResourceProfile{taskHeapMemory=1024.000gb (1099511627776 bytes),
taskOffHeapMemory=1024.000gb (1099511627776 bytes), managedMemory=128.000mb
(134217728 bytes), networkMemory=64.000mb (67108864 bytes)}, allocationId:
d328de590f936669e722a7ab47260ef0, jobId: fbdd0c48ba4d3498a52b59b482647989).
Aug 21, 2021 6:17:39 PM org.apache.flink.runtime.jobmaster.JobMaster
dissolveResourceManagerConnection
INFO: Close ResourceManager connection a81da05d04bd5d78f7e5c7e939e7c331:
Stopping JobMaster for job
BeamApp-jenkins-0821181714-bc8cb588(fbdd0c48ba4d3498a52b59b482647989)..
Aug 21, 2021 6:17:39 PM
org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager
processResourceRequirements
INFO: Clearing resource requirements of job fbdd0c48ba4d3498a52b59b482647989
Aug 21, 2021 6:17:39 PM
org.apache.flink.runtime.resourcemanager.ResourceManager
closeJobManagerConnection
INFO: Disconnect job manager
8d37707d91235eadcfee51171c5b421d@akka://flink/user/rpc/jobmanager_3 for job
fbdd0c48ba4d3498a52b59b482647989 from the resource manager.
Aug 21, 2021 6:17:39 PM
org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService removeJob
INFO: Remove job fbdd0c48ba4d3498a52b59b482647989 from job leader monitoring.
Aug 21, 2021 6:17:39 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
disconnectJobManagerConnection
INFO: Close JobManager connection for job fbdd0c48ba4d3498a52b59b482647989.
INFO:apache_beam.runners.portability.portable_runner:Job state changed to DONE
kill %1 || echo "Failed to shut down Flink mini cluster"
rm -rf "$ENV_DIR"
Aug 21, 2021 6:17:45 PM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Aug 21, 2021 6:17:45 PM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Aug 21, 2021 6:17:45 PM
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager shutdown
INFO: Shutting down TaskExecutorLocalStateStoresManager.
>>> SUCCESS
if [[ "$TEST_EXIT_CODE" -eq 0 ]]; then
echo ">>> SUCCESS"
else
echo ">>> FAILURE"
fi
exit $TEST_EXIT_CODE
FAILURE: Build completed with 2 failures.
1: Task failed with an exception.
-----------
* Where:
Script
'<https://ci-beam.apache.org/job/beam_PostCommit_PortableJar_Flink/ws/src/sdks/python/test-suites/portable/common.gradle'>
line: 238
* What went wrong:
Execution failed for task
':sdks:python:test-suites:portable:py36:testJavaJarCreatorFlinkRunner'.
> Process 'command 'sh'' finished with non-zero exit value 1
* Try:
Run with --stacktrace option to get the stack trace. Run with --info or --debug
option to get more log output. Run with --scan to get full insights.
==============================================================================
2: Task failed with an exception.
-----------
* Where:
Script
'<https://ci-beam.apache.org/job/beam_PostCommit_PortableJar_Flink/ws/src/sdks/python/test-suites/portable/common.gradle'>
line: 238
* What went wrong:
Execution failed for task
':sdks:python:test-suites:portable:py37:testJavaJarCreatorFlinkRunner'.
> Process 'command 'sh'' finished with non-zero exit value 1
* Try:
Run with --stacktrace option to get the stack trace. Run with --info or --debug
option to get more log output. Run with --scan to get full insights.
==============================================================================
* Get more help at https://help.gradle.org
Deprecated Gradle features were used in this build, making it incompatible with
Gradle 7.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See
https://docs.gradle.org/6.8.3/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 17m 17s
150 actionable tasks: 106 executed, 41 from cache, 3 up-to-date
Publishing build scan...
https://gradle.com/s/6vvzmt2dnwa2a
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
