Weiqing Yang created SAMZA-1937: ----------------------------------- Summary: Enable users to perform Sql queries (SELECT statement) Key: SAMZA-1937 URL: https://issues.apache.org/jira/browse/SAMZA-1937 Project: Samza Issue Type: Bug Components: sql Reporter: Weiqing Yang Fix For: 0.15.0
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. -- This message was sent by Atlassian JIRA (v7.6.3#76005)