You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by bl...@apache.org on 2019/08/01 22:56:08 UTC
[flink] branch release-1.9 updated: [FLINK-12966][hive] finalize
package name of Hive table source/sink
This is an automated email from the ASF dual-hosted git repository.
bli pushed a commit to branch release-1.9
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.9 by this push:
new 646d1a3 [FLINK-12966][hive] finalize package name of Hive table source/sink
646d1a3 is described below
commit 646d1a376cfb80fe923dfc0b68d355063dab2105
Author: zjuwangg <zj...@foxmail.com>
AuthorDate: Wed Jul 31 15:46:59 2019 +0800
[FLINK-12966][hive] finalize package name of Hive table source/sink
finalize package name of Hive table source/sink from org.apache.flink.batch.connector to org.apache.flink.connector.
This closes #9290.
---
.../apache/flink/{batch => }/connectors/hive/FlinkHiveException.java | 2 +-
.../apache/flink/{batch => }/connectors/hive/HiveTableFactory.java | 2 +-
.../flink/{batch => }/connectors/hive/HiveTableInputFormat.java | 2 +-
.../apache/flink/{batch => }/connectors/hive/HiveTableInputSplit.java | 2 +-
.../flink/{batch => }/connectors/hive/HiveTableOutputFormat.java | 2 +-
.../apache/flink/{batch => }/connectors/hive/HiveTablePartition.java | 2 +-
.../org/apache/flink/{batch => }/connectors/hive/HiveTableSink.java | 2 +-
.../org/apache/flink/{batch => }/connectors/hive/HiveTableSource.java | 2 +-
.../main/java/org/apache/flink/table/catalog/hive/HiveCatalog.java | 2 +-
.../flink/{batch => }/connectors/hive/FlinkStandaloneHiveRunner.java | 2 +-
.../{batch => }/connectors/hive/FlinkStandaloneHiveServerContext.java | 2 +-
.../apache/flink/{batch => }/connectors/hive/HiveInputFormatTest.java | 2 +-
.../org/apache/flink/{batch => }/connectors/hive/HiveRunnerShim.java | 2 +-
.../flink/{batch => }/connectors/hive/HiveRunnerShimLoader.java | 2 +-
.../apache/flink/{batch => }/connectors/hive/HiveRunnerShimV3.java | 2 +-
.../apache/flink/{batch => }/connectors/hive/HiveRunnerShimV4.java | 2 +-
.../flink/{batch => }/connectors/hive/HiveTableFactoryTest.java | 4 ++--
.../apache/flink/{batch => }/connectors/hive/HiveTableSinkTest.java | 2 +-
.../apache/flink/{batch => }/connectors/hive/HiveTableSourceTest.java | 2 +-
.../flink/{batch => }/connectors/hive/TableEnvHiveConnectorTest.java | 2 +-
.../java/org/apache/flink/table/catalog/hive/HiveCatalogITCase.java | 2 +-
21 files changed, 22 insertions(+), 22 deletions(-)
diff --git a/flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/batch/connectors/hive/FlinkHiveException.java b/flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/FlinkHiveException.java
similarity index 95%
rename from flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/batch/connectors/hive/FlinkHiveException.java
rename to flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/FlinkHiveException.java
index 7c65491..6a4e2fd 100644
--- a/flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/batch/connectors/hive/FlinkHiveException.java
+++ b/flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/FlinkHiveException.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.flink.batch.connectors.hive;
+package org.apache.flink.connectors.hive;
import org.apache.flink.annotation.PublicEvolving;
diff --git a/flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/batch/connectors/hive/HiveTableFactory.java b/flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTableFactory.java
similarity index 99%
rename from flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/batch/connectors/hive/HiveTableFactory.java
rename to flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTableFactory.java
index 9c8beaa..4127bf3 100644
--- a/flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/batch/connectors/hive/HiveTableFactory.java
+++ b/flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTableFactory.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package org.apache.flink.batch.connectors.hive;
+package org.apache.flink.connectors.hive;
import org.apache.flink.api.java.typeutils.GenericTypeInfo;
import org.apache.flink.table.api.TableException;
diff --git a/flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/batch/connectors/hive/HiveTableInputFormat.java b/flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTableInputFormat.java
similarity index 99%
rename from flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/batch/connectors/hive/HiveTableInputFormat.java
rename to flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTableInputFormat.java
index 755e62c..8965320 100644
--- a/flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/batch/connectors/hive/HiveTableInputFormat.java
+++ b/flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTableInputFormat.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package org.apache.flink.batch.connectors.hive;
+package org.apache.flink.connectors.hive;
import org.apache.flink.api.common.io.LocatableInputSplitAssigner;
import org.apache.flink.api.common.io.statistics.BaseStatistics;
diff --git a/flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/batch/connectors/hive/HiveTableInputSplit.java b/flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTableInputSplit.java
similarity index 97%
rename from flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/batch/connectors/hive/HiveTableInputSplit.java
rename to flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTableInputSplit.java
index c727347..9802e31 100644
--- a/flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/batch/connectors/hive/HiveTableInputSplit.java
+++ b/flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTableInputSplit.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package org.apache.flink.batch.connectors.hive;
+package org.apache.flink.connectors.hive;
import org.apache.flink.api.java.hadoop.mapred.wrapper.HadoopInputSplit;
diff --git a/flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/batch/connectors/hive/HiveTableOutputFormat.java b/flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTableOutputFormat.java
similarity index 99%
rename from flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/batch/connectors/hive/HiveTableOutputFormat.java
rename to flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTableOutputFormat.java
index ade5830..52436cc 100644
--- a/flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/batch/connectors/hive/HiveTableOutputFormat.java
+++ b/flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTableOutputFormat.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package org.apache.flink.batch.connectors.hive;
+package org.apache.flink.connectors.hive;
import org.apache.flink.api.common.io.FinalizeOnMaster;
import org.apache.flink.api.common.io.InitializeOnMaster;
diff --git a/flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/batch/connectors/hive/HiveTablePartition.java b/flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTablePartition.java
similarity index 97%
rename from flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/batch/connectors/hive/HiveTablePartition.java
rename to flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTablePartition.java
index 20e73be..b1cf864 100644
--- a/flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/batch/connectors/hive/HiveTablePartition.java
+++ b/flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTablePartition.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package org.apache.flink.batch.connectors.hive;
+package org.apache.flink.connectors.hive;
import org.apache.hadoop.hive.metastore.api.StorageDescriptor;
diff --git a/flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/batch/connectors/hive/HiveTableSink.java b/flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTableSink.java
similarity index 99%
rename from flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/batch/connectors/hive/HiveTableSink.java
rename to flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTableSink.java
index 502f7a9..7d8a85a 100644
--- a/flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/batch/connectors/hive/HiveTableSink.java
+++ b/flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTableSink.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package org.apache.flink.batch.connectors.hive;
+package org.apache.flink.connectors.hive;
import org.apache.flink.api.common.io.OutputFormat;
import org.apache.flink.api.common.typeinfo.TypeInformation;
diff --git a/flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/batch/connectors/hive/HiveTableSource.java b/flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTableSource.java
similarity index 99%
rename from flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/batch/connectors/hive/HiveTableSource.java
rename to flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTableSource.java
index e0734f4..2df10c5 100644
--- a/flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/batch/connectors/hive/HiveTableSource.java
+++ b/flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTableSource.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package org.apache.flink.batch.connectors.hive;
+package org.apache.flink.connectors.hive;
import org.apache.flink.api.common.io.InputFormat;
import org.apache.flink.api.common.typeinfo.TypeInformation;
diff --git a/flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/HiveCatalog.java b/flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/HiveCatalog.java
index 19ffa0d..7036196 100644
--- a/flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/HiveCatalog.java
+++ b/flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/HiveCatalog.java
@@ -21,7 +21,7 @@ package org.apache.flink.table.catalog.hive;
import org.apache.flink.annotation.VisibleForTesting;
import org.apache.flink.api.java.hadoop.mapred.utils.HadoopUtils;
import org.apache.flink.api.java.tuple.Tuple2;
-import org.apache.flink.batch.connectors.hive.HiveTableFactory;
+import org.apache.flink.connectors.hive.HiveTableFactory;
import org.apache.flink.table.api.TableSchema;
import org.apache.flink.table.catalog.AbstractCatalog;
import org.apache.flink.table.catalog.CatalogBaseTable;
diff --git a/flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/batch/connectors/hive/FlinkStandaloneHiveRunner.java b/flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/FlinkStandaloneHiveRunner.java
similarity index 99%
rename from flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/batch/connectors/hive/FlinkStandaloneHiveRunner.java
rename to flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/FlinkStandaloneHiveRunner.java
index dbc7757..35dc892 100644
--- a/flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/batch/connectors/hive/FlinkStandaloneHiveRunner.java
+++ b/flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/FlinkStandaloneHiveRunner.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package org.apache.flink.batch.connectors.hive;
+package org.apache.flink.connectors.hive;
import org.apache.flink.table.catalog.hive.HiveTestUtils;
import org.apache.flink.util.Preconditions;
diff --git a/flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/batch/connectors/hive/FlinkStandaloneHiveServerContext.java b/flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/FlinkStandaloneHiveServerContext.java
similarity index 99%
rename from flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/batch/connectors/hive/FlinkStandaloneHiveServerContext.java
rename to flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/FlinkStandaloneHiveServerContext.java
index 62ccaae..605a341 100644
--- a/flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/batch/connectors/hive/FlinkStandaloneHiveServerContext.java
+++ b/flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/FlinkStandaloneHiveServerContext.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package org.apache.flink.batch.connectors.hive;
+package org.apache.flink.connectors.hive;
import com.klarna.hiverunner.HiveServerContext;
import com.klarna.hiverunner.config.HiveRunnerConfig;
diff --git a/flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/batch/connectors/hive/HiveInputFormatTest.java b/flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveInputFormatTest.java
similarity index 99%
rename from flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/batch/connectors/hive/HiveInputFormatTest.java
rename to flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveInputFormatTest.java
index fea1469..19d6da2 100644
--- a/flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/batch/connectors/hive/HiveInputFormatTest.java
+++ b/flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveInputFormatTest.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package org.apache.flink.batch.connectors.hive;
+package org.apache.flink.connectors.hive;
import org.apache.flink.api.common.typeinfo.BasicTypeInfo;
import org.apache.flink.api.common.typeinfo.TypeInformation;
diff --git a/flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/batch/connectors/hive/HiveRunnerShim.java b/flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveRunnerShim.java
similarity index 96%
rename from flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/batch/connectors/hive/HiveRunnerShim.java
rename to flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveRunnerShim.java
index 32742d8..9ae643b 100644
--- a/flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/batch/connectors/hive/HiveRunnerShim.java
+++ b/flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveRunnerShim.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package org.apache.flink.batch.connectors.hive;
+package org.apache.flink.connectors.hive;
import com.klarna.hiverunner.builder.HiveShellBuilder;
import com.klarna.hiverunner.config.HiveRunnerConfig;
diff --git a/flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/batch/connectors/hive/HiveRunnerShimLoader.java b/flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveRunnerShimLoader.java
similarity index 97%
rename from flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/batch/connectors/hive/HiveRunnerShimLoader.java
rename to flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveRunnerShimLoader.java
index 05e6430..3bf2b74 100644
--- a/flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/batch/connectors/hive/HiveRunnerShimLoader.java
+++ b/flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveRunnerShimLoader.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package org.apache.flink.batch.connectors.hive;
+package org.apache.flink.connectors.hive;
import org.apache.flink.table.catalog.hive.client.HiveShimLoader;
diff --git a/flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/batch/connectors/hive/HiveRunnerShimV3.java b/flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveRunnerShimV3.java
similarity index 96%
rename from flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/batch/connectors/hive/HiveRunnerShimV3.java
rename to flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveRunnerShimV3.java
index c405c16..b311f00 100644
--- a/flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/batch/connectors/hive/HiveRunnerShimV3.java
+++ b/flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveRunnerShimV3.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package org.apache.flink.batch.connectors.hive;
+package org.apache.flink.connectors.hive;
import com.klarna.hiverunner.builder.HiveShellBuilder;
import com.klarna.hiverunner.config.HiveRunnerConfig;
diff --git a/flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/batch/connectors/hive/HiveRunnerShimV4.java b/flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveRunnerShimV4.java
similarity index 96%
rename from flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/batch/connectors/hive/HiveRunnerShimV4.java
rename to flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveRunnerShimV4.java
index 625867a..99207a2 100644
--- a/flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/batch/connectors/hive/HiveRunnerShimV4.java
+++ b/flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveRunnerShimV4.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package org.apache.flink.batch.connectors.hive;
+package org.apache.flink.connectors.hive;
import com.klarna.hiverunner.builder.HiveShellBuilder;
import com.klarna.hiverunner.config.HiveRunnerConfig;
diff --git a/flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/batch/connectors/hive/HiveTableFactoryTest.java b/flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveTableFactoryTest.java
similarity index 96%
rename from flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/batch/connectors/hive/HiveTableFactoryTest.java
rename to flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveTableFactoryTest.java
index 8784cd8..f04d496 100644
--- a/flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/batch/connectors/hive/HiveTableFactoryTest.java
+++ b/flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveTableFactoryTest.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package org.apache.flink.batch.connectors.hive;
+package org.apache.flink.connectors.hive;
import org.apache.flink.table.api.DataTypes;
import org.apache.flink.table.api.TableSchema;
@@ -44,7 +44,7 @@ import java.util.Optional;
import static org.junit.Assert.assertTrue;
/**
- * Test for {@link org.apache.flink.batch.connectors.hive.HiveTableFactory}.
+ * Test for {@link HiveTableFactory}.
*/
public class HiveTableFactoryTest {
private static HiveCatalog catalog;
diff --git a/flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/batch/connectors/hive/HiveTableSinkTest.java b/flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveTableSinkTest.java
similarity index 99%
rename from flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/batch/connectors/hive/HiveTableSinkTest.java
rename to flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveTableSinkTest.java
index 80ad25f..48cb741 100644
--- a/flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/batch/connectors/hive/HiveTableSinkTest.java
+++ b/flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveTableSinkTest.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package org.apache.flink.batch.connectors.hive;
+package org.apache.flink.connectors.hive;
import org.apache.flink.api.common.ExecutionConfig;
import org.apache.flink.api.common.io.InputFormat;
diff --git a/flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/batch/connectors/hive/HiveTableSourceTest.java b/flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveTableSourceTest.java
similarity index 99%
rename from flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/batch/connectors/hive/HiveTableSourceTest.java
rename to flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveTableSourceTest.java
index 1283421..e5b1a45 100644
--- a/flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/batch/connectors/hive/HiveTableSourceTest.java
+++ b/flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveTableSourceTest.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package org.apache.flink.batch.connectors.hive;
+package org.apache.flink.connectors.hive;
import org.apache.flink.table.api.Table;
import org.apache.flink.table.api.TableEnvironment;
diff --git a/flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/batch/connectors/hive/TableEnvHiveConnectorTest.java b/flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/TableEnvHiveConnectorTest.java
similarity index 98%
rename from flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/batch/connectors/hive/TableEnvHiveConnectorTest.java
rename to flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/TableEnvHiveConnectorTest.java
index 7f21bc8..aa02eb6 100644
--- a/flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/batch/connectors/hive/TableEnvHiveConnectorTest.java
+++ b/flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/TableEnvHiveConnectorTest.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package org.apache.flink.batch.connectors.hive;
+package org.apache.flink.connectors.hive;
import org.apache.flink.table.api.TableEnvironment;
import org.apache.flink.table.catalog.hive.HiveCatalog;
diff --git a/flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/table/catalog/hive/HiveCatalogITCase.java b/flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/table/catalog/hive/HiveCatalogITCase.java
index 6f437df..df702ad 100644
--- a/flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/table/catalog/hive/HiveCatalogITCase.java
+++ b/flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/table/catalog/hive/HiveCatalogITCase.java
@@ -19,7 +19,7 @@
package org.apache.flink.table.catalog.hive;
import org.apache.flink.api.java.ExecutionEnvironment;
-import org.apache.flink.batch.connectors.hive.FlinkStandaloneHiveRunner;
+import org.apache.flink.connectors.hive.FlinkStandaloneHiveRunner;
import org.apache.flink.table.api.DataTypes;
import org.apache.flink.table.api.Table;
import org.apache.flink.table.api.TableSchema;