Github user danny0405 commented on a diff in the pull request:
https://github.com/apache/storm/pull/2517#discussion_r162347006
--- Diff:
storm-server/src/main/java/org/apache/storm/blobstore/KeySequenceNumber.java ---
@@ -131,9 +131,8 @@ public KeySequenceNumber(String key, NimbusInfo
nimbusInfo) {
this.nimbusInfo = nimbusInfo;
}
- public synchronized int getKeySequenceNumber(Map<String, Object> conf)
throws KeyNotFoundException {
+ public synchronized int getKeySequenceNumber(CuratorFramework
zkClient) throws KeyNotFoundException {
TreeSet<Integer> sequenceNumbers = new TreeSet<Integer>();
- CuratorFramework zkClient = BlobStoreUtils.createZKClient(conf);
--- End diff --
done
---
