diff --git a/dfsclient/src/main/java/org/hpccsystems/dfs/client/RowServiceInputStream.java b/dfsclient/src/main/java/org/hpccsystems/dfs/client/RowServiceInputStream.java index 67ef1a249..3b703b4be 100644 --- a/dfsclient/src/main/java/org/hpccsystems/dfs/client/RowServiceInputStream.java +++ b/dfsclient/src/main/java/org/hpccsystems/dfs/client/RowServiceInputStream.java @@ -2328,6 +2328,11 @@ private String makeNodeObject() sb.append(getFilePartCopy() + 1); sb.append("\", \n"); + if (this.dataPart.isTLK()) + { + sb.append("\"isTlk\" : \"true\",\n"); + } + // Do not apply filters and limits when inFetchingMode if (inFetchingMode == false) {