You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@samza.apache.org by "Weiqing Yang (JIRA)" <ji...@apache.org> on 2018/10/16 20:57:00 UTC

[jira] [Resolved] (SAMZA-1937) Enable users to perform Sql queries (SELECT statement)

     [ https://issues.apache.org/jira/browse/SAMZA-1937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Weiqing Yang resolved SAMZA-1937.
---------------------------------
    Resolution: Fixed

> 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
>            Priority: Major
>             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)