presto-raptor-legacy/src/main/java/io/prestosql/plugin/raptor/legacy/storage/organization/OrganizationJob.java/OrganizationJob/runJob
class OrganizationJob:    private void runJob(long tableId, OptionalInt bucketNumber, Set<UUID> shardUuids)
            throws IOException
    {
        long transactionId = shardManager.beginTransaction();
        try {
            runJob(transactionId, bucketNumber, tableId, shardUuids);
        }
        catch (Throwable e) {
            shardManager.rollbackTransaction(transactionId);
            throw e;
        }
    }