Dependending on the build system used, you could check the dependency tree,
e.g. for Maven it would be `mvn dependency:tree
-Dincludes=org.apache.parquet`
Matthias
On Wed, Jun 30, 2021 at 8:40 AM Thomas Wang wrote:
> Thanks Matthias. Could you advise how I can confirm this in my environment?
>
Thanks Matthias. Could you advise how I can confirm this in my environment?
Thomas
On Tue, Jun 29, 2021 at 1:41 AM Matthias Pohl
wrote:
> Hi Rommel, Hi Thomas,
> Apache Parquet was bumped from 1.10.0 to 1.11.1 for Flink 1.12 in
> FLINK-19137 [1]. The error you're seeing looks like some dependen
Hi Rommel, Hi Thomas,
Apache Parquet was bumped from 1.10.0 to 1.11.1 for Flink 1.12 in
FLINK-19137 [1]. The error you're seeing looks like some dependency issue
where you have a version other than 1.11.1
of org.apache.parquet:parquet-column:jar on your classpath?
Matthias
[1] https://issues.apac
To give more information
parquet-avro version 1.10.0 with Flink 1.11.2 and it was running fine.
now Flink 1.12.1, the error msg shows up.
Thank you for help.
Rommel
On Tue, Jun 22, 2021 at 2:41 PM Thomas Wang wrote:
> Hi,
>
> We recently upgraded our Flink version from 1.11.2 to 1.12.1 a
Hi,
In 1.10 there is no
'Lorg/apache/flink/fs/s3presto/common/HadoopConfigLoader' . So I think
there might be a legacy S3FileSystemFactory in your jar. You could check
whether there is a 'org.apache.flink.fs.s3presto.common.HadoopConfigLoader'
in your jar or not. If there is one you could remove th
On Fri, May 6, 2016 at 2:47 PM, Adrian Bartnik
wrote:
>
> org.apache.flink
> flink-scala_2.11
> ${flink.version}
>
This should be flink-java. Did you manually create this or do you get
it from the quickstart scripts?
Fixed this,
error was due to miss match between my flink version installed and the one
I mentioned in my sbt file.
On Mon, Mar 7, 2016 at 2:33 PM, Vishnu Viswanath <
vishnu.viswanat...@gmail.com> wrote:
> Hi All,
>
> After successfully writing the wordcount program, I was trying to create a
> st
I'm sorry that we changed the method name between minor versions.
We'll soon bring some infrastructure in place a) mark the audience of
classes and b) ensure that public APIs are stable.
On Wed, Sep 2, 2015 at 9:04 PM, Ferenc Turi wrote:
> Ok. As I see only the method name was changed. It was a
Ok. As I see only the method name was changed. It was an unnecessary
modification which caused the incompatibility.
F.
On Wed, Sep 2, 2015 at 8:53 PM, Márton Balassi
wrote:
> Dear Ferenc,
>
> The Kafka consumer implementations was modified from 0.9.0 to 0.9.1,
> please use the new code. [1]
>
>
Dear Ferenc,
The Kafka consumer implementations was modified from 0.9.0 to 0.9.1, please
use the new code. [1]
I suspect that your com.nventdata.kafkaflink.sink.FlinkKafkaTopicWriterSink
depends on the way the Flink code used to look in 0.9.0, if you take a
closer look Robert changed the function
10 matches
Mail list logo
