产品动态
INSERT INTO 数据目的表SELECT 子句
INSERT INTO KafkaSink1SELECT s1.time_, s1.client_ip, s1.uri, s1.protocol_version, s2.status_code, s2.date_FROM KafkaSource1 AS s1, KafkaSource2 AS s2WHERE s1.time_ = s2.time_ AND s1.client_ip = s2.client_ip;
org.apache.flink.table.api.ValidationException: Could not find any factory异常信息。flink-connector-kafka程序包,并将 connector.version参数设置为 universal,以获得最新的功能适配。不建议选择 flink-connector-kafka-0.11 等带版本号的旧版程序包。CREATE TABLE MySink (a VARCHAR,b BIGINT,c AS PROCTIME()) WITH ( ... ... );
文档反馈