Re: Bug in Table api CsvTableSink

2017-02-06 Thread Flavio Pompermaier
The error was just caused by a cut-and-paste on the shell instead of opening directly the file so bug solved :) On Mon, Feb 6, 2017 at 12:20 PM, Fabian Hueske wrote: > Hi Flavio, > > I checked the records on the current master and the CsvTableSink seemed to > work fine. > However, I had some iss

Re: Bug in Table api CsvTableSink

2017-02-06 Thread Fabian Hueske
Hi Flavio, I checked the records on the current master and the CsvTableSink seemed to work fine. However, I had some issues when converting the DataSet[Row] into a table. You have to make sure that the TypeInformation for DataSet[Row] is RowTypeInfo and not GenericType[Row]. Can you check the typ

Re: Bug in Table api CsvTableSink

2017-01-31 Thread Flavio Pompermaier
These 2 rows if converted to Row[] of Strings should cause the problem: http://www.aaa.it/xxx/v/10002780063t/000/1,f/10001957530,cf/13,cpva/77,cf/13,,sit/A2046X,strp/408,10921957530,,1,5,1,2013-01-04T15:02:25,5,,10002780063,XXX,1,,3,,,2013-01-04T15:02:25,XXX,XXX,13,2013-01-04T1

Re: Bug in Table api CsvTableSink

2017-01-31 Thread Flavio Pompermaier
I hope to have time to write a test program :) Otherwise I hope someone else could give it a try in the meantime.. Best, Flavio On Tue, Jan 31, 2017 at 4:49 PM, Fabian Hueske wrote: > Hi Flavio, > > I do not remember that such a bug was fixed. Maybe by chance, but I guess > not. > Can you open

Re: Bug in Table api CsvTableSink

2017-01-31 Thread Fabian Hueske
Hi Flavio, I do not remember that such a bug was fixed. Maybe by chance, but I guess not. Can you open a JIRA and maybe provide input data to reproduce the problem? Thank you, Fabian 2017-01-31 16:25 GMT+01:00 Flavio Pompermaier : > Hi to all, > I'm trying to read from a db and then writing to

Bug in Table api CsvTableSink

2017-01-31 Thread Flavio Pompermaier
Hi to all, I'm trying to read from a db and then writing to a csv. In my code I do the following: tableEnv.fromDataSet(myDataSet).writeToSink(new CsvTableSink(csvOutputDir, fieldDelim)); If I use fieldDelim= "," everything is Ok, if I use "\t" some tab is not printed correctly... PS: myDataSet is