diff --git a/flink-formats/flink-avro/pom.xml b/flink-formats/flink-avro/pom.xml index 50c7ec8f4e59d..7d3cdea4995de 100644 --- a/flink-formats/flink-avro/pom.xml +++ b/flink-formats/flink-avro/pom.xml @@ -102,11 +102,20 @@ under the License. org.apache.flink - flink-runtime_${scala.binary.version} + flink-scala_${scala.binary.version} ${project.version} test + + + org.apache.flink + flink-scala_${scala.binary.version} + ${project.version} + test + test-jar + + org.apache.flink flink-table-common diff --git a/flink-libraries/flink-cep/pom.xml b/flink-libraries/flink-cep/pom.xml index 32eac2a404345..7400edcd545fc 100644 --- a/flink-libraries/flink-cep/pom.xml +++ b/flink-libraries/flink-cep/pom.xml @@ -82,6 +82,14 @@ under the License. test + + + org.apache.flink + flink-scala_${scala.binary.version} + ${project.version} + test + + org.apache.flink flink-runtime_${scala.binary.version} diff --git a/flink-runtime/pom.xml b/flink-runtime/pom.xml index 6f5d302e91922..70a02449f4ff9 100644 --- a/flink-runtime/pom.xml +++ b/flink-runtime/pom.xml @@ -236,29 +236,6 @@ under the License. snappy-java - - - com.twitter - chill_${scala.binary.version} - ${chill.version} - - - - com.esotericsoftware.kryo - kryo - - - org.scala-lang - scala-library - - - - org.lz4 diff --git a/flink-scala/pom.xml b/flink-scala/pom.xml index 48006b391f15e..a78ac6271a124 100644 --- a/flink-scala/pom.xml +++ b/flink-scala/pom.xml @@ -78,19 +78,25 @@ under the License. flink-test-utils-junit + com.twitter chill_${scala.binary.version} ${chill.version} - test - - - - - org.apache.flink - flink-runtime_${scala.binary.version} - ${project.version} - test + + + + com.esotericsoftware.kryo + kryo + + + org.scala-lang + scala-library + + diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/types/FlinkChillPackageRegistrar.java b/flink-scala/src/main/scala/org/apache/flink/runtime/types/FlinkChillPackageRegistrar.java similarity index 100% rename from flink-runtime/src/main/java/org/apache/flink/runtime/types/FlinkChillPackageRegistrar.java rename to flink-scala/src/main/scala/org/apache/flink/runtime/types/FlinkChillPackageRegistrar.java diff --git a/flink-runtime/src/main/scala/org/apache/flink/runtime/types/FlinkScalaKryoInstantiator.scala b/flink-scala/src/main/scala/org/apache/flink/runtime/types/FlinkScalaKryoInstantiator.scala similarity index 100% rename from flink-runtime/src/main/scala/org/apache/flink/runtime/types/FlinkScalaKryoInstantiator.scala rename to flink-scala/src/main/scala/org/apache/flink/runtime/types/FlinkScalaKryoInstantiator.scala diff --git a/flink-runtime/src/main/scala/org/apache/flink/runtime/types/JavaIterableWrapperSerializer.scala b/flink-scala/src/main/scala/org/apache/flink/runtime/types/JavaIterableWrapperSerializer.scala similarity index 100% rename from flink-runtime/src/main/scala/org/apache/flink/runtime/types/JavaIterableWrapperSerializer.scala rename to flink-scala/src/main/scala/org/apache/flink/runtime/types/JavaIterableWrapperSerializer.scala diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/types/PriorityQueueSerializer.java b/flink-scala/src/main/scala/org/apache/flink/runtime/types/PriorityQueueSerializer.java similarity index 100% rename from flink-runtime/src/main/java/org/apache/flink/runtime/types/PriorityQueueSerializer.java rename to flink-scala/src/main/scala/org/apache/flink/runtime/types/PriorityQueueSerializer.java diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/misc/KryoSerializerRegistrationsTest.java b/flink-scala/src/test/java/org/apache/flink/runtime/misc/KryoSerializerRegistrationsTest.java similarity index 100% rename from flink-runtime/src/test/java/org/apache/flink/runtime/misc/KryoSerializerRegistrationsTest.java rename to flink-scala/src/test/java/org/apache/flink/runtime/misc/KryoSerializerRegistrationsTest.java diff --git a/flink-runtime/src/test/resources/flink_11-kryo_registrations b/flink-scala/src/test/resources/flink_11-kryo_registrations similarity index 100% rename from flink-runtime/src/test/resources/flink_11-kryo_registrations rename to flink-scala/src/test/resources/flink_11-kryo_registrations diff --git a/flink-streaming-java/pom.xml b/flink-streaming-java/pom.xml index c7192ce28f9f1..81643cd34e025 100644 --- a/flink-streaming-java/pom.xml +++ b/flink-streaming-java/pom.xml @@ -56,6 +56,13 @@ under the License. ${project.version} + + + org.apache.flink + flink-scala_${scala.binary.version} + ${project.version} + + org.apache.flink flink-java diff --git a/flink-table/flink-table-runtime-blink/pom.xml b/flink-table/flink-table-runtime-blink/pom.xml index ee41f8e0be0ba..ff0ff7fd71873 100644 --- a/flink-table/flink-table-runtime-blink/pom.xml +++ b/flink-table/flink-table-runtime-blink/pom.xml @@ -74,6 +74,14 @@ under the License. provided + + + org.apache.flink + flink-scala_${scala.binary.version} + ${project.version} + provided + + org.codehaus.janino janino diff --git a/pom.xml b/pom.xml index 7e2e39effda4c..3d40914f27f87 100644 --- a/pom.xml +++ b/pom.xml @@ -1475,7 +1475,7 @@ under the License. **/src/test/resources/*-data flink-tests/src/test/resources/testdata/terainput.txt flink-formats/flink-avro/src/test/resources/flink_11-kryo_registrations - flink-runtime/src/test/resources/flink_11-kryo_registrations + flink-scala/src/test/resources/flink_11-kryo_registrations flink-core/src/test/resources/kryo-serializer-config-snapshot-v1 flink-formats/flink-avro/src/test/resources/avro/*.avsc out/test/flink-avro/avro/user.avsc