Let's see if I can sample this :P.
--------
First i'm reading from kafka.
--------
FlinkKafkaConsumer010<DataParameterMap> consumer =
KafkaSource.consumer(this.zookeeper, this.sourceName, 5);
consumer.assignTimestampsAndWatermarks(KafkaTimestampExtractor.extractor());
--------
Then, converting my object(DataParameterMap) into a Row
--------
return ViewMapFunction.map(env.addSource(consumer), this.entity,
this.typeInfo);
--------
After that, I register the table
--------
tableEnv.registerTableSource("tableX", <previous object>)
--------
and I execute an sql ("SELECT APN, DATA_VOLUME_DOWN, DATA_VOLUME_UP, MSISDN
FROM
PGW_VIEW_A";)
--------
tableEnv.sql(sql).printSchema();
The error happens here at this point.
I'm using version 1.3.1
--
View this message in context:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Flink-shaded-table-API-tp14432p14435.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at
Nabble.com.
