Apache Flink RabbitMq SBT依賴性失敗

Question

我試圖使用Flink與RabbitMq流連接器。嘗試了所有可能的版本組合，但仍然失敗。

這裏是我的SBT構建片段

scalaVersion in ThisBuild := "2.11.7" 

val flinkVersion = "1.0.0" 

val json4sNative = "org.json4s" %% "json4s-native" % "3.3.0" 

val flinkDependencies = Seq(
    "org.apache.flink" %% "flink-scala" % flinkVersion % "provided", 
    "org.apache.flink" %% "flink-streaming-scala" % flinkVersion %  "provided", 
    "org.apache.flink" %% "flink-connector-rabbitmq" % "0.10.1", 
    json4sNative) 

片段錯誤的

[error] (root/*:assembly) deduplicate: different file contents found in the following: 
[error] /Users/gopigrip7/.ivy2/cache/javax.xml.stream/stax-api/jars/stax-api-1.0-2.jar:javax/xml/stream/EventFilter.class 
[error] /Users/gopigrip7/.ivy2/cache/stax/stax-api/jars/stax-api-1.0.1.jar:javax/xml/stream/EventFilter.class 
[error] deduplicate: different file contents found in the following: 
[error] /Users/gopigrip7/.ivy2/cache/javax.xml.stream/stax-api/jars/stax-api-1.0-2.jar:javax/xml/stream/FactoryConfigurationError.class 
[error] /Users/gopigrip7/.ivy2/cache/stax/stax-api/jars/stax-api-1.0.1.jar:javax/xml/stream/FactoryConfigurationError.class 
[error] deduplicate: different file contents found in the following: 
[error] /Users/gopigrip7/.ivy2/cache/javax.xml.stream/stax-api/jars/stax-api-1.0-2.jar:javax/xml/stream/FactoryFinder$1.class 
[error] /Users/gopigrip7/.ivy2/cache/stax/stax-api/jars/stax-api-1.0.1.jar:javax/xml/stream/FactoryFinder$1.class 
[error] deduplicate: different file contents found in the following: 
[error] /Users/gopigrip7/.ivy2/cache/javax.xml.stream/stax-api/jars/stax-api-1.0-2.jar:javax/xml/stream/FactoryFinder$ClassLoaderFinder.class 
[error] /Users/gopigrip7/.ivy2/cache/stax/stax-api/jars/stax-api-1.0.1.jar:javax/xml/stream/FactoryFinder$ClassLoaderFinder.class 
[error] deduplicate: different file contents found in the following: 
[error] /Users/gopigrip7/.ivy2/cache/javax.xml.stream/stax-api/jars/stax-api-1.0-2.jar:javax/xml/stream/FactoryFinder$ClassLoaderFinderConcrete.class 
[error] /Users/gopigrip7/.ivy2/cache/stax/stax-api/jars/stax-api-1.0.1.jar:javax/xml/stream/FactoryFinder$ClassLoaderFinderConcrete.class 
[error] deduplicate: different file contents found in the following: 
[error] /Users/gopigrip7/.ivy2/cache/javax.xml.stream/stax-api/jars/stax-api-1.0-2.jar:javax/xml/stream/FactoryFinder.class 
[error] /Users/gopigrip7/.ivy2/cache/stax/stax-api/jars/stax-api-1.0.1.jar:javax/xml/stream/FactoryFinder.class 
[error] deduplicate: different file contents found in the following: 
[error] 

Answer 1

你嘗試建立與同一弗林克相依的版本？我有以下SBT配置成功構建（sbt assembly）：

name := "flink-sbt-sample" 

version := "1.0" 

scalaVersion := "2.11.7" 

val flinkVersion = "1.0.0" 

libraryDependencies ++= Seq(
    "org.apache.flink" %% "flink-scala" % flinkVersion % "provided", 
    "org.apache.flink" %% "flink-streaming-scala" % flinkVersion % "provided", 
    "org.apache.flink" %% "flink-connector-rabbitmq" % flinkVersion, 
    "org.json4s" %% "json4s-native" % "3.3.0" 
) 

注意這裏是弗林克項目嚮導帶SBT（https://ci.apache.org/projects/flink/flink-docs-master/quickstart/scala_api_quickstart.html#sbt）。