liuzhen1207 commented on issue #3424:
URL: https://github.com/apache/iotdb/issues/3424#issuecomment-865998199


   复现过程2:
   1. bm在release 0.11.3上生成数据
   同上
   2. 0.11.3 cli修改时间序列,增加tag信息
   alter timeseries root.group_0.d_0.s_2 UPSERT ALIAS=alias_s2 TAGS(tag='hi') 
ATTRIBUTES(attr1='money')
   flush
   3.copy 0.11.3的data到rel 0.11.4
   java程序测试用例:
   import org.apache.iotdb.rpc.IoTDBConnectionException;
   import org.apache.iotdb.rpc.StatementExecutionException;
   import org.apache.iotdb.session.SessionDataSet.DataIterator;
   import org.apache.iotdb.session.pool.SessionDataSetWrapper;
   import org.apache.iotdb.session.pool.SessionPool;
   import org.apache.iotdb.tsfile.file.metadata.enums.TSDataType;
   import org.apache.iotdb.session.SessionDataSet;
   import org.apache.iotdb.session.Session;
   
   import java.util.ArrayList;
   import java.util.List;
   import java.util.concurrent.ExecutorService;
   import java.util.concurrent.Executors;
   
   public class SessionPoolExample {
   
     private static SessionPool pool;
     private static ExecutorService service;
     private static Session session;
   
     public static void main(String[] args)
         throws StatementExecutionException, IoTDBConnectionException, 
InterruptedException {
       pool = new SessionPool("127.0.0.1", 6667, "root", "root", 3);
       service = Executors.newFixedThreadPool(10);
   
       session = new Session("127.0.0.1", 6667, "root", "root");
       session.open(false);
       query();
       Thread.sleep(1000);
       pool.close();
       session.close();
       service.shutdown();
     }
   
      private static void query() throws IoTDBConnectionException, 
StatementExecutionException {
       SessionDataSet dataSet;
       String sql = "ALTER timeseries root.group_0.d_0.s_2 UPSERT 
ALIAS=alias_test 
TAGS(tag='test',dir='/data/test',exName='exTest',description='desTest',unit='unitTest')
 ATTRIBUTES(minValue=1,maxValue=1000)";
   
       pool.executeNonQueryStatement(sql);
       dataSet = session.executeQueryStatement("show timeseries where 
tag='test'");
       System.out.println(dataSet.getColumnNames());
       dataSet.setFetchSize(1024); // default is 10000
       while (dataSet.hasNext()) {
         System.out.println(dataSet.next());
       }
   
       dataSet.closeOperationHandle();
     }
   
   }
   编译,运行:
   javac -cp 
/data/lz/pr_test/rel_12/distribution/target/apache-iotdb-0.12.1-SNAPSHOT-server-bin/apache-iotdb-0.12.1-SNAPSHOT-server-bin/lib/*:.
 ./SessionPoolExample.java
   
   java -cp 
/data/lz/pr_test/rel_12/distribution/target/apache-iotdb-0.12.1-SNAPSHOT-server-bin/apache-iotdb-0.12.1-SNAPSHOT-server-bin/lib/*:.
 SessionPoolExample
   执行结果:
   
![image](https://user-images.githubusercontent.com/15992443/122935827-3ce98900-d3a3-11eb-90b9-7687717f19a0.png)
   
   **未复现。**
   


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
[email protected]


Reply via email to