You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
reacted with thumbs up emoji reacted with thumbs down emoji reacted with laugh emoji reacted with hooray emoji reacted with confused emoji reacted with heart emoji reacted with rocket emoji reacted with eyes emoji
-
CREATE SOURCE CDC_HR_WAF_CORE_ENTITY
(
EID VARCHAR,
CODE VARCHAR,
NAME VARCHAR,
TYPE VARCHAR,
UPDATETABLE VARCHAR,
PRIMARYKEY VARCHAR,
RESTRICTION VARCHAR,
DEFAULTSORT VARCHAR,
LISTEDITABLE VARCHAR,
LISTMODSUBMITLEVEL BIGINT,
LISTMODLIMITCODES VARCHAR,
LISTDELSUBMITLEVEL BIGINT,
LISTDELLIMITCODES VARCHAR,
DYNQUERYBAR VARCHAR,
PAGINATION VARCHAR,
PAGEPOSITION VARCHAR,
PAGESIZE BIGINT,
PAGELIST VARCHAR,
SHOWHEADER VARCHAR,
ROWNUMBERS VARCHAR,
SINGLESELECT VARCHAR,
NOWRAP VARCHAR,
STRIPED VARCHAR,
FITCOLUMNS VARCHAR,
FORMMODSUBMITLEVEL BIGINT,
FORMMODLIMITCODES VARCHAR,
SPRINGSPACE VARCHAR,
JPACKAGE VARCHAR,
JCO VARCHAR,
JBO VARCHAR,
JDAO VARCHAR,
JVO VARCHAR,
WLIST VARCHAR,
WFORM VARCHAR,
MRUT VARCHAR,
OPER VARCHAR,
NOTE VARCHAR,
COLASORGAN VARCHAR,
DYNENTITY VARCHAR,
TOTAL_ROW_REQUIRED VARCHAR
)
WITH (
connector = 'kafka',
--'debezium-avro-confluent.schema-registry.url' = 'http://kafka-stream-registry-cp-schema-registry.kafka-cluster:8081',
--'format' = 'debezium-avro-confluent',
properties.bootstrap.server = 'http://kafka-stream-kafka-bootstrap.kafka-cluster:9092',
--'properties.group.id' = 'flink-cdc',
scan.startup.mode = 'earliest',
topic = 'HR.HROUTPUT.WAF_CORE_ENTITY'
)
FORMAT DEBEZIUM
ENCODE AVRO (
schema.registry = 'http://kafka-stream-registry-cp-schema-registry.kafka-cluster:8081',
message = 'EID'
)
org.jkiss.dbeaver.model.sql.DBSQLException: SQL 错误 [XX000]: ERROR: Failed to execute the statement
Caused by:
Protocol error: User-defined schema from SQL is not allowed with FORMAT DEBEZIUM ENCODE AVRO. Please refer to https://www.risingwave.dev/docs/current/sql-create-source/ for more information.
Beta Was this translation helpful? Give feedback.
All reactions