Dataphin中Flink任务执行报错

问题描述

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'
);

问题原因

不支持直接写建表语句。

解决方案

所有的实时表都通过图形化定义。

适用于

• Dataphin