You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pig.apache.org by da...@apache.org on 2016/08/06 05:54:42 UTC
svn commit: r1755387 - in /pig/trunk: CHANGES.txt
test/org/apache/pig/builtin/TestOrcStorage.java
Author: daijy
Date: Sat Aug 6 05:54:42 2016
New Revision: 1755387
URL: http://svn.apache.org/viewvc?rev=1755387&view=rev
Log:
PIG-4966: Fix Pig compatibility with Hive 2.1.0
Modified:
pig/trunk/CHANGES.txt
pig/trunk/test/org/apache/pig/builtin/TestOrcStorage.java
Modified: pig/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/pig/trunk/CHANGES.txt?rev=1755387&r1=1755386&r2=1755387&view=diff
==============================================================================
--- pig/trunk/CHANGES.txt (original)
+++ pig/trunk/CHANGES.txt Sat Aug 6 05:54:42 2016
@@ -38,6 +38,8 @@ OPTIMIZATIONS
BUG FIXES
+PIG-4966: Fix Pig compatibility with Hive 2.1.0 (zyork via daijy)
+
PIG-4935: TEZ_USE_CLUSTER_HADOOP_LIBS is always set to true (rohini)
PIG-4961: CROSS followed by LIMIT inside nested foreach drop data from result (rohini)
Modified: pig/trunk/test/org/apache/pig/builtin/TestOrcStorage.java
URL: http://svn.apache.org/viewvc/pig/trunk/test/org/apache/pig/builtin/TestOrcStorage.java?rev=1755387&r1=1755386&r2=1755387&view=diff
==============================================================================
--- pig/trunk/test/org/apache/pig/builtin/TestOrcStorage.java (original)
+++ pig/trunk/test/org/apache/pig/builtin/TestOrcStorage.java Sat Aug 6 05:54:42 2016
@@ -195,7 +195,7 @@ public class TestOrcStorage {
Reader reader = OrcFile.createReader(fs, Util.getFirstPartFile(new Path(OUTPUT1)));
assertEquals(reader.getNumberOfRows(), 2);
- RecordReader rows = reader.rows(null);
+ RecordReader rows = reader.rows();
Object row = rows.next(null);
StructObjectInspector soi = (StructObjectInspector)reader.getObjectInspector();
IntWritable intWritable = (IntWritable)soi.getStructFieldData(row,
@@ -291,7 +291,7 @@ public class TestOrcStorage {
ObjectInspector oi = orcReader.getObjectInspector();
StructObjectInspector soi = (StructObjectInspector) oi;
- RecordReader reader = orcReader.rows(null);
+ RecordReader reader = orcReader.rows();
Object row = null;
while (reader.hasNext()) {
@@ -326,9 +326,9 @@ public class TestOrcStorage {
Reader orcReaderActual = OrcFile.createReader(fs, orcFile);
StructObjectInspector soiActual = (StructObjectInspector) orcReaderActual.getObjectInspector();
- RecordReader readerExpected = orcReaderExpected.rows(null);
+ RecordReader readerExpected = orcReaderExpected.rows();
Object expectedRow = null;
- RecordReader readerActual = orcReaderActual.rows(null);
+ RecordReader readerActual = orcReaderActual.rows();
Object actualRow = null;
while (readerExpected.hasNext()) {