Преглед изворни кода

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

Rohith Sharma K S пре 6 година
родитељ
комит
8de93fca3c

+ 1 - 1
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

@@ -36,7 +36,7 @@ import org.slf4j.LoggerFactory;
 public class FlowActivityTableRW extends BaseTableRW<FlowActivityTable> {
   /** flow activity table 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. */
   public static final String TABLE_NAME_CONF_NAME = PREFIX + ".table.name";

+ 1 - 1
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

@@ -38,7 +38,7 @@ import org.apache.hadoop.hbase.Coprocessor;
 public class FlowRunTableRW extends BaseTableRW<FlowRunTable> {
   /** entity 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. */
   public static final String TABLE_NAME_CONF_NAME = PREFIX + ".table.name";