(no subject)

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

(no subject)

李立伟
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?