flinkSQL + pythonUDF问题

[guaishushu1103 <gu...@163.com>]

任务运行一段时间出现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.
guaishushu1103@163.com