kfaraz commented on code in PR #13328:
URL: https://github.com/apache/druid/pull/13328#discussion_r1016871435
##########
indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/supervisor/SeekableStreamSupervisor.java:
##########
@@ -2276,17 +2280,33 @@ public Void apply(@Nullable Boolean result)
);
}
+ /**
+ * Determines whether a given task was created by the current version of the
supervisor
+ * One can choose to pass a map of activeTasks. If the taskId doesn't
correspond to any task in it, fallback to the db
Review Comment:
```suggestion
/**
* Determines whether a given task was created by the current version of
the supervisor.
* Uses the Task object present in the {@code activeTaskMap} for this
taskId, if any. Otherwise, fetches it from the metadata store.
```
--
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]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
