Skip to content

Commit 8241d89

Browse files
committed
fix
1 parent 7b9d99a commit 8241d89

1 file changed

Lines changed: 4 additions & 1 deletion

File tree

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/thrift/impl/ClientRPCServiceImpl.java

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -176,6 +176,7 @@
176176
import org.apache.tsfile.block.column.Column;
177177
import org.apache.tsfile.common.conf.TSFileConfig;
178178
import org.apache.tsfile.common.conf.TSFileDescriptor;
179+
import org.apache.tsfile.common.constant.TsFileConstant;
179180
import org.apache.tsfile.enums.TSDataType;
180181
import org.apache.tsfile.read.TimeValuePair;
181182
import org.apache.tsfile.read.common.block.TsBlock;
@@ -838,13 +839,15 @@ public TSExecuteStatementResp executeFastLastDataQueryForOnePrefixPath(
838839
final TsBlockBuilder builder = LastQueryUtil.createTsBlockBuilder(sensorNum);
839840

840841
for (final Map.Entry<PartialPath, Map<String, TimeValuePair>> result : resultMap.entrySet()) {
842+
final String deviceWithPrefix = result.getKey() + TsFileConstant.PATH_SEPARATOR;
841843
for (final Map.Entry<String, TimeValuePair> measurementLastEntry :
842844
result.getValue().entrySet()) {
843845
final TimeValuePair tvPair = measurementLastEntry.getValue();
844846
LastQueryUtil.appendLastValue(
845847
builder,
846848
tvPair.getTimestamp(),
847-
measurementLastEntry.getValue().getLeft(),
849+
new Binary(
850+
deviceWithPrefix + measurementLastEntry.getKey(), TSFileConfig.STRING_CHARSET),
848851
tvPair.getValue().getStringValue(),
849852
tvPair.getValue().getDataType().name());
850853
}

0 commit comments

Comments
 (0)