Upgrade to TestContainers 1.15.1
This commit is contained in:
@@ -19,7 +19,7 @@
|
||||
<java-functions.version>1.0.0-M4</java-functions.version>
|
||||
<stream-applications.version>3.0.0-M4</stream-applications.version>
|
||||
<mariadb-client.version>2.6.2</mariadb-client.version>
|
||||
<test-containers.version>1.15.0</test-containers.version>
|
||||
<test-containers.version>1.15.1</test-containers.version>
|
||||
<maven-checkstyle-plugin.version>3.1.0</maven-checkstyle-plugin.version>
|
||||
<disable.checks>false</disable.checks>
|
||||
<maven-checkstyle-plugin.failsOnError>true</maven-checkstyle-plugin.failsOnError>
|
||||
|
||||
@@ -46,8 +46,6 @@ public abstract class JdbcSinkTests {
|
||||
|
||||
private static StreamAppContainer sink;
|
||||
|
||||
//private static LogMatcher startupLogEntry = LogMatcher.contains("Started JdbcSink");
|
||||
|
||||
@Autowired
|
||||
private TestTopicSender testTopicSender;
|
||||
|
||||
@@ -64,7 +62,6 @@ public abstract class JdbcSinkTests {
|
||||
|
||||
@BeforeAll
|
||||
static void init() {
|
||||
// BaseContainerExtension.logMatcher().map(lm -> startupLogEntry = lm);
|
||||
sink = BaseContainerExtension.containerInstance()
|
||||
.dependsOn(mySQL)
|
||||
.withEnv("JDBC_CONSUMER_COLUMNS", "name,city:address.city,street:address.street")
|
||||
@@ -91,11 +88,6 @@ public abstract class JdbcSinkTests {
|
||||
.until(() -> jdbcTemplate.queryForObject("SELECT COUNT(*) from People", Integer.class)
|
||||
.intValue() == 0);
|
||||
sink.start();
|
||||
// await().atMost(DEFAULT_DURATION).conditionEvaluationListener(evaluatedCondition -> {
|
||||
// System.out.println("App started ....................................... in "
|
||||
// + evaluatedCondition.getElapsedTimeInMS());
|
||||
// }).until(startupLogEntry.matches());
|
||||
|
||||
}
|
||||
|
||||
@Test
|
||||
|
||||
Reference in New Issue
Block a user