You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
When creating a stream with mixed case fields and using one of them for PARTITION BY clause using double quotes to preserve case-sensitiveness it does not work and throws error. It recognizes only upper case fields,.
CREATE STREAM TEST_TIMESTAMP_X3 AS
select after->location_number AS "locationID", after->sku AS "itemID", after->qty AS "quantity"
from STREAM_tv_test;
CREATE STREAM TEST_TIMESTAMP_X3_PARTITIONED WITH
(KAFKA_TOPIC='TEST_TIMESTAMP_X3',
VALUE_FORMAT='JSON') AS
SELECT * FROM TEST_TIMESTAMP_X3
PARTITION BY "locationID"; --> Column LOCATIONID does not exist in the result schema. Error in Partition By clause.
The text was updated successfully, but these errors were encountered:
Hi @rajbhino - quoted identifiers don't yet work correctly in KSQL. Sorry for the confusion. Note: they are actively being worked on, so we should be able to support this very soon.
When creating a stream with mixed case fields and using one of them for PARTITION BY clause using double quotes to preserve case-sensitiveness it does not work and throws error. It recognizes only upper case fields,.
CREATE STREAM TEST_TIMESTAMP_X3 AS
select after->location_number AS "locationID", after->sku AS "itemID", after->qty AS "quantity"
from STREAM_tv_test;
CREATE STREAM TEST_TIMESTAMP_X3_PARTITIONED WITH
(KAFKA_TOPIC='TEST_TIMESTAMP_X3',
VALUE_FORMAT='JSON') AS
SELECT * FROM TEST_TIMESTAMP_X3
PARTITION BY "locationID"; --> Column LOCATIONID does not exist in the result schema. Error in Partition By clause.
The text was updated successfully, but these errors were encountered: