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 3a8b26b77..24036ba96 100644 --- a/dfsclient/src/main/java/org/hpccsystems/dfs/client/RowServiceInputStream.java +++ b/dfsclient/src/main/java/org/hpccsystems/dfs/client/RowServiceInputStream.java @@ -2019,6 +2019,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) {