Skip to content
Closed
Original file line number Diff line number Diff line change
Expand Up @@ -343,10 +343,10 @@ public void startThreads() throws IOException {
loadFromZKCache(true);
} catch (Exception e) {
throw new IOException("Could not start Curator tokenCacheListener for tokens", e);
}
}
}
super.startThreads();
}
}
/**
* Load the CuratorCache into the in-memory map. Possible caches to be
* loaded are keyCache and tokenCache.
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -101,6 +101,7 @@ public void testMultiNodeOperationWithoutWatch() throws Exception {
}
}

@SuppressWarnings("unchecked")
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

trunk does not suppress here. Maybe we shouldn't neither?

@Test
public void testMultiNodeTokenRemovalShortSyncWithoutWatch()
throws Exception {
Expand Down