A question about flink sql retreact stream

2020-11-04 Thread Henry Dai
Dear flink developers&users I have a question about flink sql, It gives me a lot of trouble, Thank you very much for some help. Lets's assume we have two data stream, `order` and `order_detail`, they are from mysql binlog. Table `order` schema: id int primary key

A question about flink sql retreact stream

2020-11-04 Thread Henry Dai
Dear flink developers&users I have a question about flink sql, It gives me a lot of trouble, Thank you very much for some help. Lets's assume we have two data stream, `order` and `order_detail`, they are from mysql binlog. Table `order` schema: id int primary key

A question of Flink SQL aggregation

2020-11-04 Thread Henry Dai
Hi, Let's assume we have two stream, order stream& order detail stream, they are from mysql binlog. Table `order` schema: id primary key, order_id and order_status Table `order_detail` schema: id primary key, order_id and quantity one order item have several order_detail items if we have follow

[no subject]

2018-11-27 Thread Henry Dai
Hi, Is there a way to get table's metadata in flink? if I emit a table to kafka, then how can I know the table columns when I subscribe the kafka topic and restore the table using *tableEnv.registerDataStream("t1", source, "field1, field2 ...") *in another flink program? Flink should provide some