[incubator-iotdb] branch watermark-demp updated: serialize field useWaterMark

[jiangtian]

This is an automated email from the ASF dual-hosted git repository.

jiangtian pushed a commit to branch watermark-demp
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git


The following commit(s) were added to refs/heads/watermark-demp by this push:
     new 9419122  serialize field useWaterMark
9419122 is described below

commit 9419122c8a6c04b02f497203ef318e8ceb8bda48
Author: 江天 <jt2594...@163.com>
AuthorDate: Thu May 30 15:26:36 2019 +0800

    serialize field useWaterMark
---
 .../main/java/org/apache/iotdb/db/auth/user/LocalFileUserAccessor.java  | 2 ++
 1 file changed, 2 insertions(+)

diff --git 
a/iotdb/src/main/java/org/apache/iotdb/db/auth/user/LocalFileUserAccessor.java 
b/iotdb/src/main/java/org/apache/iotdb/db/auth/user/LocalFileUserAccessor.java
index b3020ad..89d6a02 100644
--- 
a/iotdb/src/main/java/org/apache/iotdb/db/auth/user/LocalFileUserAccessor.java
+++ 
b/iotdb/src/main/java/org/apache/iotdb/db/auth/user/LocalFileUserAccessor.java
@@ -110,6 +110,7 @@ public class LocalFileUserAccessor implements IUserAccessor 
{
         roleList.add(userName);
       }
       user.setRoleList(roleList);
+      user.setUseWaterMark(dataInputStream.readInt() != 0);
       return user;
     } catch (Exception e) {
       throw new IOException(e);
@@ -147,6 +148,7 @@ public class LocalFileUserAccessor implements IUserAccessor 
{
               .writeString(outputStream, user.getRoleList().get(i), 
STRING_ENCODING,
                   encodingBufferLocal);
         }
+        IOUtils.writeInt(outputStream, user.isUseWaterMark()? 1 : 0, 
encodingBufferLocal);
         outputStream.flush();
 
       } catch (Exception e) {