lirui-apache commented on a change in pull request #10618: [FLINK-15287][hive]
Fix orc optimization for version less than 2.3 by introducing orc shim
URL: https://github.com/apache/flink/pull/10618#discussion_r360305328
##########
File path:
flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/TableEnvHiveConnectorTest.java
##########
@@ -124,9 +124,15 @@ public void testGetNonExistingFunction() throws Exception
{
public void testDifferentFormats() throws Exception {
String[] formats = new String[]{"orc", "parquet",
"sequencefile", "csv"};
for (String format : formats) {
- if (format.equals("orc") &&
HiveShimLoader.getHiveVersion().startsWith("2.0")) {
- // Ignore orc test for Hive version 2.0.x for
now due to FLINK-13998
- continue;
+ if (format.equals("orc")) {
+ String version =
HiveShimLoader.getHiveVersion();
+ // hive 2.0.x with orc can not run in local
mode, because Hadoop23Shims only
Review comment:
Actually we could make 2.0.x read ORC tables in local FS, but writing to ORC
tables didn't work. More details in
https://issues.apache.org/jira/browse/FLINK-13998
----------------------------------------------------------------
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]
With regards,
Apache Git Services
