hi I have checked all the dependences, and don't find the jar with different version, so ,I double the way to submit jar has some issue? my commend is like this:
/data/flink1.6/bin/flink run -m yarn-cluster -ytm 8032 -yn 1 -ys 1 -yqu xxxx -yt /data/flink1.6/xxxx/lib -c com.xxx.xxx.xxx.Launch -C http://xx.xxx.xxx.xxx:80/lib/slf4j-api-1.7.6.jar -C http://xx.xxx.xxx.xxx:80/lib/lucene-spatial3d-7.3.1.jar -C http://xx.xxx.xxx.xxx:80/lib/lucene-backward-codecs-7.3.1.jar -C http://xx.xxx.xxx.xxx:80/lib/log4j-to-slf4j-2.9.1.jar -C http://xx.xxx.xxx.xxx:80/lib/jackson-dataformat-smile-2.8.10.jar -C http://xx.xxx.xxx.xxx:80/lib/mysql-connector-java-5.1.39.jar -C http://xx.xxx.xxx.xxx:80/lib/commons-lang-2.6.jar -C http://xx.xxx.xxx.xxx:80/lib/apacheds-kerberos-codec-2.0.0-M15.jar -C http://xx.xxx.xxx.xxx:80/lib/slf4j-log4j12-1.7.5.jar -C http://xx.xxx.xxx.xxx:80/lib/guava-12.0.1.jar -C http://xx.xxx.xxx.xxx:80/lib/netty-all-4.0.23.Final.jar -C http://xx.xxx.xxx.xxx:80/lib/scala-parser-combinators_2.11-1.0.4.jar -C http://xx.xxx.xxx.xxx:80/lib/lucene-spatial-7.3.1.jar -C http://xx.xxx.xxx.xxx:80/lib/commons-compress-1.4.1.jar xxxxx.jar and I put all the dependence to a nginx dir, is this way have problem? because I also encounter problems like this: org.apache.kafka.common.KafkaException: Failed to construct kafka consumer at org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:765) at org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:633) at org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:615) at org.apache.flink.streaming.connectors.kafka.internal.Kafka09PartitionDiscoverer.initializeConnections(Kafka09PartitionDiscoverer.java:58) at org.apache.flink.streaming.connectors.kafka.internals.AbstractPartitionDiscoverer.open(AbstractPartitionDiscoverer.java:94) at org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBase.open(FlinkKafkaConsumerBase.java:469) at org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:36) at org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.open(AbstractUdfStreamOperator.java:102) at org.apache.flink.streaming.runtime.tasks.StreamTask.openAllOperators(StreamTask.java:424) at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:290) at org.apache.flink.runtime.taskmanager.Task.run(Task.java:711) at java.lang.Thread.run(Thread.java:748) Caused by: org.apache.kafka.common.KafkaException: org.apache.kafka.common.serialization.ByteArrayDeserializer is not an instance of org.apache.kafka.common.serialization.Deserializer at org.apache.kafka.common.config.AbstractConfig.getConfiguredInstance(AbstractConfig.java:248) at org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:673) ... 11 more but in a fat jar, these work all good -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
