Skip to content

Commit 31c6d5d

Browse files
committed
fix-2
1 parent 34f9293 commit 31c6d5d

1 file changed

Lines changed: 3 additions & 1 deletion

File tree

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest/v2/impl/RestApiServiceImpl.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -61,6 +61,7 @@
6161
import org.apache.iotdb.rpc.TSStatusCode;
6262
import org.apache.iotdb.service.rpc.thrift.TSLastDataQueryReq;
6363

64+
import org.apache.tsfile.common.constant.TsFileConstant;
6465
import org.apache.tsfile.read.TimeValuePair;
6566

6667
import javax.ws.rs.core.Response;
@@ -169,12 +170,13 @@ public Response executeFastLastQueryStatement(
169170
List<Object> valueList = new ArrayList<>();
170171
List<Object> dataTypeList = new ArrayList<>();
171172
for (Map.Entry<PartialPath, Map<String, TimeValuePair>> entry : resultMap.entrySet()) {
173+
final String deviceWithPrefix = entry.getKey() + TsFileConstant.PATH_SEPARATOR;
172174
for (Map.Entry<String, TimeValuePair> measurementEntry : entry.getValue().entrySet()) {
173175
final TimeValuePair tvPair = measurementEntry.getValue();
174176
valueList.add(tvPair.getValue().getStringValue());
175177
dataTypeList.add(tvPair.getValue().getDataType().name());
176178
targetDataSet.addTimestampsItem(tvPair.getTimestamp());
177-
timeseries.add(measurementEntry.getValue().getLeft().toString());
179+
timeseries.add(deviceWithPrefix + measurementEntry.getKey());
178180
}
179181
}
180182
if (!timeseries.isEmpty()) {

0 commit comments

Comments
 (0)