Error when querying a field with hyphen

[ardlema]

Fields with a hyphen prevent the queries from being executed. See below the output of the describe stream command:

ksql> describe sales;
Field           | Type                      
---------------------------------------------
 ROWTIME         | BIGINT           (system) 
 ROWKEY          | VARCHAR(STRING)  (system) 
 fecha-venta     | VARCHAR(STRING)           
 CANTIDAD        | DOUBLE                    
 CENTROCOMERCIAL | VARCHAR(STRING)           
---------------------------------------------
For runtime statistics and query details run: DESCRIBE EXTENDED <Stream,Table>;

And the output of the SELECT * from this stream:

ksql> select * from sales;
Code generation failed for SelectValueMapper
Caused by: Line 1, Column 12: Expression "SALES_fecha" is not an rvalue

[apurvam]

Which version of KSQL? Are you using Avro ?

[ardlema]

Than you for replying @apurvam : KSQL version 0.4 and I'm not using Avro.

[apurvam]

Can you share the statement where you created your stream/table called sales?

[apurvam]

Basically, I tried creating a stream like the following: CREATE STREAM TEST (ID bigint, NAME varchar, VALUE double, foo-dash VARCHAR) WITH (kafka_topic='test_topic', value_format='DELIMITED', key='ID'); and that statement itself failed to parse because of the hyphen. So I am not sure how you managed to create a stream with a hyphen in one of the fields.

[ardlema]

As per this issue: #769 I've created the stream using backticks, see following the statement:

CREATE STREAM test(`fecha-venta` varchar as fecha, cantidad double, centrocomercial varchar) WITH (kafka_topic='ventas-centro-comercial', value_format='JSON');

[Sebastien-GCN]

Same issue here.
We're able to create stream with either :

 CREATE STREAM myFirstKSQLStream ( `creation-time` BIGINT ) WITH (kafka_topic='my.topic' , value_format='JSON'); 

or even

CREATE STREAM myFirstKSQLStream ( "creation-time" BIGINT ) WITH (kafka_topic='my.topic' , value_format='JSON');

describe is working properly

 Name                 : MYFIRSTKSQLSTREAM
  Field                              | Type
 ----------------------------------------------------------------
  ROWTIME                            | BIGINT           (system)
  ROWKEY                             | VARCHAR(STRING)  (system)
 creation-time                       | BIGINT
 ----------------------------------------------------------------
 For runtime statistics and query details run: DESCRIBE EXTENDED <Stream,Table>;

However, the select fails.

[megaqube]

Would be nice if there is a workaround for fix. Exact same problem here.

[Sebastien-GCN]

No workaround ?

[OneCricketeer]

Copying another instance of the problem from Stackoverflow for documentation.

https://stackoverflow.com/q/53124857/2308683

[agavra]

Recent work in KSQL has fixed lots of issues, including this one, around quoted identifiers! Master, and subsequently the next release of KSQL, will include this fix:

ksql> CREATE STREAM myFirstKSQLStream ( `creation-time` BIGINT ) WITH (kafka_topic='my.topic' , value_format='JSON', partitions=1);

 Message
----------------
 Stream created
----------------
ksql> INSERT INTO myFirstKSQLStream (`creation-time`) VALUES (123);
ksql> SELECT * FROM myFirstKsqlStream EMIT CHANGES;
+------------------------------+------------------------------+------------------------------+
|ROWTIME                       |ROWKEY                        |creation-time                 |
+------------------------------+------------------------------+------------------------------+
|1571251498560                 |null                          |123                           |