This is an automated email from the ASF dual-hosted git repository.
rong pushed a commit to branch make-sure-no-frame-size-problem
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to
refs/heads/make-sure-no-frame-size-problem by this push:
new a7af9cb5bbf Update IoTDBDataNodeReceiver.java
a7af9cb5bbf is described below
commit a7af9cb5bbf59a442fa2ff69ac19029963f29dbd
Author: Steve Yurong Su <[email protected]>
AuthorDate: Sat Aug 24 03:32:36 2024 +0800
Update IoTDBDataNodeReceiver.java
---
.../iotdb/db/pipe/receiver/protocol/thrift/IoTDBDataNodeReceiver.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/protocol/thrift/IoTDBDataNodeReceiver.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/protocol/thrift/IoTDBDataNodeReceiver.java
index 0978dfa17cc..8f816df2e26 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/protocol/thrift/IoTDBDataNodeReceiver.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/protocol/thrift/IoTDBDataNodeReceiver.java
@@ -149,7 +149,7 @@ public class IoTDBDataNodeReceiver extends
IoTDBFileReceiver {
@Override
public synchronized TPipeTransferResp receive(final TPipeTransferReq req) {
try {
- long startTime = System.nanoTime();
+ final long startTime = System.nanoTime();
final short rawRequestType = req.getType();
if (PipeRequestType.isValidatedRequestType(rawRequestType)) {
switch (PipeRequestType.valueOf(rawRequestType)) {