Re: [jira] [Created] (FLINK-9832) Allow commas in job submission query params

2018-07-12 Thread Will Du
A got a similar issue that single quote ‘ get removed too. See if you can reproduce. Sent from my iPhone > On Jul 12, 2018, at 05:33, Ufuk Celebi (JIRA) wrote: > > Ufuk Celebi created FLINK-9832: > -- > > Summary: Allow commas in job submission quer

Re: Ask for SQL using kafka in Flink

2018-06-04 Thread Will Du
Yes, I am also looking for examples for Kafka avro table examples in java and command line. Also, Kafka avro table sink is still missing. In addition, once we have Kafka topic, the API should read the schema directly from schema file or schema registry. The way of current API supporting lacks of