deniskuzZ commented on a change in pull request #2642:
URL: https://github.com/apache/hive/pull/2642#discussion_r710179005
##########
File path:
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/CompactionTxnHandler.java
##########
@@ -1104,89 +1104,101 @@ public boolean checkFailedCompactions(CompactionInfo
ci) throws MetaException {
@RetrySemantics.CannotRetry
public void markFailed(CompactionInfo ci) throws MetaException {//todo: this
should not throw
if (LOG.isDebugEnabled()) {
- LOG.debug("Marking as failed: CompactionInfo: " + ci.toString());
+ LOG.debug("Marking as failed: CompactionInfo: " + ((ci != null) ?
ci.toString() : " is missing"));
}
try {
Connection dbConn = null;
- Statement stmt = null;
PreparedStatement pStmt = null;
ResultSet rs = null;
- // the error message related to the failure is wrapped inside
CompactionInfo
- // fetch this info, since ci will be reused in subsequent queries
- String errorMessage = ci.errorMessage;
+
try {
dbConn = getDbConn(Connection.TRANSACTION_READ_COMMITTED);
- stmt = dbConn.createStatement();
- pStmt = dbConn.prepareStatement("SELECT \"CQ_ID\", \"CQ_DATABASE\",
\"CQ_TABLE\", \"CQ_PARTITION\", "
- + "\"CQ_STATE\", \"CQ_TYPE\", \"CQ_TBLPROPERTIES\",
\"CQ_WORKER_ID\", \"CQ_START\", \"CQ_RUN_AS\", "
- + "\"CQ_HIGHEST_WRITE_ID\", \"CQ_META_INFO\",
\"CQ_HADOOP_JOB_ID\", \"CQ_ERROR_MESSAGE\", "
- + "\"CQ_ENQUEUE_TIME\", \"CQ_WORKER_VERSION\",
\"CQ_INITIATOR_ID\", \"CQ_INITIATOR_VERSION\" "
- + "FROM \"COMPACTION_QUEUE\" WHERE \"CQ_ID\" = ?");
- pStmt.setLong(1, ci.id);
- rs = pStmt.executeQuery();
- if (rs.next()) {
- ci = CompactionInfo.loadFullFromCompactionQueue(rs);
- String s = "DELETE FROM \"COMPACTION_QUEUE\" WHERE \"CQ_ID\" = ?";
- pStmt = dbConn.prepareStatement(s);
- pStmt.setLong(1, ci.id);
- LOG.debug("Going to execute update <" + s + ">");
- int updCnt = pStmt.executeUpdate();
- }
- else {
- if(ci.id > 0) {
- //the record with valid CQ_ID has disappeared - this is a sign of
something wrong
- throw new IllegalStateException("No record with CQ_ID=" + ci.id +
" found in COMPACTION_QUEUE");
- }
- }
- if(ci.id == 0) {
- //The failure occurred before we even made an entry in
COMPACTION_QUEUE
- //generate ID so that we can make an entry in COMPLETED_COMPACTIONS
- ci.id = generateCompactionQueueId(stmt);
- //mostly this indicates that the Initiator is paying attention to
some table even though
- //compactions are not happening.
+ if(ci == null) {
+ LOG.debug("CompactionInfo was null, creating a new one");
+ ci = new CompactionInfo();
Review comment:
my two cents here: I think, it would make sense to return right away
from markFailed if a `NULL` ci is passed.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
