From 028d4bc0991a983efdccb42da11ca5fb363a1e3b Mon Sep 17 00:00:00 2001 From: srima Date: Wed, 8 Dec 2021 10:11:26 +0530 Subject: [PATCH] [177]: Fix for spot bug OrcPageSource --- .../java/io/prestosql/plugin/hive/orc/OrcPageSource.java | 6 ------ 1 file changed, 6 deletions(-) diff --git a/presto-hive/src/main/java/io/prestosql/plugin/hive/orc/OrcPageSource.java b/presto-hive/src/main/java/io/prestosql/plugin/hive/orc/OrcPageSource.java index c6b882bb7..dfe32eb25 100644 --- a/presto-hive/src/main/java/io/prestosql/plugin/hive/orc/OrcPageSource.java +++ b/presto-hive/src/main/java/io/prestosql/plugin/hive/orc/OrcPageSource.java @@ -21,7 +21,6 @@ import io.prestosql.orc.OrcDataSourceId; import io.prestosql.orc.OrcRecordReader; import io.prestosql.plugin.hive.FileFormatDataSourceStats; import io.prestosql.plugin.hive.HiveErrorCode; -import io.prestosql.plugin.hive.HiveType; import io.prestosql.spi.Page; import io.prestosql.spi.PrestoException; import io.prestosql.spi.block.Block; @@ -31,7 +30,6 @@ import io.prestosql.spi.block.RowBlock; import io.prestosql.spi.block.RunLengthEncodedBlock; import io.prestosql.spi.connector.ConnectorPageSource; import io.prestosql.spi.type.Type; -import org.apache.hadoop.hive.serde2.typeinfo.PrimitiveTypeInfo; import org.apache.hadoop.hive.serde2.typeinfo.StructTypeInfo; import java.io.IOException; @@ -320,10 +318,6 @@ public class OrcPageSource @Override public Block block(Page sourcePage, OrcDeletedRows.MaskDeletedRowsFunction maskDeletedRowsFunction) { - List types = structTypeInfo.getAllStructFieldTypeInfos().stream() - .map(typeInfo -> HiveType - .getPrimitiveType((PrimitiveTypeInfo.class.cast(typeInfo)))) - .collect(Collectors.toList()); List fieldBlocks = columnAdaptations.stream().map(adaptation -> adaptation.block(sourcePage, maskDeletedRowsFunction)).collect(Collectors.toList()); Block block = RowBlock.fromFieldBlocks(sourcePage.getPositionCount(), Optional.empty(), fieldBlocks.toArray(new Block[fieldBlocks.size()])); return new LazyBlock(maskDeletedRowsFunction.getPositionCount(), new SourceColumn.MaskingBlockLoader(maskDeletedRowsFunction, block));