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

Question

更新："state" 未编入索引 :( 我已将 属性 和查询 运行 编入索引。

当 运行 使用 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，"state" 未编入索引。我为 属性 建立了索引，它运行良好。