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?
