任务运行一段时间出现Apache beam问题 有哪位大佬能帮忙看看：
Caused by: java.lang.RuntimeException: Error received from SDK harness for
instruction 3134: Traceback (most recent call last): File
"/home/yarn/software/python/lib/python3.6/site-packages/apache_beam/runners/worker/data_plane.py",
line 421, in input_elements element = received.get(timeout=1) File
"/home/yarn/software/python/lib/python3.6/queue.py", line 172, in get raise
Empty queue.Empty During handling of the above exception, another exception
occurred: Traceback (most recent call last): File
"/home/yarn/software/python/lib/python3.6/site-packages/apache_beam/runners/worker/sdk_worker.py",
line 253, in _execute response = task() File
"/home/yarn/software/python/lib/python3.6/site-packages/apache_beam/runners/worker/sdk_worker.py",
line 310, in <lambda> lambda: self.create_worker().do_instruction(request),
request) File
"/home/yarn/software/python/lib/python3.6/site-packages/apache_beam/runners/worker/sdk_worker.py",
line 480, in do_instruction getattr(request, request_type),
request.instruction_id) File
"/home/yarn/software/python/lib/python3.6/site-packages/apache_beam/runners/worker/sdk_worker.py",
line 515, in process_bundle bundle_processor.process_bundle(instruction_id))
File
"/home/yarn/software/python/lib/python3.6/site-packages/apache_beam/runners/worker/bundle_processor.py",
line 967, in process_bundle expected_inputs): File
"/home/yarn/software/python/lib/python3.6/site-packages/apache_beam/runners/worker/data_plane.py",
line 424, in input_elements raise RuntimeError('Channel closed prematurely.')
RuntimeError: Channel closed prematurely.
[email protected]
