You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ji...@apache.org on 2023/05/16 03:40:00 UTC
[iotdb] branch native_raft updated (2b64d3c0c3 -> 59bbc2cf1c)
This is an automated email from the ASF dual-hosted git repository.
jiangtian pushed a change to branch native_raft
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 2b64d3c0c3 Merge branch 'handle_redirection_during_dispatching' into native_raft
add 268fae19a0 use preferred location to redirect
new 59bbc2cf1c Merge branch 'handle_redirection_during_dispatching' into native_raft
The 1 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:
.../planner/plan/node/write/InsertTabletNode.java | 82 ++++++++++++++++------
1 file changed, 59 insertions(+), 23 deletions(-)
[iotdb] 01/01: Merge branch 'handle_redirection_during_dispatching' into native_raft
Posted by ji...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
jiangtian pushed a commit to branch native_raft
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 59bbc2cf1cd5000d89870b35e9eb0fb692bc8718
Merge: 2b64d3c0c3 268fae19a0
Author: Tian Jiang <jt...@163.com>
AuthorDate: Tue May 16 11:42:39 2023 +0800
Merge branch 'handle_redirection_during_dispatching' into native_raft
.../planner/plan/node/write/InsertTabletNode.java | 82 ++++++++++++++++------
1 file changed, 59 insertions(+), 23 deletions(-)
diff --cc server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/write/InsertTabletNode.java
index 546628e7e6,8348dbac45..af8909113b
--- a/server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/write/InsertTabletNode.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/write/InsertTabletNode.java
@@@ -466,10 -469,12 +469,12 @@@ public class InsertTabletNode extends I
}
}
- /** Serialize measurements or measurement schemas, ignoring failed time series */
+ /**
+ * Serialize measurements or measurement schemas, ignoring failed time series
+ */
private void writeMeasurementsOrSchemas(DataOutputStream stream) throws IOException {
- ReadWriteIOUtils.write(measurements.length - getFailedMeasurementNumber(), stream);
- ReadWriteIOUtils.write((byte) (measurementSchemas != null ? 1 : 0), stream);
+ stream.writeInt(measurements.length - getFailedMeasurementNumber());
+ stream.write((byte) (measurementSchemas != null ? 1 : 0));
for (int i = 0; i < measurements.length; i++) {
// ignore failed partial insert