Description
Current DSL converter does not support the use case that users use Samza Sql Console or Samza Sql shell to perform SELECT query. The reason is "log.outputStream" does not have schema while Calcite asks for its schema when Calcite do validation for the Sql statement (we only passed selectQuery to Calcite before, but now we pass the whole sql to Calcite). Also, it seems "log.outputStream" does not work with ModifyTranslator.