Axel Magnuson created BEAM-5464: ----------------------------------- Summary: Portable beam hangs while running TFX preprocessing step on a distributed cluster Key: BEAM-5464 URL: https://issues.apache.org/jira/browse/BEAM-5464 Project: Beam Issue Type: Bug Components: java-fn-execution Reporter: Axel Magnuson Assignee: Ankur Goenka
Recently I went through the exercise of running the TFX taxi example on a dataproc cluster. However it would always hang indefinitely. The flink UI indicated that the job was halfway done. However I could not see any clear errors in the job driver logs, the job service logs, or the Flink logs. The root cause is still a mystery to me. -- This message was sent by Atlassian JIRA (v7.6.3#76005)