[ https://issues.apache.org/jira/browse/YARN-7852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Haibo Chen resolved YARN-7852. ------------------------------ Resolution: Invalid > FlowRunReader constructs min_start_time filter for both createdtimestart and > createdtimeend. > -------------------------------------------------------------------------------------------- > > Key: YARN-7852 > URL: https://issues.apache.org/jira/browse/YARN-7852 > Project: Hadoop YARN > Issue Type: Sub-task > Components: timelinereader > Affects Versions: 3.0.0 > Reporter: Haibo Chen > Assignee: Haibo Chen > Priority: Major > > {code:java} > 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; > }{code} > > createdTimeEnd is used as an upper bound for MIN_START_TIME. We should > create one filter based on createdTimeBegin and another based on > createdTimeEnd. -- This message was sent by Atlassian JIRA (v7.6.3#76005) --------------------------------------------------------------------- To unsubscribe, e-mail: yarn-dev-unsubscr...@hadoop.apache.org For additional commands, e-mail: yarn-dev-h...@hadoop.apache.org