DBZ-3229 Increase wait time; do not rely on record delivery in case of failure
This commit is contained in:
parent
12c20fad53
commit
2c49b0277e
2
.github/workflows/sqlserver-workflow.yml
vendored
2
.github/workflows/sqlserver-workflow.yml
vendored
@ -49,4 +49,4 @@ jobs:
|
||||
restore-keys: |
|
||||
${{ runner.os }}-maven-
|
||||
- name: Check changes in Debezium Connector SQL Server
|
||||
run: mvn clean install -B -pl debezium-connector-sqlserver -am -Passembly -Dformat.formatter.goal=validate -Dformat.imports.goal=check -Dorg.slf4j.simpleLogger.log.org.apache.maven.cli.transfer.Slf4jMavenTransferListener=warn -Dmaven.wagon.http.pool=false -Dmaven.wagon.httpconnectionManager.ttlSeconds=120
|
||||
run: mvn clean install -B -pl debezium-connector-sqlserver -am -Passembly -Dformat.formatter.goal=validate -Dformat.imports.goal=check -Dorg.slf4j.simpleLogger.log.org.apache.maven.cli.transfer.Slf4jMavenTransferListener=warn -Dmaven.wagon.http.pool=false -Dmaven.wagon.httpconnectionManager.ttlSeconds=120 -Ddebezium.test.records.waittime=10
|
||||
|
@ -147,8 +147,6 @@ public void fail() throws Exception {
|
||||
"INSERT INTO tableb VALUES(" + id + ", 'b')");
|
||||
}
|
||||
|
||||
SourceRecords records = consumeRecordsByTopic(1);
|
||||
Assertions.assertThat(records.recordsForTopic("server1.dbo.tablea")).hasSize(1);
|
||||
Awaitility.await()
|
||||
.alias("Found warning message in logs")
|
||||
.atMost(TestHelper.waitTimeForRecords(), TimeUnit.SECONDS).until(() -> {
|
||||
|
Loading…
Reference in New Issue
Block a user