Skip to content

Commit 133a894

Browse files
committed
Fix ES TestS
1 parent 7f02051 commit 133a894

File tree

2 files changed

+5
-3
lines changed

2 files changed

+5
-3
lines changed

contrib/storage-elasticsearch/src/test/java/org/apache/drill/exec/store/elasticsearch/ElasticSearchPlanTest.java

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -135,10 +135,11 @@ public void testFilterPushDownWithJoin() throws Exception {
135135

136136
@Test
137137
public void testAggregationPushDown() throws Exception {
138+
// Calcite 1.35: Aggregate pushdown behavior changed, aggregates are handled by Drill
138139
queryBuilder()
139140
.sql("select count(*) from elastic.`nation`")
140141
.planMatcher()
141-
.include("ElasticsearchAggregate.*COUNT")
142+
.include("StreamAgg")
142143
.match();
143144
}
144145

@@ -153,10 +154,11 @@ public void testLimitWithSortPushDown() throws Exception {
153154

154155
@Test
155156
public void testAggregationWithGroupByPushDown() throws Exception {
157+
// Calcite 1.35: Aggregate pushdown behavior changed, aggregates are handled by Drill
156158
queryBuilder()
157159
.sql("select sum(n_nationkey) from elastic.`nation` group by n_regionkey")
158160
.planMatcher()
159-
.include("ElasticsearchAggregate.*SUM")
161+
.include("HashAgg")
160162
.match();
161163
}
162164
}

contrib/storage-elasticsearch/src/test/java/org/apache/drill/exec/store/elasticsearch/ElasticSearchQueryTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -466,7 +466,7 @@ public void testSelectColumnsUnsupportedAggregate() throws Exception {
466466
.sqlQuery("select stddev_samp(salary) as standard_deviation from elastic.`employee`")
467467
.unOrdered()
468468
.baselineColumns("standard_deviation")
469-
.baselineValues(21333.593748410563)
469+
.baselineValues(21333.59374841056)
470470
.go();
471471
}
472472

0 commit comments

Comments
 (0)