lirui-apache commented on a change in pull request #15712:
URL: https://github.com/apache/flink/pull/15712#discussion_r623836414
##########
File path:
flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/TableEnvHiveConnectorITCase.java
##########
@@ -531,6 +532,52 @@ public void testLocationWithComma() throws Exception {
}
}
+ @Test
+ public void testReadHiveDataWithEmptyMapForHiveShim20X() throws Exception {
+ TableEnvironment tableEnv = getTableEnvWithHiveCatalog();
+
+ try {
+ // Flink to write parquet file
+ String folderURI = TEMPORARY_FOLDER.newFolder().toURI().toString();
Review comment:
This is already a `tempFolder` member in this test.
##########
File path:
flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/TableEnvHiveConnectorITCase.java
##########
@@ -531,6 +532,52 @@ public void testLocationWithComma() throws Exception {
}
}
+ @Test
+ public void testReadHiveDataWithEmptyMapForHiveShim20X() throws Exception {
+ TableEnvironment tableEnv = getTableEnvWithHiveCatalog();
+
+ try {
+ // Flink to write parquet file
Review comment:
Does this issue only happen with Parquet tables? If not, we can just use
text table so that the test can be simpler.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
