AWS TimeStream Java SDK 查询列数限制问题及配置咨询

问题背景 #

我正在使用AWS TimeStream Java SDK查询TimeStream表，出现了如下不一致的查询结果：

正常场景（7列查询） #

当SELECT语句选择7列时，代码执行正常，返回5000行数据：

String query = """
            SELECT
              Response,
              ResponseSize,
              RequestSize,
              Url,
              StatusCode,
              time AS RequestTime,
              measure_value::bigint AS RequestDuration
            FROM (table name)
            WHERE (clause)
            """;
QueryRequest queryRequest = QueryRequest.builder()
        .queryString(query)
        .build();

var queryResult = timestreamQueryClient.query(queryRequest);

System.out.println(queryResult.rows().size()); // 5000

异常场景（8列查询） #

添加TestId列后，SELECT列数变为8列，请求成功但返回0行数据，且提示存在更多结果；但在AWS控制台查询编辑器执行相同查询可正常返回数据：

String query = """
            SELECT
              TestId,
              Response,
              ResponseSize,
              RequestSize,
              Url,
              StatusCode,
              time AS RequestTime,
              measure_value::bigint AS RequestDuration
            FROM (table name)
            WHERE (clause)
            """;
QueryRequest queryRequest = QueryRequest.builder()
        .queryString(query)
        .build();

var queryResult = timestreamQueryClient.query(queryRequest);

System.out.println(queryResult.rows().size()); // 0 Rows

咨询问题 #

• 能否在SDK中设置查询的最大列数？
• 这种返回空行而非400错误的情况是否属于SDK Bug？

1. 查询最大列数的设置 #

AWS TimeStream服务端没有明确限制查询的列数，SDK也没有提供设置最大列数的配置参数。查询的限制主要体现在单页结果的数据大小上，只要结果数据量不超过服务端的单页响应配额，多列查询即可正常执行。

2. 返回空行的问题分析 #

这种情况基本不属于SDK Bug，更可能是分页逻辑缺失或数据解析异常导致：

• TimeStream查询默认分页返回结果，当queryResult.hasMoreResults()为true时，必须使用nextToken调用后续请求获取完整数据。你当前仅调用一次query()，可能第一页无数据，但后续分页存在结果。
• 另外，需检查TestId列的数据类型，比如该列是否为多值属性、是否存在隐式类型转换问题，导致SDK解析第一页结果时未抛出错误但返回空行。

建议先补充分页处理代码验证：

String nextToken = null;
do {
    QueryRequest queryRequest = QueryRequest.builder()
            .queryString(query)
            .nextToken(nextToken)
            .build();
    var queryResult = timestreamQueryClient.query(queryRequest);
    System.out.println("当前页行数：" + queryResult.rows().size());
    nextToken = queryResult.nextToken();
} while (nextToken != null);

如果问题仍存在，可开启SDK调试日志查看服务端原始响应，或尝试对TestId添加明确类型转换（如TestId::varchar）排查解析问题。

内容的提问来源于stack exchange，提问作者Borislav Stoilov