This is an automated email from the ASF dual-hosted git repository.
gaoyunhaii pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-ml.git
The following commit(s) were added to refs/heads/master by this push:
new 551023c [hotfix] Move infra from flink-ml-lib to flink-ml-core
551023c is described below
commit 551023c7f96466e3dda51831e5af58b59427b7e6
Author: zhangzp <zhangzhipe...@gmail.com>
AuthorDate: Fri Nov 26 18:11:39 2021 +0800
[hotfix] Move infra from flink-ml-lib to flink-ml-core
This closes #39.
---
flink-ml-core/pom.xml | 42 +++++++++++++++++++---
.../ml/common/broadcast/BroadcastContext.java | 0
.../BroadcastStreamingRuntimeContext.java | 0
.../flink/ml/common/broadcast/BroadcastUtils.java | 0
.../operator/AbstractBroadcastWrapperOperator.java | 0
.../BroadcastVariableReceiverOperator.java | 0
.../BroadcastVariableReceiverOperatorFactory.java | 0
.../broadcast/operator/BroadcastWrapper.java | 0
.../operator/OneInputBroadcastWrapperOperator.java | 0
.../operator/TwoInputBroadcastWrapperOperator.java | 0
.../ml/common/broadcast/typeinfo/CacheElement.java | 0
.../broadcast/typeinfo/CacheElementSerializer.java | 0
.../broadcast/typeinfo/CacheElementTypeInfo.java | 0
.../ml/common/datastream/EndOfStreamWindows.java | 0
.../datastream/MapPartitionFunctionWrapper.java | 0
.../flink/ml/common/datastream/TableUtils.java | 0
.../ml/{ => common}/distance/DistanceMeasure.java | 2 +-
.../distance/EuclideanDistanceMeasure.java | 2 +-
.../common/iteration/ForwardInputsOfLastRound.java | 0
.../iteration/TerminateOnMaxIterationNum.java | 0
.../ml/common/broadcast/BroadcastUtilsTest.java | 0
.../apache/flink/ml/common/broadcast/TestSink.java | 0
.../flink/ml/common/broadcast/TestSource.java | 0
.../BroadcastVariableReceiverOperatorTest.java | 0
.../operator/BroadcastWrapperOperatorFactory.java | 0
.../OneInputBroadcastWrapperOperatorTest.java | 0
.../common/broadcast/operator/TestOneInputOp.java | 0
.../common/broadcast/operator/TestTwoInputOp.java | 0
.../TwoInputBroadcastWrapperOperatorTest.java | 0
flink-ml-lib/pom.xml | 7 ----
.../apache/flink/ml/clustering/kmeans/KMeans.java | 2 +-
.../flink/ml/clustering/kmeans/KMeansModel.java | 2 +-
.../flink/ml/common/param/HasDistanceMeasure.java | 2 +-
.../org/apache/flink/ml/clustering/KMeansTest.java | 2 +-
34 files changed, 43 insertions(+), 18 deletions(-)
diff --git a/flink-ml-core/pom.xml b/flink-ml-core/pom.xml
index 79a9654..6541a35 100644
--- a/flink-ml-core/pom.xml
+++ b/flink-ml-core/pom.xml
@@ -34,6 +34,13 @@ under the License.
<dependencies>
<dependency>
<groupId>org.apache.flink</groupId>
+ <artifactId>flink-ml-iteration</artifactId>
+ <version>${project.version}</version>
+ <scope>provided</scope>
+ </dependency>
+
+ <dependency>
+ <groupId>org.apache.flink</groupId>
<artifactId>flink-table-api-java</artifactId>
<version>${flink.version}</version>
<scope>provided</scope>
@@ -55,6 +62,21 @@ under the License.
<dependency>
<groupId>org.apache.flink</groupId>
+ <artifactId>flink-table-runtime_${scala.binary.version}</artifactId>
+ <version>${flink.version}</version>
+ <scope>provided</scope>
+ </dependency>
+
+ <dependency>
+ <groupId>org.apache.flink</groupId>
+ <artifactId>flink-streaming-java_${scala.binary.version}</artifactId>
+ <version>${flink.version}</version>
+ <scope>test</scope>
+ <type>test-jar</type>
+ </dependency>
+
+ <dependency>
+ <groupId>org.apache.flink</groupId>
<artifactId>flink-test-utils_${scala.binary.version}</artifactId>
<version>${flink.version}</version>
<scope>test</scope>
@@ -71,10 +93,20 @@ under the License.
<artifactId>blas</artifactId>
<version>2.2.0</version>
</dependency>
- <dependency>
- <groupId>org.apache.flink</groupId>
- <artifactId>flink-table-api-java-bridge_2.11</artifactId>
- <version>1.14.0</version>
- </dependency>
+
+ <dependency>
+ <groupId>org.apache.flink</groupId>
+ <artifactId>flink-table-api-java-bridge_2.11</artifactId>
+ <version>${flink.version}</version>
+ </dependency>
+
+ <dependency>
+ <groupId>org.mockito</groupId>
+ <artifactId>mockito-core</artifactId>
+ <version>2.21.0</version>
+ <type>jar</type>
+ <scope>test</scope>
+ </dependency>
+
</dependencies>
</project>
diff --git
a/flink-ml-lib/src/main/java/org/apache/flink/ml/common/broadcast/BroadcastContext.java
b/flink-ml-core/src/main/java/org/apache/flink/ml/common/broadcast/BroadcastContext.java
similarity index 100%
rename from
flink-ml-lib/src/main/java/org/apache/flink/ml/common/broadcast/BroadcastContext.java
rename to
flink-ml-core/src/main/java/org/apache/flink/ml/common/broadcast/BroadcastContext.java
diff --git
a/flink-ml-lib/src/main/java/org/apache/flink/ml/common/broadcast/BroadcastStreamingRuntimeContext.java
b/flink-ml-core/src/main/java/org/apache/flink/ml/common/broadcast/BroadcastStreamingRuntimeContext.java
similarity index 100%
rename from
flink-ml-lib/src/main/java/org/apache/flink/ml/common/broadcast/BroadcastStreamingRuntimeContext.java
rename to
flink-ml-core/src/main/java/org/apache/flink/ml/common/broadcast/BroadcastStreamingRuntimeContext.java
diff --git
a/flink-ml-lib/src/main/java/org/apache/flink/ml/common/broadcast/BroadcastUtils.java
b/flink-ml-core/src/main/java/org/apache/flink/ml/common/broadcast/BroadcastUtils.java
similarity index 100%
rename from
flink-ml-lib/src/main/java/org/apache/flink/ml/common/broadcast/BroadcastUtils.java
rename to
flink-ml-core/src/main/java/org/apache/flink/ml/common/broadcast/BroadcastUtils.java
diff --git
a/flink-ml-lib/src/main/java/org/apache/flink/ml/common/broadcast/operator/AbstractBroadcastWrapperOperator.java
b/flink-ml-core/src/main/java/org/apache/flink/ml/common/broadcast/operator/AbstractBroadcastWrapperOperator.java
similarity index 100%
rename from
flink-ml-lib/src/main/java/org/apache/flink/ml/common/broadcast/operator/AbstractBroadcastWrapperOperator.java
rename to
flink-ml-core/src/main/java/org/apache/flink/ml/common/broadcast/operator/AbstractBroadcastWrapperOperator.java
diff --git
a/flink-ml-lib/src/main/java/org/apache/flink/ml/common/broadcast/operator/BroadcastVariableReceiverOperator.java
b/flink-ml-core/src/main/java/org/apache/flink/ml/common/broadcast/operator/BroadcastVariableReceiverOperator.java
similarity index 100%
rename from
flink-ml-lib/src/main/java/org/apache/flink/ml/common/broadcast/operator/BroadcastVariableReceiverOperator.java
rename to
flink-ml-core/src/main/java/org/apache/flink/ml/common/broadcast/operator/BroadcastVariableReceiverOperator.java
diff --git
a/flink-ml-lib/src/main/java/org/apache/flink/ml/common/broadcast/operator/BroadcastVariableReceiverOperatorFactory.java
b/flink-ml-core/src/main/java/org/apache/flink/ml/common/broadcast/operator/BroadcastVariableReceiverOperatorFactory.java
similarity index 100%
rename from
flink-ml-lib/src/main/java/org/apache/flink/ml/common/broadcast/operator/BroadcastVariableReceiverOperatorFactory.java
rename to
flink-ml-core/src/main/java/org/apache/flink/ml/common/broadcast/operator/BroadcastVariableReceiverOperatorFactory.java
diff --git
a/flink-ml-lib/src/main/java/org/apache/flink/ml/common/broadcast/operator/BroadcastWrapper.java
b/flink-ml-core/src/main/java/org/apache/flink/ml/common/broadcast/operator/BroadcastWrapper.java
similarity index 100%
rename from
flink-ml-lib/src/main/java/org/apache/flink/ml/common/broadcast/operator/BroadcastWrapper.java
rename to
flink-ml-core/src/main/java/org/apache/flink/ml/common/broadcast/operator/BroadcastWrapper.java
diff --git
a/flink-ml-lib/src/main/java/org/apache/flink/ml/common/broadcast/operator/OneInputBroadcastWrapperOperator.java
b/flink-ml-core/src/main/java/org/apache/flink/ml/common/broadcast/operator/OneInputBroadcastWrapperOperator.java
similarity index 100%
rename from
flink-ml-lib/src/main/java/org/apache/flink/ml/common/broadcast/operator/OneInputBroadcastWrapperOperator.java
rename to
flink-ml-core/src/main/java/org/apache/flink/ml/common/broadcast/operator/OneInputBroadcastWrapperOperator.java
diff --git
a/flink-ml-lib/src/main/java/org/apache/flink/ml/common/broadcast/operator/TwoInputBroadcastWrapperOperator.java
b/flink-ml-core/src/main/java/org/apache/flink/ml/common/broadcast/operator/TwoInputBroadcastWrapperOperator.java
similarity index 100%
rename from
flink-ml-lib/src/main/java/org/apache/flink/ml/common/broadcast/operator/TwoInputBroadcastWrapperOperator.java
rename to
flink-ml-core/src/main/java/org/apache/flink/ml/common/broadcast/operator/TwoInputBroadcastWrapperOperator.java
diff --git
a/flink-ml-lib/src/main/java/org/apache/flink/ml/common/broadcast/typeinfo/CacheElement.java
b/flink-ml-core/src/main/java/org/apache/flink/ml/common/broadcast/typeinfo/CacheElement.java
similarity index 100%
rename from
flink-ml-lib/src/main/java/org/apache/flink/ml/common/broadcast/typeinfo/CacheElement.java
rename to
flink-ml-core/src/main/java/org/apache/flink/ml/common/broadcast/typeinfo/CacheElement.java
diff --git
a/flink-ml-lib/src/main/java/org/apache/flink/ml/common/broadcast/typeinfo/CacheElementSerializer.java
b/flink-ml-core/src/main/java/org/apache/flink/ml/common/broadcast/typeinfo/CacheElementSerializer.java
similarity index 100%
rename from
flink-ml-lib/src/main/java/org/apache/flink/ml/common/broadcast/typeinfo/CacheElementSerializer.java
rename to
flink-ml-core/src/main/java/org/apache/flink/ml/common/broadcast/typeinfo/CacheElementSerializer.java
diff --git
a/flink-ml-lib/src/main/java/org/apache/flink/ml/common/broadcast/typeinfo/CacheElementTypeInfo.java
b/flink-ml-core/src/main/java/org/apache/flink/ml/common/broadcast/typeinfo/CacheElementTypeInfo.java
similarity index 100%
rename from
flink-ml-lib/src/main/java/org/apache/flink/ml/common/broadcast/typeinfo/CacheElementTypeInfo.java
rename to
flink-ml-core/src/main/java/org/apache/flink/ml/common/broadcast/typeinfo/CacheElementTypeInfo.java
diff --git
a/flink-ml-lib/src/main/java/org/apache/flink/ml/common/datastream/EndOfStreamWindows.java
b/flink-ml-core/src/main/java/org/apache/flink/ml/common/datastream/EndOfStreamWindows.java
similarity index 100%
rename from
flink-ml-lib/src/main/java/org/apache/flink/ml/common/datastream/EndOfStreamWindows.java
rename to
flink-ml-core/src/main/java/org/apache/flink/ml/common/datastream/EndOfStreamWindows.java
diff --git
a/flink-ml-lib/src/main/java/org/apache/flink/ml/common/datastream/MapPartitionFunctionWrapper.java
b/flink-ml-core/src/main/java/org/apache/flink/ml/common/datastream/MapPartitionFunctionWrapper.java
similarity index 100%
rename from
flink-ml-lib/src/main/java/org/apache/flink/ml/common/datastream/MapPartitionFunctionWrapper.java
rename to
flink-ml-core/src/main/java/org/apache/flink/ml/common/datastream/MapPartitionFunctionWrapper.java
diff --git
a/flink-ml-lib/src/main/java/org/apache/flink/ml/common/datastream/TableUtils.java
b/flink-ml-core/src/main/java/org/apache/flink/ml/common/datastream/TableUtils.java
similarity index 100%
rename from
flink-ml-lib/src/main/java/org/apache/flink/ml/common/datastream/TableUtils.java
rename to
flink-ml-core/src/main/java/org/apache/flink/ml/common/datastream/TableUtils.java
diff --git
a/flink-ml-core/src/main/java/org/apache/flink/ml/distance/DistanceMeasure.java
b/flink-ml-core/src/main/java/org/apache/flink/ml/common/distance/DistanceMeasure.java
similarity index 97%
rename from
flink-ml-core/src/main/java/org/apache/flink/ml/distance/DistanceMeasure.java
rename to
flink-ml-core/src/main/java/org/apache/flink/ml/common/distance/DistanceMeasure.java
index 09efe2a..0fe01fe 100644
---
a/flink-ml-core/src/main/java/org/apache/flink/ml/distance/DistanceMeasure.java
+++
b/flink-ml-core/src/main/java/org/apache/flink/ml/common/distance/DistanceMeasure.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package org.apache.flink.ml.distance;
+package org.apache.flink.ml.common.distance;
import org.apache.flink.ml.linalg.Vector;
diff --git
a/flink-ml-core/src/main/java/org/apache/flink/ml/distance/EuclideanDistanceMeasure.java
b/flink-ml-core/src/main/java/org/apache/flink/ml/common/distance/EuclideanDistanceMeasure.java
similarity index 97%
rename from
flink-ml-core/src/main/java/org/apache/flink/ml/distance/EuclideanDistanceMeasure.java
rename to
flink-ml-core/src/main/java/org/apache/flink/ml/common/distance/EuclideanDistanceMeasure.java
index 571f4c0..fcb5cc6 100644
---
a/flink-ml-core/src/main/java/org/apache/flink/ml/distance/EuclideanDistanceMeasure.java
+++
b/flink-ml-core/src/main/java/org/apache/flink/ml/common/distance/EuclideanDistanceMeasure.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package org.apache.flink.ml.distance;
+package org.apache.flink.ml.common.distance;
import org.apache.flink.ml.linalg.Vector;
diff --git
a/flink-ml-lib/src/main/java/org/apache/flink/ml/common/iteration/ForwardInputsOfLastRound.java
b/flink-ml-core/src/main/java/org/apache/flink/ml/common/iteration/ForwardInputsOfLastRound.java
similarity index 100%
rename from
flink-ml-lib/src/main/java/org/apache/flink/ml/common/iteration/ForwardInputsOfLastRound.java
rename to
flink-ml-core/src/main/java/org/apache/flink/ml/common/iteration/ForwardInputsOfLastRound.java
diff --git
a/flink-ml-lib/src/main/java/org/apache/flink/ml/common/iteration/TerminateOnMaxIterationNum.java
b/flink-ml-core/src/main/java/org/apache/flink/ml/common/iteration/TerminateOnMaxIterationNum.java
similarity index 100%
rename from
flink-ml-lib/src/main/java/org/apache/flink/ml/common/iteration/TerminateOnMaxIterationNum.java
rename to
flink-ml-core/src/main/java/org/apache/flink/ml/common/iteration/TerminateOnMaxIterationNum.java
diff --git
a/flink-ml-lib/src/test/java/org/apache/flink/ml/common/broadcast/BroadcastUtilsTest.java
b/flink-ml-core/src/test/java/org/apache/flink/ml/common/broadcast/BroadcastUtilsTest.java
similarity index 100%
rename from
flink-ml-lib/src/test/java/org/apache/flink/ml/common/broadcast/BroadcastUtilsTest.java
rename to
flink-ml-core/src/test/java/org/apache/flink/ml/common/broadcast/BroadcastUtilsTest.java
diff --git
a/flink-ml-lib/src/test/java/org/apache/flink/ml/common/broadcast/TestSink.java
b/flink-ml-core/src/test/java/org/apache/flink/ml/common/broadcast/TestSink.java
similarity index 100%
rename from
flink-ml-lib/src/test/java/org/apache/flink/ml/common/broadcast/TestSink.java
rename to
flink-ml-core/src/test/java/org/apache/flink/ml/common/broadcast/TestSink.java
diff --git
a/flink-ml-lib/src/test/java/org/apache/flink/ml/common/broadcast/TestSource.java
b/flink-ml-core/src/test/java/org/apache/flink/ml/common/broadcast/TestSource.java
similarity index 100%
rename from
flink-ml-lib/src/test/java/org/apache/flink/ml/common/broadcast/TestSource.java
rename to
flink-ml-core/src/test/java/org/apache/flink/ml/common/broadcast/TestSource.java
diff --git
a/flink-ml-lib/src/test/java/org/apache/flink/ml/common/broadcast/operator/BroadcastVariableReceiverOperatorTest.java
b/flink-ml-core/src/test/java/org/apache/flink/ml/common/broadcast/operator/BroadcastVariableReceiverOperatorTest.java
similarity index 100%
rename from
flink-ml-lib/src/test/java/org/apache/flink/ml/common/broadcast/operator/BroadcastVariableReceiverOperatorTest.java
rename to
flink-ml-core/src/test/java/org/apache/flink/ml/common/broadcast/operator/BroadcastVariableReceiverOperatorTest.java
diff --git
a/flink-ml-lib/src/test/java/org/apache/flink/ml/common/broadcast/operator/BroadcastWrapperOperatorFactory.java
b/flink-ml-core/src/test/java/org/apache/flink/ml/common/broadcast/operator/BroadcastWrapperOperatorFactory.java
similarity index 100%
rename from
flink-ml-lib/src/test/java/org/apache/flink/ml/common/broadcast/operator/BroadcastWrapperOperatorFactory.java
rename to
flink-ml-core/src/test/java/org/apache/flink/ml/common/broadcast/operator/BroadcastWrapperOperatorFactory.java
diff --git
a/flink-ml-lib/src/test/java/org/apache/flink/ml/common/broadcast/operator/OneInputBroadcastWrapperOperatorTest.java
b/flink-ml-core/src/test/java/org/apache/flink/ml/common/broadcast/operator/OneInputBroadcastWrapperOperatorTest.java
similarity index 100%
rename from
flink-ml-lib/src/test/java/org/apache/flink/ml/common/broadcast/operator/OneInputBroadcastWrapperOperatorTest.java
rename to
flink-ml-core/src/test/java/org/apache/flink/ml/common/broadcast/operator/OneInputBroadcastWrapperOperatorTest.java
diff --git
a/flink-ml-lib/src/test/java/org/apache/flink/ml/common/broadcast/operator/TestOneInputOp.java
b/flink-ml-core/src/test/java/org/apache/flink/ml/common/broadcast/operator/TestOneInputOp.java
similarity index 100%
rename from
flink-ml-lib/src/test/java/org/apache/flink/ml/common/broadcast/operator/TestOneInputOp.java
rename to
flink-ml-core/src/test/java/org/apache/flink/ml/common/broadcast/operator/TestOneInputOp.java
diff --git
a/flink-ml-lib/src/test/java/org/apache/flink/ml/common/broadcast/operator/TestTwoInputOp.java
b/flink-ml-core/src/test/java/org/apache/flink/ml/common/broadcast/operator/TestTwoInputOp.java
similarity index 100%
rename from
flink-ml-lib/src/test/java/org/apache/flink/ml/common/broadcast/operator/TestTwoInputOp.java
rename to
flink-ml-core/src/test/java/org/apache/flink/ml/common/broadcast/operator/TestTwoInputOp.java
diff --git
a/flink-ml-lib/src/test/java/org/apache/flink/ml/common/broadcast/operator/TwoInputBroadcastWrapperOperatorTest.java
b/flink-ml-core/src/test/java/org/apache/flink/ml/common/broadcast/operator/TwoInputBroadcastWrapperOperatorTest.java
similarity index 100%
rename from
flink-ml-lib/src/test/java/org/apache/flink/ml/common/broadcast/operator/TwoInputBroadcastWrapperOperatorTest.java
rename to
flink-ml-core/src/test/java/org/apache/flink/ml/common/broadcast/operator/TwoInputBroadcastWrapperOperatorTest.java
diff --git a/flink-ml-lib/pom.xml b/flink-ml-lib/pom.xml
index 4477ded..7262cb9 100644
--- a/flink-ml-lib/pom.xml
+++ b/flink-ml-lib/pom.xml
@@ -99,13 +99,6 @@ under the License.
<version>${flink.version}</version>
<scope>test</scope>
</dependency>
- <dependency>
- <groupId>org.mockito</groupId>
- <artifactId>mockito-core</artifactId>
- <version>2.21.0</version>
- <type>jar</type>
- <scope>test</scope>
- </dependency>
</dependencies>
</project>
diff --git
a/flink-ml-lib/src/main/java/org/apache/flink/ml/clustering/kmeans/KMeans.java
b/flink-ml-lib/src/main/java/org/apache/flink/ml/clustering/kmeans/KMeans.java
index 3966626..0e6f2ac 100644
---
a/flink-ml-lib/src/main/java/org/apache/flink/ml/clustering/kmeans/KMeans.java
+++
b/flink-ml-lib/src/main/java/org/apache/flink/ml/clustering/kmeans/KMeans.java
@@ -39,9 +39,9 @@ import org.apache.flink.iteration.ReplayableDataStreamList;
import org.apache.flink.ml.api.Estimator;
import org.apache.flink.ml.common.datastream.EndOfStreamWindows;
import org.apache.flink.ml.common.datastream.MapPartitionFunctionWrapper;
+import org.apache.flink.ml.common.distance.DistanceMeasure;
import org.apache.flink.ml.common.iteration.ForwardInputsOfLastRound;
import org.apache.flink.ml.common.iteration.TerminateOnMaxIterationNum;
-import org.apache.flink.ml.distance.DistanceMeasure;
import org.apache.flink.ml.linalg.DenseVector;
import org.apache.flink.ml.linalg.typeinfo.DenseVectorTypeInfo;
import org.apache.flink.ml.param.Param;
diff --git
a/flink-ml-lib/src/main/java/org/apache/flink/ml/clustering/kmeans/KMeansModel.java
b/flink-ml-lib/src/main/java/org/apache/flink/ml/clustering/kmeans/KMeansModel.java
index d5d94e1..b7685e9 100644
---
a/flink-ml-lib/src/main/java/org/apache/flink/ml/clustering/kmeans/KMeansModel.java
+++
b/flink-ml-lib/src/main/java/org/apache/flink/ml/clustering/kmeans/KMeansModel.java
@@ -26,7 +26,7 @@ import
org.apache.flink.api.java.typeutils.ObjectArrayTypeInfo;
import org.apache.flink.api.java.typeutils.RowTypeInfo;
import org.apache.flink.ml.api.Model;
import org.apache.flink.ml.common.datastream.TableUtils;
-import org.apache.flink.ml.distance.DistanceMeasure;
+import org.apache.flink.ml.common.distance.DistanceMeasure;
import org.apache.flink.ml.linalg.DenseVector;
import org.apache.flink.ml.linalg.typeinfo.DenseVectorTypeInfo;
import org.apache.flink.ml.param.Param;
diff --git
a/flink-ml-lib/src/main/java/org/apache/flink/ml/common/param/HasDistanceMeasure.java
b/flink-ml-lib/src/main/java/org/apache/flink/ml/common/param/HasDistanceMeasure.java
index f58d08a..a01de99 100644
---
a/flink-ml-lib/src/main/java/org/apache/flink/ml/common/param/HasDistanceMeasure.java
+++
b/flink-ml-lib/src/main/java/org/apache/flink/ml/common/param/HasDistanceMeasure.java
@@ -18,7 +18,7 @@
package org.apache.flink.ml.common.param;
-import org.apache.flink.ml.distance.EuclideanDistanceMeasure;
+import org.apache.flink.ml.common.distance.EuclideanDistanceMeasure;
import org.apache.flink.ml.param.Param;
import org.apache.flink.ml.param.ParamValidators;
import org.apache.flink.ml.param.StringParam;
diff --git
a/flink-ml-lib/src/test/java/org/apache/flink/ml/clustering/KMeansTest.java
b/flink-ml-lib/src/test/java/org/apache/flink/ml/clustering/KMeansTest.java
index c2331a3..1e280f8 100644
--- a/flink-ml-lib/src/test/java/org/apache/flink/ml/clustering/KMeansTest.java
+++ b/flink-ml-lib/src/test/java/org/apache/flink/ml/clustering/KMeansTest.java
@@ -22,7 +22,7 @@ import
org.apache.flink.api.common.restartstrategy.RestartStrategies;
import org.apache.flink.configuration.Configuration;
import org.apache.flink.ml.clustering.kmeans.KMeans;
import org.apache.flink.ml.clustering.kmeans.KMeansModel;
-import org.apache.flink.ml.distance.EuclideanDistanceMeasure;
+import org.apache.flink.ml.common.distance.EuclideanDistanceMeasure;
import org.apache.flink.ml.linalg.DenseVector;
import org.apache.flink.ml.linalg.Vectors;
import org.apache.flink.ml.util.ReadWriteUtils;
