[flink] branch master updated: [FLINK-13006][hive] remove GenericUDTFReplicateRows from GenericUDTFTest because Hive 1.2.1 doesn't have it

[bli]

This is an automated email from the ASF dual-hosted git repository.

bli pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new 0aa7762  [FLINK-13006][hive] remove GenericUDTFReplicateRows from 
GenericUDTFTest because Hive 1.2.1 doesn't have it
0aa7762 is described below

commit 0aa7762eff6d9bbb40b968e3f392327fa5baa7eb
Author: bowen.li <bowenl...@gmail.com>
AuthorDate: Wed Jun 26 19:09:59 2019 -0700

    [FLINK-13006][hive] remove GenericUDTFReplicateRows from GenericUDTFTest 
because Hive 1.2.1 doesn't have it
    
    This PR removes GenericUDTFReplicateRows from HiveGenericUDTFTest because 
Hive 1.2.1 doesn't have it and thus the build profile for Hive 1.2.1 would fail.
    
    I've added pretty a lot test coverage for HiveGenericUDTF, so removing just 
this one test should be fine.
    
    This closes #8905.
---
 .../table/functions/hive/HiveGenericUDTFTest.java  | 24 ----------------------
 1 file changed, 24 deletions(-)

diff --git 
a/flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/table/functions/hive/HiveGenericUDTFTest.java
 
b/flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/table/functions/hive/HiveGenericUDTFTest.java
index 15d2152..71712b7 100644
--- 
a/flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/table/functions/hive/HiveGenericUDTFTest.java
+++ 
b/flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/table/functions/hive/HiveGenericUDTFTest.java
@@ -29,7 +29,6 @@ import org.apache.hadoop.hive.ql.udf.generic.Collector;
 import org.apache.hadoop.hive.ql.udf.generic.GenericUDTF;
 import org.apache.hadoop.hive.ql.udf.generic.GenericUDTFInline;
 import org.apache.hadoop.hive.ql.udf.generic.GenericUDTFPosExplode;
-import org.apache.hadoop.hive.ql.udf.generic.GenericUDTFReplicateRows;
 import org.apache.hadoop.hive.ql.udf.generic.GenericUDTFStack;
 import org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector;
 import org.apache.hadoop.hive.serde2.objectinspector.ObjectInspectorFactory;
@@ -111,29 +110,6 @@ public class HiveGenericUDTFTest {
        }
 
        @Test
-       public void testReplicateRows() throws Exception {
-               Object[] constantArgs = new Object[] {
-                       2L,
-                       null
-               };
-
-               DataType[] dataTypes = new DataType[] {
-                       DataTypes.BIGINT(),
-                       DataTypes.INT()
-               };
-
-               HiveGenericUDTF udf = init(
-                       GenericUDTFReplicateRows.class,
-                       constantArgs,
-                       dataTypes
-               );
-
-               udf.eval(2L, 5);
-
-               assertEquals(Arrays.asList(Row.of(2L, 5), Row.of(2L, 5)), 
collector.result);
-       }
-
-       @Test
        public void testStack() throws Exception {
                Object[] constantArgs = new Object[] {
                        2,