Skip to content

Instantly share code, notes, and snippets.

View arhimondr's full-sized avatar

Andrii Rosa arhimondr

  • Facebook
  • Boston
View GitHub Profile
public static class Parts
{
private final Optional<StatisticAggregations> finalAggregation;
private final Optional<StatisticAggregations> intermediateAggregation;
private final StatisticAggregations partialAggregation;
public Parts(
Optional<StatisticAggregations> finalAggregation,
Optional<StatisticAggregations> intermediateAggregation,
StatisticAggregations partialAggregation)
diff --git a/drift-transport-netty/src/test/java/com/facebook/drift/transport/netty/codec/TestHeaderTransport.java b/drift-transport-netty/src/test/java/com/facebook/drift/transport/netty/codec/TestHeaderTransport.java
index 01b02ab7..c51fff35 100644
--- a/drift-transport-netty/src/test/java/com/facebook/drift/transport/netty/codec/TestHeaderTransport.java
+++ b/drift-transport-netty/src/test/java/com/facebook/drift/transport/netty/codec/TestHeaderTransport.java
@@ -29,6 +29,7 @@ import org.testng.annotations.Test;
import java.util.List;
import java.util.Optional;
+import java.util.UUID;
public enum Transform
{
ZLIB_TRANSFORM(0x01) {
private static final int ZLIB_COMPRESSION_BUFFER_SIZE = 512;
@Override
public ByteBuf transform(ByteBuf data)
{
ByteBuf output = Unpooled.buffer(ZLIB_COMPRESSION_BUFFER_SIZE);
pi@raspberrypi:~ $ cat /etc/os-release
PRETTY_NAME="Raspbian GNU/Linux 9 (stretch)"
NAME="Raspbian GNU/Linux"
VERSION_ID="9"
VERSION="9 (stretch)"
ID=raspbian
ID_LIKE=debian
HOME_URL="http://www.raspbian.org/"
SUPPORT_URL="http://www.raspbian.org/RaspbianForums"
BUG_REPORT_URL="http://www.raspbian.org/RaspbianBugs"
remote-ssh@0.42.0
SSH Resolver called for "ssh-remote+pi"
SSH Resolver called for host: pi
Setting up SSH remote "pi"
Using commit id "553cfb2c2205db5f15f3ee8395bbd5cf066d357d" and quality "stable" for server
Install and start server if needed
> Installing to /home/pi/.vscode-server/bin/553cfb2c2205db5f15f3ee8395bbd5cf066d357d...
> Downloading with wget
> Printing the current remote environment...
> LC_ALL=en_US.UTF-8
public static HiveSplitSource bucketedRewindable(
ConnectorSession session,
String databaseName,
String tableName,
TupleDomain<? extends ColumnHandle> compactEffectivePredicate,
int maxInitialSplits,
DataSize maxOutstandingSplitsSize,
HiveSplitLoader splitLoader,
Executor executor,
CounterStat highMemorySplitSourceCounter)
public static HiveSplitSource bucketedRewindable(
ConnectorSession session,
String databaseName,
String tableName,
TupleDomain<? extends ColumnHandle> compactEffectivePredicate,
int maxInitialSplits,
DataSize maxOutstandingSplitsSize,
HiveSplitLoader splitLoader,
Executor executor,
CounterStat highMemorySplitSourceCounter)
java.util.NoSuchElementException
at java.util.ArrayList$Itr.next(ArrayList.java:862)
at com.google.common.collect.Ordering.min(Ordering.java:550)
at com.google.common.collect.Ordering.min(Ordering.java:576)
at com.facebook.presto.sql.planner.iterative.rule.ReorderJoins$JoinEnumerator.setJoinNodeProperties(ReorderJoins.java:385)
at com.facebook.presto.sql.planner.iterative.rule.ReorderJoins$JoinEnumerator.createJoin(ReorderJoins.java:290)
at com.facebook.presto.sql.planner.iterative.rule.ReorderJoins$JoinEnumerator.createJoinAccordingToPartitioning(ReorderJoins.java:228)
at com.facebook.presto.sql.planner.iterative.rule.ReorderJoins$JoinEnumerator.chooseJoinOrder(ReorderJoins.java:172)
at com.facebook.presto.sql.planner.iterative.rule.ReorderJoins$JoinEnumerator.access$000(ReorderJoins.java:134)
at com.facebook.presto.sql.planner.iterative.rule.ReorderJoins.apply(ReorderJoins.java:126)
Caused by: java.lang.IllegalArgumentException: Nulls fraction should be within [0, 1] or NaN, got: 1.0000000000000044
at com.google.common.base.Preconditions.checkArgument(Preconditions.java:210)
at com.facebook.presto.cost.SymbolStatsEstimate.<init>(SymbolStatsEstimate.java:69)
at com.facebook.presto.cost.SymbolStatsEstimate$Builder.build(SymbolStatsEstimate.java:257)
at com.facebook.presto.cost.PlanNodeStatsEstimateMath.subtractColumnStats(PlanNodeStatsEstimateMath.java:95)
at com.facebook.presto.cost.PlanNodeStatsEstimateMath.lambda$differenceInStatsWithRangeStrategy$1(PlanNodeStatsEstimateMath.java:48)
at java.base/java.util.Iterator.forEachRemaining(Iterator.java:133)
at java.base/java.util.Spliterators$IteratorSpliterator.forEachRemaining(Spliterators.java:1801)
at java.base/java.util.stream.Streams$ConcatSpliterator.forEachRemaining(Streams.java:734)
at java.base/java.util.stream.ReferencePipeline$Head.forEach(ReferencePipeline.java:658)
Caused by: java.lang.IllegalArgumentException: Average row size should be non-negative or NaN, got: -Infinity
at com.google.common.base.Preconditions.checkArgument(Preconditions.java:210)
at com.facebook.presto.cost.SymbolStatsEstimate.<init>(SymbolStatsEstimate.java:76)
at com.facebook.presto.cost.SymbolStatsEstimate$Builder.build(SymbolStatsEstimate.java:257)
at com.facebook.presto.cost.PlanNodeStatsEstimateMath.subtractColumnStats(PlanNodeStatsEstimateMath.java:95)
at com.facebook.presto.cost.PlanNodeStatsEstimateMath.lambda$differenceInStatsWithRangeStrategy$1(PlanNodeStatsEstimateMath.java:48)
at java.base/java.util.Iterator.forEachRemaining(Iterator.java:133)
at java.base/java.util.Spliterators$IteratorSpliterator.forEachRemaining(Spliterators.java:1801)
at java.base/java.util.stream.Streams$ConcatSpliterator.forEachRemaining(Streams.java:734)
at java.base/java.util.stream.ReferencePipeline$Head.forEach(ReferencePipeline.java:658)