????????
????????flink??????????????????join??????????????join??????????????????????????????https://help.aliyun.com/document_detail/62506.html??flink
sql?????????? ddl??????
create table phoneNumber( name VARCHAR, phoneNumber bigint, primary key(name),
PERIOD FOR SYSTEM_TIME )with( type='rds' );
??????????????????
create table source_1(
id int,
data TINYINT,
primary key (id),
PERIOD FOR SYSTEM_TIME
)with(
'connector' = 'datagen',
'fields.id.kind'='sequence',
'fields.id.start'='5',
'fields.id.end'='8',
'fields.data.kind'='sequence',
'fields.data.start'='4',
'fields.data.end'='11'
)??????????????????????
py4j.protocol.Py4JJavaError: An error occurred while calling o1.executeSql.
: org.apache.flink.table.api.SqlParserException: SQL parse failed. Incorrect
syntax near the keyword 'PERIOD' at line 6, column 9.
Was expecting one of:
"CONSTRAINT" ...
"PRIMARY" ...
????
??????????????????flink????????????????????????????????????????????
CREATE TABLE currency_rates ( currency STRING, conversion_rate
DECIMAL(32, 2), update_time TIMESTAMP(3) METADATA FROM
`values.source.timestamp` VIRTUAL, WATERMARK FOR update_time AS
update_time, PRIMARY KEY(currency) NOT ENFORCED ) WITH ( 'connector' =
'kafka', 'value.format' = 'debezium-json', /* ... */
);????????????????????????????1.????????????????datagen??????????????????pyflink
1.14
??????????????ddl??2.????????????ddl????????????????ddl????????????????????????????????????????3.????????????????????????????????????join????????????????????????
