Hi,
I use Flink source master to build a snapshot and use the jars in my
project. The goal is to avoid hacky deserialization code caused by avro 1.8
in old Flink versions since Flink 1.12 uses avro 1.10. Unfortunately, the
code throws below ClassNotFoundException. I have verified that the
akka-act
Hi Lian,
I suspect that it is caused by an incompatible Akka version. Flink uses
Akka 2.5.21 instead of 2.5.12. Moreover, you are mixing Flink jars which
use Scala 2.11 with Akka dependencies which are built against Scala 2.12.
I am not an Gradle expert but can't Gradle simply pull in the transit
Thanks Till. Making the scala version consistent using 2.11 solved the
ClassNotFoundException.
On Tue, Sep 29, 2020 at 11:58 PM Till Rohrmann wrote:
> Hi Lian,
>
> I suspect that it is caused by an incompatible Akka version. Flink uses
> Akka 2.5.21 instead of 2.5.12. Moreover, you are mixing F
Great to hear that it works now :-)
On Fri, Oct 2, 2020 at 2:17 AM Lian Jiang wrote:
> Thanks Till. Making the scala version consistent using 2.11 solved the
> ClassNotFoundException.
>
> On Tue, Sep 29, 2020 at 11:58 PM Till Rohrmann
> wrote:
>
>> Hi Lian,
>>
>> I suspect that it is caused by
