79153225

Date: 2024-11-03 17:05:48
Score: 0.5
Natty:
Report link

I solved the above by changing the runner from DirectRunner to DataflowRunner it seems directrunner which is meant for local testing does not support fully all the to_dataframe functionalities when streaming is set to True(above am streaming data from a pubsub topic)

Reasons:
  • Whitelisted phrase (-2): I solved
  • Low length (0.5):
  • No code block (0.5):
  • Self-answer (0.5):
  • Single line (0.5):
  • Low reputation (0.5):
Posted by: oyugi.collins