This is an automated email from the ASF dual-hosted git repository.
Caideyipi pushed a change to branch empty-file
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 85a9b39183f fix
add 44398ab4458 Pipe: Fixed the event clear logic of drop pipe (#17560)
add 8c3d2b6d4fd Pipe: Removed the failed partial insert from auth check &
Implemented skipReportOnCommit for PipeRealtimeEvent to avoid premature report
for unordered flush (#17561)
add 26583b8d0ab Fix/session c exception report (#17571)
add 70ba5fc4508 Fixed the print-tsfile.sh to avoid wrong IOTDB_HOME
(#17596)
add cee5fbb958f Pipe: Fixed the bug that the split historical pipe's
enable-send-tsfile-limit cannot be configured (#17598)
add b57a0fdd425 Fixed the bug that create attribute does not consider
nameList size > valueList size (#17593)
add 0008782ae79 Pipe: Fixed the first-chunk calculation bug for scan
parser (#17597)
add d1a234fc51e Load: Fixed multiple bugs (#17565)
add cbce31eb1f1 Merge branch 'master' of https://github.com/apache/iotdb
into empty-file
No new revisions were added by this update.
Summary of changes:
.../treemodel/auto/basic/IoTDBPipeAutoSplitIT.java | 14 +-
iotdb-client/client-cpp/src/main/Common.cpp | 25 ++++
iotdb-client/client-cpp/src/main/Common.h | 3 +
iotdb-client/client-cpp/src/main/Session.cpp | 16 +--
iotdb-client/client-cpp/src/main/Session.h | 8 +-
.../client-cpp/src/main/SessionConnection.h | 18 +--
.../src/test/cpp/sessionRelationalIT.cpp | 23 +++-
.../agent/task/connection/PipeEventCollector.java | 18 ++-
.../sink/PipeRealtimePriorityBlockingQueue.java | 13 +-
.../agent/task/subtask/sink/PipeSinkSubtask.java | 13 +-
.../subtask/sink/PipeSinkSubtaskLifeCycle.java | 5 +-
.../task/subtask/sink/PipeSinkSubtaskManager.java | 2 +-
.../tablet/PipeInsertNodeTabletInsertionEvent.java | 4 +
.../scan/TsFileInsertionEventScanParser.java | 21 ++-
.../db/pipe/event/realtime/PipeRealtimeEvent.java | 10 ++
.../evolvable/batch/PipeTabletEventBatch.java | 7 +-
.../batch/PipeTransferBatchReqBuilder.java | 9 +-
.../thrift/async/IoTDBDataRegionAsyncSink.java | 50 ++++++--
.../thrift/sync/IoTDBDataRegionSyncSink.java | 5 +-
.../websocket/WebSocketConnectorServer.java | 141 +++++++++++++++++----
.../sink/protocol/websocket/WebSocketSink.java | 11 +-
.../config/executor/ClusterConfigTaskExecutor.java | 22 ++--
.../plan/statement/crud/LoadTsFileStatement.java | 1 +
.../attribute/DeviceAttributeStore.java | 3 +
.../db/storageengine/load/LoadTsFileManager.java | 54 +++++---
.../load/memory/LoadTsFileMemoryManager.java | 13 +-
.../subtask/SubscriptionSinkSubtaskLifeCycle.java | 3 +-
.../subtask/SubscriptionSinkSubtaskManager.java | 2 +-
.../task/connection/PipeEventCollectorTest.java | 97 ++++++++++++++
.../sink/PipeSinkSubtaskTest.java} | 39 ++++--
.../iotdb/db/pipe/event/PipeRealtimeEventTest.java | 101 +++++++++++++++
.../pipe/event/PipeTabletInsertionEventTest.java | 58 +++++++++
.../pipe/event/TsFileInsertionEventParserTest.java | 49 +++++++
.../apache/iotdb/db/pipe/sink/PipeSinkTest.java | 105 +++++++++++++++
.../statement/crud/LoadTsFileStatementTest.java | 79 ++++++++++++
.../attribute/DeviceAttributeStoreTest.java | 68 ++++++++++
.../load/memory/LoadTsFileMemoryManagerTest.java | 106 ++++++++++++++++
.../task/connection/BlockingPendingQueue.java | 55 +++++++-
.../datastructure/Triple.java} | 44 +++----
.../commons/pipe/sink/protocol/IoTDBSink.java | 5 +-
.../protocol/PipeConnectorWithEventDiscard.java | 6 +-
scripts/tools/tsfile/print-tsfile.sh | 6 +-
42 files changed, 1160 insertions(+), 172 deletions(-)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/agent/task/connection/PipeEventCollectorTest.java
copy
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/agent/task/{PipeSinkSubtaskExecutorTest.java
=> subtask/sink/PipeSinkSubtaskTest.java} (52%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/event/PipeRealtimeEventTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/statement/crud/LoadTsFileStatementTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/schemaengine/schemaregion/attribute/DeviceAttributeStoreTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/load/memory/LoadTsFileMemoryManagerTest.java
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/{queryengine/plan/relational/type/RowFieldName.java
=> pipe/datastructure/Triple.java} (60%)
copy
iotdb-client/subscription/src/main/java/org/apache/iotdb/session/subscription/payload/SubscriptionMessageHandler.java
=>
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/sink/protocol/PipeConnectorWithEventDiscard.java
(81%)
