anchor.diff:  CREATE TABLE `yarn_allocate_response` (
     `applicationattemptid` VARCHAR(45) NOT NULL,
     `allocate_response` VARBINARY(13500) NULL,
  +  `responseid` INT NOT NULL,
   PRIMARY KEY (`applicationattemptid`)
  -) ENGINE=ndbcluster DEFAULT CHARSET=latin1$$
  +) ENGINE=ndbcluster DEFAULT CHARSET=latin1 PARTITION BY KEY(applicationattemptid)$$
  +
  +delimiter $$
  +
  +CREATE TABLE `yarn_allocated_containers` (
  +  `applicationattemptid` VARCHAR(45) NOT NULL,
  + `containerid` VARCHAR(45) NOT NULL,
  + `responseid` INT NOT NULL,
  +PRIMARY KEY (`applicationattemptid`, `containerid`,`responseid`),
  +CONSTRAINT `appandresponseid`
  +    FOREIGN KEY (`applicationattemptid`)
  +    REFERENCES `yarn_allocate_response` (`applicationattemptid`)
  +    ON DELETE CASCADE
  +    ON UPDATE NO ACTION
  +) ENGINE=ndbcluster DEFAULT CHARSET=latin1 PARTITION BY KEY(applicationattemptid)$$
  +
  +delimiter $$
  +
  +CREATE TABLE `yarn_completed_containers_status` (
  +  `applicationattemptid` VARCHAR(45) NOT NULL,
  + `containerid` VARCHAR(45) NOT NULL,
  + `responseid` INT NOT NULL,
  + `status` varbinary(1000),
  +PRIMARY KEY (`applicationattemptid`, `containerid`,`responseid`),
  +INDEX `applicationattemptid` (`applicationattemptid` ASC),
  +INDEX `responseid` (`responseid` ASC),
  +CONSTRAINT `appandresponseid`
  +    FOREIGN KEY (`applicationattemptid`)
  +    REFERENCES `yarn_allocate_response` (`applicationattemptid`)
  +    ON DELETE CASCADE
  +    ON UPDATE NO ACTION
  +) ENGINE=ndbcluster DEFAULT CHARSET=latin1 PARTITION BY KEY(responseid)$$
  +
  +delimiter $$
  +
  +CREATE TABLE `yarn_allocated_nmtokens` (
  +  `applicationattemptid` VARCHAR(45) NOT NULL,
  + `nmtoken` VARBINARY(1000) NOT NULL,
  +  `responseid` INT NOT NULL,
  +PRIMARY KEY (`applicationattemptid`, `nmtoken`,`responseid`),
  +CONSTRAINT `applicationattemptid`
  +    FOREIGN KEY (`applicationattemptid`)
  +    REFERENCES `yarn_allocate_response` (`applicationattemptid`)
  +    ON DELETE CASCADE
  +    ON UPDATE NO ACTION
  +) ENGINE=ndbcluster DEFAULT CHARSET=latin1 PARTITION BY KEY(applicationattemptid)$$
   
   delimiter $$
   
  
positive.code:   `user` VARCHAR(45) NULL,
    `queuename` VARCHAR(45) NULL,
    PRIMARY KEY (`appid`)
  ) ENGINE=ndbcluster DEFAULT CHARSET=latin1$$
  
  
  delimiter $$
  
negative.code:     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`
  