This is an automated email from the ASF dual-hosted git repository.
vitalii pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/drill.git.
from 3bc3b66 DRILL-5782: Web UI: do not attempt to build visualized plan
when plan is absent
new 98e5de3 DRILL-6724: Dump operator context to logs when error occurs
during query execution
new 3b1ae15 DRILL-6755: Avoid building Hash Table for inner/left join
when probe side is empty
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../drill/common/exceptions/UserException.java | 4 +-
.../common/exceptions/UserExceptionContext.java | 19 ++-
.../store/mapr/db/json/MaprDBJsonRecordReader.java | 17 ++-
.../drill/exec/store/hbase/HBaseRecordReader.java | 5 +
.../store/hive/readers/HiveAbstractReader.java | 15 ++
.../drill/exec/store/jdbc/JdbcRecordReader.java | 8 +-
.../drill/exec/store/kafka/KafkaRecordReader.java | 26 +++-
.../store/kafka/decoders/JsonMessageReader.java | 4 +
.../drill/exec/store/kudu/KuduRecordReader.java | 11 ++
.../apache/drill/exec/store/kudu/KuduWriter.java | 5 +
.../drill/exec/store/mongo/MongoRecordReader.java | 5 +
.../drill/exec/physical/config/HashAggregate.java | 8 ++
.../physical/config/OrderedPartitionSender.java | 11 ++
.../drill/exec/physical/config/PartitionLimit.java | 5 +
.../apache/drill/exec/physical/config/Sort.java | 7 +
.../apache/drill/exec/physical/config/TopN.java | 7 +
.../drill/exec/physical/config/WindowPOP.java | 16 +++
.../drill/exec/physical/impl/BaseRootExec.java | 23 +++
.../apache/drill/exec/physical/impl/RootExec.java | 6 +
.../apache/drill/exec/physical/impl/ScanBatch.java | 30 +++-
.../drill/exec/physical/impl/TopN/TopNBatch.java | 9 +-
.../exec/physical/impl/WriterRecordBatch.java | 6 +
.../exec/physical/impl/aggregate/HashAggBatch.java | 9 ++
.../physical/impl/aggregate/HashAggTemplate.java | 9 ++
.../impl/aggregate/SpilledRecordbatch.java | 35 ++++-
.../physical/impl/aggregate/StreamingAggBatch.java | 6 +
.../impl/aggregate/StreamingAggTemplate.java | 10 ++
.../physical/impl/filter/FilterRecordBatch.java | 8 ++
.../exec/physical/impl/filter/FilterTemplate2.java | 7 +
.../exec/physical/impl/filter/FilterTemplate4.java | 6 +
.../impl/filter/RuntimeFilterRecordBatch.java | 9 +-
.../physical/impl/flatten/FlattenRecordBatch.java | 6 +
.../physical/impl/flatten/FlattenTemplate.java | 11 ++
.../exec/physical/impl/join/HashJoinBatch.java | 66 ++++++---
.../physical/impl/join/HashJoinProbeTemplate.java | 13 ++
.../exec/physical/impl/join/LateralJoinBatch.java | 8 ++
.../exec/physical/impl/join/MergeJoinBatch.java | 7 +
.../physical/impl/join/NestedLoopJoinBatch.java | 8 ++
.../exec/physical/impl/limit/LimitRecordBatch.java | 74 +++++-----
.../impl/limit/PartitionLimitRecordBatch.java | 10 +-
.../impl/mergereceiver/MergingRecordBatch.java | 8 ++
.../OrderedPartitionRecordBatch.java | 6 +
.../impl/producer/ProducerConsumerBatch.java | 5 +
.../physical/impl/project/ProjectRecordBatch.java | 6 +
.../physical/impl/project/ProjectorTemplate.java | 6 +
.../impl/protocol/OperatorRecordBatch.java | 18 ++-
.../drill/exec/physical/impl/sort/SortBatch.java | 4 +
.../exec/physical/impl/sort/SortTemplate.java | 4 +
.../impl/svremover/RemovingRecordBatch.java | 5 +
.../exec/physical/impl/trace/TraceRecordBatch.java | 6 +-
.../physical/impl/union/UnionAllRecordBatch.java | 5 +
.../exec/physical/impl/unnest/UnnestImpl.java | 10 ++
.../physical/impl/unnest/UnnestRecordBatch.java | 7 +-
.../unorderedreceiver/UnorderedReceiverBatch.java | 36 +++--
.../validate/IteratorValidatorBatchIterator.java | 13 +-
.../physical/impl/window/FrameSupportTemplate.java | 11 ++
.../impl/window/NoFrameSupportTemplate.java | 11 ++
.../exec/physical/impl/window/WindowDataBatch.java | 5 +
.../impl/window/WindowFrameRecordBatch.java | 7 +
.../physical/impl/xsort/ExternalSortBatch.java | 4 +
.../exec/physical/impl/xsort/MSortTemplate.java | 9 ++
.../impl/xsort/SingleBatchSorterTemplate.java | 5 +
.../impl/xsort/managed/ExternalSortBatch.java | 7 +
.../physical/impl/xsort/managed/SortConfig.java | 9 ++
.../exec/physical/impl/xsort/managed/SortImpl.java | 8 ++
.../exec/record/AbstractBinaryRecordBatch.java | 2 +-
.../drill/exec/record/AbstractRecordBatch.java | 50 +++++--
.../record/AbstractTableFunctionRecordBatch.java | 1 -
.../org/apache/drill/exec/record/RecordBatch.java | 15 ++
.../drill/exec/record/RecordBatchLoader.java | 8 ++
.../apache/drill/exec/record/RecordIterator.java | 14 ++
.../apache/drill/exec/record/SchemalessBatch.java | 10 ++
.../drill/exec/record/SimpleRecordBatch.java | 13 ++
.../exec/record/selection/SelectionVector4.java | 9 ++
.../drill/exec/store/AbstractRecordReader.java | 1 -
.../org/apache/drill/exec/store/RecordReader.java | 4 +-
.../apache/drill/exec/store/StorageStrategy.java | 7 +-
.../drill/exec/store/avro/AvroRecordReader.java | 15 +-
.../drill/exec/store/bson/BsonRecordReader.java | 25 ++--
.../drill/exec/store/dfs/easy/EasyWriter.java | 8 ++
.../exec/store/easy/json/JSONRecordReader.java | 46 +++---
.../drill/exec/store/easy/json/JsonProcessor.java | 16 +--
.../store/easy/json/reader/BaseJsonProcessor.java | 48 ++++---
.../store/easy/json/reader/CountingJsonReader.java | 14 +-
.../sequencefile/SequenceFileRecordReader.java | 17 ++-
.../text/compliant/CompliantTextRecordReader.java | 9 +-
.../exec/store/easy/text/compliant/TextReader.java | 8 ++
.../exec/store/httpd/HttpdLogFormatPlugin.java | 8 ++
.../drill/exec/store/image/ImageRecordReader.java | 7 +-
.../drill/exec/store/log/LogRecordReader.java | 9 +-
.../drill/exec/store/parquet/ParquetWriter.java | 7 +
.../parquet/columnreaders/ParquetRecordReader.java | 10 ++
.../exec/store/parquet2/DrillParquetReader.java | 5 +
.../drill/exec/store/pcap/PcapRecordReader.java | 5 +
.../exec/store/text/DrillTextRecordReader.java | 9 ++
.../drill/exec/vector/complex/fn/JsonReader.java | 62 +++-----
.../drill/exec/work/batch/BaseRawBatchBuffer.java | 2 +-
.../drill/exec/work/fragment/FragmentExecutor.java | 4 +
.../parquet/hadoop/ColumnChunkIncReadStore.java | 5 +
.../java/org/apache/drill/TestOperatorDump.java | 159 +++++++++++++++++++++
.../drill/exec/physical/impl/MockRecordBatch.java | 9 ++
.../drill/exec/physical/impl/SimpleRootExec.java | 5 +
.../physical/impl/join/TestHashJoinOutcome.java | 43 ++++++
.../physical/impl/unnest/MockLateralJoinBatch.java | 9 ++
.../drill/exec/work/filter/BloomFilterTest.java | 9 ++
.../java/org/apache/drill/test/LogFixture.java | 12 +-
106 files changed, 1249 insertions(+), 234 deletions(-)
create mode 100644
exec/java-exec/src/test/java/org/apache/drill/TestOperatorDump.java
