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)

Reply via email to