We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
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
Describe the bug Udf parameters are interpreted as BigDecimals which causes existing udf to fail because they expect double.
To Reproduce Steps to reproduce the behavior, include:
CREATE STREAM riderLocations (profileId VARCHAR, latitude DOUBLE, longitude DOUBLE) WITH (kafka_topic='locations', key='profileId', value_format='json', partitions=1);
SELECT * FROM riderLocations WHERE GEO_DISTANCE(latitude, longitude, 37.4133, -122.1162) <= 5 EMIT CHANGES;
Actual behaviour A clear and concise description of what actually happens, including:
Code generation failed for Predicate: Function 'geo_distance' does not accept parameters of types:[DOUBLE, DOUBLE, DECIMAL(6, 4), DECIMAL(7, 4)]. expression:(GEO_DISTANCE(LATITUDE, LONGITUDE, 37.4133, -122.1162) <= 5), schema:`ROWKEY` STRING KEY, `ROWTIME` BIGINT, `ROWKEY` STRING, `PROFILEID` STRING, `LATITUDE` DOUBLE, `LONGITUDE` DOUBLE Caused by: Function 'geo_distance' does not accept parameters of types:[DOUBLE, DOUBLE, DECIMAL(6, 4), DECIMAL(7, 4)]
The text was updated successfully, but these errors were encountered:
agavra
Successfully merging a pull request may close this issue.
Describe the bug
Udf parameters are interpreted as BigDecimals which causes existing udf to fail because they expect double.
To Reproduce
Steps to reproduce the behavior, include:
Current master
No data needed
Quickstart guide:
Actual behaviour
A clear and concise description of what actually happens, including:
The text was updated successfully, but these errors were encountered: