-
Notifications
You must be signed in to change notification settings - Fork 162
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 backticks to column identifiers to fix queries for column names with .
#343
base: main
Are you sure you want to change the base?
Conversation
|
@@ -33,7 +33,7 @@ check_flink_version_supported $flink_minor_version | |||
flink_version="$(get_flink_version $flink_minor_version)" | |||
kafka_connector_version="$(get_kafka_connector_version $flink_minor_version)" | |||
|
|||
${MVN_CMD} clean package -DskipTests \ | |||
${MVN_CMD} clean package -DskipTests -Drat.skip=true \ |
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.
disable rat to get build to work
@@ -376,7 +376,7 @@ limitations under the License. | |||
<execution> | |||
<phase>package</phase> | |||
<goals> | |||
<goal>jar</goal> | |||
<goal>test-jar</goal> |
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.
hack to get build to work
for (int index : curProjectedFields) { | ||
String columnName = flinkSchema.getFieldName(index).get(); | ||
String columnName = "`" + flinkSchema.getFieldName(index).get() + "`"; |
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.
backtick added here
@@ -85,7 +85,7 @@ public String visit(ValueLiteralExpression valueLiteral) { | |||
|
|||
@Override | |||
public String visit(FieldReferenceExpression fieldReference) { | |||
return fieldReference.getName(); | |||
return "`" + fieldReference.getName() + "`"; |
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.
backtick added here
As title
Not production ready yet - need to make this solution a little bit cleaner and ensure no regressions occur