XComp commented on a change in pull request #18189:
URL: https://github.com/apache/flink/pull/18189#discussion_r780397929
##########
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/highavailability/zookeeper/ZooKeeperHaServicesTest.java
##########
@@ -235,8 +235,7 @@ private void runCleanupTestWithJob(
final LeaderElectionService jobManagerLeaderElectionService =
zooKeeperHaServices.getJobManagerLeaderElectionService(jobId);
- final RunningJobsRegistry runningJobsRegistry =
- zooKeeperHaServices.getRunningJobsRegistry();
+ final JobResultStore jobResultStore =
zooKeeperHaServices.getJobResultStore();
Review comment:
good catch. We should remove it. The test is about cleaning up the
znodes. It's just about creating some paths. The integration of this component
into the test becomes obsolete with the `JobResultStore` replacing the
`RunningJobRegistry` since no ZK-related artifacts are created by the
`JobResultStore`.
--
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: issues-unsubscr...@flink.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
