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 e2467b066..95c035f35 100644 --- a/dfsclient/src/main/java/org/hpccsystems/dfs/client/RowServiceInputStream.java +++ b/dfsclient/src/main/java/org/hpccsystems/dfs/client/RowServiceInputStream.java @@ -2351,6 +2351,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) {