ah it seems that one needs to use chill 0.7.6 in order to get it to work
with flink.

On Sat, Apr 24, 2021 at 1:18 PM Prashant Deva <prash...@astradot.com> wrote:

> I am trying to use chill-protobuf to serialize protobuf messages.
> However, I am getting this exception:
>
>
> Caused by: java.lang.NoSuchMethodError: 'boolean
> com.twitter.chill.java.Java8ClosureRegistrar.areOnJava8
> <http://com.twitter.chill.java.java8closureregistrar.areonjava8/>()'
> at com.twitter.chill.KryoBase.isJavaLambda(KryoBase.scala:47)
> at com.twitter.chill.KryoBase.getRegistration(KryoBase.scala:50)
> at com.esotericsoftware.kryo.Kryo.getSerializer(Kryo.java:476
> <http://kryo.java:476/>)
> at com.esotericsoftware.kryo.Kryo.copy(Kryo.java:862
> <http://kryo.java:862/>)
> at org.apache.flink.api.java.typeutils.runtime.kryo.KryoSerializer.copy
> <http://org.apache.flink.api.java.typeutils.runtime.kryo.kryoserializer.copy/>
> (KryoSerializer.java:260 <http://kryoserializer.java:260/>)
> at
> org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.pushToOperator(
> CopyingChainingOutput.java:69 <http://copyingchainingoutput.java:69/>)
> at org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.collect(
> CopyingChainingOutput.java:46 <http://copyingchainingoutput.java:46/>)
> at org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.collect(
> CopyingChainingOutput.java:26 <http://copyingchainingoutput.java:26/>)
> at org.apache.flink.streaming.api.operators.CountingOutput.collect(
> CountingOutput.java:50 <http://countingoutput.java:50/>)
> at org.apache.flink.streaming.api.operators.CountingOutput.collect(
> CountingOutput.java:28 <http://countingoutput.java:28/>)
> at
> org.apache.flink.streaming.api.operators.StreamSourceContexts$ManualWatermarkContext.processAndCollectWithTimestamp(
> StreamSourceContexts.java:322 <http://streamsourcecontexts.java:322/>)
> at
> org.apache.flink.streaming.api.operators.StreamSourceContexts$WatermarkContext.collectWithTimestamp(
> StreamSourceContexts.java:426 <http://streamsourcecontexts.java:426/>)
> at
> org.apache.flink.streaming.connectors.kafka.internals.AbstractFetcher.emitRecordsWithTimestamps(
> AbstractFetcher.java:365 <http://abstractfetcher.java:365/>)
> at
> org.apache.flink.streaming.connectors.kafka.internals.KafkaFetcher.partitionConsumerRecordsHandler(
> KafkaFetcher.java:183 <http://kafkafetcher.java:183/>)
> at
> org.apache.flink.streaming.connectors.kafka.internals.KafkaFetcher.runFetchLoop(
> KafkaFetcher.java:142 <http://kafkafetcher.java:142/>)
> at org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBase.run
> <http://org.apache.flink.streaming.connectors.kafka.flinkkafkaconsumerbase.run/>
> (FlinkKafkaConsumerBase.java:826 <http://flinkkafkaconsumerbase.java:826/>
> )
> at org.apache.flink.streaming.api.operators.StreamSource.run
> <http://org.apache.flink.streaming.api.operators.streamsource.run/>(
> StreamSource.java:110 <http://streamsource.java:110/>)
> at org.apache.flink.streaming.api.operators.StreamSource.run
> <http://org.apache.flink.streaming.api.operators.streamsource.run/>(
> StreamSource.java:66 <http://streamsource.java:66/>)
> at
> org.apache.flink.streaming.runtime.tasks.SourceStreamTask$LegacySourceFunctionThread.run
> <http://org.apache.flink.streaming.runtime.tasks.sourcestreamtask$legacysourcefunctionthread.run/>
> (SourceStreamTask.java:263 <http://sourcestreamtask.java:263/>)
>
>
>
> Here is my dependencies. It seems fine according to the docs.
> Am i doing something wrong? How do I fix this?
>
>
>        <dependency>
>             <groupId>org.apache.flink</groupId>
>             <artifactId>flink-clients_2.12</artifactId>
>             <version>${flink.version}</version>
>         </dependency>
>
>         <dependency>
>             <groupId>org.apache.flink</groupId>
>             <artifactId>flink-streaming-java_2.12</artifactId>
>             <version>${flink.version}</version>
>         </dependency>
>
>         <dependency>
>             <groupId>org.apache.flink</groupId>
>             <artifactId>flink-connector-kafka_2.12</artifactId>
>             <version>${flink.version}</version>
>         </dependency>
>
>         <dependency>
>             <groupId>com.google.protobuf</groupId>
>             <artifactId>protobuf-java</artifactId>
>             <version>3.15.8</version>
>         </dependency>
>
>         <dependency>
>             <groupId>com.twitter</groupId>
>             <artifactId>chill-protobuf</artifactId>
>             <version>0.9.5</version>
>             <!-- exclusions for dependency conversion -->
>             <exclusions>
>                 <exclusion>
>                     <groupId>com.esotericsoftware.kryo</groupId>
>                     <artifactId>kryo</artifactId>
>                 </exclusion>
>             </exclusions>
>         </dependency>
>
> Sent via Superhuman <https://sprh.mn/?vip=prash...@astradot.com>
>
>

Reply via email to