??????:
{
"types": "pg",
"event_time_line": [{
"count": 24,
"rule_name": "????24"
},
{
"count": 25,
"rule_name": "??????25"
}
]
}
DDL:
CREATE TABLE sourceTable (
types varchar,
event_time_line ROW (
`rule_name` VARCHAR,
`count` VARCHAR
),
proctime AS PROCTIME ()
) WITH (
'connector.type' = 'kafka',
'connector.version' = 'universal',
'connector.startup-mode' = 'earliest-offset',
'connector.topic' = 'topic_test_1',
'connector.properties.zookeeper.connect' = 'localhost:2181',
'connector.properties.bootstrap.servers' = 'localhost:9092',
'update-mode' = 'append',
'format.type' = 'json',
'format.derive-schema' = 'true',
'format.json-schema' = '{type: "object", properties:
{"types":{type:"string"}},{ "event_time_line": {type:"object",
"properties":
{"rule_name": {type: "string"}},
"count": {"type": "string"}}}}'
);
ERROR:
table field 'event_time_line' does not match with the physical type
ROW<`rule_name` STRING> of the 'event_time_line' field of the TableSource
return type.