Re: Compiler error while using 'CsvTableSource'

2017-02-06 Thread nsengupta
NabbleNamespace-nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespace&am

Re: Compiler error while using 'CsvTableSource'

2017-02-06 Thread Timo Walther
the air, your work need not be lost. That is where they should be. Now put the foundation under them." ---------------- View this message in context: Re: Compiler error while using 'CsvTableSource' <http://apache-flink-user-mailing-list-archive.2336050

Re: Compiler error while using 'CsvTableSource'

2017-02-04 Thread nsengupta
Thanks, Till, for taking time to share your understanding. -- N On Sun, Feb 5, 2017 at 12:49 AM, Till Rohrmann [via Apache Flink User Mailing List archive.] wrote: > I think the problem is that there are actually two constructors with the > same signature. The one is defined with default argume

Re: Compiler error while using 'CsvTableSource'

2017-02-04 Thread Till Rohrmann
I think the problem is that there are actually two constructors with the same signature. The one is defined with default arguments and the other has the same signature as the one with default arguments when you leave all default arguments out. I assume that this confuses the Scala compiler and only

Re: Compiler error while using 'CsvTableSource'

2017-02-03 Thread nsengupta
Till, Many thanks. Just to confirm that it is working fine at my end, here's a screenshot. This is Flink 1.1.4 but Flink-1.2/Flink-1.3 shouldn't be any problem. It never struck me that lack of

Re: Compiler error while using 'CsvTableSource'

2017-02-03 Thread Till Rohrmann
This should do the trick val csvTableSource = new CsvTableSource("foobar", Array("base"), Array[org.apache.flink.api.common.typeinfo.TypeInformation[_]](Types.STRING)). The problem is that arrays in Scala are not covariant. Cheers, Till ​ On Fri, Feb 3, 2017 at 6:39 AM, nsengupta wrote: > Til,

Re: Compiler error while using 'CsvTableSource'

2017-02-02 Thread nsengupta
Til, FWIW, I have fired the entire testsuite for Flink latest Snapshot. Almost all testcases passed, particularly this one: This case uses a bulit-in loaded CSV (in org.apache.flink.table.api.s

Re: Compiler error while using 'CsvTableSource'

2017-02-02 Thread nsengupta
Hello Till, Many thanks for a quick reply. I have tried to follow your suggestion, with no luck: Just to give it a shot, I have tried this too (following Flink Documentation):

Re: Compiler error while using 'CsvTableSource'

2017-02-02 Thread Till Rohrmann
Hi Nirmalya, could you try casting the Types.STRING into a org.apache.flink.api.common.typeinfo.TypeInformation[String] type? Cheers, Till On Thu, Feb 2, 2017 at 5:55 PM, nsengupta wrote: > I am using *flink-shell*, available with flink-1.2-SNAPSHOT. > > While loading a CSV file into a CsvTabl