为什么数据流数据存储区查询不匹配文字字符串？

Question

更新：“状态”未编入索引：(我已将该属性编入索引，查询运行良好。

[使用DirectPipelineRunner运行数据流管道时，我的查询没有任何匹配，尽管我可以在数据存储区中看到实体。当我删除过滤器时，它会找到实体并运行。

这似乎很简单。为什么查询不匹配任何实体？

    val readyToGoFilter = DatastoreHelper.makeFilter("state",
      PropertyFilter.Operator.EQUAL,
      DatastoreHelper.makeValue("SUBMITTED"))

    val query = Query.newBuilder()
      .addKind(kind)
      .setFilter(readyToGoFilter)
      .build()

    val in = sc
      .withName("FindBatch")
      .datastore(projectId, query)

Answer 1

Arg，“状态”未建立索引。我将该属性编入索引，并且效果很好。