[hotfix] Move CompressionUtils to flink-core

lovepoem · Jul 12, 2024 · 1226ab5 · 1226ab5
1 parent 957804a
commit 1226ab5
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 5 deletions.
diff --git a/...e/flink/python/util/CompressionUtils.java → ...g/apache/flink/util/CompressionUtils.java b/...e/flink/python/util/CompressionUtils.java → ...g/apache/flink/util/CompressionUtils.java
@@ -16,11 +16,9 @@
  * limitations under the License.
  */
 
-package org.apache.flink.python.util;
+package org.apache.flink.util;
 
 import org.apache.flink.annotation.Internal;
-import org.apache.flink.util.IOUtils;
-import org.apache.flink.util.OperatingSystem;
 
 import org.apache.commons.compress.archivers.tar.TarArchiveEntry;
 import org.apache.commons.compress.archivers.tar.TarArchiveInputStream;

diff --git a/flink-python/src/main/java/org/apache/flink/client/python/PythonEnvUtils.java b/flink-python/src/main/java/org/apache/flink/client/python/PythonEnvUtils.java
@@ -22,8 +22,8 @@
 import org.apache.flink.configuration.ConfigConstants;
 import org.apache.flink.configuration.ReadableConfig;
 import org.apache.flink.core.fs.Path;
-import org.apache.flink.python.util.CompressionUtils;
 import org.apache.flink.python.util.PythonDependencyUtils;
+import org.apache.flink.util.CompressionUtils;
 import org.apache.flink.util.ExceptionUtils;
 import org.apache.flink.util.FileUtils;
 import org.apache.flink.util.NetUtils;

diff --git a/flink-python/src/main/java/org/apache/flink/python/env/AbstractPythonEnvironmentManager.java b/flink-python/src/main/java/org/apache/flink/python/env/AbstractPythonEnvironmentManager.java
@@ -22,8 +22,8 @@
 import org.apache.flink.annotation.VisibleForTesting;
 import org.apache.flink.api.common.JobID;
 import org.apache.flink.api.java.tuple.Tuple2;
-import org.apache.flink.python.util.CompressionUtils;
 import org.apache.flink.python.util.PythonEnvironmentManagerUtils;
+import org.apache.flink.util.CompressionUtils;
 import org.apache.flink.util.FileUtils;
 import org.apache.flink.util.Preconditions;
 import org.apache.flink.util.ShutdownHookUtil;

diff --git a/flink-python/src/test/java/org/apache/flink/python/util/CompressionUtilsTest.java b/flink-python/src/test/java/org/apache/flink/python/util/CompressionUtilsTest.java
@@ -18,6 +18,7 @@
 package org.apache.flink.python.util;
 
 import org.apache.flink.configuration.ConfigConstants;
+import org.apache.flink.util.CompressionUtils;
 
 import org.apache.commons.compress.archivers.zip.ZipArchiveEntry;
 import org.apache.commons.compress.archivers.zip.ZipArchiveOutputStream;