This is an automated email from the ASF dual-hosted git repository.
JackieTien97 pushed a change to branch ty/fixOpt
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from c2193aa934f Fix repeated RPC dispatch reusing a released
FragmentInstanceContext (NPE)
add 93438bf34ba fix: supply the key word in antlr module (#17789)
add 33c3ef7196b Pipe: Harden legacy pipe file transfer validation and
access checks (#17741)
add b616502aec0 Pipe Log: Added the remaining chinese logs & Further
reduced the repeatable logs (#17700)
add a2368b2955f Fix C++ client reading FLOAT inference columns declared as
DOUBLE (#17759)
add b4486807c6d Merge remote-tracking branch 'origin/master' into ty/fixOpt
add 33c94363250 fix review
No new revisions were added by this update.
Summary of changes:
.../single/IoTDBLegacyPipeReceiverSecurityIT.java | 112 +++++++++++++++++++
iotdb-client/client-cpp/src/main/Column.cpp | 20 ++++
iotdb-client/client-cpp/src/main/Column.h | 5 +
iotdb-client/client-cpp/src/test/cpp/sessionIT.cpp | 20 ++++
.../org/apache/iotdb/db/qp/sql/IdentifierParser.g4 | 1 +
.../iotdb/confignode/i18n/ManagerMessages.java | 14 +--
.../apache/iotdb/db/i18n/DataNodePipeMessages.java | 19 ++++
.../apache/iotdb/db/i18n/DataNodePipeMessages.java | 73 +++++++-----
.../pipe/agent/plugin/PipeDataNodePluginAgent.java | 22 ++--
.../common/tsfile/PipeTsFileInsertionEvent.java | 10 +-
.../legacy/IoTDBLegacyPipeReceiverAgent.java | 40 ++++++-
.../client/IoTDBDataNodeAsyncClientManager.java | 28 +++--
.../iotconsensusv2/IoTConsensusV2AsyncSink.java | 103 ++++++++++++-----
.../handler/IoTConsensusV2DeleteEventHandler.java | 16 ++-
.../IoTConsensusV2TabletBatchEventHandler.java | 20 +++-
.../IoTConsensusV2TabletInsertionEventHandler.java | 17 ++-
.../IoTConsensusV2TsFileInsertionEventHandler.java | 18 ++-
.../sink/protocol/legacy/IoTDBLegacyPipeSink.java | 29 ++++-
.../thrift/async/IoTDBDataRegionAsyncSink.java | 33 ++++--
.../handler/PipeTransferTrackableHandler.java | 21 ++--
.../async/handler/PipeTransferTsFileHandler.java | 23 +++-
.../PipeRealtimeDataRegionHybridSource.java | 4 +-
.../realtime/PipeRealtimeDataRegionLogSource.java | 5 +-
.../realtime/PipeRealtimeDataRegionSource.java | 8 +-
.../PipeRealtimeDataRegionTsFileSource.java | 5 +-
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 53 +++++++--
.../fragment/FragmentInstanceManager.java | 66 +++++------
.../legacy/IoTDBLegacyPipeReceiverAgentTest.java | 122 +++++++++++++++++++++
.../apache/iotdb/commons/i18n/PipeMessages.java | 14 +++
.../apache/iotdb/commons/i18n/PipeMessages.java | 14 +++
.../pipe/datastructure/pattern/TreePattern.java | 36 +++---
31 files changed, 770 insertions(+), 201 deletions(-)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/pipe/it/single/IoTDBLegacyPipeReceiverSecurityIT.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/receiver/protocol/legacy/IoTDBLegacyPipeReceiverAgentTest.java
