[YARN-7852] FlowRunReader constructs min_start_time filter for both createdtimestart and createdtimeend.

• Type: Sub-task
• Status: Resolved
• Priority: Major
• Resolution: Invalid
• Affects Version/s: 3.0.0
• Component/s: timelinereader
• Target Version/s: 3.1.0
• Assignee: Haibo Chen
• Reporter: Haibo Chen
• Created: 30/Jan/18 00:51
• Updated: 30/Jan/18 22:13
• Resolved: 30/Jan/18 22:13

Description

protected FilterList constructFilterListBasedOnFilters() throws IOException {
    FilterList listBasedOnFilters = new FilterList();
    // Filter based on created time range.
    Long createdTimeBegin = getFilters().getCreatedTimeBegin();
    Long createdTimeEnd = getFilters().getCreatedTimeEnd();
    if (createdTimeBegin != 0 || createdTimeEnd != Long.MAX_VALUE) {
      listBasedOnFilters.addFilter(TimelineFilterUtils
          .createSingleColValueFiltersByRange(FlowRunColumn.MIN_START_TIME,
              createdTimeBegin, createdTimeEnd));
    }
    // Filter based on metric filters.
    TimelineFilterList metricFilters = getFilters().getMetricFilters();
    if (metricFilters != null && !metricFilters.getFilterList().isEmpty()) {
      listBasedOnFilters.addFilter(TimelineFilterUtils.createHBaseFilterList(
          FlowRunColumnPrefix.METRIC, metricFilters));
    }
    return listBasedOnFilters;
  }

 

createdTimeEnd is used as an upper bound for MIN_START_TIME.  We should create one filter based on createdTimeBegin and another based on createdTimeEnd.