Removing this requires other changes to the pipeline creation/fusioning, 
DirectRunner, non-portable FlinkRunner, ApexRunner, SamzaRunner. Definitely 
doable but we should fix the pending issue first, and then move towards 
removing CREATE_VIEW.

> I would prefer we fix this in the Java SDK as otherwise it will leak into 
> every runner.

It's already leaked into every Runner since it was originally part of the 
pipeline translation.


I'm for supporting this with a NOOP. It's very little maintenance cost for the 
portable FlinkRunner and fixes a critical issue which prevents pipeline 
execution.

[ Full content available at: https://github.com/apache/beam/pull/6523 ]
This message was relayed via gitbox.apache.org for [email protected]

Reply via email to