Dataphin中Flink任务执行报错

CREATE TEMPORARY TABLE tbl_test(
id int,
num int
) WITH (
  'connector' = 'kafka',
  'topic' = 'order_line',
  'properties.bootstrap.servers' = 'kafka1.xcf.net:9092,kafka2.xcf.net:9092,kafka3.xcf.net:9092',
  'properties.group.id' = 'flink-oc-rt2-test2',
  'format' = 'json',
  'scan.startup.mode' = 'latest-offset'
);