Skip to content

Commit 7d9ca1a

Browse files
committed
test: #464 flink JSON_VALUE RETURNING
1 parent f76619f commit 7d9ca1a

File tree

1 file changed

+6
-0
lines changed

1 file changed

+6
-0
lines changed

test/parser/flink/syntax/fixtures/insertFromSelectQueries.sql

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -76,3 +76,9 @@ UNIX_TIMESTAMP(DATE_FORMAT(kafka_timestamp, 'yyyy-MM-dd HH:mm:ss')) * 1000
7676
+ EXTRACT(MILLISECOND FROM kafka_timestamp) AS kafka_ts -- Kafka时间戳(毫秒)
7777
FROM ods_track_vcos_log_prs_rt2
7878
WHERE JSON_VALUE(parse_track_pb(data), '$.eid') = '1570001000';
79+
80+
INSERT INTO Paimon.iov_paimon_prd.ods_track_vcos_log_prs_hi
81+
SELECT
82+
vin AS vin
83+
FROM ods_track_vcos_log_prs_rt2
84+
WHERE JSON_VALUE(parse_track_pb(data), '$.eid' RETURNING STRING) = '1570001000';

0 commit comments

Comments
 (0)