@Test
/**
 * Tests the merge partition without dedupe and the merge partition with dedupe
 */
public void testMergePartitionNoProcessingDttm() throws Exception {

    String targetTable = "employeepd";
    // Insert one record to start
    hiveShell.execute(
        "insert into emp_sr.employeepd partition(country='USA',year=2015) (`id`, `timestamp`, `name`,`company`,`zip`,`phone`,`email`,  `hired`)  values (60,'1','Billy',"
        + "'ABC','94550',"
        + "'555-1212',"
        + "'billy@acme.org','2015-01-01');");
    // Validate one record initial test condition
    List<String> results = fetchEmployees(targetSchema, targetTable);
    assertEquals(1, results.size());
    // Call merge
    mergeSyncSupport.doMerge(sourceSchema, sourceTable, targetSchema, targetTable, spec, processingPartition, false);
    // We should have 5 records 4 from the sourceTable and 1 existing
    results = fetchEmployees(targetSchema, targetTable);
    assertEquals(5, results.size());
    // Now create a duplicate record and ensure we don't see it twice the final table
    hiveShell.execute("insert into emp_sr.employeepd partition(country='Canada',year=2016) (`id`, `timestamp`, `name`,`company`,`zip`,`phone`,`email`,  `hired`)  "
                      + "values (100, '1', 'Bruce','ABC','94550','555-1212','bruce@acme.org','2016-01-01');");
    mergeSyncSupport.doMerge(sourceSchema, sourceTable, targetSchema, targetTable, spec, "20160119974350", true);
    results = fetchEmployees(targetSchema, targetTable);
    assertEquals(7, results.size());
    verifyUnique(results);
}