Merge pull request #32 from prazanna/master
Make sure to fail with HoodieUpsertException if HoodieUpdateHandle is…
This commit is contained in:
@@ -107,6 +107,9 @@ import java.util.Iterator;
|
|||||||
} catch (Exception e) {
|
} catch (Exception e) {
|
||||||
logger.error("Error in update task at commit " + commitTime, e);
|
logger.error("Error in update task at commit " + commitTime, e);
|
||||||
writeStatus.setGlobalError(e);
|
writeStatus.setGlobalError(e);
|
||||||
|
throw new HoodieUpsertException(
|
||||||
|
"Failed to initialize HoodieUpdateHandle for FileId: " + fileId + " on commit "
|
||||||
|
+ commitTime + " on HDFS path " + metadata.getBasePath());
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user