Details
-
Bug
-
Status: Resolved
-
P3
-
Resolution: Fixed
-
None
-
None
Description
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.
Attachments
Issue Links
- blocks
-
BEAM-2889 Flink runs portable pipelines
- Resolved
- is blocked by
-
FLINK-10672 Task stuck while writing output to flink
- Closed
- links to