You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by lz...@apache.org on 2020/06/09 04:17:15 UTC
[flink] branch release-1.11 updated: [FLINK-16559][hive] Add test
for avro table
This is an automated email from the ASF dual-hosted git repository.
lzljs3620320 pushed a commit to branch release-1.11
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.11 by this push:
new c98122c [FLINK-16559][hive] Add test for avro table
c98122c is described below
commit c98122c29ef875d7fbc2b85fc9496bcfa11e0363
Author: Rui Li <li...@apache.org>
AuthorDate: Tue Jun 9 12:15:55 2020 +0800
[FLINK-16559][hive] Add test for avro table
This closes #12408
---
.../apache/flink/connectors/hive/TableEnvHiveConnectorITCase.java | 5 ++++-
1 file changed, 4 insertions(+), 1 deletion(-)
diff --git a/flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/TableEnvHiveConnectorITCase.java b/flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/TableEnvHiveConnectorITCase.java
index 2da7d10..367edb9 100644
--- a/flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/TableEnvHiveConnectorITCase.java
+++ b/flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/TableEnvHiveConnectorITCase.java
@@ -128,11 +128,14 @@ public class TableEnvHiveConnectorITCase {
@Test
public void testDifferentFormats() throws Exception {
- String[] formats = new String[]{"orc", "parquet", "sequencefile", "csv"};
+ String[] formats = new String[]{"orc", "parquet", "sequencefile", "csv", "avro"};
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;
+ } else if (format.equals("avro") && !HiveVersionTestUtil.HIVE_110_OR_LATER) {
+ // timestamp is not supported for avro tables before 1.1.0
+ continue;
}
readWriteFormat(format);
}