concurrent.ExecutionException: java.lang.RuntimeException: Error␣ ˓→received from SDK harness for instruction 4: Traceback (most recent call last): File "/usr/local/lib/python3.7/site-packages/apache_beam self.create_worker().do_instruction(request), request) File "/usr/local/lib/python3.7/site-packages/apache_beam/runners/worker/sdk_worker.py",␣ ˓→line 607, in do_instruction getattr(request, request_type) request.instruction_id) File "/usr/local/lib/python3.7/site-packages/apache_beam/runners/worker/sdk_worker.py",␣ ˓→line 644, in process_bundle bundle_processor.process_bundle(instruction_id)) File

concurrent.ExecutionException: java.lang.RuntimeException: Error␣ ˓→received from SDK harness for instruction 4: Traceback (most recent call last): File "/usr/local/lib/python3.7/site-packages/apache_beam self.create_worker().do_instruction(request), request) File "/usr/local/lib/python3.7/site-packages/apache_beam/runners/worker/sdk_worker.py",␣ ˓→line 607, in do_instruction getattr(request, request_type) request.instruction_id) File "/usr/local/lib/python3.7/site-packages/apache_beam/runners/worker/sdk_worker.py",␣ ˓→line 644, in process_bundle bundle_processor.process_bundle(instruction_id)) File