[Bug]: FlinkSQL's function syntax problem

[Cythia828]

Version

lasted

Which SQL?

Flink

SQL content

insert into rocketmq_sink_1
select
    'rocket_mq' as type_name
    -- ,elements.`value` as col
    ,`columns` as v1
    ,JSON_VALUE(`columns`,'$[0].value') as col1     --  PLAN_MONTH
    ,JSON_VALUE(`columns`,'$[2].value') as col2     --  STATUS
    ,JSON_VALUE(`columns`,'$[6].value') as col3     --  SUB_ID
    ,JSON_VALUE(`columns`,'$[22].value') as col4     -- UNIONID
    ,JSON_VALUE(`columns`,'$[23].value') as col5      -- UPDATE_TIME
    -- ,JSON_VALUE(`columns`,'$[0].value') as col6
    -- ,opType as col
from rocketmq_source
-- ,unnest(`columns`) as elements
;


CREATE TABLE rocketmq_source(
    `columns` string,
    opType string
 )WITH(
    'consumer.group' = 'sss',
    'time.zone' = 'Asia/Shanghai',
    'connector' = 'rocketmq-x',
    'nameserver.address' = '172.18.0.633:9876;172.18.0.33:9876',
    'consumer.start-offset-mode' = 'timestamp',
    'topic' = 'xsfdf',
    'start.message-timestamp' = '1745513610910',
    'tag' = 'B_SUBSCRIBE_PLAN',
    'encoding' = 'utf-8'
 );

JavaScript/TypeScript code

What happened?

在具体使用过程中发现JSON_VALUE函数报错

Relevant log output

[mumiao]

done