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

Question

更新：“状态”没有被索引:(我索引了那个属性并且查询运行良好。

使用 DirectPipelineRunner 运行 Dataflow 管道时，我的查询不匹配任何内容，尽管我可以看到 Datastore 中的实体。当我删除过滤器时，它会找到实体并运行。

这看起来很简单。为什么查询不匹配任何实体？

    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，“状态”未编入索引。我为该属性编制了索引，它运行良好。