Great, you figured it out. Thanks for posting this back to the list.
On Sat, Feb 24, 2024 at 5:23 PM George Dekermenjian
wrote:
> Adding the following to both Dockerfile.launcher and Dockerfile.worker did
> the trick for me.
>
>
>
> COPY --from=apache/beam_java11_sdk:latest
Adding the following to both Dockerfile.launcher and Dockerfile.worker did
the trick for me.
COPY --from=apache/beam_java11_sdk:latest /opt/apache/beam/jars
/opt/apache/beam/jars COPY --from=apache/beam_java11_sdk:latest
/opt/java/openjdk /opt/java/openjdk ENV JAVA_HOME=/opt/java/openjdk ENV
Does your code work without the launcher? Better check this step by step to
figure out which part causes this error.
On Sat, Feb 24, 2024 at 3:25 AM George Dekermenjian
wrote:
> I have a python pipeline that uses the bigquery storage write method
> (cross language with Java). I’m building
I have a python pipeline that uses the bigquery storage write method (cross
language with Java). I’m building launcher and worker docker images and
then launching the flex template. The launcher fails due to the following
runtime error in dataflow.
I’m using runner v2 and it is a streaming