This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a change to branch TYQuery
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
from c281a85 fix test
add c50628b [IOTDB-1181] Upgrade jetty jar to fix CVE-2020-27216
add d622fe8 Add welcome info for who submit issues/PRs the first time.
(#2779)
add e9bd562 [IOTDB-1186] Remove redundant sync meta leader in query
process for cluster module
add 7c40ce7 Update IoTDBConstant.java remove unused field (#2777)
add 4c2a3b5 [IOTDB-1189] [Distributed]optimize thread pool client close
(#2782)
add ca02b36 Add max direct memory size parameter to env.sh
add 6694c5d Update the SeedUrl Format Exception Info when using cluster
mode (#2786)
add 6832eee [ISSUE-2661] SyncClientPool And AsyncClientPool have
concurrency problem (#2791)
add 74cd5fb [To Vector] Support vector write in tsfile (#2799)
add 9c72690 Add the missing apache header
add 20ecbc7 [IOTDB-1203] Create interface of IMeasurementSchema (#2810)
new ef1ea01 fix conflicts
The 1 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:
.github/workflows/greetings.yml | 13 ++
.../java/org/apache/iotdb/cluster/ClientMain.java | 5 +-
.../java/org/apache/iotdb/cluster/ClusterMain.java | 4 +-
.../iotdb/cluster/client/DataClientProvider.java | 4 +-
.../cluster/client/async/AsyncClientPool.java | 34 ++++--
.../cluster/client/sync/SyncClientAdaptor.java | 6 +-
.../iotdb/cluster/client/sync/SyncClientPool.java | 59 +++++----
.../iotdb/cluster/client/sync/SyncDataClient.java | 9 +-
.../iotdb/cluster/client/sync/SyncMetaClient.java | 10 +-
.../exception/BadSeedUrlFormatException.java | 3 +-
.../apache/iotdb/cluster/metadata/CMManager.java | 92 ++++++--------
.../apache/iotdb/cluster/metadata/MetaPuller.java | 29 ++---
.../cluster/query/ClusterDataQueryExecutor.java | 8 ++
.../iotdb/cluster/query/ClusterPlanExecutor.java | 37 ++----
.../iotdb/cluster/query/LocalQueryExecutor.java | 6 +-
.../cluster/query/aggregate/ClusterAggregator.java | 14 +--
.../cluster/query/fill/ClusterPreviousFill.java | 14 +--
.../query/groupby/RemoteGroupByExecutor.java | 27 ++--
.../query/last/ClusterLastQueryExecutor.java | 14 +--
.../cluster/query/reader/ClusterReaderFactory.java | 24 ++--
.../cluster/query/reader/ClusterTimeGenerator.java | 4 +-
.../iotdb/cluster/query/reader/DataSourceInfo.java | 12 +-
.../apache/iotdb/cluster/server/ClientServer.java | 11 +-
.../cluster/server/PullSnapshotHintService.java | 9 +-
.../caller/PullMeasurementSchemaHandler.java | 7 +-
.../cluster/server/service/BaseSyncService.java | 15 +--
.../cluster/server/service/DataSyncService.java | 7 +-
.../cluster/server/service/MetaSyncService.java | 5 +-
.../cluster/client/DataClientProviderTest.java | 136 +++++++++++++++++++++
.../cluster/client/sync/SyncClientAdaptorTest.java | 5 +-
.../cluster/client/sync/SyncClientPoolTest.java | 17 ++-
.../cluster/client/sync/SyncDataClientTest.java | 51 ++++++++
.../cluster/client/sync/SyncMetaClientTest.java | 47 +++++++
.../org/apache/iotdb/cluster/common/IoTDBTest.java | 4 +-
.../org/apache/iotdb/cluster/common/TestUtils.java | 9 +-
.../caller/PullMeasurementSchemaHandlerTest.java | 10 +-
.../cluster/server/member/DataGroupMemberTest.java | 3 +-
.../cluster/server/member/MetaGroupMemberTest.java | 10 +-
pom.xml | 2 +-
server/src/assembly/resources/conf/iotdb-env.bat | 5 +
server/src/assembly/resources/conf/iotdb-env.sh | 3 +
.../org/apache/iotdb/db/conf/IoTDBConstant.java | 1 -
.../iotdb/db/engine/flush/MemTableFlushTask.java | 8 +-
.../iotdb/db/engine/flush/NotifyFlushMemTable.java | 4 +-
.../iotdb/db/engine/memtable/AbstractMemTable.java | 8 +-
.../apache/iotdb/db/engine/memtable/IMemTable.java | 4 +-
.../db/engine/memtable/IWritableMemChunk.java | 4 +-
.../db/engine/memtable/PrimitiveMemTable.java | 4 +-
.../iotdb/db/engine/memtable/WritableMemChunk.java | 8 +-
.../db/engine/merge/manage/MergeResource.java | 12 +-
.../db/engine/merge/task/MergeMultiChunkTask.java | 6 +-
.../iotdb/db/engine/merge/task/MergeTask.java | 4 +-
.../engine/storagegroup/StorageGroupProcessor.java | 4 +-
.../apache/iotdb/db/metadata/MLogTxtWriter.java | 4 +-
.../org/apache/iotdb/db/metadata/MManager.java | 13 +-
.../java/org/apache/iotdb/db/metadata/MTree.java | 8 +-
.../apache/iotdb/db/metadata/MeasurementMeta.java | 14 +--
.../iotdb/db/metadata/mnode/MeasurementMNode.java | 11 +-
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 8 +-
.../db/qp/physical/sys/MeasurementMNodePlan.java | 9 +-
.../db/tools/upgrade/TsFileOnlineUpgradeTool.java | 29 ++---
.../org/apache/iotdb/db/utils/SchemaUtils.java | 3 +-
.../query/reader/series/SeriesReaderTestUtil.java | 3 +-
.../db/writelog/recover/SeqTsFileRecoverTest.java | 3 +-
.../java/org/apache/iotdb/session/Session.java | 6 +-
.../iotdb/spark/tsfile/NarrowConverter.scala | 4 +-
.../apache/iotdb/spark/tsfile/WideConverter.scala | 5 +-
.../iotdb/tsfile/read/TsFileSequenceReader.java | 13 +-
.../apache/iotdb/tsfile/write/TsFileWriter.java | 13 +-
.../tsfile/write/chunk/ChunkGroupWriterImpl.java | 3 +-
.../iotdb/tsfile/write/chunk/ChunkWriterImpl.java | 8 +-
.../tsfile/write/chunk/IChunkGroupWriter.java | 4 +-
.../apache/iotdb/tsfile/write/page/PageWriter.java | 7 +-
.../tsfile/write/schema/IMeasurementSchema.java | 15 +++
.../tsfile/write/schema/MeasurementSchema.java | 38 +++++-
.../apache/iotdb/tsfile/write/schema/Schema.java | 25 ++--
.../write/writer/RestorableTsFileIOWriter.java | 8 +-
.../org/apache/iotdb/tsfile/utils/RecordUtils.java | 4 +-
.../tsfile/write/DefaultDeviceTemplateTest.java | 3 +-
.../write/schema/converter/SchemaBuilderTest.java | 17 +--
.../write/writer/VectorChunkWriterImplTest.java | 8 ++
.../write/writer/VectorMeasurementSchemaStub.java | 29 +++++
82 files changed, 749 insertions(+), 417 deletions(-)
create mode 100644 .github/workflows/greetings.yml
