Re: [jira] [Created] (FLINK-15283) Scala version of TableSinkUtils has a problem when validating sinks.

2019-12-16 Thread jingjing bai
- I think you might have misunderstood the sink schema. It is a order field but not json (or mapping) field in table sink ddl. At least that's the case in Sql. - for exemple. DDL sink schema as and the sql is insert into table select A, C ,B from t2。 - A ,B and

Re: [DISCUSS] FLIP-85: Delayed Job Graph Generation

2019-12-18 Thread jingjing bai
hi peter: we had extension SqlClent to support sql job submit in web base on flink 1.9. we support submit to yarn on per job mode too. in this case, the job graph generated on client side . I think this discuss Mainly to improve api programme. but in my case , there is no jar to upload