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 2022/01/22 12:17:39 UTC
Build failed in Jenkins: beam_PostCommit_PortableJar_Flink #4609
See <https://ci-beam.apache.org/job/beam_PostCommit_PortableJar_Flink/4609/display/redirect>
Changes:
------------------------------------------
[...truncated 1.15 MB...]
INFO: Shutting down BLOB cache
Jan 22, 2022 12:17:35 PM org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager shutdown
INFO: Shutting down TaskExecutorLocalStateStoresManager.
if [[ "$TEST_EXIT_CODE" -eq 0 ]]; then
echo ">>> SUCCESS"
else
echo ">>> FAILURE"
fi
exit $TEST_EXIT_CODE
> Task :sdks:python:test-suites:portable:py37:testUberJarFlinkRunnerSaveMainSession
Jan 22, 2022 12:17:31 PM org.apache.beam.runners.fnexecution.logging.GrpcLoggingService logging
INFO: Beam Fn Logging client connected.
Jan 22, 2022 12:17:31 PM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Logging handler created.
Jan 22, 2022 12:17:31 PM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: semi_persistent_directory: /tmp
Jan 22, 2022 12:17:31 PM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
WARNING: Discarding unparseable args: ['--app_name=None', '--direct_runner_use_stacked_bundle', '--job_server_timeout=60', '--options_id=1', '--parallelism=1', '--pipeline_type_check']
Jan 22, 2022 12:17:31 PM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Pipeline_options: {'job_name': 'BeamApp-jenkins-0122121706-1725e5a8', 'experiments': ['beam_fn_api'], 'save_main_session': True, 'sdk_location': 'container', 'environment_type': 'DOCKER', 'environment_options': ['docker_container_image=apache/beam_python3.7_sdk:2.37.0.dev'], 'sdk_worker_parallelism': '1', 'environment_cache_millis': '0', 'flink_job_server_jar': '<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.37.0-SNAPSHOT.jar',> 'flink_submit_uber_jar': True}
Jan 22, 2022 12:17:31 PM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Creating state cache with size 0
Jan 22, 2022 12:17:31 PM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Creating insecure control channel for localhost:46213.
Jan 22, 2022 12:17:31 PM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Control channel established.
Jan 22, 2022 12:17:31 PM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Initializing SDKHarness with unbounded number of workers.
Jan 22, 2022 12:17:31 PM org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService control
INFO: Beam Fn Control client connected with id 1-1
Jan 22, 2022 12:17:31 PM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Python sdk harness starting.
Jan 22, 2022 12:17:31 PM org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService getProcessBundleDescriptor
INFO: getProcessBundleDescriptor request with id 1-5
Jan 22, 2022 12:17:31 PM org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService getProcessBundleDescriptor
INFO: getProcessBundleDescriptor request with id 1-2
Jan 22, 2022 12:17:31 PM org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService getProcessBundleDescriptor
INFO: getProcessBundleDescriptor request with id 1-3
Jan 22, 2022 12:17:31 PM org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService getProcessBundleDescriptor
INFO: getProcessBundleDescriptor request with id 1-4
Jan 22, 2022 12:17:31 PM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Creating insecure state channel for localhost:39713.
Jan 22, 2022 12:17:31 PM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: State channel established.
Jan 22, 2022 12:17:31 PM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Creating client data channel for localhost:36913
Jan 22, 2022 12:17:31 PM org.apache.beam.runners.fnexecution.data.GrpcDataService data
INFO: Beam Fn Data client connected.
Jan 22, 2022 12:17:31 PM org.apache.flink.runtime.taskmanager.Task transitionState
INFO: CHAIN MapPartition (MapPartition at [1]Create/FlatMap(<lambda at core.py:3228>)) -> FlatMap (FlatMap at ExtractOutput[0]) (1/1)#0 (167dc405323a2142f5bd7d63ee3e71e5) switched from RUNNING to FINISHED.
Jan 22, 2022 12:17:31 PM org.apache.flink.runtime.taskmanager.Task transitionState
INFO: CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) -> FlatMap (FlatMap at ExtractOutput[0]) (1/1)#0 (17111b6af927bfa8278bfc4845466f67) switched from RUNNING to FINISHED.
Jan 22, 2022 12:17:31 PM org.apache.flink.runtime.taskmanager.Task doRun
INFO: Freeing task resources for CHAIN MapPartition (MapPartition at [1]Create/FlatMap(<lambda at core.py:3228>)) -> FlatMap (FlatMap at ExtractOutput[0]) (1/1)#0 (167dc405323a2142f5bd7d63ee3e71e5).
Jan 22, 2022 12:17:31 PM org.apache.flink.runtime.taskmanager.Task doRun
INFO: Freeing task resources for CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) -> FlatMap (FlatMap at ExtractOutput[0]) (1/1)#0 (17111b6af927bfa8278bfc4845466f67).
Jan 22, 2022 12:17:31 PM org.apache.flink.runtime.taskmanager.Task transitionState
INFO: Partition (1/1)#0 (ffa95d7a746cc73feb4293aa72183094) switched from RUNNING to FINISHED.
Jan 22, 2022 12:17:31 PM org.apache.flink.runtime.taskmanager.Task doRun
INFO: Freeing task resources for Partition (1/1)#0 (ffa95d7a746cc73feb4293aa72183094).
Jan 22, 2022 12:17:31 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 [4]assert_that/{Create, Group}) -> FlatMap (FlatMap at ExtractOutput[0]) (1/1)#0 17111b6af927bfa8278bfc4845466f67.
Jan 22, 2022 12:17:31 PM org.apache.flink.runtime.taskmanager.Task transitionState
INFO: CHAIN MapPartition (MapPartition at [6]{Create, Map(<lambda at <string>:23>), assert_that}) -> FlatMap (FlatMap at ExtractOutput[0]) (1/1)#0 (b561ba3778791d391d2a4f5149da654d) switched from RUNNING to FINISHED.
Jan 22, 2022 12:17:31 PM org.apache.flink.runtime.taskmanager.Task doRun
INFO: Freeing task resources for CHAIN MapPartition (MapPartition at [6]{Create, Map(<lambda at <string>:23>), assert_that}) -> FlatMap (FlatMap at ExtractOutput[0]) (1/1)#0 (b561ba3778791d391d2a4f5149da654d).
Jan 22, 2022 12:17:31 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:3228>)) -> FlatMap (FlatMap at ExtractOutput[0]) (1/1)#0 167dc405323a2142f5bd7d63ee3e71e5.
Jan 22, 2022 12:17:31 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 ffa95d7a746cc73feb4293aa72183094.
Jan 22, 2022 12:17:31 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 b561ba3778791d391d2a4f5149da654d.
Jan 22, 2022 12:17:31 PM org.apache.flink.runtime.taskmanager.Task transitionState
INFO: CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: assert_that/Group/CoGroupByKeyImpl/GroupByKey) -> Map (Key Extractor) (1/1)#0 (748e320493655229bf69037ec081706b) switched from RUNNING to FINISHED.
Jan 22, 2022 12:17:31 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/CoGroupByKeyImpl/GroupByKey) -> Map (Key Extractor) (1/1)#0 (748e320493655229bf69037ec081706b).
Jan 22, 2022 12:17:31 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/CoGroupByKeyImpl/GroupByKey) -> Map (Key Extractor) (1/1)#0 748e320493655229bf69037ec081706b.
Jan 22, 2022 12:17:31 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.
Jan 22, 2022 12:17:31 PM org.apache.flink.runtime.taskmanager.Task transitionState
INFO: GroupReduce (GroupReduce at assert_that/Group/CoGroupByKeyImpl/GroupByKey) (1/1)#0 (04b3d47b3f120bc1b0897fdb139fd4d5) switched from RUNNING to FINISHED.
Jan 22, 2022 12:17:31 PM org.apache.flink.runtime.taskmanager.Task doRun
INFO: Freeing task resources for GroupReduce (GroupReduce at assert_that/Group/CoGroupByKeyImpl/GroupByKey) (1/1)#0 (04b3d47b3f120bc1b0897fdb139fd4d5).
Jan 22, 2022 12:17:31 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/CoGroupByKeyImpl/GroupByKey) (1/1)#0 04b3d47b3f120bc1b0897fdb139fd4d5.
Jan 22, 2022 12:17:31 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) (17111b6af927bfa8278bfc4845466f67) switched from RUNNING to FINISHED.
Jan 22, 2022 12:17:31 PM org.apache.flink.runtime.executiongraph.Execution transitionState
INFO: CHAIN MapPartition (MapPartition at [1]Create/FlatMap(<lambda at core.py:3228>)) -> FlatMap (FlatMap at ExtractOutput[0]) (1/1) (167dc405323a2142f5bd7d63ee3e71e5) switched from RUNNING to FINISHED.
Jan 22, 2022 12:17:31 PM org.apache.flink.runtime.executiongraph.Execution transitionState
INFO: Partition (1/1) (ffa95d7a746cc73feb4293aa72183094) switched from RUNNING to FINISHED.
Jan 22, 2022 12:17:31 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) (b561ba3778791d391d2a4f5149da654d) switched from RUNNING to FINISHED.
Jan 22, 2022 12:17:31 PM org.apache.flink.runtime.executiongraph.Execution transitionState
INFO: CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: assert_that/Group/CoGroupByKeyImpl/GroupByKey) -> Map (Key Extractor) (1/1) (748e320493655229bf69037ec081706b) switched from RUNNING to FINISHED.
Jan 22, 2022 12:17:31 PM org.apache.flink.runtime.executiongraph.Execution transitionState
INFO: GroupReduce (GroupReduce at assert_that/Group/CoGroupByKeyImpl/GroupByKey) (1/1) (04b3d47b3f120bc1b0897fdb139fd4d5) switched from RUNNING to FINISHED.
Jan 22, 2022 12:17:31 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.37.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.37.0.dev"
capabilities: "beam:transform:sdf_truncate_sized_restrictions:v1"
capabilities: "beam:transform:to_string:v1"
capabilities: "beam:protocol:sibling_workers:v1"
dependencies {
type_urn: "beam:artifact:type:file:v1"
type_payload: "\n\253\001classpath://BEAM-PIPELINE/pipeline/artifacts/job-6d2e617e-912e-47d2-9590-1df496ae15ed/ee70037f4707fd954c5f24ee71c28c486296ad0dc1d1d8ab7f1b2171213e10d5-pickled_main_session"
role_urn: "beam:artifact:role:staging_to:v1"
role_payload: "\n\024pickled_main_session"
}
Jan 22, 2022 12:17:31 PM org.apache.beam.runners.fnexecution.logging.GrpcLoggingService close
INFO: 1 Beam Fn Logging clients still connected during shutdown.
Jan 22, 2022 12:17:31 PM org.apache.beam.sdk.fn.data.BeamFnDataGrpcMultiplexer$InboundObserver onCompleted
WARNING: Hanged up for unknown endpoint.
Jan 22, 2022 12:17:31 PM org.apache.beam.runners.fnexecution.environment.DockerContainerEnvironment close
INFO: Closing Docker container db9290fc831709defc662dbfb6051e62bf6f708d3fb7354e28921aad75b40e02. Logs:
2022/01/22 12:17:29 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_artifact_caching: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.37.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.37.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-0122121706-1725e5a8"}} 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:pickle_library:v1" value:{string_value:"default"}} 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:43637"} artifact_endpoint:{url:"localhost:35519"} control_endpoint:{url:"localhost:46213"} dependencies:{type_urn:"beam:artifact:type:file:v1" type_payload:"\n\xab\x01classpath://BEAM-PIPELINE/pipeline/artifacts/job-6d2e617e-912e-47d2-9590-1df496ae15ed/ee70037f4707fd954c5f24ee71c28c486296ad0dc1d1d8ab7f1b2171213e10d5-pickled_main_session" role_urn:"beam:artifact:role:staging_to:v1" role_payload:"\n\x14pickled_main_session"}
2022/01/22 12:17:29 Initializing python harness: /opt/apache/beam/boot --id=1-1 --provision_endpoint=localhost:45579
2022/01/22 12:17:29 Downloaded: /tmp/staged/pickled_main_session (sha256: d08637bbc9e4a9e7aa9f331b48e57e33fd7078d16aea619a033bebc832d974b0, size: 2814)
2022/01/22 12:17:29 Found artifact: pickled_main_session
2022/01/22 12:17:29 Installing setup packages ...
2022/01/22 12:17:29 Executing: python -m apache_beam.runners.worker.sdk_worker_main
Jan 22, 2022 12:17:32 PM org.apache.flink.runtime.taskmanager.Task transitionState
INFO: MapPartition (MapPartition at [4]assert_that/{Group, Unkey, Match}) (1/1)#0 (9765ceb412656c18363fcf5f58bbf03b) switched from RUNNING to FINISHED.
Jan 22, 2022 12:17:32 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 (9765ceb412656c18363fcf5f58bbf03b).
Jan 22, 2022 12:17:32 PM org.apache.flink.runtime.taskmanager.Task transitionState
INFO: DataSink (DiscardingOutput) (1/1)#0 (7b69f842676e4d8c50689071c79a739e) switched from RUNNING to FINISHED.
Jan 22, 2022 12:17:32 PM org.apache.flink.runtime.taskmanager.Task doRun
INFO: Freeing task resources for DataSink (DiscardingOutput) (1/1)#0 (7b69f842676e4d8c50689071c79a739e).
Jan 22, 2022 12:17:32 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 9765ceb412656c18363fcf5f58bbf03b.
Jan 22, 2022 12:17:32 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 7b69f842676e4d8c50689071c79a739e.
Jan 22, 2022 12:17:32 PM org.apache.flink.runtime.executiongraph.Execution transitionState
INFO: MapPartition (MapPartition at [4]assert_that/{Group, Unkey, Match}) (1/1) (9765ceb412656c18363fcf5f58bbf03b) switched from RUNNING to FINISHED.
Jan 22, 2022 12:17:32 PM org.apache.flink.runtime.executiongraph.Execution transitionState
INFO: DataSink (DiscardingOutput) (1/1) (7b69f842676e4d8c50689071c79a739e) switched from RUNNING to FINISHED.
Jan 22, 2022 12:17:32 PM org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager processResourceRequirements
INFO: Clearing resource requirements of job 97ae06e3ad788fa6f5a41547e9df5f8c
Jan 22, 2022 12:17:32 PM org.apache.flink.runtime.executiongraph.DefaultExecutionGraph transitionState
INFO: Job BeamApp-jenkins-0122121706-1725e5a8 (97ae06e3ad788fa6f5a41547e9df5f8c) switched from state RUNNING to FINISHED.
Jan 22, 2022 12:17:32 PM org.apache.flink.runtime.dispatcher.Dispatcher jobReachedTerminalState
INFO: Job 97ae06e3ad788fa6f5a41547e9df5f8c reached terminal state FINISHED.
Jan 22, 2022 12:17:32 PM org.apache.flink.runtime.jobmaster.JobMaster onStop
INFO: Stopping the JobMaster for job BeamApp-jenkins-0122121706-1725e5a8(97ae06e3ad788fa6f5a41547e9df5f8c).
Jan 22, 2022 12:17:32 PM org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool releaseSlots
INFO: Releasing slot [b378095c0f4a8882f59eb1d194f156f3].
Jan 22, 2022 12:17:32 PM org.apache.flink.runtime.jobmaster.JobMaster dissolveResourceManagerConnection
INFO: Close ResourceManager connection 1a582c2f153f2413fbb282adf4c95bd6: Stopping JobMaster for job BeamApp-jenkins-0122121706-1725e5a8(97ae06e3ad788fa6f5a41547e9df5f8c)..
Jan 22, 2022 12:17:32 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: b378095c0f4a8882f59eb1d194f156f3, jobId: 97ae06e3ad788fa6f5a41547e9df5f8c).
Jan 22, 2022 12:17:32 PM org.apache.flink.runtime.resourcemanager.ResourceManager closeJobManagerConnection
INFO: Disconnect job manager b4ac912bd138c08e73223cc6118845a7@akka://flink/user/rpc/jobmanager_3 for job 97ae06e3ad788fa6f5a41547e9df5f8c from the resource manager.
Jan 22, 2022 12:17:32 PM org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService removeJob
INFO: Remove job 97ae06e3ad788fa6f5a41547e9df5f8c from job leader monitoring.
Jan 22, 2022 12:17:32 PM org.apache.flink.runtime.taskexecutor.TaskExecutor disconnectJobManagerConnection
INFO: Close JobManager connection for job 97ae06e3ad788fa6f5a41547e9df5f8c.
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"
Jan 22, 2022 12:17:36 PM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Jan 22, 2022 12:17:36 PM org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager shutdown
INFO: Shutting down TaskExecutorLocalStateStoresManager.
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: 335
* 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: 335
* 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 8.0.
You can use '--warning-mode all' to show the individual deprecation warnings and determine if they come from your own scripts or plugins.
See https://docs.gradle.org/7.3.2/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 17m 7s
156 actionable tasks: 107 executed, 44 from cache, 5 up-to-date
Publishing build scan...
https://gradle.com/s/6djttjn6pzwlm
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
---------------------------------------------------------------------
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_PortableJar_Flink #4612
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://ci-beam.apache.org/job/beam_PostCommit_PortableJar_Flink/4612/display/redirect>
---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscribe@beam.apache.org
For additional commands, e-mail: builds-help@beam.apache.org
Build failed in Jenkins: beam_PostCommit_PortableJar_Flink #4611
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://ci-beam.apache.org/job/beam_PostCommit_PortableJar_Flink/4611/display/redirect>
Changes:
------------------------------------------
[...truncated 240.06 KB...]
symbol: class JvmInitializer
location: class JvmInitializers
<https://ci-beam.apache.org/job/beam_PostCommit_PortableJar_Flink/ws/src/sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/data/BeamFnDataBufferingOutboundObserver.java>:75: error: cannot find symbol
List<String> experiments = options.as(ExperimentalOptions.class).getExperiments();
^
symbol: class ExperimentalOptions
location: interface BeamFnDataBufferingOutboundObserver<T>
where T is a type-variable:
T extends Object declared in interface BeamFnDataBufferingOutboundObserver
<https://ci-beam.apache.org/job/beam_PostCommit_PortableJar_Flink/ws/src/sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/data/BeamFnDataBufferingOutboundObserver.java>:91: error: cannot find symbol
List<String> experiments = options.as(ExperimentalOptions.class).getExperiments();
^
symbol: class ExperimentalOptions
location: interface BeamFnDataBufferingOutboundObserver<T>
where T is a type-variable:
T extends Object declared in interface BeamFnDataBufferingOutboundObserver
<https://ci-beam.apache.org/job/beam_PostCommit_PortableJar_Flink/ws/src/sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/data/DataEndpoint.java>:27: error: cannot find symbol
return new AutoValue_DataEndpoint<>(transformId, coder, receiver);
^
symbol: class AutoValue_DataEndpoint
location: class DataEndpoint<T>
where T is a type-variable:
T extends Object declared in class DataEndpoint
<https://ci-beam.apache.org/job/beam_PostCommit_PortableJar_Flink/ws/src/sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/data/TimerEndpoint.java>:27: error: cannot find symbol
return new AutoValue_TimerEndpoint<>(transformId, timerFamilyId, coder, receiver);
^
symbol: class AutoValue_TimerEndpoint
location: class TimerEndpoint<T>
where T is a type-variable:
T extends Object declared in class TimerEndpoint
<https://ci-beam.apache.org/job/beam_PostCommit_PortableJar_Flink/ws/src/sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/data/BeamFnDataInboundObserver2.java>:142: error: cannot find symbol
Coder<Object> coder = (Coder<Object>) endpoint.endpoint.getCoder();
^
symbol: class Coder
location: class BeamFnDataInboundObserver2
<https://ci-beam.apache.org/job/beam_PostCommit_PortableJar_Flink/ws/src/sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/data/BeamFnDataInboundObserver2.java>:142: error: cannot find symbol
Coder<Object> coder = (Coder<Object>) endpoint.endpoint.getCoder();
^
symbol: class Coder
location: class BeamFnDataInboundObserver2
<https://ci-beam.apache.org/job/beam_PostCommit_PortableJar_Flink/ws/src/sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/data/BeamFnDataInboundObserver2.java>:176: error: cannot find symbol
Coder<Object> coder = (Coder<Object>) endpoint.endpoint.getCoder();
^
symbol: class Coder
location: class BeamFnDataInboundObserver2
<https://ci-beam.apache.org/job/beam_PostCommit_PortableJar_Flink/ws/src/sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/data/BeamFnDataInboundObserver2.java>:176: error: cannot find symbol
Coder<Object> coder = (Coder<Object>) endpoint.endpoint.getCoder();
^
symbol: class Coder
location: class BeamFnDataInboundObserver2
<https://ci-beam.apache.org/job/beam_PostCommit_PortableJar_Flink/ws/src/sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/splittabledofn/RestrictionTrackers.java>:57: error: method does not override or implement a method from a supertype
@Override
^
<https://ci-beam.apache.org/job/beam_PostCommit_PortableJar_Flink/ws/src/sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/splittabledofn/RestrictionTrackers.java>:68: error: method does not override or implement a method from a supertype
@Override
^
<https://ci-beam.apache.org/job/beam_PostCommit_PortableJar_Flink/ws/src/sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/splittabledofn/RestrictionTrackers.java>:73: error: method does not override or implement a method from a supertype
@Override
^
<https://ci-beam.apache.org/job/beam_PostCommit_PortableJar_Flink/ws/src/sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/splittabledofn/RestrictionTrackers.java>:78: error: method does not override or implement a method from a supertype
@Override
^
<https://ci-beam.apache.org/job/beam_PostCommit_PortableJar_Flink/ws/src/sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/splittabledofn/RestrictionTrackers.java>:83: error: method does not override or implement a method from a supertype
@Override
^
Note: Some input files use or override a deprecated API.
Note: Recompile with -Xlint:deprecation for details.
Note: Some input files use unchecked or unsafe operations.
Note: Recompile with -Xlint:unchecked for details.
87 errors
> Task :sdks:java:fn-execution:compileJava FAILED
> Task :sdks:python:setupVirtualenv
> Task :sdks:python:sdist
Regenerating Python proto definitions (no output files).
Found protoc_gen_mypy at <https://ci-beam.apache.org/job/beam_PostCommit_PortableJar_Flink/ws/src/build/gradleenv/1922375555/bin/protoc-gen-mypy>
beam_interactive_api.proto:36:1: warning: Import google/protobuf/timestamp.proto is unused.
Writing mypy to external_transforms_pb2.pyi
Writing mypy to beam_runner_api_pb2.pyi
Writing mypy to standard_window_fns_pb2.pyi
Writing mypy to metrics_pb2.pyi
Writing mypy to endpoints_pb2.pyi
Writing mypy to schema_pb2.pyi
Writing mypy to beam_artifact_api_pb2.pyi
Writing mypy to beam_expansion_api_pb2.pyi
Writing mypy to beam_job_api_pb2.pyi
Writing mypy to beam_provision_api_pb2.pyi
Writing mypy to beam_fn_api_pb2.pyi
Writing mypy to beam_interactive_api_pb2.pyi
Writing urn stubs: <https://ci-beam.apache.org/job/beam_PostCommit_PortableJar_Flink/ws/src/sdks/python/apache_beam/portability/api/metrics_pb2_urns.py>
Writing urn stubs: <https://ci-beam.apache.org/job/beam_PostCommit_PortableJar_Flink/ws/src/sdks/python/apache_beam/portability/api/beam_artifact_api_pb2_urns.py>
Writing urn stubs: <https://ci-beam.apache.org/job/beam_PostCommit_PortableJar_Flink/ws/src/sdks/python/apache_beam/portability/api/standard_window_fns_pb2_urns.py>
Writing urn stubs: <https://ci-beam.apache.org/job/beam_PostCommit_PortableJar_Flink/ws/src/sdks/python/apache_beam/portability/api/external_transforms_pb2_urns.py>
Writing urn stubs: <https://ci-beam.apache.org/job/beam_PostCommit_PortableJar_Flink/ws/src/sdks/python/apache_beam/portability/api/beam_runner_api_pb2_urns.py>
<https://ci-beam.apache.org/job/beam_PostCommit_PortableJar_Flink/ws/src/build/gradleenv/1922375555/lib/python3.8/site-packages/setuptools/dist.py>:493: UserWarning: Normalizing '2.37.0.dev' to '2.37.0.dev0'
warnings.warn(tmpl.format(**locals()))
warning: no files found matching 'README.md'
warning: no files found matching 'NOTICE'
warning: no files found matching 'LICENSE'
warning: no files found matching 'LICENSE.python'
warning: sdist: standard file not found: should have one of README, README.rst, README.txt, README.md
> Task :sdks:python:container:py36:copyDockerfileDependencies
> Task :sdks:python:container:py37:copyDockerfileDependencies
> Task :release:go-licenses:py:dockerRun
+ go-licenses save github.com/apache/beam/sdks/python/container --save_path=/output/licenses
+ tee /output/licenses/list.csv
+ go-licenses csv github.com/apache/beam/sdks/python/container
github.com/apache/beam/sdks/go/pkg/beam,https://github.com/apache/beam/blob/master/sdks/go/README.md,Apache-2.0
golang.org/x/net,https://go.googlesource.com/net/+/refs/heads/master/LICENSE,BSD-3-Clause
golang.org/x/text,https://go.googlesource.com/text/+/refs/heads/master/LICENSE,BSD-3-Clause
github.com/nightlyone/lockfile,https://github.com/nightlyone/lockfile/blob/master/LICENSE,MIT
github.com/apache/beam/sdks/python/container,https://github.com/apache/beam/blob/master/LICENSE,Apache-2.0
google.golang.org/grpc,https://github.com/grpc/grpc-go/blob/master/LICENSE,Apache-2.0
github.com/golang/protobuf,https://github.com/golang/protobuf/blob/master/LICENSE,BSD-3-Clause
google.golang.org/protobuf,https://go.googlesource.com/protobuf/+/refs/heads/master/LICENSE,BSD-3-Clause
google.golang.org/genproto/googleapis/rpc/status,https://github.com/googleapis/go-genproto/blob/master/LICENSE,Apache-2.0
golang.org/x/sys,https://go.googlesource.com/sys/+/refs/heads/master/LICENSE,BSD-3-Clause
+ chmod -R a+w /output/licenses
> Task :release:go-licenses:py:createLicenses
> Task :sdks:python:container:py37:copyGolangLicenses
> Task :sdks:python:container:py36:copyGolangLicenses
> Task :sdks:python:container:py37:dockerPrepare
> Task :sdks:python:container:py36:dockerPrepare
> Task :sdks:python:container:py37:docker
> Task :sdks:python:container:py36:docker
Removing intermediate container 00e0d1d593c8
---> aca2b224c0d9
Successfully built aca2b224c0d9
Successfully tagged apache/beam_python3.6_sdk:2.37.0.dev
FAILURE: Build completed with 8 failures.
1: Task failed with an exception.
-----------
* What went wrong:
Execution failed for task ':sdks:java:extensions:protobuf:extractIncludeProto'.
> Cannot expand ZIP '<https://ci-beam.apache.org/job/beam_PostCommit_PortableJar_Flink/ws/src/sdks/java/core/build/libs/beam-sdks-java-core-2.37.0-SNAPSHOT.jar'> as it does not exist.
* 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.
-----------
* What went wrong:
Execution failed for task ':sdks:java:extensions:join-library:compileJava'.
> Compilation failed; see the compiler error output for details.
* 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.
==============================================================================
3: Task failed with an exception.
-----------
* What went wrong:
Execution failed for task ':sdks:java:io:hadoop-common:compileJava'.
> Compilation failed; see the compiler error output for details.
* 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.
==============================================================================
4: Task failed with an exception.
-----------
* What went wrong:
Execution failed for task ':sdks:java:io:mongodb:compileJava'.
> Compilation failed; see the compiler error output for details.
* 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.
==============================================================================
5: Task failed with an exception.
-----------
* What went wrong:
Execution failed for task ':sdks:java:extensions:arrow:compileJava'.
> Compilation failed; see the compiler error output for details.
* 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.
==============================================================================
6: Task failed with an exception.
-----------
* What went wrong:
Execution failed for task ':sdks:java:io:amazon-web-services2:compileJava'.
> Compilation failed; see the compiler error output for details.
* 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.
==============================================================================
7: Task failed with an exception.
-----------
* What went wrong:
Execution failed for task ':runners:local-java:compileJava'.
> Compilation failed; see the compiler error output for details.
* 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.
==============================================================================
8: Task failed with an exception.
-----------
* What went wrong:
Execution failed for task ':sdks:java:fn-execution:compileJava'.
> Compilation failed; see the compiler error output for details.
* 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 8.0.
You can use '--warning-mode all' to show the individual deprecation warnings and determine if they come from your own scripts or plugins.
See https://docs.gradle.org/7.3.2/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 13m 10s
108 actionable tasks: 85 executed, 18 from cache, 5 up-to-date
Publishing build scan...
https://gradle.com/s/bcs3vei2izwta
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscribe@beam.apache.org
For additional commands, e-mail: builds-help@beam.apache.org
Build failed in Jenkins: beam_PostCommit_PortableJar_Flink #4610
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://ci-beam.apache.org/job/beam_PostCommit_PortableJar_Flink/4610/display/redirect>
Changes:
------------------------------------------
[...truncated 486.15 KB...]
INFO: Shutting down BLOB cache
Jan 22, 2022 6:16:35 PM org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager shutdown
INFO: Shutting down TaskExecutorLocalStateStoresManager.
if [[ "$TEST_EXIT_CODE" -eq 0 ]]; then
echo ">>> SUCCESS"
else
echo ">>> FAILURE"
fi
exit $TEST_EXIT_CODE
> Task :sdks:python:test-suites:portable:py37:testUberJarFlinkRunnerSaveMainSession
Jan 22, 2022 6:16:30 PM org.apache.beam.runners.fnexecution.logging.GrpcLoggingService logging
INFO: Beam Fn Logging client connected.
Jan 22, 2022 6:16:30 PM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Logging handler created.
Jan 22, 2022 6:16:30 PM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: semi_persistent_directory: /tmp
Jan 22, 2022 6:16:30 PM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
WARNING: Discarding unparseable args: ['--app_name=None', '--direct_runner_use_stacked_bundle', '--job_server_timeout=60', '--options_id=1', '--parallelism=1', '--pipeline_type_check']
Jan 22, 2022 6:16:30 PM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Pipeline_options: {'job_name': 'BeamApp-jenkins-0122181605-102fb570', 'experiments': ['beam_fn_api'], 'save_main_session': True, 'sdk_location': 'container', 'environment_type': 'DOCKER', 'environment_options': ['docker_container_image=apache/beam_python3.7_sdk:2.37.0.dev'], 'sdk_worker_parallelism': '1', 'environment_cache_millis': '0', 'flink_job_server_jar': '<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.37.0-SNAPSHOT.jar',> 'flink_submit_uber_jar': True}
Jan 22, 2022 6:16:30 PM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Creating state cache with size 0
Jan 22, 2022 6:16:30 PM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Creating insecure control channel for localhost:36899.
Jan 22, 2022 6:16:30 PM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Control channel established.
Jan 22, 2022 6:16:30 PM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Initializing SDKHarness with unbounded number of workers.
Jan 22, 2022 6:16:30 PM org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService control
INFO: Beam Fn Control client connected with id 1-1
Jan 22, 2022 6:16:30 PM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Python sdk harness starting.
Jan 22, 2022 6:16:30 PM org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService getProcessBundleDescriptor
INFO: getProcessBundleDescriptor request with id 1-2
Jan 22, 2022 6:16:30 PM org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService getProcessBundleDescriptor
INFO: getProcessBundleDescriptor request with id 1-4
Jan 22, 2022 6:16:30 PM org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService getProcessBundleDescriptor
INFO: getProcessBundleDescriptor request with id 1-5
Jan 22, 2022 6:16:30 PM org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService getProcessBundleDescriptor
INFO: getProcessBundleDescriptor request with id 1-3
Jan 22, 2022 6:16:30 PM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Creating insecure state channel for localhost:33759.
Jan 22, 2022 6:16:30 PM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: State channel established.
Jan 22, 2022 6:16:30 PM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Creating client data channel for localhost:43661
Jan 22, 2022 6:16:30 PM org.apache.beam.runners.fnexecution.data.GrpcDataService data
INFO: Beam Fn Data client connected.
Jan 22, 2022 6:16:30 PM org.apache.flink.runtime.taskmanager.Task transitionState
INFO: CHAIN MapPartition (MapPartition at [1]Create/FlatMap(<lambda at core.py:3228>)) -> FlatMap (FlatMap at ExtractOutput[0]) (1/1)#0 (9258bf5a4346051e7f6510060111063c) switched from RUNNING to FINISHED.
Jan 22, 2022 6:16:30 PM org.apache.flink.runtime.taskmanager.Task doRun
INFO: Freeing task resources for CHAIN MapPartition (MapPartition at [1]Create/FlatMap(<lambda at core.py:3228>)) -> FlatMap (FlatMap at ExtractOutput[0]) (1/1)#0 (9258bf5a4346051e7f6510060111063c).
Jan 22, 2022 6:16:30 PM org.apache.flink.runtime.taskmanager.Task transitionState
INFO: CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) -> FlatMap (FlatMap at ExtractOutput[0]) (1/1)#0 (6092d0cb46932a5f08a7f9cddfd98a22) switched from RUNNING to FINISHED.
Jan 22, 2022 6:16:30 PM org.apache.flink.runtime.taskmanager.Task transitionState
INFO: Partition (1/1)#0 (e9ae4b29a8e6be5e622f4dfe67f79e31) switched from RUNNING to FINISHED.
Jan 22, 2022 6:16:30 PM org.apache.flink.runtime.taskmanager.Task doRun
INFO: Freeing task resources for CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) -> FlatMap (FlatMap at ExtractOutput[0]) (1/1)#0 (6092d0cb46932a5f08a7f9cddfd98a22).
Jan 22, 2022 6:16:30 PM org.apache.flink.runtime.taskmanager.Task doRun
INFO: Freeing task resources for Partition (1/1)#0 (e9ae4b29a8e6be5e622f4dfe67f79e31).
Jan 22, 2022 6:16:30 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 [4]assert_that/{Create, Group}) -> FlatMap (FlatMap at ExtractOutput[0]) (1/1)#0 6092d0cb46932a5f08a7f9cddfd98a22.
Jan 22, 2022 6:16:30 PM org.apache.flink.runtime.taskmanager.Task transitionState
INFO: CHAIN MapPartition (MapPartition at [6]{Create, Map(<lambda at <string>:23>), assert_that}) -> FlatMap (FlatMap at ExtractOutput[0]) (1/1)#0 (491a6c9c5a4d4a9e6a3c15dfbdd9b32f) switched from RUNNING to FINISHED.
Jan 22, 2022 6:16:30 PM org.apache.flink.runtime.taskmanager.Task doRun
INFO: Freeing task resources for CHAIN MapPartition (MapPartition at [6]{Create, Map(<lambda at <string>:23>), assert_that}) -> FlatMap (FlatMap at ExtractOutput[0]) (1/1)#0 (491a6c9c5a4d4a9e6a3c15dfbdd9b32f).
Jan 22, 2022 6:16:30 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 e9ae4b29a8e6be5e622f4dfe67f79e31.
Jan 22, 2022 6:16:30 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:3228>)) -> FlatMap (FlatMap at ExtractOutput[0]) (1/1)#0 9258bf5a4346051e7f6510060111063c.
Jan 22, 2022 6:16:30 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 491a6c9c5a4d4a9e6a3c15dfbdd9b32f.
Jan 22, 2022 6:16:30 PM org.apache.flink.runtime.taskmanager.Task transitionState
INFO: CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: assert_that/Group/CoGroupByKeyImpl/GroupByKey) -> Map (Key Extractor) (1/1)#0 (52d650a4f32b6c28e2a0bba9c858dca1) switched from RUNNING to FINISHED.
Jan 22, 2022 6:16:30 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/CoGroupByKeyImpl/GroupByKey) -> Map (Key Extractor) (1/1)#0 (52d650a4f32b6c28e2a0bba9c858dca1).
Jan 22, 2022 6:16:30 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/CoGroupByKeyImpl/GroupByKey) -> Map (Key Extractor) (1/1)#0 52d650a4f32b6c28e2a0bba9c858dca1.
Jan 22, 2022 6:16:30 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.
Jan 22, 2022 6:16:30 PM org.apache.flink.runtime.taskmanager.Task transitionState
INFO: GroupReduce (GroupReduce at assert_that/Group/CoGroupByKeyImpl/GroupByKey) (1/1)#0 (8d25b3cdb6d67f98e94a24947ab9341b) switched from RUNNING to FINISHED.
Jan 22, 2022 6:16:30 PM org.apache.flink.runtime.taskmanager.Task doRun
INFO: Freeing task resources for GroupReduce (GroupReduce at assert_that/Group/CoGroupByKeyImpl/GroupByKey) (1/1)#0 (8d25b3cdb6d67f98e94a24947ab9341b).
Jan 22, 2022 6:16:30 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/CoGroupByKeyImpl/GroupByKey) (1/1)#0 8d25b3cdb6d67f98e94a24947ab9341b.
Jan 22, 2022 6:16:30 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) (6092d0cb46932a5f08a7f9cddfd98a22) switched from RUNNING to FINISHED.
Jan 22, 2022 6:16:30 PM org.apache.flink.runtime.executiongraph.Execution transitionState
INFO: Partition (1/1) (e9ae4b29a8e6be5e622f4dfe67f79e31) switched from RUNNING to FINISHED.
Jan 22, 2022 6:16:30 PM org.apache.flink.runtime.executiongraph.Execution transitionState
INFO: CHAIN MapPartition (MapPartition at [1]Create/FlatMap(<lambda at core.py:3228>)) -> FlatMap (FlatMap at ExtractOutput[0]) (1/1) (9258bf5a4346051e7f6510060111063c) switched from RUNNING to FINISHED.
Jan 22, 2022 6:16:30 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) (491a6c9c5a4d4a9e6a3c15dfbdd9b32f) switched from RUNNING to FINISHED.
Jan 22, 2022 6:16:30 PM org.apache.flink.runtime.executiongraph.Execution transitionState
INFO: CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: assert_that/Group/CoGroupByKeyImpl/GroupByKey) -> Map (Key Extractor) (1/1) (52d650a4f32b6c28e2a0bba9c858dca1) switched from RUNNING to FINISHED.
Jan 22, 2022 6:16:30 PM org.apache.flink.runtime.executiongraph.Execution transitionState
INFO: GroupReduce (GroupReduce at assert_that/Group/CoGroupByKeyImpl/GroupByKey) (1/1) (8d25b3cdb6d67f98e94a24947ab9341b) switched from RUNNING to FINISHED.
Jan 22, 2022 6:16:30 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.37.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.37.0.dev"
capabilities: "beam:transform:sdf_truncate_sized_restrictions:v1"
capabilities: "beam:transform:to_string:v1"
capabilities: "beam:protocol:sibling_workers:v1"
dependencies {
type_urn: "beam:artifact:type:file:v1"
type_payload: "\n\253\001classpath://BEAM-PIPELINE/pipeline/artifacts/job-ce9fd8fb-0f5b-4f82-8dca-f4976e26c505/a3aa7bc21e060981863f3ec3fb7be614b0bd8ca614e5edd544caf5d8fde6eebf-pickled_main_session"
role_urn: "beam:artifact:role:staging_to:v1"
role_payload: "\n\024pickled_main_session"
}
Jan 22, 2022 6:16:30 PM org.apache.beam.runners.fnexecution.logging.GrpcLoggingService close
INFO: 1 Beam Fn Logging clients still connected during shutdown.
Jan 22, 2022 6:16:30 PM org.apache.beam.sdk.fn.data.BeamFnDataGrpcMultiplexer$InboundObserver onCompleted
WARNING: Hanged up for unknown endpoint.
Jan 22, 2022 6:16:30 PM org.apache.beam.runners.fnexecution.environment.DockerContainerEnvironment close
INFO: Closing Docker container cbdf4761ed256dc3932d76b2f6d78a7bd2fd207fcfc088232d4872584b11751b. Logs:
2022/01/22 18:16:28 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_artifact_caching: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.37.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.37.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-0122181605-102fb570"}} 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:pickle_library:v1" value:{string_value:"default"}} 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:43321"} artifact_endpoint:{url:"localhost:34179"} control_endpoint:{url:"localhost:36899"} dependencies:{type_urn:"beam:artifact:type:file:v1" type_payload:"\n\xab\x01classpath://BEAM-PIPELINE/pipeline/artifacts/job-ce9fd8fb-0f5b-4f82-8dca-f4976e26c505/a3aa7bc21e060981863f3ec3fb7be614b0bd8ca614e5edd544caf5d8fde6eebf-pickled_main_session" role_urn:"beam:artifact:role:staging_to:v1" role_payload:"\n\x14pickled_main_session"}
2022/01/22 18:16:28 Initializing python harness: /opt/apache/beam/boot --id=1-1 --provision_endpoint=localhost:44505
2022/01/22 18:16:28 Downloaded: /tmp/staged/pickled_main_session (sha256: d08637bbc9e4a9e7aa9f331b48e57e33fd7078d16aea619a033bebc832d974b0, size: 2814)
2022/01/22 18:16:28 Found artifact: pickled_main_session
2022/01/22 18:16:28 Installing setup packages ...
2022/01/22 18:16:28 Executing: python -m apache_beam.runners.worker.sdk_worker_main
Jan 22, 2022 6:16:31 PM org.apache.flink.runtime.taskmanager.Task transitionState
INFO: MapPartition (MapPartition at [4]assert_that/{Group, Unkey, Match}) (1/1)#0 (260b3dc3b297a5be429a50afe5ea444f) switched from RUNNING to FINISHED.
Jan 22, 2022 6:16:31 PM org.apache.flink.runtime.taskmanager.Task transitionState
INFO: DataSink (DiscardingOutput) (1/1)#0 (342b6942c92092a8a1c8732c3b5ef901) switched from RUNNING to FINISHED.
Jan 22, 2022 6:16:31 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 (260b3dc3b297a5be429a50afe5ea444f).
Jan 22, 2022 6:16:31 PM org.apache.flink.runtime.taskmanager.Task doRun
INFO: Freeing task resources for DataSink (DiscardingOutput) (1/1)#0 (342b6942c92092a8a1c8732c3b5ef901).
Jan 22, 2022 6:16:31 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 260b3dc3b297a5be429a50afe5ea444f.
Jan 22, 2022 6:16:31 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 342b6942c92092a8a1c8732c3b5ef901.
Jan 22, 2022 6:16:31 PM org.apache.flink.runtime.executiongraph.Execution transitionState
INFO: MapPartition (MapPartition at [4]assert_that/{Group, Unkey, Match}) (1/1) (260b3dc3b297a5be429a50afe5ea444f) switched from RUNNING to FINISHED.
Jan 22, 2022 6:16:31 PM org.apache.flink.runtime.executiongraph.Execution transitionState
INFO: DataSink (DiscardingOutput) (1/1) (342b6942c92092a8a1c8732c3b5ef901) switched from RUNNING to FINISHED.
Jan 22, 2022 6:16:31 PM org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager processResourceRequirements
INFO: Clearing resource requirements of job bcff1f3fdd1696e7f0d8578b0ff96cfb
Jan 22, 2022 6:16:31 PM org.apache.flink.runtime.executiongraph.DefaultExecutionGraph transitionState
INFO: Job BeamApp-jenkins-0122181605-102fb570 (bcff1f3fdd1696e7f0d8578b0ff96cfb) switched from state RUNNING to FINISHED.
Jan 22, 2022 6:16:31 PM org.apache.flink.runtime.dispatcher.Dispatcher jobReachedTerminalState
INFO: Job bcff1f3fdd1696e7f0d8578b0ff96cfb reached terminal state FINISHED.
Jan 22, 2022 6:16:31 PM org.apache.flink.runtime.jobmaster.JobMaster onStop
INFO: Stopping the JobMaster for job BeamApp-jenkins-0122181605-102fb570(bcff1f3fdd1696e7f0d8578b0ff96cfb).
Jan 22, 2022 6:16:31 PM org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool releaseSlots
INFO: Releasing slot [f0a5be1609df12eb14b64f58f8399ef1].
Jan 22, 2022 6:16:31 PM org.apache.flink.runtime.jobmaster.JobMaster dissolveResourceManagerConnection
INFO: Close ResourceManager connection 4cc124abdae8555ed92d002f9f1b3133: Stopping JobMaster for job BeamApp-jenkins-0122181605-102fb570(bcff1f3fdd1696e7f0d8578b0ff96cfb)..
Jan 22, 2022 6:16:31 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: f0a5be1609df12eb14b64f58f8399ef1, jobId: bcff1f3fdd1696e7f0d8578b0ff96cfb).
Jan 22, 2022 6:16:31 PM org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService removeJob
INFO: Remove job bcff1f3fdd1696e7f0d8578b0ff96cfb from job leader monitoring.
Jan 22, 2022 6:16:31 PM org.apache.flink.runtime.resourcemanager.ResourceManager closeJobManagerConnection
INFO: Disconnect job manager 950a496aabc40c9fbdecf489e0f74ca1@akka://flink/user/rpc/jobmanager_3 for job bcff1f3fdd1696e7f0d8578b0ff96cfb from the resource manager.
Jan 22, 2022 6:16:31 PM org.apache.flink.runtime.taskexecutor.TaskExecutor disconnectJobManagerConnection
INFO: Close JobManager connection for job bcff1f3fdd1696e7f0d8578b0ff96cfb.
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"
Jan 22, 2022 6:16:35 PM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Jan 22, 2022 6:16:35 PM org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager shutdown
INFO: Shutting down TaskExecutorLocalStateStoresManager.
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: 335
* 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: 335
* 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 8.0.
You can use '--warning-mode all' to show the individual deprecation warnings and determine if they come from your own scripts or plugins.
See https://docs.gradle.org/7.3.2/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 16m 6s
156 actionable tasks: 107 executed, 44 from cache, 5 up-to-date
Publishing build scan...
https://gradle.com/s/4ggz6nxnbxuaa
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscribe@beam.apache.org
For additional commands, e-mail: builds-help@beam.apache.org