-
Notifications
You must be signed in to change notification settings - Fork 13.8k
[FLINK-27185][connectors] Convert connector-jdbc module to assertj #19807
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.
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
Conversation
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
In general lgtm, I left some comments
...ors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/JdbcDataTypeTest.java
Outdated
Show resolved
Hide resolved
.../flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/JdbcInputFormatTest.java
Outdated
Show resolved
Hide resolved
.../flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/JdbcInputFormatTest.java
Outdated
Show resolved
Hide resolved
...nector-jdbc/src/test/java/org/apache/flink/connector/jdbc/catalog/PostgresCatalogITCase.java
Outdated
Show resolved
Hide resolved
...nector-jdbc/src/test/java/org/apache/flink/connector/jdbc/catalog/PostgresCatalogITCase.java
Outdated
Show resolved
Hide resolved
...va/org/apache/flink/connector/jdbc/internal/connection/SimpleJdbcConnectionProviderTest.java
Outdated
Show resolved
Hide resolved
...va/org/apache/flink/connector/jdbc/internal/connection/SimpleJdbcConnectionProviderTest.java
Outdated
Show resolved
Hide resolved
...tor-jdbc/src/test/java/org/apache/flink/connector/jdbc/table/JdbcRowDataInputFormatTest.java
Outdated
Show resolved
Hide resolved
...tor-jdbc/src/test/java/org/apache/flink/connector/jdbc/table/JdbcRowDataInputFormatTest.java
Outdated
Show resolved
Hide resolved
...ctors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/xa/XidImplTest.java
Outdated
Show resolved
Hide resolved
6b10b67 to
4623827
Compare
|
Thanks for taking the time to review @snuyanzin, I just pushed again with the requested changes |
4623827 to
387a1f3
Compare
|
LGTM as soon as the build completes successfully |
387a1f3 to
097847a
Compare
|
LGTM |
|
@alpreu Sorry for replying that late, but what about also migrating from junit4 to junit5 as part of that effort? Since we decided to go for assertj/junit5 in general? What's the motivation of moving to assertj only? |
The migration to assertJ was mainly done using the script written by @slinkydeveloper (https://github.com/assertj/assertj-migrator). We did have to manually touch some files though because not all assertions worked out of the box and some had better alternatives. I believe there is another umbrella ticket tracking the Junit5 migration |
|
I see, thanks for clarification. I guess, you're refering to FLINK-25325. I'm just wondering why there's not |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Thanks, @alpreu . In the end, I decided to go over the diff once more as well because I was curious about the assertj migration. I identified a few nitty things which we might want to fix before merging...
...-jdbc/src/test/java/org/apache/flink/connector/jdbc/table/JdbcRowDataLookupFunctionTest.java
Outdated
Show resolved
Hide resolved
...-jdbc/src/test/java/org/apache/flink/connector/jdbc/table/JdbcRowDataLookupFunctionTest.java
Outdated
Show resolved
Hide resolved
...-jdbc/src/test/java/org/apache/flink/connector/jdbc/table/JdbcRowDataLookupFunctionTest.java
Outdated
Show resolved
Hide resolved
097847a to
d450d9f
Compare
There was no initial list of modules, people kept adding what they were working on. I agree that we should create a list for the sdk modules |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Thanks for addressing my comments. It looks good now. Two question popped up, though, when doing my final pass over the change. Please see them below...
...nk-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/JdbcRowOutputFormatTest.java
Show resolved
Hide resolved
...connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/table/JdbcOutputFormatTest.java
Show resolved
Hide resolved
Co-authored-by: slinkydeveloper <francescoguard@gmail.com> Co-authored-by: Sergey Nuyanzin <sergey.nuyanzin@aiven.io>
d450d9f to
41d785a
Compare
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM 👍
|
The CI failure isn't related to the change but is caused by FLINK-27791. I'm going to go ahead and merge the PR. |
Cherry-picked commits from #19660 to get the individual changes merged faster