Skip to content Skip to sidebar Skip to footer
Home / Apache Beam / Apache Flink / Python

Input Of Apache_beam.examples.wordcount

Post a Comment
I was trying to run the beam Python-SDK example, but I had problem in reading the input. https://cwiki.apache.org/confluence/display/BEAM/Usage+Guide#UsageGuide-RunaPython-SDKPipel

Solution 1:

This error is because your version of google-apitools is too old. You need v0.5.23 or newer to avoid this error.

Beam python has strict version requirements for dependencies. If you are running Beam 2.11, you need to be using google-apitools v0.5.26.

Post a Comment for "Input Of Apache_beam.examples.wordcount"