[iotdb] branch enable_cache_leaderv2 updated: fix

[ha...@apache.org]

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

haonan pushed a commit to branch enable_cache_leaderv2
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/enable_cache_leaderv2 by this push:
     new c920752  fix
c920752 is described below

commit c92075298a5163f20be74598ca0d1dc5a745a21f
Author: HTHou <hh...@outlook.com>
AuthorDate: Thu Jul 1 23:22:28 2021 +0800

    fix
---
 cli/src/main/java/org/apache/iotdb/tool/ImportCsv.java      | 1 +
 session/src/main/java/org/apache/iotdb/session/Session.java | 2 +-
 2 files changed, 2 insertions(+), 1 deletion(-)

diff --git a/cli/src/main/java/org/apache/iotdb/tool/ImportCsv.java b/cli/src/main/java/org/apache/iotdb/tool/ImportCsv.java
index 6959360..acb0c53 100644
--- a/cli/src/main/java/org/apache/iotdb/tool/ImportCsv.java
+++ b/cli/src/main/java/org/apache/iotdb/tool/ImportCsv.java
@@ -291,6 +291,7 @@ public class ImportCsv extends AbstractCsvTool {
       String ip, String port, String username, String password, String filename, String timeZone) {
     try {
       session = new Session(ip, Integer.parseInt(port), username, password);
+      session.enableCacheLeader = false;
       session.open(false);
       timeZoneID = timeZone;
       setTimeZone();
diff --git a/session/src/main/java/org/apache/iotdb/session/Session.java b/session/src/main/java/org/apache/iotdb/session/Session.java
index 1b2f812..1ec8aea 100644
--- a/session/src/main/java/org/apache/iotdb/session/Session.java
+++ b/session/src/main/java/org/apache/iotdb/session/Session.java
@@ -97,7 +97,7 @@ public class Session {
   private boolean isClosed = true;
 
   // Cluster version cache
-  protected boolean enableCacheLeader;
+  public boolean enableCacheLeader;
   protected SessionConnection metaSessionConnection;
   protected Map<String, EndPoint> deviceIdToEndpoint;
   protected Map<EndPoint, SessionConnection> endPointToSessionConnection;