diff --git a/presto-pinot-toolkit/src/main/java/com/facebook/presto/pinot/PinotConfig.java b/presto-pinot-toolkit/src/main/java/com/facebook/presto/pinot/PinotConfig.java index 872e7a9fd4f4d..f57d8566bdaf3 100644 --- a/presto-pinot-toolkit/src/main/java/com/facebook/presto/pinot/PinotConfig.java +++ b/presto-pinot-toolkit/src/main/java/com/facebook/presto/pinot/PinotConfig.java @@ -96,7 +96,7 @@ public class PinotConfig // Requires Pinot version >= 0.4.0. private boolean usePinotSqlForBrokerQueries = true; // Requires Pinot version >= 0.6.0. - private boolean useStreamingForSegmentQueries; + private boolean useStreamingForSegmentQueries = true; private int streamingServerGrpcMaxInboundMessageBytes = DEFAULT_STREAMING_SERVER_GRPC_MAX_INBOUND_MESSAGE_BYTES; private int numSegmentsPerSplit = 1; diff --git a/presto-pinot-toolkit/src/test/java/com/facebook/presto/pinot/TestPinotConfig.java b/presto-pinot-toolkit/src/test/java/com/facebook/presto/pinot/TestPinotConfig.java index 3b76421a789ad..9ffa19ebd8b21 100644 --- a/presto-pinot-toolkit/src/test/java/com/facebook/presto/pinot/TestPinotConfig.java +++ b/presto-pinot-toolkit/src/test/java/com/facebook/presto/pinot/TestPinotConfig.java @@ -71,7 +71,7 @@ public void testDefaults() .setIgnoreEmptyResponses(false) .setUseDateTrunc(false) .setForbidSegmentQueries(false) - .setUseStreamingForSegmentQueries(false) + .setUseStreamingForSegmentQueries(true) .setStreamingServerGrpcMaxInboundMessageBytes(PinotConfig.DEFAULT_STREAMING_SERVER_GRPC_MAX_INBOUND_MESSAGE_BYTES) .setNonAggregateLimitForBrokerQueries(PinotConfig.DEFAULT_NON_AGGREGATE_LIMIT_FOR_BROKER_QUERIES) .setUseDateTrunc(false)); @@ -115,7 +115,7 @@ public void testExplicitPropertyMappings() .put("pinot.limit-large-for-segment", "100") .put("pinot.pushdown-topn-broker-queries", "false") .put("pinot.forbid-segment-queries", "true") - .put("pinot.use-streaming-for-segment-queries", "true") + .put("pinot.use-streaming-for-segment-queries", "false") .put("pinot.streaming-server-grpc-max-inbound-message-bytes", "65536") .put("pinot.secure-connection", "true") .put("pinot.override-distinct-count-function", "distinctCountBitmap") @@ -162,7 +162,7 @@ public void testExplicitPropertyMappings() .setLimitLargeForSegment(100) .setPushdownTopNBrokerQueries(false) .setForbidSegmentQueries(true) - .setUseStreamingForSegmentQueries(true) + .setUseStreamingForSegmentQueries(false) .setStreamingServerGrpcMaxInboundMessageBytes(65536) .setUseDateTrunc(true) .setUseProxy(true)