Hi team,

I'm trying to create an External transform in Java SDK, which expands into
several ParDo and a Window.into(FixWindow). When I use this transform in
Python SDK, I get an pipeline construction error:

apache_beam/utils/urns.py", line 186, in from_runner_api
    parameter_type, constructor = cls._known_urns[fn_proto.urn]
KeyError: 'beam:window_fn:serialized_java:v1'

Is it expected that I cannot use a Window.into when building External
Ptransform? Or do I miss anything here?


Thanks for your help!

Reply via email to