This is an automated email from the ASF dual-hosted git repository.
haonan pushed a change to branch rc/1.3.1
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 71f060fae39 Fix compaction schedule task manager cannot stop and
modify some output in log (#12125)
new 86f946a283b Storage Engine: put DeviceCache into the total memory of
the storage engine (#12016)
new 4f80becac86 DataNodeDevicePathCache should use free memory of memtable
(#12034)
new 6c185be5b3a [IOTDB-6302] Enhance the support of ISO_LOCAL_DATE_TIME
timestamp format (#12086)
new af1b661f18d Fix fail to read memTable ids from the wal file (#12132)
new 71c28576874 [IOTDB-6305] Add show current_timestamp statement (#12106)
new 6252a973c49 [IOTDB-6300] Support place time column at any column index
in insert statement
new fdc14c9dce1 [IOTDB-6306] Fix the issue that UDTF with boolean type is
not supported in filter (#12105)
new 3a6dcc64be7 fix.root privileges lost and grant role
new 6def1830b67 fix StorageEngine recover slowly (#12151)
new 864740a4b73 [IOTDB-6310] Optimize for query resource init
new 3fbbd374102 fix error log caused by ClosedByInterruptException in
compaction module
new 44ba2df40f2 feat(jdbc):getDouble add type check
new 6e67840d976 fix: IoTDBPreparedStatement implement addBatch function
(#12095)
new 6b3a4e371e7 fix(jdbc): when catalog is "Apache IoTDB", ignore it
(#12166)
new 8866b04e090 Print native request api in datanode_slow_sql.log
new 8043509b6ac Fix compaction schedule task manager cannot stop and
modify some output in log (#12125)
new 9e17d079089 Random schedule compaction of bound data regions in one
compaction schedule worker (#12167)
new fbc62d386cf Fix flush command failed when dataregion using ratis
consensus (#12194)
new ad87f69f595 Pipe: Fixed potential lose point bug when an unclosed
tsfile reaches `isEventTimeOverlappedWithTimeRange()` judgement (CI fails on
testInsertNullValueTemplate) (#12156)
The 19 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:
...T.java => IOTDBInsertWithTimeAtAnyIndexIT.java} | 77 ++++++--------
.../java/org/apache/iotdb/db/it/IoTDBFilterIT.java | 34 ++++++
.../iotdb/db/it/IoTDBInsertWithoutTimeIT.java | 8 +-
...thIT.java => IoTDBSimpleQueryStandaloneIT.java} | 35 +++---
.../it/IoTDBSyntaxConventionStringLiteralIT.java | 8 +-
.../aggregation/IoTDBCountTimeAlignedDeviceIT.java | 2 +-
.../org/apache/iotdb/db/it/auth/IoTDBAuthIT.java | 2 +
.../org/apache/iotdb/db/it/cq/IoTDBCQExecIT.java | 10 +-
.../apache/iotdb/db/it/cq/IoTDBCQExecInNsIT.java | 10 +-
.../apache/iotdb/db/it/cq/IoTDBCQExecInUsIT.java | 10 +-
iotdb-client/jdbc/pom.xml | 4 +
.../org/apache/iotdb/jdbc/IoTDBConnection.java | 4 +-
.../apache/iotdb/jdbc/IoTDBDatabaseMetadata.java | 40 ++++---
.../org/apache/iotdb/jdbc/IoTDBJDBCResultSet.java | 9 ++
.../apache/iotdb/jdbc/IoTDBPreparedStatement.java | 4 +-
.../org/apache/iotdb/db/qp/sql/IdentifierParser.g4 | 1 +
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 28 +++--
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 4 +
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 23 ++--
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 118 +++++++++++----------
.../apache/iotdb/db/pipe/event/EnrichedEvent.java | 7 +-
.../event/common/heartbeat/PipeHeartbeatEvent.java | 2 +-
.../tablet/PipeInsertNodeTabletInsertionEvent.java | 2 +-
.../common/tablet/PipeRawTabletInsertionEvent.java | 2 +-
.../common/tsfile/PipeTsFileInsertionEvent.java | 8 +-
.../db/pipe/event/realtime/PipeRealtimeEvent.java | 4 +-
.../realtime/PipeRealtimeDataRegionExtractor.java | 2 +-
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 27 +++--
.../common/header/ColumnHeaderConstant.java | 6 ++
.../common/header/DatasetHeaderFactory.java | 4 +
.../iotdb/db/queryengine/plan/Coordinator.java | 10 +-
.../queryengine/plan/analyze/AnalyzeVisitor.java | 11 ++
.../queryengine/plan/analyze/PredicateUtils.java | 2 +
.../cache/schema/DataNodeDevicePathCache.java | 20 +++-
.../analyze/schema/ClusterSchemaFetchExecutor.java | 2 +-
.../memory/StatementMemorySourceVisitor.java | 16 +++
.../db/queryengine/plan/parser/ASTVisitor.java | 110 +++++++++++--------
.../planner/plan/node/write/DeleteDataNode.java | 5 +-
.../planner/plan/node/write/InsertRowNode.java | 5 +-
.../planner/plan/node/write/InsertTabletNode.java | 4 +-
.../plan/statement/StatementVisitor.java | 6 ++
...ent.java => ShowCurrentTimestampStatement.java} | 9 +-
.../apache/iotdb/db/service/IoTDBShutdownHook.java | 2 +-
.../iotdb/db/storageengine/StorageEngine.java | 2 +-
.../db/storageengine/dataregion/DataRegion.java | 6 +-
.../execute/task/InnerSpaceCompactionTask.java | 6 +-
.../compaction/io/CompactionTsFileInput.java | 104 ++++++++++++++++++
.../compaction/io/CompactionTsFileReader.java | 1 +
.../compaction/repair/RepairDataFileScanUtil.java | 8 +-
.../schedule/CompactionScheduleTaskWorker.java | 13 ++-
.../compaction/schedule/CompactionScheduler.java | 6 +-
.../estimator/AbstractCompactionEstimator.java | 5 +-
.../estimator/AbstractCrossSpaceEstimator.java | 8 ++
.../estimator/AbstractInnerSpaceEstimator.java | 13 +++
.../impl/RewriteCrossSpaceCompactionSelector.java | 6 +-
.../dataregion/modification/Deletion.java | 6 +-
.../dataregion/tsfile/TsFileManager.java | 10 +-
.../tsfile/timeindex/DeviceTimeIndex.java | 14 ++-
.../storageengine/dataregion/wal/WALManager.java | 20 +++-
.../dataregion/wal/buffer/WALBuffer.java | 8 +-
.../org/apache/iotdb/db/utils/CommonUtils.java | 78 ++++++++++++++
.../org/apache/iotdb/db/utils/DateTimeUtils.java | 11 +-
.../org/apache/iotdb/db/auth/entity/RoleTest.java | 31 ++++--
.../pipe/event/PipeTabletInsertionEventTest.java | 14 +--
.../db/storageengine/DevicePathCacheTests.java | 67 ++++++++++++
.../apache/iotdb/db/utils/DateTimeUtilsTest.java | 41 +++++++
.../resources/conf/iotdb-common.properties | 11 +-
.../commons/auth/authorizer/BasicAuthorizer.java | 10 ++
.../org/apache/iotdb/commons/auth/entity/Role.java | 14 ++-
.../iotdb/commons/auth/user/BasicUserManager.java | 15 ++-
.../iotdb/commons/utils/TimePartitionUtils.java | 7 +-
.../StopReadTsFileByInterruptException.java} | 7 +-
.../iotdb/tsfile/read/TsFileSequenceReader.java | 37 +++++++
.../iotdb/tsfile/read/reader/LocalTsFileInput.java | 6 +-
74 files changed, 953 insertions(+), 329 deletions(-)
copy
integration-test/src/test/java/org/apache/iotdb/db/it/{last/IoTDBLastWithTTLIT.java
=> IOTDBInsertWithTimeAtAnyIndexIT.java} (58%)
copy
integration-test/src/test/java/org/apache/iotdb/db/it/{strangepath/IoTDBStrangePathIT.java
=> IoTDBSimpleQueryStandaloneIT.java} (68%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/{CountDevicesStatement.java
=> ShowCurrentTimestampStatement.java} (80%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/io/CompactionTsFileInput.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/DevicePathCacheTests.java
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/api/YieldableReader.java
=>
tsfile/src/main/java/org/apache/iotdb/tsfile/exception/StopReadTsFileByInterruptException.java}
(85%)
