Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3829#discussion_r139530556 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/calcite/FlinkPlannerImpl.scala --- @@ -85,16 +84,15 @@ class FlinkPlannerImpl( validator = new FlinkCalciteSqlValidator(operatorTable, createCatalogReader, typeFactory) validator.setIdentifierExpansion(true) try { - validatedSqlNode = validator.validate(sqlNode) + validator.validate(sqlNode) --- End diff -- indent -1 space
---