Skip to content

Commit 80f1219

Browse files
committed
[FLINK-38239][oceanbase] Re-enable OceanBase CDC integration tests in CI with Docker image
- Remove @disabled annotations from OceanBase test classes - Replace environment variable dependencies with obbinlog-ce:4.2.5-test container - Add comprehensive e2e integration tests for oceanbase-cdc connector
1 parent 722efc0 commit 80f1219

1 file changed

Lines changed: 2 additions & 1 deletion

File tree

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/oceanbase/OceanBaseSourceTestBase.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -165,9 +165,10 @@ protected static void dropDatabase(String dbName) {
165165

166166
protected static List<String> fetchRows(Iterator<Row> iter, int size) {
167167
List<String> rows = new ArrayList<>(size);
168-
for (int i = 0; i < size; i++) {
168+
while (size > 0 && iter.hasNext()) {
169169
Row row = iter.next();
170170
rows.add(row.toString());
171+
size--;
171172
}
172173
return rows;
173174
}

0 commit comments

Comments
 (0)