Apache
/
hadoop
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

YARN-9389. FlowActivity and FlowRun table prefix is wrong. Contributed by Prabhu Joseph.

This commit is contained in:
Rohith Sharma K S 2019-03-20 21:18:19 +05:30
parent 072750c00a
commit c1a4eeb7c8
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-timelineservice-hbase/hadoop-yarn-server-timelineservice-hbase-client/src/main/java/org/apache/hadoop/yarn/server/timelineservice/storage/flow/FlowActivityTableRW.java
View File

@ -36,7 +36,7 @@ import org.slf4j.LoggerFactory;
public class FlowActivityTableRW extends BaseTableRW<FlowActivityTable> { public class FlowActivityTableRW extends BaseTableRW<FlowActivityTable> {
/** flow activity table prefix. */ /** flow activity table prefix. */
private static final String PREFIX = private static final String PREFIX =
YarnConfiguration.TIMELINE_SERVICE_PREFIX + ".flowactivity"; YarnConfiguration.TIMELINE_SERVICE_PREFIX + "flowactivity";
/** config param name that specifies the flowactivity table name. */ /** config param name that specifies the flowactivity table name. */
public static final String TABLE_NAME_CONF_NAME = PREFIX + ".table.name"; public static final String TABLE_NAME_CONF_NAME = PREFIX + ".table.name";

2
hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-timelineservice-hbase/hadoop-yarn-server-timelineservice-hbase-client/src/main/java/org/apache/hadoop/yarn/server/timelineservice/storage/flow/FlowRunTableRW.java
View File

@ -38,7 +38,7 @@ import org.apache.hadoop.hbase.Coprocessor;
public class FlowRunTableRW extends BaseTableRW<FlowRunTable> { public class FlowRunTableRW extends BaseTableRW<FlowRunTable> {
/** entity prefix. */ /** entity prefix. */
private static final String PREFIX = private static final String PREFIX =
YarnConfiguration.TIMELINE_SERVICE_PREFIX + ".flowrun"; YarnConfiguration.TIMELINE_SERVICE_PREFIX + "flowrun";
/** config param name that specifies the flowrun table name. */ /** config param name that specifies the flowrun table name. */
public static final String TABLE_NAME_CONF_NAME = PREFIX + ".table.name"; public static final String TABLE_NAME_CONF_NAME = PREFIX + ".table.name";