This is an automated email from the ASF dual-hosted git repository.
CRZbulabula pushed a change to branch upgrade-heartbeat-service
in repository https://gitbox.apache.org/repos/asf/iotdb.git
discard bfbda1a1e68 Refine topology probing, push, and ClusterTopology
omit b0e2df75ae8 better impl 4 topology service
omit 3e5f0d733fc update
omit 2ddad6d48eb ready 4 review
add 8b293bc8a1f Pipe: Fixed the bug that the pipe will restart a pipe
stopped by user but encountered sync failure later (#17586)
add 2fbbd5ea015 Pipe: Fixed the potential leak file handle at the receiver
(#17589)
add bbc3c703237 Pipe: Fixed the bug that the timeout ms is regarded as s
(#17590)
add 6042c4f909f Fix the issue where `list user` throws an error when
executed concurrently with `create user`. (#17583)
add b1f01d5d6f9 ready 4 review
add af504f9cfa8 update
add e992d04a204 better impl 4 topology service
add 10c29118aa9 Refine topology probing, push, and ClusterTopology
add 431e2b37f27 Drop PipeDataNodeTaskAgent change — already fixed in
master (#17590)
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (bfbda1a1e68)
\
N -- N -- N refs/heads/upgrade-heartbeat-service (431e2b37f27)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.../confignode/persistence/pipe/PipeTaskInfo.java | 8 ++
.../pipe/PipeTaskInfoAutoRestartTest.java | 128 +++++++++++++++++++++
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 4 +-
.../db/auth/user/LocalFileUserManagerTest.java | 49 ++++++++
.../iotdb/commons/auth/role/BasicRoleManager.java | 6 +-
.../commons/pipe/agent/task/PipeTaskAgent.java | 16 ++-
.../commons/pipe/receiver/IoTDBFileReceiver.java | 26 ++++-
.../pipe/receiver/IoTDBFileReceiverTest.java | 124 +++++++++++++++++++-
8 files changed, 350 insertions(+), 11 deletions(-)
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/persistence/pipe/PipeTaskInfoAutoRestartTest.java
