when I run locally:
```
python -m apache_beam.examples.wordcount --input=/etc/profile
--output=/tmp/py-wordcount-direct --experiments=beam_fn_api
--runner=PortableRunner --sdk_location=container --job_endpoint=localhost:8099
```
I see failures like:
```
java.lang.Exception: The user defined 'open()' method caused an exception:
java.lang.IllegalStateException: The passed environment does not contain a
DockerPayload.
at org.apache.flink.runtime.operators.BatchTask.run(BatchTask.java:498)
at
org.apache.flink.runtime.operators.BatchTask.invoke(BatchTask.java:368)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:712)
at java.lang.Thread.run(Thread.java:745)
```
([more
output](https://gist.github.com/ryan-williams/653861032f4c6e12e6e1b4220f753348))
have no leads on what could be causing that / haven't looked yet, but wanted to
get this out for folks to look at
[ Full content available at: https://github.com/apache/beam/pull/6461 ]
This message was relayed via gitbox.apache.org for [email protected]
