beam-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Ruoyun Huang <>
Subject Re: Portable wordcount on Flink runner broken
Date Sun, 18 Nov 2018 22:11:25 GMT
I was after the same issue (I was using reference runner job server, but
same error message), had some clue but no conclusion yet.

By retaining the container instance, error message says "bad MD5" (see the
other thread [1] I asked in dev last week). My hypothesis, based on the
symptoms, is that the underlying container expects an MD5 to validate
staged files, but job request from python SDK does not send file hash
code.  Hope someone can confirm if that is the case (I am still trying to
understand how come dataflow does not have such issue), and if so, the best
way to fix it.


On Fri, Nov 16, 2018 at 7:06 PM Thomas Weise <> wrote:

> Since last few days, the steps under
> are broken.
> The gradle task hangs because the job server isn't able to launch the
> docker container.
> ./gradlew :beam-sdks-python:portableWordCount -PjobEndpoint=localhost:8099
> [CHAIN MapPartition (MapPartition at
> 36write/Write/WriteImpl/DoOnce/Impulse.None/beam:env:docker:v1:0) ->
> FlatMap (FlatMap at
> 36write/Write/WriteImpl/DoOnce/Impulse.None/beam:env:docker:v1:0/out.0)
> (8/8)] INFO
> org.apache.beam.runners.fnexecution.environment.DockerEnvironmentFactory -
> Still waiting for startup of environment
> for worker id 1
> Unfortunately this isn't covered by tests yet. Is anyone aware what change
> may have caused this or looking into resolving it?
> Thanks,
> Thomas

Ruoyun  Huang

View raw message