You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@drill.apache.org by cg...@apache.org on 2022/09/12 04:06:40 UTC
[drill] branch master updated: [MINOR UPDATE] Fix some issues highlighted in lgtm.com (#2642)
This is an automated email from the ASF dual-hosted git repository.
cgivre pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/drill.git
The following commit(s) were added to refs/heads/master by this push:
new bd8f4027a7 [MINOR UPDATE] Fix some issues highlighted in lgtm.com (#2642)
bd8f4027a7 is described below
commit bd8f4027a783ac9f92d8ac93137a2f26ed2d2a15
Author: PJ Fanning <pj...@users.noreply.github.com>
AuthorDate: Mon Sep 12 05:06:35 2022 +0100
[MINOR UPDATE] Fix some issues highlighted in lgtm.com (#2642)
---
.../main/java/org/apache/drill/common/config/DrillProperties.java | 2 +-
.../main/java/org/apache/drill/exec/store/kudu/KuduGroupScan.java | 2 +-
.../src/main/java/org/apache/drill/exec/expr/ClassGenerator.java | 2 +-
.../org/apache/drill/exec/expr/fn/FunctionGenerationHelper.java | 2 --
.../java/org/apache/drill/exec/expr/fn/impl/StringFunctions.java | 2 +-
.../org/apache/drill/exec/physical/impl/join/HashJoinBatch.java | 2 --
.../org/apache/drill/exec/physical/impl/join/MergeJoinBatch.java | 2 +-
.../exec/planner/index/generators/AbstractIndexPlanGenerator.java | 4 ----
.../src/main/java/org/apache/drill/exec/schema/ListSchema.java | 3 ++-
.../src/main/java/org/apache/drill/exec/server/Drillbit.java | 2 +-
.../org/apache/drill/exec/server/rest/profile/OperatorWrapper.java | 7 -------
.../exec/store/parquet/columnreaders/NullableColumnReader.java | 4 ++--
.../drill/exec/util/filereader/BufferedDirectBufInputStream.java | 2 +-
13 files changed, 11 insertions(+), 25 deletions(-)
diff --git a/common/src/main/java/org/apache/drill/common/config/DrillProperties.java b/common/src/main/java/org/apache/drill/common/config/DrillProperties.java
index 7726808150..0ea0fbb1c5 100644
--- a/common/src/main/java/org/apache/drill/common/config/DrillProperties.java
+++ b/common/src/main/java/org/apache/drill/common/config/DrillProperties.java
@@ -115,7 +115,7 @@ public final class DrillProperties extends Properties {
}
@Override
- public Object setProperty(final String key, final String value) {
+ public synchronized Object setProperty(final String key, final String value) {
return super.setProperty(key.toLowerCase(), value);
}
diff --git a/contrib/storage-kudu/src/main/java/org/apache/drill/exec/store/kudu/KuduGroupScan.java b/contrib/storage-kudu/src/main/java/org/apache/drill/exec/store/kudu/KuduGroupScan.java
index b66d684122..7655f80290 100644
--- a/contrib/storage-kudu/src/main/java/org/apache/drill/exec/store/kudu/KuduGroupScan.java
+++ b/contrib/storage-kudu/src/main/java/org/apache/drill/exec/store/kudu/KuduGroupScan.java
@@ -207,7 +207,7 @@ public class KuduGroupScan extends AbstractGroupScan {
// List<KuduSubScanSpec> tabletInfoList, List<SchemaPath> columns
@Override
public ScanStats getScanStats() {
- long recordCount = 100000 * kuduWorkList.size();
+ long recordCount = 100000L * kuduWorkList.size();
return new ScanStats(GroupScanProperty.NO_EXACT_ROW_COUNT, recordCount, 1, recordCount);
}
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/expr/ClassGenerator.java b/exec/java-exec/src/main/java/org/apache/drill/exec/expr/ClassGenerator.java
index 2c2b6345c0..8082bfc17f 100644
--- a/exec/java-exec/src/main/java/org/apache/drill/exec/expr/ClassGenerator.java
+++ b/exec/java-exec/src/main/java/org/apache/drill/exec/expr/ClassGenerator.java
@@ -173,7 +173,7 @@ public class ClassGenerator<T> {
innerClasses.put(innerClassName, new ClassGenerator<>(codeGenerator, mappingSet, child, eval, innerClazz, model, optionManager));
}
long maxExprsNumber = optionManager != null ? optionManager.getOption(ExecConstants.CODE_GEN_EXP_IN_METHOD_SIZE_VALIDATOR) : 50;
- maxIndex = Math.round((0xFFFF / (1 + 3. / (3 * sig.size() + maxExprsNumber)) - 1000) / 3);
+ maxIndex = Math.round((0xFFFF / (1 + 3. / (3L * sig.size() + maxExprsNumber)) - 1000) / 3);
}
public ClassGenerator<T> getInnerGenerator(String name) {
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/expr/fn/FunctionGenerationHelper.java b/exec/java-exec/src/main/java/org/apache/drill/exec/expr/fn/FunctionGenerationHelper.java
index f7c32aa59c..95827d8e0e 100644
--- a/exec/java-exec/src/main/java/org/apache/drill/exec/expr/fn/FunctionGenerationHelper.java
+++ b/exec/java-exec/src/main/java/org/apache/drill/exec/expr/fn/FunctionGenerationHelper.java
@@ -95,10 +95,8 @@ public class FunctionGenerationHelper implements FunctionNames {
}
private static LogicalExpression getFunctionExpression(String name, HoldingContainer... args) {
- List<MajorType> argTypes = new ArrayList<MajorType>(args.length);
List<LogicalExpression> argExpressions = new ArrayList<LogicalExpression>(args.length);
for (HoldingContainer c : args) {
- argTypes.add(c.getMajorType());
argExpressions.add(new HoldingContainerExpression(c));
}
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/expr/fn/impl/StringFunctions.java b/exec/java-exec/src/main/java/org/apache/drill/exec/expr/fn/impl/StringFunctions.java
index 305cfcdac3..9a8446f681 100644
--- a/exec/java-exec/src/main/java/org/apache/drill/exec/expr/fn/impl/StringFunctions.java
+++ b/exec/java-exec/src/main/java/org/apache/drill/exec/expr/fn/impl/StringFunctions.java
@@ -345,7 +345,7 @@ public class StringFunctions{
@Override
public void eval() {
- out.value = (input.end - input.start) * 8;
+ out.value = (input.end - input.start) * 8L;
}
}
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/join/HashJoinBatch.java b/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/join/HashJoinBatch.java
index 00d5bae1c6..a08e4308cd 100644
--- a/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/join/HashJoinBatch.java
+++ b/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/join/HashJoinBatch.java
@@ -1322,10 +1322,8 @@ public class HashJoinBatch extends AbstractBinaryRecordBatch<HashJoinPOP>
rightExpr = new ArrayList<>(conditions.size());
buildJoinColumns = Sets.newHashSet();
- List<SchemaPath> rightConditionPaths = new ArrayList<>();
for (int i = 0; i < conditions.size(); i++) {
SchemaPath rightPath = (SchemaPath) conditions.get(i).getRight();
- rightConditionPaths.add(rightPath);
}
for (int i = 0; i < conditions.size(); i++) {
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/join/MergeJoinBatch.java b/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/join/MergeJoinBatch.java
index f4ec939b4c..5e032647c5 100644
--- a/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/join/MergeJoinBatch.java
+++ b/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/join/MergeJoinBatch.java
@@ -196,7 +196,7 @@ public class MergeJoinBatch extends AbstractBinaryRecordBatch<MergeJoinPOP> {
break;
case NO_MORE_DATA:
status.resetOutputPos();
- logger.debug("NO MORE DATA; returning {} NONE");
+ logger.debug("NO MORE DATA; returning NONE");
return IterOutcome.NONE;
case FAILURE:
status.left.clearInflightBatches();
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/planner/index/generators/AbstractIndexPlanGenerator.java b/exec/java-exec/src/main/java/org/apache/drill/exec/planner/index/generators/AbstractIndexPlanGenerator.java
index 88e569a9f0..c4b6c72932 100644
--- a/exec/java-exec/src/main/java/org/apache/drill/exec/planner/index/generators/AbstractIndexPlanGenerator.java
+++ b/exec/java-exec/src/main/java/org/apache/drill/exec/planner/index/generators/AbstractIndexPlanGenerator.java
@@ -261,10 +261,6 @@ public abstract class AbstractIndexPlanGenerator extends SubsetTransformer<RelNo
DrillSortRel topSort = (DrillSortRel)top;
input = topSort.getInput();
}
- else if ( top instanceof DrillSortRel) {
- DrillSortRel topSort = (DrillSortRel) top;
- input = topSort.getInput();
- }
else {
return;
}
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/schema/ListSchema.java b/exec/java-exec/src/main/java/org/apache/drill/exec/schema/ListSchema.java
index bd32804399..a767641209 100644
--- a/exec/java-exec/src/main/java/org/apache/drill/exec/schema/ListSchema.java
+++ b/exec/java-exec/src/main/java/org/apache/drill/exec/schema/ListSchema.java
@@ -20,6 +20,7 @@ package org.apache.drill.exec.schema;
import static org.apache.drill.shaded.guava.com.google.common.base.Preconditions.checkArgument;
import java.util.List;
+import java.util.Objects;
import org.apache.drill.common.types.TypeProtos.DataMode;
@@ -37,7 +38,7 @@ public class ListSchema implements RecordSchema {
@Override
public void addField(Field field) {
if (field.getFieldType().getMode() == DataMode.REPEATED || fields.isEmpty() || !isSingleTyped() ||
- !Iterables.getOnlyElement(fields).equals(field.getFieldType())) {
+ !Objects.equals(Iterables.getOnlyElement(fields).getFieldType(), field.getFieldType())) {
fields.add(field);
}
}
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/server/Drillbit.java b/exec/java-exec/src/main/java/org/apache/drill/exec/server/Drillbit.java
index 8228550d67..ad68a60a6a 100644
--- a/exec/java-exec/src/main/java/org/apache/drill/exec/server/Drillbit.java
+++ b/exec/java-exec/src/main/java/org/apache/drill/exec/server/Drillbit.java
@@ -306,7 +306,7 @@ public class Drillbit implements AutoCloseable {
coord.unregister(registrationHandle);
}
try {
- Thread.sleep(context.getConfig().getInt(ExecConstants.ZK_REFRESH) * 2);
+ Thread.sleep(context.getConfig().getInt(ExecConstants.ZK_REFRESH) * 2L);
} catch (final InterruptedException e) {
logger.warn("Interrupted while sleeping during coordination deregistration.");
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/server/rest/profile/OperatorWrapper.java b/exec/java-exec/src/main/java/org/apache/drill/exec/server/rest/profile/OperatorWrapper.java
index 25fad85aaf..0e93d4310f 100644
--- a/exec/java-exec/src/main/java/org/apache/drill/exec/server/rest/profile/OperatorWrapper.java
+++ b/exec/java-exec/src/main/java/org/apache/drill/exec/server/rest/profile/OperatorWrapper.java
@@ -24,8 +24,6 @@ import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Objects;
-import java.util.Set;
-import java.util.TreeSet;
import java.util.concurrent.TimeUnit;
import org.apache.commons.lang3.tuple.ImmutablePair;
@@ -372,8 +370,6 @@ public class OperatorWrapper {
.build());
final Number[] values = new Number[metricNames.length];
- //Track new/Unknown Metrics
- final Set<Integer> unknownMetrics = new TreeSet<>();
for (final MetricValue metric : op.getMetricList()) {
if (metric.getMetricId() < metricNames.length) {
if (metric.hasLongValue()) {
@@ -381,9 +377,6 @@ public class OperatorWrapper {
} else if (metric.hasDoubleValue()) {
values[metric.getMetricId()] = metric.getDoubleValue();
}
- } else {
- //Tracking unknown metric IDs
- unknownMetrics.add(metric.getMetricId());
}
}
for (final Number value : values) {
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/columnreaders/NullableColumnReader.java b/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/columnreaders/NullableColumnReader.java
index 67531f2cf0..c16b82a7aa 100644
--- a/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/columnreaders/NullableColumnReader.java
+++ b/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/columnreaders/NullableColumnReader.java
@@ -163,7 +163,7 @@ abstract class NullableColumnReader<V extends ValueVector> extends ColumnReader<
this.recordsReadInThisIteration += runLength;
this.readStartInBytes = pageReader.readPosInBytes;
- this.readLengthInBits = runLength * dataTypeLengthInBits;
+ this.readLengthInBits = (long) runLength * dataTypeLengthInBits;
this.readLength = (int) Math.ceil(readLengthInBits / 8.0);
readField(runLength);
@@ -278,7 +278,7 @@ abstract class NullableColumnReader<V extends ValueVector> extends ColumnReader<
this.recordsReadInThisIteration += numNonNullValues;
this.readStartInBytes = pageReader.readPosInBytes;
- this.readLengthInBits = numNonNullValues * dataTypeLengthInBits;
+ this.readLengthInBits = (long) numNonNullValues * dataTypeLengthInBits;
this.readLength = (int) Math.ceil(readLengthInBits / 8.0);
readField(numNonNullValues);
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/util/filereader/BufferedDirectBufInputStream.java b/exec/java-exec/src/main/java/org/apache/drill/exec/util/filereader/BufferedDirectBufInputStream.java
index c32ef55ebe..a0effe8f73 100644
--- a/exec/java-exec/src/main/java/org/apache/drill/exec/util/filereader/BufferedDirectBufInputStream.java
+++ b/exec/java-exec/src/main/java/org/apache/drill/exec/util/filereader/BufferedDirectBufInputStream.java
@@ -395,7 +395,7 @@ public class BufferedDirectBufInputStream extends DirectBufInputStream implement
return curPosInBuffer + startOffset;
}
- public void close() throws IOException {
+ @Override public synchronized void close() throws IOException {
DrillBuf buffer;
InputStream inp;
synchronized (this) {