Hi dev team, I want to add a side_input into a ParDo transform. Side_input is a table from Bigquery. However, I am facing a weird issue. I could run this pipeline with *DirectRunner* on a local machine but I am not able to run this pipeline with *DataflowRunner. *The error message is: ``` Job did not reach to a terminal state after waiting indefinitely ``` And it traced into my *sales_transaction *table. Attachment is the pipeline issue.
I am looking for help from the community. Thanks and best regards.
data.py
Description: Binary data
