See
<https://ci-beam.apache.org/job/beam_PreCommit_Portable_Python_Cron/4638/display/redirect?page=changes>
Changes:
[stranniknm] [BEAM-13785] playground - enable scio sdk
[noreply] Merge pull request #16753 from [BEAM-13837] [Playground] show graph on
------------------------------------------
[...truncated 458.45 KB...]
INFO:apache_beam.utils.subprocess_server:b' "type":
"beam:metrics:distribution_int64:v1",'
INFO:apache_beam.utils.subprocess_server:b' "payload": "Aa0ErQStBA==",'
INFO:apache_beam.utils.subprocess_server:b' "labels": {'
INFO:apache_beam.utils.subprocess_server:b' "PCOLLECTION":
"ref_PCollection_PCollection_2"'
INFO:apache_beam.utils.subprocess_server:b' }'
INFO:apache_beam.utils.subprocess_server:b' }, {'
INFO:apache_beam.utils.subprocess_server:b' "urn":
"beam:metric:sampled_byte_size:v1",'
INFO:apache_beam.utils.subprocess_server:b' "type":
"beam:metrics:distribution_int64:v1",'
INFO:apache_beam.utils.subprocess_server:b' "payload": "AZIKkgqSCg==",'
INFO:apache_beam.utils.subprocess_server:b' "labels": {'
INFO:apache_beam.utils.subprocess_server:b' "PCOLLECTION":
"ref_PCollection_PCollection_2/SplitAndSize0"'
INFO:apache_beam.utils.subprocess_server:b' }'
INFO:apache_beam.utils.subprocess_server:b' }, {'
INFO:apache_beam.utils.subprocess_server:b' "urn":
"beam:metric:sampled_byte_size:v1",'
INFO:apache_beam.utils.subprocess_server:b' "type":
"beam:metrics:distribution_int64:v1",'
INFO:apache_beam.utils.subprocess_server:b' "payload": "AQ0NDQ==",'
INFO:apache_beam.utils.subprocess_server:b' "labels": {'
INFO:apache_beam.utils.subprocess_server:b' "PCOLLECTION":
"ref_PCollection_PCollection_1"'
INFO:apache_beam.utils.subprocess_server:b' }'
INFO:apache_beam.utils.subprocess_server:b' }, {'
INFO:apache_beam.utils.subprocess_server:b' "urn":
"beam:metric:sampled_byte_size:v1",'
INFO:apache_beam.utils.subprocess_server:b' "type":
"beam:metrics:distribution_int64:v1",'
INFO:apache_beam.utils.subprocess_server:b' "payload": "AYYMhgyGDA==",'
INFO:apache_beam.utils.subprocess_server:b' "labels": {'
INFO:apache_beam.utils.subprocess_server:b' "PCOLLECTION":
"ref_PCollection_PCollection_2/PairWithRestriction0"'
INFO:apache_beam.utils.subprocess_server:b' }'
INFO:apache_beam.utils.subprocess_server:b' }]'
INFO:apache_beam.utils.subprocess_server:b' }'
INFO:apache_beam.utils.subprocess_server:b'}'
INFO:apache_beam.utils.subprocess_server:b'Feb 16, 2022 12:25:35 PM
org.apache.flink.runtime.jobmaster.JobMaster onStop'
INFO:apache_beam.utils.subprocess_server:b'INFO: Stopping the JobMaster for job
BeamApp-jenkins-0216122520-31886724(a2d24db7867af9621cd8ac4c3da5eb27).'
INFO:apache_beam.utils.subprocess_server:b'Feb 16, 2022 12:25:35 PM
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool
releaseSlots'
INFO:apache_beam.utils.subprocess_server:b'INFO: Releasing slot
[2744687bcbf37972d3d87b69ccfc1662].'
INFO:apache_beam.utils.subprocess_server:b'Feb 16, 2022 12:25:35 PM
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool
releaseSlots'
INFO:apache_beam.utils.subprocess_server:b'INFO: Releasing slot
[03235f7a47a1cd7b2aef3a5c24a7c0f6].'
INFO:apache_beam.utils.subprocess_server:b'Feb 16, 2022 12:25:35 PM
org.apache.flink.runtime.jobmaster.JobMaster dissolveResourceManagerConnection'
INFO:apache_beam.utils.subprocess_server:b'INFO: Close ResourceManager
connection fa6821d548a3dc9ed48f566ee0e0ddaf: Stopping JobMaster for job
BeamApp-jenkins-0216122520-31886724(a2d24db7867af9621cd8ac4c3da5eb27)..'
INFO:apache_beam.utils.subprocess_server:b'Feb 16, 2022 12:25:35 PM
org.apache.flink.runtime.resourcemanager.ResourceManager
closeJobManagerConnection'
INFO:apache_beam.utils.subprocess_server:b'INFO: Disconnect job manager
96129c2d109b8060de0e619944d343a0@akka://flink/user/rpc/jobmanager_3 for job
a2d24db7867af9621cd8ac4c3da5eb27 from the resource manager.'
INFO:apache_beam.utils.subprocess_server:b'Feb 16, 2022 12:25:36 PM
org.apache.flink.runtime.taskexecutor.TaskExecutor$JobLeaderListenerImpl
jobManagerLostLeadership'
INFO:apache_beam.utils.subprocess_server:b'INFO: JobManager for job
a2d24db7867af9621cd8ac4c3da5eb27 with leader id
96129c2d109b8060de0e619944d343a0 lost leadership.'
INFO:apache_beam.utils.subprocess_server:b'Feb 16, 2022 12:25:36 PM
org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService stop'
INFO:apache_beam.utils.subprocess_server:b'INFO: Stop job leader service.'
INFO:apache_beam.utils.subprocess_server:b'Feb 16, 2022 12:25:36 PM
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager shutdown'
INFO:apache_beam.utils.subprocess_server:b'INFO: Shutting down
TaskExecutorLocalStateStoresManager.'
INFO:apache_beam.utils.subprocess_server:b'Feb 16, 2022 12:25:36 PM
org.apache.flink.runtime.io.disk.FileChannelManagerImpl lambda$getFileCloser$0'
INFO:apache_beam.utils.subprocess_server:b'INFO: FileChannelManager removed
spill file directory /tmp/flink-io-9d11a5a8-33b7-40cb-b0ba-f8c1086688e1'
INFO:apache_beam.utils.subprocess_server:b'Feb 16, 2022 12:25:36 PM
org.apache.flink.runtime.io.network.NettyShuffleEnvironment close'
INFO:apache_beam.utils.subprocess_server:b'INFO: Shutting down the network
environment and its components.'
INFO:apache_beam.utils.subprocess_server:b'Feb 16, 2022 12:25:36 PM
org.apache.flink.runtime.io.disk.FileChannelManagerImpl lambda$getFileCloser$0'
INFO:apache_beam.utils.subprocess_server:b'INFO: FileChannelManager removed
spill file directory
/tmp/flink-netty-shuffle-91249f4b-80fa-49e7-b1ab-b0ee0be172fe'
INFO:apache_beam.utils.subprocess_server:b'Feb 16, 2022 12:25:36 PM
org.apache.flink.runtime.taskexecutor.KvStateService shutdown'
INFO:apache_beam.utils.subprocess_server:b'INFO: Shutting down the kvState
service and its components.'
INFO:apache_beam.utils.subprocess_server:b'Feb 16, 2022 12:25:36 PM
org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService stop'
INFO:apache_beam.utils.subprocess_server:b'INFO: Stop job leader service.'
INFO:apache_beam.utils.subprocess_server:b'Feb 16, 2022 12:25:36 PM
org.apache.flink.runtime.filecache.FileCache shutdown'
INFO:apache_beam.utils.subprocess_server:b'INFO: removed file cache directory
/tmp/flink-dist-cache-aa711ba8-5cb8-49a1-bfa9-e8bbe5d0a6ca'
INFO:apache_beam.utils.subprocess_server:b'Feb 16, 2022 12:25:36 PM
org.apache.flink.runtime.taskexecutor.TaskExecutor handleOnStopException'
INFO:apache_beam.utils.subprocess_server:b'INFO: Stopped TaskExecutor
akka://flink/user/rpc/taskmanager_0.'
INFO:apache_beam.utils.subprocess_server:b'Feb 16, 2022 12:25:36 PM
org.apache.flink.runtime.webmonitor.WebMonitorEndpoint
lambda$shutDownInternal$5'
INFO:apache_beam.utils.subprocess_server:b'INFO: Removing cache directory
/tmp/flink-web-ui'
INFO:apache_beam.utils.subprocess_server:b'Feb 16, 2022 12:25:36 PM
org.apache.flink.runtime.rest.RestServerEndpoint lambda$closeAsync$1'
INFO:apache_beam.utils.subprocess_server:b'INFO: Shut down complete.'
INFO:apache_beam.utils.subprocess_server:b'Feb 16, 2022 12:25:36 PM
org.apache.flink.runtime.resourcemanager.ResourceManager deregisterApplication'
INFO:apache_beam.utils.subprocess_server:b'INFO: Shut down cluster because
application is in CANCELED, diagnostics DispatcherResourceManagerComponent has
been closed..'
INFO:apache_beam.utils.subprocess_server:b'Feb 16, 2022 12:25:36 PM
org.apache.flink.runtime.entrypoint.component.DispatcherResourceManagerComponent
closeAsyncInternal'
INFO:apache_beam.utils.subprocess_server:b'INFO: Closing components.'
INFO:apache_beam.utils.subprocess_server:b'Feb 16, 2022 12:25:36 PM
org.apache.flink.runtime.dispatcher.runner.AbstractDispatcherLeaderProcess
closeInternal'
INFO:apache_beam.utils.subprocess_server:b'INFO: Stopping
SessionDispatcherLeaderProcess.'
INFO:apache_beam.utils.subprocess_server:b'Feb 16, 2022 12:25:36 PM
org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager
close'
INFO:apache_beam.utils.subprocess_server:b'INFO: Closing the slot manager.'
INFO:apache_beam.utils.subprocess_server:b'Feb 16, 2022 12:25:36 PM
org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager
suspend'
INFO:apache_beam.utils.subprocess_server:b'INFO: Suspending the slot manager.'
INFO:apache_beam.utils.subprocess_server:b'Feb 16, 2022 12:25:36 PM
org.apache.flink.runtime.dispatcher.Dispatcher onStop'
INFO:apache_beam.utils.subprocess_server:b'INFO: Stopping dispatcher
akka://flink/user/rpc/dispatcher_2.'
INFO:apache_beam.utils.subprocess_server:b'Feb 16, 2022 12:25:36 PM
org.apache.flink.runtime.dispatcher.Dispatcher terminateRunningJobs'
INFO:apache_beam.utils.subprocess_server:b'INFO: Stopping all currently running
jobs of dispatcher akka://flink/user/rpc/dispatcher_2.'
INFO:apache_beam.runners.portability.portable_runner:Job state changed to DONE
INFO:apache_beam.utils.subprocess_server:b'Feb 16, 2022 12:25:36 PM
org.apache.flink.runtime.blob.AbstractBlobCache close'
INFO:apache_beam.utils.subprocess_server:b'INFO: Shutting down BLOB cache'
INFO:apache_beam.utils.subprocess_server:b'Feb 16, 2022 12:25:36 PM
org.apache.flink.runtime.blob.AbstractBlobCache close'
INFO:apache_beam.utils.subprocess_server:b'INFO: Shutting down BLOB cache'
ERROR:apache_beam.runners.worker.data_plane:Failed to read inputs in the data
plane.
Traceback (most recent call last):
File
"<https://ci-beam.apache.org/job/beam_PreCommit_Portable_Python_Cron/ws/src/build/gradleenv/2022703440/lib/python3.6/site-packages/apache_beam/runners/worker/data_plane.py";,>
line 634, in _read_inputs
for elements in elements_iterator:
File
"<https://ci-beam.apache.org/job/beam_PreCommit_Portable_Python_Cron/ws/src/build/gradleenv/2022703440/lib/python3.6/site-packages/grpc/_channel.py";,>
line 426, in __next__
return self._next()
File
"<https://ci-beam.apache.org/job/beam_PreCommit_Portable_Python_Cron/ws/src/build/gradleenv/2022703440/lib/python3.6/site-packages/grpc/_channel.py";,>
line 826, in _next
raise self
grpc._channel._MultiThreadedRendezvous: <_MultiThreadedRendezvous of RPC that
terminated with:
status = StatusCode.UNAVAILABLE
details = "Socket closed"
debug_error_string =
"{"created":"@1645014337.095920754","description":"Error received from peer
ipv6:[::1]:46759","file":"src/core/lib/surface/call.cc","file_line":1074,"grpc_message":"Socket
closed","grpc_status":14}"
>
Exception in thread read_grpc_client_inputs:
Traceback (most recent call last):
File "/usr/lib/python3.6/threading.py", line 916, in _bootstrap_inner
self.run()
File "/usr/lib/python3.6/threading.py", line 864, in run
self._target(*self._args, **self._kwargs)
File
"<https://ci-beam.apache.org/job/beam_PreCommit_Portable_Python_Cron/ws/src/build/gradleenv/2022703440/lib/python3.6/site-packages/apache_beam/runners/worker/data_plane.py";,>
line 651, in <lambda>
target=lambda: self._read_inputs(elements_iterator),
File
"<https://ci-beam.apache.org/job/beam_PreCommit_Portable_Python_Cron/ws/src/build/gradleenv/2022703440/lib/python3.6/site-packages/apache_beam/runners/worker/data_plane.py";,>
line 634, in _read_inputs
for elements in elements_iterator:
File
"<https://ci-beam.apache.org/job/beam_PreCommit_Portable_Python_Cron/ws/src/build/gradleenv/2022703440/lib/python3.6/site-packages/grpc/_channel.py";,>
line 426, in __next__
return self._next()
File
"<https://ci-beam.apache.org/job/beam_PreCommit_Portable_Python_Cron/ws/src/build/gradleenv/2022703440/lib/python3.6/site-packages/grpc/_channel.py";,>
line 826, in _next
raise self
grpc._channel._MultiThreadedRendezvous: <_MultiThreadedRendezvous of RPC that
terminated with:
status = StatusCode.UNAVAILABLE
details = "Socket closed"
debug_error_string =
"{"created":"@1645014337.095920754","description":"Error received from peer
ipv6:[::1]:46759","file":"src/core/lib/surface/call.cc","file_line":1074,"grpc_message":"Socket
closed","grpc_status":14}"
>
Exception in thread read_state:
Traceback (most recent call last):
File "/usr/lib/python3.6/threading.py", line 916, in _bootstrap_inner
self.run()
File "/usr/lib/python3.6/threading.py", line 864, in run
self._target(*self._args, **self._kwargs)
File
"<https://ci-beam.apache.org/job/beam_PreCommit_Portable_Python_Cron/ws/src/build/gradleenv/2022703440/lib/python3.6/site-packages/apache_beam/runners/worker/sdk_worker.py";,>
line 957, in pull_responses
for response in responses:
File
"<https://ci-beam.apache.org/job/beam_PreCommit_Portable_Python_Cron/ws/src/build/gradleenv/2022703440/lib/python3.6/site-packages/grpc/_channel.py";,>
line 426, in __next__
return self._next()
File
"<https://ci-beam.apache.org/job/beam_PreCommit_Portable_Python_Cron/ws/src/build/gradleenv/2022703440/lib/python3.6/site-packages/grpc/_channel.py";,>
line 826, in _next
raise self
grpc._channel._MultiThreadedRendezvous: <_MultiThreadedRendezvous of RPC that
terminated with:
status = StatusCode.UNAVAILABLE
details = "Socket closed"
debug_error_string =
"{"created":"@1645014337.099243750","description":"Error received from peer
ipv6:[::1]:37247","file":"src/core/lib/surface/call.cc","file_line":1074,"grpc_message":"Socket
closed","grpc_status":14}"
>
Exception in thread run_worker_1-1:
Traceback (most recent call last):
File "/usr/lib/python3.6/threading.py", line 916, in _bootstrap_inner
self.run()
File "/usr/lib/python3.6/threading.py", line 864, in run
self._target(*self._args, **self._kwargs)
File
"<https://ci-beam.apache.org/job/beam_PreCommit_Portable_Python_Cron/ws/src/build/gradleenv/2022703440/lib/python3.6/site-packages/apache_beam/runners/worker/sdk_worker.py";,>
line 234, in run
for work_request in self._control_stub.Control(get_responses()):
File
"<https://ci-beam.apache.org/job/beam_PreCommit_Portable_Python_Cron/ws/src/build/gradleenv/2022703440/lib/python3.6/site-packages/grpc/_channel.py";,>
line 426, in __next__
return self._next()
File
"<https://ci-beam.apache.org/job/beam_PreCommit_Portable_Python_Cron/ws/src/build/gradleenv/2022703440/lib/python3.6/site-packages/grpc/_channel.py";,>
line 826, in _next
raise self
grpc._channel._MultiThreadedRendezvous: <_MultiThreadedRendezvous of RPC that
terminated with:
status = StatusCode.UNAVAILABLE
details = "Socket closed"
debug_error_string =
"{"created":"@1645014337.099262706","description":"Error received from peer
ipv6:[::1]:39819","file":"src/core/lib/surface/call.cc","file_line":1074,"grpc_message":"Socket
closed","grpc_status":14}"
>
> Task
> :sdks:python:test-suites:portable:py36:portableWordCountFlinkRunnerStreaming
INFO:apache_beam.runners.worker.worker_pool_main:Listening for workers at
localhost:43571
WARNING:root:Make sure that locally built Python SDK docker image has Python
3.6 interpreter.
INFO:root:Default Python SDK image for environment is
apache/beam_python3.6_sdk:2.38.0.dev
INFO:apache_beam.utils.subprocess_server:Starting service with ['java' '-jar'
'<https://ci-beam.apache.org/job/beam_PreCommit_Portable_Python_Cron/ws/src/runners/flink/1.13/job-server/build/libs/beam-runners-flink-1.13-job-server-2.38.0-SNAPSHOT.jar'>
'--flink-master' '[auto]' '--artifacts-dir'
'/tmp/beam-tempokugevb4/artifactsk1g2q2ns' '--job-port' '39419'
'--artifact-port' '0' '--expansion-port' '0']
INFO:apache_beam.utils.subprocess_server:b'Feb 16, 2022 12:25:50 PM
software.amazon.awssdk.regions.internal.util.EC2MetadataUtils getItems'
INFO:apache_beam.utils.subprocess_server:b'WARNING: Unable to retrieve the
requested metadata.'
INFO:apache_beam.utils.subprocess_server:b'Feb 16, 2022 12:25:50 PM
org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO:apache_beam.utils.subprocess_server:b"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."
INFO:apache_beam.utils.subprocess_server:b'Feb 16, 2022 12:25:51 PM
org.apache.beam.runners.jobsubmission.JobServerDriver
createArtifactStagingService'
INFO:apache_beam.utils.subprocess_server:b'INFO: ArtifactStagingService started
on localhost:35535'
INFO:apache_beam.utils.subprocess_server:b'Feb 16, 2022 12:25:51 PM
org.apache.beam.runners.jobsubmission.JobServerDriver createExpansionService'
INFO:apache_beam.utils.subprocess_server:b'INFO: Java ExpansionService started
on localhost:40511'
INFO:apache_beam.utils.subprocess_server:b'Feb 16, 2022 12:25:51 PM
org.apache.beam.runners.jobsubmission.JobServerDriver run'
INFO:apache_beam.utils.subprocess_server:b'WARNING: Exception during job server
creation'
INFO:apache_beam.utils.subprocess_server:b'java.io.IOException: Failed to bind
to address 0.0.0.0/0.0.0.0:39419'
INFO:apache_beam.utils.subprocess_server:b'\tat
org.apache.beam.vendor.grpc.v1p43p2.io.grpc.netty.NettyServer.start(NettyServer.java:328)'
INFO:apache_beam.utils.subprocess_server:b'\tat
org.apache.beam.vendor.grpc.v1p43p2.io.grpc.internal.ServerImpl.start(ServerImpl.java:183)'
INFO:apache_beam.utils.subprocess_server:b'\tat
org.apache.beam.vendor.grpc.v1p43p2.io.grpc.internal.ServerImpl.start(ServerImpl.java:92)'
INFO:apache_beam.utils.subprocess_server:b'\tat
org.apache.beam.sdk.fn.server.ServerFactory$InetSocketAddressServerFactory.createServer(ServerFactory.java:162)'
INFO:apache_beam.utils.subprocess_server:b'\tat
org.apache.beam.sdk.fn.server.ServerFactory$InetSocketAddressServerFactory.create(ServerFactory.java:145)'
INFO:apache_beam.utils.subprocess_server:b'\tat
org.apache.beam.sdk.fn.server.GrpcFnServer.create(GrpcFnServer.java:110)'
INFO:apache_beam.utils.subprocess_server:b'\tat
org.apache.beam.runners.jobsubmission.JobServerDriver.createJobServer(JobServerDriver.java:238)'
INFO:apache_beam.utils.subprocess_server:b'\tat
org.apache.beam.runners.jobsubmission.JobServerDriver.run(JobServerDriver.java:176)'
INFO:apache_beam.utils.subprocess_server:b'\tat
org.apache.beam.runners.flink.FlinkJobServerDriver.main(FlinkJobServerDriver.java:77)'
INFO:apache_beam.utils.subprocess_server:b'Caused by:
org.apache.beam.vendor.grpc.v1p43p2.io.netty.channel.unix.Errors$NativeIoException:
bind(..) failed: Address already in use'
INFO:apache_beam.utils.subprocess_server:b''
INFO:apache_beam.utils.subprocess_server:b'Feb 16, 2022 12:25:51 PM
org.apache.beam.runners.jobsubmission.JobServerDriver stop'
INFO:apache_beam.utils.subprocess_server:b'INFO: ArtifactStagingServer stopped
on localhost:35535'
INFO:apache_beam.utils.subprocess_server:b'Feb 16, 2022 12:25:51 PM
org.apache.beam.runners.jobsubmission.JobServerDriver stop'
INFO:apache_beam.utils.subprocess_server:b'INFO: Expansion stopped on
localhost:40511'
Traceback (most recent call last):
File "/usr/lib/python3.6/runpy.py", line 193, in _run_module_as_main
"__main__", mod_spec)
File "/usr/lib/python3.6/runpy.py", line 85, in _run_code
exec(code, run_globals)
File
"<https://ci-beam.apache.org/job/beam_PreCommit_Portable_Python_Cron/ws/src/build/gradleenv/2022703440/lib/python3.6/site-packages/apache_beam/examples/wordcount.py";,>
line 105, in <module>
run()
File
"<https://ci-beam.apache.org/job/beam_PreCommit_Portable_Python_Cron/ws/src/build/gradleenv/2022703440/lib/python3.6/site-packages/apache_beam/examples/wordcount.py";,>
line 100, in run
output | 'Write' >> WriteToText(known_args.output)
File
"<https://ci-beam.apache.org/job/beam_PreCommit_Portable_Python_Cron/ws/src/build/gradleenv/2022703440/lib/python3.6/site-packages/apache_beam/pipeline.py";,>
line 596, in __exit__
self.result = self.run()
File
"<https://ci-beam.apache.org/job/beam_PreCommit_Portable_Python_Cron/ws/src/build/gradleenv/2022703440/lib/python3.6/site-packages/apache_beam/pipeline.py";,>
line 573, in run
return self.runner.run_pipeline(self, self._options)
File
"<https://ci-beam.apache.org/job/beam_PreCommit_Portable_Python_Cron/ws/src/build/gradleenv/2022703440/lib/python3.6/site-packages/apache_beam/runners/portability/flink_runner.py";,>
line 45, in run_pipeline
return super().run_pipeline(pipeline, options)
File
"<https://ci-beam.apache.org/job/beam_PreCommit_Portable_Python_Cron/ws/src/build/gradleenv/2022703440/lib/python3.6/site-packages/apache_beam/runners/portability/portable_runner.py";,>
line 440, in run_pipeline
job_service_handle.submit(proto_pipeline)
File
"<https://ci-beam.apache.org/job/beam_PreCommit_Portable_Python_Cron/ws/src/build/gradleenv/2022703440/lib/python3.6/site-packages/apache_beam/runners/portability/portable_runner.py";,>
line 107, in submit
prepare_response = self.prepare(proto_pipeline)
File
"<https://ci-beam.apache.org/job/beam_PreCommit_Portable_Python_Cron/ws/src/build/gradleenv/2022703440/lib/python3.6/site-packages/apache_beam/runners/portability/portable_runner.py";,>
line 201, in prepare
pipeline_options=self.get_pipeline_options()),
File
"<https://ci-beam.apache.org/job/beam_PreCommit_Portable_Python_Cron/ws/src/build/gradleenv/2022703440/lib/python3.6/site-packages/apache_beam/runners/portability/portable_runner.py";,>
line 144, in get_pipeline_options
options_response = send_options_request()
File
"<https://ci-beam.apache.org/job/beam_PreCommit_Portable_Python_Cron/ws/src/build/gradleenv/2022703440/lib/python3.6/site-packages/apache_beam/runners/portability/portable_runner.py";,>
line 141, in send_options_request
raise e
File
"<https://ci-beam.apache.org/job/beam_PreCommit_Portable_Python_Cron/ws/src/build/gradleenv/2022703440/lib/python3.6/site-packages/apache_beam/runners/portability/portable_runner.py";,>
line 134, in send_options_request
timeout=self.timeout)
File
"<https://ci-beam.apache.org/job/beam_PreCommit_Portable_Python_Cron/ws/src/build/gradleenv/2022703440/lib/python3.6/site-packages/grpc/_channel.py";,>
line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File
"<https://ci-beam.apache.org/job/beam_PreCommit_Portable_Python_Cron/ws/src/build/gradleenv/2022703440/lib/python3.6/site-packages/grpc/_channel.py";,>
line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNIMPLEMENTED
details = "Method not found!"
debug_error_string =
"{"created":"@1645014352.140974200","description":"Error received from peer
ipv6:[::1]:39419","file":"src/core/lib/surface/call.cc","file_line":1074,"grpc_message":"Method
not found!","grpc_status":12}"
>
> Task
> :sdks:python:test-suites:portable:py36:portableWordCountFlinkRunnerStreaming
> FAILED
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task
':sdks:python:test-suites:portable:py36:portableWordCountFlinkRunnerStreaming'.
> 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 15m 5s
145 actionable tasks: 93 executed, 40 from cache, 12 up-to-date
Publishing build scan...
https://gradle.com/s/4j6vsvoovnpoq
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]
