snuyanzin commented on code in PR #21203:
URL: https://github.com/apache/flink/pull/21203#discussion_r1022488387
##########
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/casting/AbstractCodeGeneratorCastRule.java:
##########
@@ -204,9 +204,10 @@ public String getSessionTimeZoneTerm() {
}
@Override
- public String declareVariable(String type, String variablePrefix) {
+ public String declareVariable(String type, String variablePrefix,
String defaultValue) {
Review Comment:
I added these mentioned changes making Flink working with Calcite 1.28.0 and
Janino 3.0.11
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
