📣 极限科技诚招搜索运维工程师(Elasticsearch/Easysearch)- 全职/北京 👉 : 立即申请加入

适用版本: 6.8-8.9

1. 错误异常的基本描述 #

could not parse [schedule_type] schedule. invalid value for [field] 是 Elasticsearch Watcher 在解析 schedule 配置时抛出的异常。此错误表示 Watcher 已经识别出字段名,但字段值本身不符合该字段允许的取值规则。

从日志片段看,这类报错常发生在 minute 字段解析分支里,表示分钟值不合法。

常见现象 #

  • 创建或更新 watch 时返回 HTTP 400 错误。
  • 报错信息明确指出哪个字段的值不合法(invalid value for [field])。
  • 常见于 dailyweeklymonthly 等 schedule 的 minutehourtime 等时间字段配置中。
  • 如果分钟值超出范围(如 60)或不是数字,就会触发此错误。

典型报错与异常栈 #

{
  "error": {
    "root_cause": [
      {
        "type": "parse_exception",
        "reason": "could not parse [daily] schedule. invalid value for [minute]"
      }
    ],
    "type": "parse_exception",
    "reason": "could not parse [daily] schedule. invalid value for [minute]"
  },
  "status": 400
}

服务端日志中可能出现类似以下内容:

[2024-01-15T10:30:00,123][WARN ][o.e.x.w.t.s.DayTimes   ] [node-1] failed to parse schedule
ElasticsearchParseException[could not parse [daily] schedule. invalid value for [minute]]
    at org.elasticsearch.xpack.watcher.trigger.schedule.DayTimes.parseMinuteValue(DayTimes.java:145)
    at org.elasticsearch.xpack.watcher.trigger.schedule.DailySchedule.parse(DailySchedule.java:89)

2. 为什么会发生这个错误 #

Watcher 的 schedule 解析器在遇到时间字段(如 minutehourtime 等)后,会调用相应的解析方法验证值的合法性。如果单个值或数组中的某个元素无法解析,就会抛出此异常。

常见原因包括:

  • minute 不是数字:例如 "minute": "abc" 应该是 "minute": 30
  • 分钟值超出允许范围:分钟值必须在 0-59 之间,例如 60-1 都是非法的。
  • 数组里混入非法元素:例如 "minute": [0, 30, "abc"] 包含非数字元素。
  • 空串或 null 值:例如 "minute": """minute": null
  • 对象而不是标量值:例如 "minute": {"value": 30} 应该是 "minute": 30
  • 模板占位符未渲染:例如 "minute": "{{ctx.minute}}"ctx.minute 未定义。
  • 时间格式错误:例如 "time": "25:00" 小时值超出范围。

3. 如何排查和解决这个异常和解决这个异常 #

排查步骤 #

  1. 确认报错信息中的字段名:从错误信息中提取哪个字段的值不合法(invalid value for [field])。

  2. 检查 Watch 中的 schedule 配置

# 获取 watch 配置
GET _watcher/watch/<watch_id>?pretty

# 检查 trigger 部分的 schedule
  1. 验证时间字段的值:确认值在合法范围内,且类型正确。
# 正确的 daily schedule 格式示例
PUT _watcher/watch/<watch_id>
{
  "trigger": {
    "schedule": {
      "daily": {
        "at": ["12:00", "18:00"]
      }
    }
  },
  ...
}

时间字段的合法范围:

  • minute: 0-59
  • hour: 0-23
  • day: 1-31(取决于月份)
  • month: 1-12
  • time: 格式必须为 HH:MM(24小时制)
  1. 检查数组元素:如果字段值是数组,逐个检查每个元素是否合法。

排查时需要注意的问题 #

  • 注意 minutehour 的取值范围是 0-59 和 0-23,不要超出范围。
  • 如果使用了模板变量,确保变量渲染后是合法的数字或字符串。
  • 检查是否有空串、null 或其他非法值混入数组。

4. 如何解决这个错误 #

常用修复方式 #

  1. 修正字段值为合法取值:根据报错信息,将字段值改为合法的取值。
# 修复前(错误:minute 值超出范围)
PUT _watcher/watch/<watch_id>
{
  "trigger": {
    "schedule": {
      "daily": {
        "at": ["12:60"]  # 错误:分钟值 60 超出范围
      }
    }
  }
}

# 修复后(正确:分钟值在 0-59 范围内)
PUT _watcher/watch/<watch_id>
{
  "trigger": {
    "schedule": {
      "daily": {
        "at": ["12:59"]  # 正确
      }
    }
  }
}
  1. 清理数组中的非法元素
# 修复前(错误:数组包含非法元素)
"minute": [0, 30, "abc"]

# 修复后(正确:所有元素都是合法数字)
"minute": [0, 30]
  1. 为模板添加默认值:如果使用动态模板,确保即使数据缺失也有合理的默认值。
# 使用 Mustache 模板并提供默认值
{
  "at": ["{{ctx.hour | default('12')}}:{{ctx.minute | default('00')}}"]
}

后续注意事项与推荐建议 #

  • 在编写 schedule 配置时,始终确保时间字段的值在合法范围内。
  • 对动态生成的配置进行范围验证,确保时间值合法。
  • 在测试环境验证 schedule 配置,特别是在使用模板或程序生成配置时。

借助 INFINI 产品提升排障效率 #

  • INFINI Console 提供可视化的 Watch 编辑和验证功能,可以在保存前检查 schedule 配置中时间字段的合法性,自动检测超出范围的值。
  • INFINI Gateway 可以记录 Watcher API 的完整请求内容,帮助捕获 schedule 配置的详细错误上下文,并通过流量回放验证修复方案。
  • 通过 INFINI Console 的 Watch 测试功能,可以在不执行完整 Watch 的情况下验证 schedule 配置的合法性。

5. 小结 #

could not parse [schedule_type] schedule. invalid value for [field] 是一个字段值合法性错误,表示 schedule 的某个时间字段值不合法。解决此问题的关键是:根据报错信息确认是哪个字段,将该字段的值修正为合法取值(如 minute 必须在 0-59 范围内)。

通过 INFINI Console 的配置验证功能和 INFINI Gateway 的请求捕获能力,可以更高效地定位和修复 schedule 时间字段的值合法性问题。

相关错误 #

参考文档 #

附:日志上下文 #

下面保留当前页面中的源码或日志片段,便于继续结合异常调用栈定位问题:

    } else if (MINUTE_FIELD.match(currentFieldName, parser.getDeprecationHandler())) {
        if (token.isValue()) {
            try {
                minutes.add(DayTimes.parseMinuteValue(parser, token));
            } catch (ElasticsearchParseException pe) {
                throw new ElasticsearchParseException("could not parse [{}] schedule. invalid value for [{}]", pe, TYPE, currentFieldName);
            }
        } else if (token == XContentParser.Token.START_ARRAY) {
            while ((token = parser.nextToken()) != XContentParser.Token.END_ARRAY) {