DICT_DATASET_WRITER.close();
<BUG>datasetId = Integer.valueOf(DatasetDao.getDatasetByUrn(urn).get("id").toString());
}</BUG>
else {
DICT_DATASET_WRITER.execute(UPDATE_DICT_DATASET_WITH_SCHEMA_CHANGE,
<BUG>new Object[]{rec.getOriginalSchema(), rec.getFormat(), rec.getFieldSchema().toString(), "API", eventTime, datasetId});
}</BUG>
List<Map<String, Object>> oldInfo;
try {
oldInfo = getDatasetFieldsByDatasetId(datasetId);

DICT_DATASET_WRITER.close();
datasetId = Integer.valueOf(DatasetDao.getDatasetByUrn(urn).get("id").toString());
rec.setDatasetId(datasetId);
}
else {
DICT_DATASET_WRITER.execute(UPDATE_DICT_DATASET_WITH_SCHEMA_CHANGE,
new Object[]{rec.getOriginalSchema(), rec.getFormat(), StringUtil.objectToJsonString(rec.getFieldSchema()),
"API", System.currentTimeMillis() / 1000, datasetId});
}
List<Map<String, Object>> oldInfo;
try {
oldInfo = getDatasetFieldsByDatasetId(datasetId);
