This is an automated email from the ASF dual-hosted git repository.
lta pushed a change to branch cluster_lta
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git.
from 9a513f3 fix a bug of MManager to get all file names of a path
new c362bfe update
new 08b5793 fix a name bug
new 26fc982 Merge branch 'cluster' of github.com:apache/incubator-iotdb
into cluster
new f2e5900 add metadata cluster test
new 0e7ad31 fix a bug of MManager to get all file names of a path (#137)
new 743a0bf Merge branch 'cluster' of github.com:apache/incubator-iotdb
into cluster
new 0c09b8a add tests
new 414fe8d fix conflicts
new f18df43 add header
new a28d5bb Merge branch 'cluster' of github.com:apache/incubator-iotdb
into cluster
new cb40df1 fix a bug of execute batch
new a3391f4 fix a bug of execute batch
new f92bd3c fix serve cluster create ts function
new 3591574 add config for raft election timeout
new bd191b7 add new test case
new f07dc37 add show timeseries in json query case
new d02e9ef fix conflicts
new cd5f160 fix a bug
new 8b4fd87 fix bug of manager metadata
new 2742e0a fix bug of manager metadata
new 078ed72 fix a bug of set read consistency level
new b5d3fa3 rehandle excepetion during sending task vai client
new 334282c add config for raft election timeout
new b882b3f Merge branch 'cluster' of github.com:apache/incubator-iotdb
into cluster
new 686209f add some comment
new 1f9d97f add metadata test
new 36d8cda fix it bug
new d379b7e Merge remote-tracking branch 'origin/cluster' into cluster
new 9bb899f merge
new 598e9c0 add test show timeseries in json
new 5c8ae5b Merge branch 'cluster' of github.com:apache/incubator-iotdb
into cluster
new dea17d6 fix metadata bug
new 0e39049 reconstruct package
new 48c8eb7 add deploy script
new 08380eb Merge branch 'cluster' of github.com:apache/incubator-iotdb
into cluster
new e456ed5 remove useless codes
new 57b8069 Merge branch 'cluster' of github.com:apache/incubator-iotdb
into cluster
new 96c87a0 remove system.exit() on Test for better checking the problem
when running test
new d3fda08 Merge pull request #134 from apache/remove_system_exit
new f949dd9 replace renameTo() with FileUtils.moveFile()
new 6aacb62 Merge pull request #136 from apache/fix_rename_in_version
new f1d3f44 Fix a bug of reading data with value filter (#135)
new f190a95 merge master
new cc70b51 mvn -B (#141)
new c161120 bug fix: version files of different storage groups are placed
into the same place (#138)
new 9bbb2d5 Merge branch 'master' into cluster
new f5d77cb add EnvironmentUtils for cluster test
new 8562d67 remove EnvironmentUtils in RouterTest
new dd1c302 Merge branch 'cluster' of github.com:apache/incubator-iotdb
into cluster
new fe0ee65 add sync client thread pool
new 00ad433 add concurrent pool
The 1729 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.travis.yml | 10 +-
cluster/pom.xml | 6 +
cluster/script/deploy.sh | 80 ++++
.../bin/stop-cluster.sh => cluster/script/stop.sh | 24 +-
.../iotdb/cluster/concurrent/ThreadName.java | 16 +-
.../cluster/concurrent/pool/QPTaskManager.java | 72 ++--
.../cluster/concurrent/pool/RaftTaskManager.java | 78 ++--
.../apache/iotdb/cluster/config/ClusterConfig.java | 66 +++-
.../iotdb/cluster/config/ClusterConstant.java | 4 +-
.../iotdb/cluster/config/ClusterDescriptor.java | 20 +-
.../org/apache/iotdb/cluster/entity/Server.java | 34 +-
.../cluster/entity/raft/DataStateMachine.java | 144 +++----
.../cluster/entity/raft/MetadataStateManchine.java | 6 +-
.../iotdb/cluster/entity/raft/RaftService.java | 1 +
.../apache/iotdb/cluster/qp/ClusterQPExecutor.java | 42 +-
.../cluster/{ => qp}/callback/BatchQPTask.java | 93 +++--
.../cluster/{ => qp}/callback/MultiQPTask.java | 16 +-
.../iotdb/cluster/{ => qp}/callback/QPTask.java | 8 +-
.../cluster/{ => qp}/callback/SingleQPTask.java | 24 +-
.../cluster/qp/executor/NonQueryExecutor.java | 84 ++--
.../cluster/qp/executor/QueryMetadataExecutor.java | 117 +++---
.../iotdb/cluster/rpc/{ => raft}/NodeAsClient.java | 6 +-
.../rpc/{ => raft}/closure/ResponseClosure.java | 4 +-
.../{ => raft}/impl/RaftNodeAsClientManager.java | 25 +-
.../processor/BasicAsyncUserProcessor.java | 4 +-
.../processor/BasicSyncUserProcessor.java | 4 +-
.../processor/DataGroupNonQueryAsyncProcessor.java | 12 +-
.../processor/MetaGroupNonQueryAsyncProcessor.java | 12 +-
.../QueryMetadataInStringAsyncProcessor.java | 17 +-
.../processor/QueryTimeSeriesAsyncProcessor.java | 21 +-
.../rpc/{ => raft}/request/BasicQueryRequest.java | 2 +-
.../rpc/{ => raft}/request/BasicRequest.java | 2 +-
.../request/DataGroupNonQueryRequest.java | 2 +-
.../request/MetaGroupNonQueryRequest.java | 2 +-
.../request/QueryMetadataInStringRequest.java | 2 +-
.../request/QueryStorageGroupRequest.java | 2 +-
.../{ => raft}/request/QueryTimeSeriesRequest.java | 2 +-
.../rpc/{ => raft}/response/BasicResponse.java | 2 +-
.../response/DataGroupNonQueryResponse.java | 8 +-
.../response/MetaGroupNonQueryResponse.java | 6 +-
.../response/QueryMetadataInStringResponse.java | 6 +-
.../response/QueryStorageGroupResponse.java | 6 +-
.../response/QueryTimeSeriesResponse.java | 9 +-
.../cluster/rpc/service/TSServiceClusterImpl.java | 29 +-
.../org/apache/iotdb/cluster/utils/RaftUtils.java | 66 +++-
.../cluster/concurrent/pool/QPTaskManagerTest.java | 112 ++++++
.../cluster/config/ClusterDescriptorTest.java | 13 +-
.../integration/IoTDBMetadataFetchAbstract.java | 435 +++++++++++++++++++++
.../IoTDBMetadataFetchLocallyIT.java} | 55 ++-
.../integration/IoTDBMetadataFetchRemoteIT.java | 117 ++++++
.../iotdb/cluster/qp/ClusterQPExecutorTest.java | 19 +-
.../cluster/utils/ClusterConfigureGenerator.java | 92 +++++
.../iotdb/cluster/utils/EnvironmentUtils.java | 35 +-
.../java/org/apache/iotdb/cluster/utils/Utils.java | 27 +-
.../iotdb/cluster/utils/hash/RouterTest.java | 3 -
iotdb/iotdb/conf/iotdb-cluster.properties | 21 +-
.../db/concurrent/IoTDBThreadPoolFactory.java | 8 +-
.../org/apache/iotdb/db/concurrent/ThreadName.java | 2 +-
.../org/apache/iotdb/db/conf/IoTDBConstant.java | 2 +
.../db/engine/filenode/FileNodeProcessor.java | 20 +-
.../version/SimpleFileVersionController.java | 31 +-
.../qp/strategy/optimizer/ConcatPathOptimizer.java | 4 +-
.../dataset/EngineDataSetWithTimeGenerator.java | 50 ++-
.../org/apache/iotdb/db/service/JDBCService.java | 2 +-
.../org/apache/iotdb/db/service/TSServiceImpl.java | 19 +-
.../iotdb/db/sync/receiver/SyncServerManager.java | 5 +-
.../db/concurrent/IoTDBThreadPoolFactoryTest.java | 2 +-
.../version/SimpleFileVersionControllerTest.java | 15 +-
.../iotdb/db/integration/IoTDBLimitSlimitIT.java | 4 +-
.../iotdb/db/integration/IoTDBVersionIT.java | 84 ++++
.../EngineDataSetWithTimeGeneratorTest.java | 123 ++++++
.../apache/iotdb/db/utils/EnvironmentUtils.java | 3 +-
72 files changed, 1873 insertions(+), 626 deletions(-)
create mode 100755 cluster/script/deploy.sh
copy iotdb/iotdb/bin/stop-cluster.sh => cluster/script/stop.sh (63%)
copy
tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/factory/FilterType.java
=> cluster/src/main/java/org/apache/iotdb/cluster/concurrent/ThreadName.java
(80%)
copy iotdb/src/main/java/org/apache/iotdb/db/engine/pool/MergeManager.java =>
cluster/src/main/java/org/apache/iotdb/cluster/concurrent/pool/QPTaskManager.java
(53%)
copy iotdb/src/main/java/org/apache/iotdb/db/engine/pool/MergeManager.java =>
cluster/src/main/java/org/apache/iotdb/cluster/concurrent/pool/RaftTaskManager.java
(51%)
rename cluster/src/main/java/org/apache/iotdb/cluster/{ =>
qp}/callback/BatchQPTask.java (71%)
rename cluster/src/main/java/org/apache/iotdb/cluster/{ =>
qp}/callback/MultiQPTask.java (73%)
rename cluster/src/main/java/org/apache/iotdb/cluster/{ =>
qp}/callback/QPTask.java (93%)
rename cluster/src/main/java/org/apache/iotdb/cluster/{ =>
qp}/callback/SingleQPTask.java (69%)
rename cluster/src/main/java/org/apache/iotdb/cluster/rpc/{ =>
raft}/NodeAsClient.java (91%)
rename cluster/src/main/java/org/apache/iotdb/cluster/rpc/{ =>
raft}/closure/ResponseClosure.java (92%)
rename cluster/src/main/java/org/apache/iotdb/cluster/rpc/{ =>
raft}/impl/RaftNodeAsClientManager.java (92%)
rename cluster/src/main/java/org/apache/iotdb/cluster/rpc/{ =>
raft}/processor/BasicAsyncUserProcessor.java (89%)
rename cluster/src/main/java/org/apache/iotdb/cluster/rpc/{ =>
raft}/processor/BasicSyncUserProcessor.java (89%)
rename cluster/src/main/java/org/apache/iotdb/cluster/rpc/{ =>
raft}/processor/DataGroupNonQueryAsyncProcessor.java (88%)
rename cluster/src/main/java/org/apache/iotdb/cluster/rpc/{ =>
raft}/processor/MetaGroupNonQueryAsyncProcessor.java (87%)
rename cluster/src/main/java/org/apache/iotdb/cluster/rpc/{ =>
raft}/processor/QueryMetadataInStringAsyncProcessor.java (83%)
rename cluster/src/main/java/org/apache/iotdb/cluster/rpc/{ =>
raft}/processor/QueryTimeSeriesAsyncProcessor.java (84%)
rename cluster/src/main/java/org/apache/iotdb/cluster/rpc/{ =>
raft}/request/BasicQueryRequest.java (96%)
rename cluster/src/main/java/org/apache/iotdb/cluster/rpc/{ =>
raft}/request/BasicRequest.java (97%)
rename cluster/src/main/java/org/apache/iotdb/cluster/rpc/{ =>
raft}/request/DataGroupNonQueryRequest.java (96%)
rename cluster/src/main/java/org/apache/iotdb/cluster/rpc/{ =>
raft}/request/MetaGroupNonQueryRequest.java (96%)
rename cluster/src/main/java/org/apache/iotdb/cluster/rpc/{ =>
raft}/request/QueryMetadataInStringRequest.java (95%)
rename cluster/src/main/java/org/apache/iotdb/cluster/rpc/{ =>
raft}/request/QueryStorageGroupRequest.java (95%)
rename cluster/src/main/java/org/apache/iotdb/cluster/rpc/{ =>
raft}/request/QueryTimeSeriesRequest.java (95%)
rename cluster/src/main/java/org/apache/iotdb/cluster/rpc/{ =>
raft}/response/BasicResponse.java (97%)
rename cluster/src/main/java/org/apache/iotdb/cluster/rpc/{ =>
raft}/response/DataGroupNonQueryResponse.java (83%)
rename cluster/src/main/java/org/apache/iotdb/cluster/rpc/{ =>
raft}/response/MetaGroupNonQueryResponse.java (85%)
rename cluster/src/main/java/org/apache/iotdb/cluster/rpc/{ =>
raft}/response/QueryMetadataInStringResponse.java (87%)
rename cluster/src/main/java/org/apache/iotdb/cluster/rpc/{ =>
raft}/response/QueryStorageGroupResponse.java (89%)
rename cluster/src/main/java/org/apache/iotdb/cluster/rpc/{ =>
raft}/response/QueryTimeSeriesResponse.java (85%)
create mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/concurrent/pool/QPTaskManagerTest.java
create mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/integration/IoTDBMetadataFetchAbstract.java
copy
cluster/src/test/java/org/apache/iotdb/cluster/{utils/hash/MD5HashTest.java =>
integration/IoTDBMetadataFetchLocallyIT.java} (50%)
create mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/integration/IoTDBMetadataFetchRemoteIT.java
create mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/utils/ClusterConfigureGenerator.java
copy tsfile/src/main/java/org/apache/iotdb/tsfile/file/MetaMarker.java =>
cluster/src/test/java/org/apache/iotdb/cluster/utils/Utils.java (65%)
create mode 100644
iotdb/src/test/java/org/apache/iotdb/db/integration/IoTDBVersionIT.java
create mode 100644
iotdb/src/test/java/org/apache/iotdb/db/query/dataset/EngineDataSetWithTimeGeneratorTest.java
