[
https://issues.apache.org/jira/browse/YARN-7852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haibo Chen updated YARN-7852:
-----------------------------
Issue Type: Sub-task (was: Bug)
Parent: YARN-7055
> 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-issues-unsubscr...@hadoop.apache.org
For additional commands, e-mail: yarn-issues-h...@hadoop.apache.org
