79340861

Date: 2025-01-08 22:05:08
Score: 1
Natty:
Report link

You should be able to change:

| beam.Map(lambda x: f"{x[0]},{x[1]}")

to

| beam.Map(lambda x: f"{x[0]},{x[1]}").with_output_types(str)

this error is coming because Beam is not able to automatically infer the output type of your map stage, so it is not able to convert it to a schema'd element.

Reasons:
  • Low length (0.5):
  • Has code block (-0.5):
  • Low reputation (1):
Posted by: Danny McCormick