Xin Gong created FLINK-34715:
--------------------------------

             Summary: Fix mysql ut about closing BinlogSplitReader
                 Key: FLINK-34715
                 URL: https://issues.apache.org/jira/browse/FLINK-34715
             Project: Flink
          Issue Type: Improvement
          Components: Flink CDC
            Reporter: Xin Gong
             Fix For: cdc-3.1.0


BinlogSplitReaderTest#readBinlogSplitsFromSnapshotSplits should test binlog 
reader is closed after binlog reader close. But code always test snapshot split 
reader is closed.

```java

binlogReader.close();

assertNotNull(snapshotSplitReader.getExecutorService());
assertTrue(snapshotSplitReader.getExecutorService().isTerminated());

```

We shoud change code to 

```java

binlogReader.close();

assertNotNull(binlogReader.getExecutorService());
assertTrue(binlogReader.getExecutorService().isTerminated());

```



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to