Skip to content

[Bug]: Some flinksql grammar errors #464

@liuxy0551

Description

@liuxy0551

Version

latest

Which SQL?

Flink

SQL content

SELECT * FROM orders ORDER BY price * quantity ASC LIMIT 10;


INSERT INTO Paimon.iov_paimon_prd.ods_track_vcos_log_prs_hi
SELECT
vin AS vin, -- 车架号
-- Kafka时间戳转毫秒级(含毫秒精度)
UNIX_TIMESTAMP(DATE_FORMAT(kafka_timestamp, 'yyyy-MM-dd HH:mm:ss')) * 1000
+ EXTRACT(MILLISECOND FROM kafka_timestamp) AS kafka_ts -- Kafka时间戳(毫秒)
FROM ods_track_vcos_log_prs_rt2
WHERE JSON_VALUE(parse_track_pb(data), '$.eid') = '1570001000';


INSERT INTO Paimon.iov_paimon_prd.ods_track_vcos_log_prs_hi
SELECT
vin AS vin, -- 车架号
-- Kafka时间戳转毫秒级(含毫秒精度)
UNIX_TIMESTAMP(DATE_FORMAT(kafka_timestamp, 'yyyy-MM-dd HH:mm:ss')) * 1000
+ EXTRACT(MILLISECOND FROM kafka_timestamp) AS kafka_ts -- Kafka时间戳(毫秒)
FROM ods_track_vcos_log_prs_rt2
WHERE JSON_VALUE(parse_track_pb(data), '$.eid' RETURNING STRING) = '1570001000';

JavaScript/TypeScript code

What happened?

  • ORDER BY + expression
Image
  • EXTRACT 函数
Image
  • JSON_VALUE RETURNING

https://nightlies.apache.org/flink/flink-docs-release-1.16/docs/dev/table/functions/systemfunctions/

Image

Relevant log output

Metadata

Metadata

Assignees

Labels

No labels
No labels

Type

No type

Projects

No projects

Milestone

No milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions