退订

退订

Flink sql CLI parsing avro format data error 解析avro数据失败

i have Apache Avro schema 我的avro schema 如下 { "type" : "record", "name" : "KafkaAvroMessage", "namespace" : "xxx", "fields" : [ { "name" : "aaa", "type" : "string" }, { "name" : "bbb", "type" : [ "null", "string" ], "default" : null },{ "name" : "ccc", "

Flink sql CLI parsing avro format data error 解析avro数据失败

i have Apache Avro schema 我的avro schema 如下 { "type" : "record", "name" : "KafkaAvroMessage", "namespace" : "xxx", "fields" : [ { "name" : "aaa", "type" : "string" }, { "name" : "bbb", "type" : [ "null", "string" ], "default" : null },{ "name" : "ccc", "

Question regarding date conditions/row expirations on Dynamic Tables

27;s continuous query. I've posted the question to StackOverflow and it hasn't gotten any traction yet. Here's the SO question with a lot more detail: https://stackoverflow.com/questions/56227783/is-there-a-way-to-define-a-dynamic-table-comprised-of-entries-that-have-not-been Thanks, Wayne