Top Questions

1. No module named airfow.gcp - how to run dataflow job that uses python3/beam 2.15?
   8 votes

   3 answers
2. Efficiently calculating weighted rolling average in Pyspark with some caveats
   4 votes

   1 answers
3. Exporting data from delta lake to single jsonl file and preserve nested field names (struct issue)
   4 votes

   0 answers
4. Is it possible to invoke BigQuery procedures in python client?
   3 votes

   2 answers
5. Airflow DAG - how to check BQ first (delete if necessary) and then run dataflow job?
   3 votes

   1 answers