baeminbo commented on code in PR #28548:
URL: https://github.com/apache/beam/pull/28548#discussion_r1341036490
##########
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/WorkerCustomSources.java:
##########
@@ -776,7 +776,7 @@ public double getRemainingParallelism() {
private static class UnboundedReaderIterator<T>
extends
NativeReader.NativeReaderIterator<WindowedValue<ValueWithRecordId<T>>> {
- private final UnboundedSource.UnboundedReader<T> reader;
+ private final UnboundedSource.UnboundedReader<T> reader; // not owned
Review Comment:
Thanks, I added a comment to explain it in detail, rather than a short
ambiguous comment.
--
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.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
