AHeise commented on a change in pull request #15294:
URL: https://github.com/apache/flink/pull/15294#discussion_r600282231
##########
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/OperatorChain.java
##########
@@ -715,7 +715,12 @@ public OP getMainOperator() {
taskEnvironment.getUserCodeClassLoader().asClassLoader());
}
- return new RecordWriterOutput<>(recordWriter, outSerializer,
sideOutputTag, this);
+ return new RecordWriterOutput<>(
+ recordWriter,
+ outSerializer,
+ sideOutputTag,
+ this,
+ edge.getPartitioner().isPointwise());
Review comment:
I think you are right. I was falsely assuming that we decide persisting
on gate level but in reality any gate can cause a `prepareSnapshot` even on the
pointwise connection.
That would effectively mean that we need to disable it on all inputs of task
X if X has at least one pointwise, right?
--
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
