-
Notifications
You must be signed in to change notification settings - Fork 1k
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
test: add DATE/TIME to connect integration test #7732
Conversation
final RestResponse<List<StreamedRow>> queryTime = ksqlRestClient.makeQueryRequest("SELECT CAST(PAYLOAD AS STRING) FROM TIME_STREAM EMIT CHANGES LIMIT 1;", 1L); | ||
final RestResponse<List<StreamedRow>> queryDate = ksqlRestClient.makeQueryRequest("SELECT CAST(PAYLOAD AS STRING) FROM DATE_STREAM EMIT CHANGES LIMIT 1;", 1L); |
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.
Shouldn't we wait on this PR until the string implicit casting is done automatically? Like the timestamp example.
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 was due to the REST API not converting Date/Time objects to String correctly. I ended up just adding that fix to this PR though, since it is a small fix.
@@ -35,6 +35,12 @@ | |||
<version>${io.confluent.ksql.version}</version> | |||
</dependency> | |||
|
|||
<dependency> | |||
<groupId>io.confluent.ksql</groupId> | |||
<artifactId>ksqldb-engine-common</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.
Needed because SqlTimeTypes
is in this package. It's a very lightweight package and only has one dependency on ksqldb-common
though.
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
Description
Check that DATE/TIME work with connect by adding them to the connect integration test.
Reviewer checklist