public boolean existCompaction(long txnId) {
        return compactionScheduler.existCompaction(txnId);
    }
@Test
    public void testExistCompaction() {
        long txnId = 11111;
        CompactionMgr compactionManager = new CompactionMgr();
        CompactionScheduler compactionScheduler =
                new CompactionScheduler(compactionManager, GlobalStateMgr.getCurrentState().getNodeMgr().getClusterInfo(),
                        GlobalStateMgr.getCurrentState().getGlobalTransactionMgr(), GlobalStateMgr.getCurrentState(), "");
        compactionManager.setCompactionScheduler(compactionScheduler);
        new MockUp<CompactionScheduler>() {
            @Mock
            public ConcurrentHashMap<PartitionIdentifier, CompactionJob> getRunningCompactions() {
                ConcurrentHashMap<PartitionIdentifier, CompactionJob> r = new ConcurrentHashMap<>();
                PartitionIdentifier partitionIdentifier = new PartitionIdentifier(1, 2, 3);
                Database db = new Database();
                Table table = new LakeTable();
                PhysicalPartition partition = new Partition(123, "aaa", null, null);
                CompactionJob job = new CompactionJob(db, table, partition, txnId, false);
                r.put(partitionIdentifier, job);
                return r;
            }
        };
        Assert.assertEquals(true, compactionManager.existCompaction(txnId));
    }