Hi Yinhua, This is actually a bug in Flink table, you can check this issue https://issues.apache.org/jira/browse/FLINK-10290 <https://issues.apache.org/jira/browse/FLINK-10290>.
I opened a PR for this issue a couple of days ago, but there is still some problem so it’s not ready to be merged. We have used that in our internal Flink version, and for now it works well. May be you can take a look at it. Best, wangsan > On Oct 24, 2018, at 9:31 AM, yinhua.dai <yinhua.2...@outlook.com> wrote: > > Hi Timo, > > I write simple testing code for the issue, please checkout > https://gist.github.com/yinhua-dai/143304464270afd19b6a926531f9acb1 > > I write a custom table source which just use RowCsvInputformat to create the > dataset, and use the provided CsvTableSink, and can reproduce the issue. > > > > -- > Sent from: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
