Skip to content

fix: logging for flaky MySQLSchema E2E test #3198

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
csviri merged 4 commits into from
Mar 2, 2026
Merged

fix: logging for flaky MySQLSchema E2E test #3198

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
4 commits
Select commit Hold shift + click to select a range
ce60835
fix: flaky MySQLSchema E2E test
csviri Mar 2, 2026
d4aadd0
log fixes
csviri Mar 2, 2026
2c6f41c
logging improve
csviri Mar 2, 2026
22d7bd6
wip
csviri Mar 2, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
5 changes: 5 additions & 0 deletions sample-operators/mysql-schema/pom.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -90,6 +90,11 @@
<artifactId>operator-framework-junit</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.assertj</groupId>
<artifactId>assertj-core</artifactId>
<scope>test</scope>
</dependency>
</dependencies>

<build>
Expand Down
1 change: 1 addition & 0 deletions ...a/src/main/java/io/javaoperatorsdk/operator/sample/dependent/SchemaDependentResource.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -110,6 +110,7 @@ private Connection getConnection() throws SQLException {

@Override
public void delete(MySQLSchema primary, Context<MySQLSchema> context) {
log.debug("Deleting schema");
Copy link

Copilot AI Mar 2, 2026

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

The new debug log line is quite generic and may not help diagnose which resource is being deleted during flaky runs. Consider including identifying details (e.g., schema name/namespace and possibly username/secret when available) so the log can be correlated to a specific reconciliation/deletion event.

Copilot uses AI. Check for mistakes.
Copy link
Collaborator Author

@csviri csviri Mar 2, 2026

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Note that those are already included from MDC

try (Connection connection = getConnection()) {
var userName = primary.getStatus() != null ? primary.getStatus().getUserName() : null;
SchemaService.deleteSchemaAndRelatedUser(
Expand Down
5 changes: 4 additions & 1 deletion sample-operators/mysql-schema/src/main/resources/log4j2.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,10 @@
</Console>
</Appenders>
<Loggers>
<Root level="debug">
<Logger level="debug" name="io.javaoperatorsdk.operator" additivity="false">
<AppenderRef ref="Console"/>
</Logger>
<Root level="info">
<AppenderRef ref="Console"/>
</Root>
</Loggers>
Expand Down
16 changes: 6 additions & 10 deletions ...mysql-schema/src/test/java/io/javaoperatorsdk/operator/sample/MySQLSchemaOperatorE2E.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -36,12 +36,8 @@
import io.javaoperatorsdk.operator.sample.dependent.SchemaDependentResource;

import static java.util.concurrent.TimeUnit.MINUTES;
import static org.assertj.core.api.Assertions.assertThat;
import static org.awaitility.Awaitility.await;
import static org.hamcrest.CoreMatchers.equalTo;
import static org.hamcrest.CoreMatchers.is;
import static org.hamcrest.MatcherAssert.assertThat;
import static org.hamcrest.Matchers.notNullValue;
import static org.hamcrest.Matchers.nullValue;

class MySQLSchemaOperatorE2E {

Expand Down Expand Up @@ -114,10 +110,10 @@ void test() {
.inNamespace(operator.getNamespace())
.withName(testSchema.getMetadata().getName())
.get();
assertThat(updatedSchema.getStatus(), is(notNullValue()));
assertThat(updatedSchema.getStatus().getStatus(), equalTo("CREATED"));
assertThat(updatedSchema.getStatus().getSecretName(), is(notNullValue()));
assertThat(updatedSchema.getStatus().getUserName(), is(notNullValue()));
assertThat(updatedSchema.getStatus()).isNotNull();
assertThat(updatedSchema.getStatus().getStatus()).isEqualTo("CREATED");
assertThat(updatedSchema.getStatus().getSecretName()).isNotNull();
assertThat(updatedSchema.getStatus().getUserName()).isNotNull();
});

client
Expand All @@ -137,7 +133,7 @@ void test() {
.inNamespace(operator.getNamespace())
.withName(testSchema.getMetadata().getName())
.get();
assertThat(updatedSchema, is(nullValue()));
assertThat(updatedSchema).isNull();
});
}
}