public TxnCoordinator getCoordinator() {
        return txnCoordinator;
    }
@Test
    public void testSerDe() {
        UUID uuid = UUID.randomUUID();
        TransactionState transactionState = new TransactionState(1000L, Lists.newArrayList(20000L, 20001L),
                3000, "label123", new TUniqueId(uuid.getMostSignificantBits(), uuid.getLeastSignificantBits()),
                LoadJobSourceType.BACKEND_STREAMING, new TxnCoordinator(TxnSourceType.BE, "127.0.0.1"), 50000L,
                60 * 1000L);

        String json = GsonUtils.GSON.toJson(transactionState);
        TransactionState readTransactionState = GsonUtils.GSON.fromJson(json, TransactionState.class);
        Assert.assertEquals(transactionState.getCoordinator().ip, readTransactionState.getCoordinator().ip);
    }