-
Notifications
You must be signed in to change notification settings - Fork 3k
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
Migrate Kudu to use BaseConnectorTest #11113
Conversation
This is a preparatory commit for migrating to BaseConnectorTest.
Merge TestKuduDistributedQueries into AbstractKuduConnectorTest.
26ca440
to
79fe1c9
Compare
CI #11130 |
@@ -43,6 +43,12 @@ | |||
<artifactId>log</artifactId> | |||
</dependency> | |||
|
|||
<dependency> | |||
<groupId>io.airlift</groupId> | |||
<artifactId>log-manager</artifactId> |
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.
Just curious what is the log-manager dep for? I assumed it would be in test scope only.
@@ -152,4 +154,19 @@ public static Session createSession(String schema) | |||
.setSchema(schema) | |||
.build(); | |||
} | |||
|
|||
public static void main(String[] args) |
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.
This is just for manual testing correct?
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.
Yes. Also this is where log-manager gets pulled in because of Logging.initialize
.
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, just had a few questions
testColumnName(columnName, true); | ||
} | ||
|
||
private void testColumnName(String columnName, boolean delimited) |
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.
This is same as the definition inherited from AbstractTestDistributedQueries except for the CREATE TABLE query.
Can we make the method in ATDQ protected and override here with a comment so that we know to unify this/make base class more flexible at some point in future?
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.
This is a general deficiency in our base tests today - they cannot be adapted to fit different CREATE TABLE/CTAS syntax. The connectors which might benefit from this are ClickHouse, Druid, Kudu and Phoenix IIRC.
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.
I think we can make it protected
or extract one line for creating a table. Let me handle in another PR because other tests also has the similar issue.
Description
Migrate Kudu to use BaseConnectorTest
Related issues, pull requests, and links
Documentation
(x) No documentation is needed.
Release notes
(x) No release notes entries required.