gavinchou commented on code in PR #37293:
URL: https://github.com/apache/doris/pull/37293#discussion_r1694299096
##########
fe/fe-core/src/main/java/org/apache/doris/cloud/datasource/CloudInternalCatalog.java:
##########
@@ -810,6 +810,48 @@ private void dropCloudPartition(long dbId, long tableId,
List<Long> partitionIds
}
}
+ public void removeSchemaChangeJob(long dbId, long tableId, long indexId,
long partitionId, long tabletId)
+ throws DdlException {
+ Cloud.FinishTabletJobRequest.Builder finishTabletJobRequestBuilder =
Cloud.FinishTabletJobRequest.newBuilder();
+ finishTabletJobRequestBuilder.setCloudUniqueId(Config.cloud_unique_id);
+
finishTabletJobRequestBuilder.setAction(Cloud.FinishTabletJobRequest.Action.ABORT);
+ Cloud.TabletJobInfoPB.Builder tabletJobInfoPBBuilder =
Cloud.TabletJobInfoPB.newBuilder();
+
+ Cloud.TabletIndexPB.Builder tabletIndexPBBuilder =
Cloud.TabletIndexPB.newBuilder();
+ tabletIndexPBBuilder.setDbId(dbId);
+ tabletIndexPBBuilder.setTableId(tableId);
+ tabletIndexPBBuilder.setIndexId(indexId);
+ tabletIndexPBBuilder.setPartitionId(partitionId);
+ tabletIndexPBBuilder.setTabletId(tabletId);
+ final Cloud.TabletIndexPB tabletIndex = tabletIndexPBBuilder.build();
+ tabletJobInfoPBBuilder.setIdx(tabletIndex);
+ final Cloud.TabletJobInfoPB tabletJobInfoPB =
tabletJobInfoPBBuilder.build();
+ finishTabletJobRequestBuilder.setJob(tabletJobInfoPB);
+
+ final Cloud.FinishTabletJobRequest request =
finishTabletJobRequestBuilder.build();
+
+ Cloud.FinishTabletJobResponse response = null;
+ int tryTimes = 0;
+ while (tryTimes++ < Config.metaServiceRpcRetryTimes()) {
+ try {
+ response =
MetaServiceProxy.getInstance().finishTabletJob(request);
+ if (response.getStatus().getCode() !=
Cloud.MetaServiceCode.KV_TXN_CONFLICT) {
+ break;
+ }
+ } catch (RpcException e) {
+ LOG.warn("tryTimes:{}, dropIndex RpcException", tryTimes, e);
Review Comment:
typo?
--
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: commits-unsubscr...@doris.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
