carbondata-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From 李立伟 <hilili...@gmail.com>
Subject [No Subject]
Date Wed, 28 Nov 2018 09:10:33 GMT
Hi,everyone
i create carbondata stream table like this

carbon.sql(
>
>       s"""
>         CREATE TABLE source1(
>           id INT,
>           name STRING,
>           age INT
>         )
>         STORED AS carbondata
>         TBLPROPERTIES(
>          'streaming'='source',
>          'format'='socket',
>          'host'='localhost',
>          'port'='8888',
>          'record_format'='csv',
>          'delimiter'='|'
>         )
>       """.stripMargin)
>
> when i start stream job on this table ,i get error log

carbon.sql("START STREAM source_job1 ON TABLE  source1").show()

org.apache.spark.sql.AnalysisException: == Parse1 ==
> missing 'TRANSACTION' at 'STREAM'(line 1, pos 6)
> == SQL ==
> START STREAM source_job1 ON TABLE  source1
> ------^^^
> == Parse2 ==
> [1.1] failure: identifier matching regex (?i)SHOW expected
> START STREAM source_job1 ON TABLE  source1
> ^;;
>   at
> org.apache.spark.sql.util.CarbonException$.analysisException(CarbonException.scala:23)
>   at
> org.apache.spark.sql.parser.CarbonSparkSqlParser.parsePlan(CarbonSparkSqlParser.scala:64)
>   at
> org.apache.spark.sql.CarbonSession.withProfiler(CarbonSession.scala:143)
>   at org.apache.spark.sql.CarbonSession.sql(CarbonSession.scala:93)
>   ... 51 elided



Ive tried multiple variations of this, but none of them seem to work. Any
ideas?

Mime
View raw message