Apache Beam Python SDK + Flink Runner: How to disable operator chaining?

I am using Python Beam SDK + Flink + Kafka.

In Pure Java + Flink implementation, I could use disableOperationChaining.

Refer to the example in the picture above, I am curious how can I unchain the second operator.

from Apache Beam Python SDK + Flink Runner: How to disable operator chaining?