[ 
https://issues.apache.org/jira/browse/FLINK-20236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17237282#comment-17237282
 ] 

Rui Li commented on FLINK-20236:
--------------------------------

Hi [~ZhuShang], I downloaded 1.11 from 
[here|https://archive.apache.org/dist/flink/flink-1.11.1/flink-1.11.1-bin-scala_2.11.tgz]
 and it seems the protobuf-java classes are already relocated in flink-dist. Is 
it possible the classes come from other jars?
{noformat}
[lirui@liruideMacBook-Pro lib]# jar tf flink-dist_2.11-1.11.1.jar |grep 
protobuf/Descriptors
akka/protobuf/Descriptors$1.class
akka/protobuf/Descriptors$Descriptor.class
akka/protobuf/Descriptors$DescriptorPool$DescriptorIntPair.class
akka/protobuf/Descriptors$DescriptorPool$PackageDescriptor.class
akka/protobuf/Descriptors$DescriptorPool$SearchFilter.class
akka/protobuf/Descriptors$DescriptorPool.class
akka/protobuf/Descriptors$DescriptorValidationException.class
akka/protobuf/Descriptors$EnumDescriptor.class
akka/protobuf/Descriptors$EnumValueDescriptor.class
akka/protobuf/Descriptors$FieldDescriptor$JavaType.class
akka/protobuf/Descriptors$FieldDescriptor$Type.class
akka/protobuf/Descriptors$FieldDescriptor.class
akka/protobuf/Descriptors$FileDescriptor$InternalDescriptorAssigner.class
akka/protobuf/Descriptors$FileDescriptor.class
akka/protobuf/Descriptors$GenericDescriptor.class
akka/protobuf/Descriptors$MethodDescriptor.class
akka/protobuf/Descriptors$ServiceDescriptor.class
akka/protobuf/Descriptors.class
org/apache/flink/mesos/shaded/com/google/protobuf/Descriptors$1.class
org/apache/flink/mesos/shaded/com/google/protobuf/Descriptors$Descriptor.class
org/apache/flink/mesos/shaded/com/google/protobuf/Descriptors$DescriptorPool$DescriptorIntPair.class
org/apache/flink/mesos/shaded/com/google/protobuf/Descriptors$DescriptorPool$PackageDescriptor.class
org/apache/flink/mesos/shaded/com/google/protobuf/Descriptors$DescriptorPool$SearchFilter.class
org/apache/flink/mesos/shaded/com/google/protobuf/Descriptors$DescriptorPool.class
org/apache/flink/mesos/shaded/com/google/protobuf/Descriptors$DescriptorValidationException.class
org/apache/flink/mesos/shaded/com/google/protobuf/Descriptors$EnumDescriptor.class
org/apache/flink/mesos/shaded/com/google/protobuf/Descriptors$EnumValueDescriptor.class
org/apache/flink/mesos/shaded/com/google/protobuf/Descriptors$FieldDescriptor$JavaType.class
org/apache/flink/mesos/shaded/com/google/protobuf/Descriptors$FieldDescriptor$Type.class
org/apache/flink/mesos/shaded/com/google/protobuf/Descriptors$FieldDescriptor.class
org/apache/flink/mesos/shaded/com/google/protobuf/Descriptors$FileDescriptor$InternalDescriptorAssigner.class
org/apache/flink/mesos/shaded/com/google/protobuf/Descriptors$FileDescriptor.class
org/apache/flink/mesos/shaded/com/google/protobuf/Descriptors$GenericDescriptor.class
org/apache/flink/mesos/shaded/com/google/protobuf/Descriptors$MethodDescriptor.class
org/apache/flink/mesos/shaded/com/google/protobuf/Descriptors$OneofDescriptor.class
org/apache/flink/mesos/shaded/com/google/protobuf/Descriptors$ServiceDescriptor.class
org/apache/flink/mesos/shaded/com/google/protobuf/Descriptors.class
{noformat}

> flink-dist.jar and hive-exec.jar have conflict with protobuf-java.jar
> ---------------------------------------------------------------------
>
>                 Key: FLINK-20236
>                 URL: https://issues.apache.org/jira/browse/FLINK-20236
>             Project: Flink
>          Issue Type: Bug
>          Components: Build System, Connectors / Hive
>    Affects Versions: 1.12.0, 1.11.1
>         Environment: flink 1.11.1
> hive 2.3.4
>            Reporter: CloseRiver
>            Priority: Critical
>             Fix For: 1.12.0, 1.11.3
>
>
> We customed the protobuf format.When using the hive catalog and consume the 
> protobuf data from kafka,the following exception appear
> {code:java}
> java.lang.NoSuchMethodError: 
> com.google.protobuf.Descriptors$Descriptor.getOneofs()Ljava/util/List;java.lang.NoSuchMethodError:
>  com.google.protobuf.Descriptors$Descriptor.getOneofs()Ljava/util/List; at 
> com.google.protobuf.GeneratedMessageV3$FieldAccessorTable.<init>(GeneratedMessageV3.java:1813)
> {code}
> What should i do,exclude the protobuf-java from flink-dist or from hive-exec.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to