flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Chesnay Schepler <ches...@apache.org>
Subject Re: Flink shaded table API
Date Tue, 25 Jul 2017 11:30:34 GMT
This sounds similar to https://issues.apache.org/jira/browse/FLINK-6173.

On 25.07.2017 13:07, nragon wrote:
> 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.
>


Mime
View raw message