This is an automated email from the ASF dual-hosted git repository.
qiaojialin pushed a change to branch new_sync
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
from 7005997 [To new_sync][IOTDB-2770] Extract configurable parameters to
iotdb-engine.properties (#5354)
add a6b81b2 [To new_sync][IOTDB-2731] Check before start or stop
pipeserver (#5264)
No new revisions were added by this update.
Summary of changes:
.../sync/IoTDBSyncReceiverCollectorIT.java | 2 +-
.../db/integration/sync/IoTDBSyncReceiverIT.java | 351 +++++++++++++++++++++
.../iotdb/db/integration/sync/SyncTestUtil.java | 7 -
integration/src/test/resources/logback.xml | 1 +
.../db/exception/{ => sync}/PipeException.java | 3 +-
.../PipeServerException.java} | 13 +-
.../db/exception/{ => sync}/PipeSinkException.java | 3 +-
.../pipedata/queue/PipeDataQueueFactory.java | 13 +-
.../iotdb/db/newsync/receiver/ReceiverService.java | 85 +++--
.../db/newsync/receiver/collector/Collector.java | 26 +-
.../db/newsync/receiver/manager/PipeMessage.java | 16 +-
.../db/newsync/receiver/manager/PipeStatus.java | 2 +-
.../newsync/receiver/manager/ReceiverManager.java | 12 +-
.../db/newsync/receiver/recovery/ReceiverLog.java | 70 ++--
.../db/newsync/sender/pipe/IoTDBPipeSink.java | 2 +-
.../apache/iotdb/db/newsync/sender/pipe/Pipe.java | 2 +-
.../iotdb/db/newsync/sender/pipe/PipeSink.java | 2 +-
.../iotdb/db/newsync/sender/pipe/TsFilePipe.java | 2 +-
.../newsync/sender/recovery/SenderLogAnalyzer.java | 2 +-
.../db/newsync/sender/service/SenderService.java | 4 +-
.../transport/server/TransportServerManager.java | 2 +
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 31 +-
.../apache/iotdb/db/utils/EnvironmentUtils.java | 4 +
.../receiver/manager/ReceiverManagerTest.java | 2 +-
.../receiver/recovery/ReceiverLogAnalyzerTest.java | 2 +-
server/src/test/resources/logback.xml | 1 +
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 1 +
27 files changed, 547 insertions(+), 114 deletions(-)
create mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/sync/IoTDBSyncReceiverIT.java
copy server/src/main/java/org/apache/iotdb/db/exception/{ =>
sync}/PipeException.java (92%)
rename server/src/main/java/org/apache/iotdb/db/exception/{PipeException.java
=> sync/PipeServerException.java} (73%)
rename server/src/main/java/org/apache/iotdb/db/exception/{ =>
sync}/PipeSinkException.java (93%)
