mxm commented on a change in pull request #12708:
URL: https://github.com/apache/beam/pull/12708#discussion_r479392671
##########
File path:
runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkStreamingPipelineTranslator.java
##########
@@ -99,6 +99,13 @@ public CompositeBehavior
enterCompositeTransform(TransformHierarchy.Node node) {
PTransform<?, ?> transform = node.getTransform();
if (transform != null) {
+ // TODO(BEAM-10670): Remove this and the ReadTranslator once the
"use_deprecated_read"
+ // experiment is removed. Don't translate composite Read transforms
since we expect the
+ // primitive expansion containing an SDF to be used.
+ if (PTransformTranslation.READ_TRANSFORM_URN.equals(
+ PTransformTranslation.urnForTransformOrNull(transform))) {
+ return CompositeBehavior.ENTER_TRANSFORM;
+ }
Review comment:
Makes sense!
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
