support customize twepoch

wenhaibin · Oct 8, 2019 · 0dc819c · 0dc819c
1 parent 0e810c0
commit 0dc819c
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/leaf-core/src/main/java/com/sankuai/inf/leaf/snowflake/SnowflakeIDGenImpl.java b/leaf-core/src/main/java/com/sankuai/inf/leaf/snowflake/SnowflakeIDGenImpl.java
@@ -47,7 +47,7 @@ public SnowflakeIDGenImpl(String zkAddress, int port, long twepoch) {
         final String ip = Utils.getIp();
         SnowflakeZookeeperHolder holder = new SnowflakeZookeeperHolder(ip, String.valueOf(port), zkAddress);
         LOGGER.info("twepoch:{} ,ip:{} ,zkAddress:{} port:{}", twepoch, ip, zkAddress, port);
-        initFlag = holder.init();
+        boolean initFlag = holder.init();
         if (initFlag) {
             workerId = holder.getWorkerID();
             LOGGER.info("START SUCCESS USE ZK WORKERID-{}", workerId);