anchor.diff:      ON UPDATE NO ACTION
   ) ENGINE=ndbcluster DEFAULT CHARSET=latin1 PARTITION BY KEY(rmnodeid) $$
   
  +delimiter $$
  +
  +CREATE TABLE `yarn_updated_node` (
  +  `applicationid` VARCHAR(45) NOT NULL,
  +  `nodeid` VARCHAR(45) NULL,
  +  PRIMARY KEY (`applicationid`, `nodeid`),
  +  CONSTRAINT `nodeid`
  +    FOREIGN KEY (`nodeid`)
  +    REFERENCES `yarn_rmnode` (`rmnodeid`)
  +    ON DELETE CASCADE
  +    ON UPDATE NO ACTION
  +) ENGINE=ndbcluster DEFAULT CHARSET=latin1 PARTITION BY KEY(applicationid) $$
  +
  +delimiter $$
  +
  +CREATE TABLE `yarn_ran_node` (
  +  `application_attempt_id` VARCHAR(45) NOT NULL,
  +  `nodeid` VARCHAR(45) NULL,
  +  PRIMARY KEY (`application_attempt_id`, `nodeid`),
  +  CONSTRAINT `nodeid`
  +    FOREIGN KEY (`nodeid`)
  +    REFERENCES `yarn_rmnode` (`rmnodeid`)
  +    ON DELETE CASCADE
  +    ON UPDATE NO ACTION
  +) ENGINE=ndbcluster DEFAULT CHARSET=latin1 PARTITION BY KEY(application_attempt_id) $$
   
   delimiter $$
   
   CREATE TABLE `yarn_containerid_toclean` (
     `rmnodeid` VARCHAR(45) NOT NULL,
     `containerid` VARCHAR(45) NOT NULL,
  +  `pendingeventid` INT,
     PRIMARY KEY (`rmnodeid`, `containerid`),
     INDEX `rmnodeId` (`containerid` ASC),
     CONSTRAINT `rmnodeid`
  
positive.code:   `state` VARCHAR(45) NULL,
    `finishedstatusstate` VARCHAR(45) NULL,
    `exitstatus` INT NULL,
    PRIMARY KEY (`containerid_id`)
  ) ENGINE=ndbcluster DEFAULT CHARSET=latin1$$
  
  
  delimiter $$
  
negative.code: ) ENGINE=ndbcluster DEFAULT CHARSET=latin1$$
  
  delimiter $$
  
  CREATE TABLE `yarn_schedulerapp_reservations` (
    `schedulerapp_id` VARCHAR(45) NOT NULL,
    `priority_id` INT NOT NULL,
    `counter` INT NULL,
    PRIMARY KEY (`schedulerapp_id`, `priority_id`))
  ENGINE = ndbcluster$$
  
  delimiter $$
  
  CREATE TABLE `yarn_localitylevel` (
    `schedulerapp_id` VARCHAR(45) NOT NULL,
    `priority_id` INT NOT NULL,
    `nodetype` VARCHAR(45) NULL,
    PRIMARY KEY (`schedulerapp_id`, `priority_id`))
  ENGINE = ndbcluster$$
  
  delimiter $$
  
  CREATE TABLE `yarn_csleafqueueuserinfo` (
    `username` VARCHAR(45) NOT NULL,
    `consumed_memory` INT NULL,
    `consumed_vcores` INT NULL,
    `pending_applications` INT NULL,
    `active_applications` INT NULL,
    PRIMARY KEY (`username`))
  ENGINE = ndbcluster$$
  
  delimiter $$
  
  CREATE TABLE `yarn_csqueue` (
    `path` VARCHAR(45) NOT NULL,
    `name` VARCHAR(45) NULL,
    `used_capacity` FLOAT NULL,
    `used_resource_memory` INT NULL,
    `used_resource_vcores` INT NULL,
    `absolute_used_capacity` FLOAT NULL,
    `is_parent` INT NULL,
    `num_containers` INT NULL,
    PRIMARY KEY (`path`))
  ENGINE = ndbcluster$$
  
  delimiter $$
  
  CREATE TABLE `yarn_appschedulable` (
    `schedulerapp_id` VARCHAR(45) NOT NULL,
    `starttime` BIGINT NULL,
    `fsqueuename` VARCHAR(45) NULL,
    PRIMARY KEY (`schedulerapp_id`))
  ENGINE = ndbcluster$$
  
  delimiter $$
  
  CREATE TABLE `yarn_preemptionmap` (
    `schedulerapp_id` VARCHAR(45) NOT NULL,
    `rmcontainer_id` VARCHAR(45) NOT NULL,
    `value` BIGINT NULL,
    PRIMARY KEY (`schedulerapp_id`, `rmcontainer_id`))
  ENGINE = ndbcluster$$
  
  delimiter $$
  
  CREATE TABLE `yarn_runnable_apps` (
    `queuename` VARCHAR(45) NOT NULL,
    `schedulerapp_id` VARCHAR(45) NOT NULL,
    `isrunnable` BIT NOT NULL,
    PRIMARY KEY (`queuename`, `schedulerapp_id`))
  ENGINE = ndbcluster$$
  