processing_dttm added to final table
@@ -434,7 +434,7 @@ public class TableMergeSyncSupport implements Serializable {
" union all " +
" select " + selectSQL +
" from " + HiveUtils.quoteIdentifier(targetSchema, targetTable) +
- ") x group by " + groupBySQL + " having min(processing_dttm) = " + HiveUtils.quoteString(feedPartitionValue) + ";";
+ ") x group by " + groupBySQL + " having min(processing_dttm) = " + HiveUtils.quoteString(feedPartitionValue);
}
/**
