Github user jackylk commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/2148#discussion_r182777721
--- Diff:
store/search/src/main/java/org/apache/carbondata/store/worker/SearchRequestHandler.java
---
@@ -93,14 +93,14 @@ public ShutdownResponse handleShutdown(ShutdownRequest
request) {
List<CarbonRow> rows = new LinkedList<>();
try {
while (reader.nextKeyValue()) {
- // copy the data as the reader may reuse the same buffer, if
unsafe is enabled
- rows.add(new CarbonRow(reader.getCurrentValue().getData()));
+ rows.add(reader.getCurrentValue());
}
} catch (InterruptedException e) {
throw new IOException(e);
} finally {
reader.close();
}
+ LOG.error("finished reading");
--- End diff --
fixed
---
