Hi Fabian,
It's a dependency problem between our current libraries and flink's.
Thanks
--
View this message in context:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Flink-shaded-table-API-tp14432p14461.html
Sent from the Apache Flink User Mailing List archive. mailing l
Hi,
I tried to reproduce the problem, but did not get the exception you posted.
I implemented a job similar to yours and ran it both from the IDE and using
the flink submission client using the 1.3.1 binaries.
In both cases, the schema was correctly printed.
Do you get the exception in the IDE or
Well, it might be scala conflits on my client side since no job is sent to
stream environment.
When i remove print schema or explain the job in sent and executed properly
on flink side.
Thanks
--
View this message in context:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
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 consumer =
KafkaSource.consumer(this.zookeeper, this.sourceName, 5);
consum
Let's see if I can sample this :P.
First i'm reading from kafka.
FlinkKafkaConsumer010 consumer =
KafkaSource.consumer(this.zookeeper, this.sourceName, 5);
consumer.assignTimestampsAndWatermarks(KafkaTimestampExtractor.extractor());
Then, converting my object(Data
Can you post a small example to reproduce the issue?
Also, which version are you using?
Thanks,
Fabian
2017-07-25 12:44 GMT+02:00 nragon :
> I'm getting the following error when using table API:
>
> Caused by: java.lang.NoClassDefFoundError:
> org/apache/flink/shaded/calcite/com/fasterxml/jacks
